分布式数据库定时同步问题之－－SqlCommand不可序列化

分布式数据库定时同步问题之－－SqlCommand不可序列化

近日，做一个分布式数据库定时同步的项目，也就是说有多个物理节点上的数据库需要在每天某时来同步表中的数据，对于某个指定节点上的某个表发生的变化（增量）可以通过对该表执行的SqlCommand来记录，当同步过程发生时，需要对其它所有节点上的同名表执行相同的SqlCommand。由于，同步是定时发生的，所以增量SqlCommand就需要首先被保存起来，开始我们计划将其序列化后保存在数据库中，但是到运行时，问题来了，SqlCommand是不可序列化的！！！所有继承自IDbCommand的类都是不可序列化的，所有继承自IDbParameter的实现类都是不可序列化的。    遇到了这个问题，是我们当初没有料想到的，看来要妥善的解决这个问题，否则，我们的设计和实现不可避免的要进行大量的修改！我们最后采用的解决方案是自己手写一个可以序列化的ESqlCommand，它可以和SqlCommand相互转换，就像这样：

SqlCommand command = new SqlCommand(this.cmdText ,new SqlConnection(connStr) ,null) ;            //正向            ESqlCommand esCommand = new ESqlCommand(command) ;            //反向            SqlCommand command2 = esCommand.ToSqlCommand(connStr) ;

有了ESqlCommand之后，我们的设计几乎不需要修改，仅仅在增量序列化保存到数据库之前转换为ESqlCommand，而读出增量字段反序列化之后再转换为SqlCommand即可。    下面给出ESqlCommand的实现（当然，不可避免的也要包含可序列化的ESqlParameter实现）：

#region ESqlCommand    /// 

    /// ESqlCommand 可序列化的SqlCommand。System.Data.SqlClient.SqlCommand是不可序列化的    /// 

    [Serializable]    public class ESqlCommand    {        private ESqlParameter[] esParas ;        private string          cmdText ;        private CommandType     cmdType ;        public ESqlCommand(SqlCommand command)        {            this.cmdText = command.CommandText ;            this.cmdType = command.CommandType ;            this.esParas = new ESqlParameter[command.Parameters.Count] ;            int index = 0 ;            foreach(SqlParameter para in command.Parameters)            {                this.esParas[index] = new ESqlParameter(para) ;                index++ ;            }        }        public SqlCommand ToSqlCommand(string connStr)        {            SqlCommand command = new SqlCommand(this.cmdText ,new SqlConnection(connStr) ,null) ;                      for(int i=0 ;i

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。