C# SQL封装（四）

欲忘树

/// 　　
        /// 构建T-SQL参数 UPDATE
　　
        ///
　　
        ///
　　
        /// 原model
　　
        /// 更改后model
　　
        ///
　　
        public static SqlParameter[] UPDATE_T_SQL(T model, T model_change) where T : BaseModel
　　
        {
　　
            Type model_type = model.GetType();
　　
            Type model_change_type = model_change.GetType();
　　
            if (model_type.Name == model_change_type.Name)
　　
            {
　　
                PropertyInfo[] p_intos = model_type.GetProperties();
　　
                PropertyInfo item = null;
　　
                PropertyInfo item_change = null;
　　
                string item_value = string.Empty;
　　
                string item_change_value = string.Empty;
　　
                List sql_param = null;
　　
                SqlParameter cell = null;
　　
                bool is_change_model = false;//是否有字段进行了更改
　　
                for (int i = 0; i < p_intos.Length; i++)
　　
                {
　　
                    item = p_intos;
　　
                    item_change = model_change_type.GetProperty(item.Name);
　　
                    item_value = item.GetValue(model, null).ToString();
　　
                    item_change_value = item_change.GetValue(model_change, null).ToString();
　　
                    if (item.Name == "id")
　　
                    {
　　
                        if (item_value != item_change_value)
　　
                        {
　　
                            throw new Exception(
　　
                                string.Format("model类 id : {0} 与model_change类id:{1} 不一致,请确保是同一条数据",
　　
                                    item_value,
　　
                                    item_change_value
　　
                                )
　　
                                );
　　
                        }
　　
                        else
　　
                        {
　　
                            if (sql_param == null) sql_param = new List();
　　
                            cell = new SqlParameter(item.Name, SqlParameter_Structure.Get_SqlDbType_SqlType(item.PropertyType));
　　
                            cell.Value = item.GetValue(model, null);
　　
                            sql_param.Add(cell);
　　
                        }
　　
                    }
　　
                    else
　　
                    {
　　
                        if (item_value != item_change_value)
　　
                        {
　　
                            if (!is_change_model) is_change_model = true;
　　
                            if (sql_param == null) sql_param = new List();
　　
                            cell = new SqlParameter(item_change.Name, SqlParameter_Structure.Get_SqlDbType_SqlType(item_change.PropertyType));
　　
                            cell.Value = item_change.GetValue(model_change, null);//加入改变的值
　　
                            sql_param.Add(cell);
　　
                        }
　　
                    }
　　
                }
　　
                if (is_change_model)
　　
                {
　　
                    return sql_param.ToArray();
　　
                }
　　
                else
　　
                {
　　
                    return null;//没有任何字段更改
　　
                }
　　
            }
　　
            else
　　
            {
　　
                throw new Exception(
　　
                    string.Format("model类 : {0} 与model_change类 :{1} 不匹配",
　　
                        model_type.Name,
　　
                        model_change_type.Name
　　
                        )
　　
                    );
　　
            }
　　
        }