重构insert update 比较两个datatbale
Posted 余生请你多指教
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了重构insert update 比较两个datatbale相关的知识，希望对你有一定的参考价值。
#region 下载时重构insert（数据带null处理） public void DownDataInsert(DataTable _dt, string TableName,DBHelper dbhelper) { List<string> _List = new List<string>(); try { if (_dt == null) { throw new Exception("datatable不可为空！"); } if (string.IsNullOrEmpty(TableName)) { throw new Exception("表名不可为空！"); } for (int i = 0; i < _dt.Rows.Count; i++) { string sqlstring = string.Empty; string sqlString = "insert into " + TableName + " ({0}) VALUES ({1})"; string Names = string.Empty; string values = string.Empty; foreach (DataColumn c in _dt.Columns) { if (_dt.Rows[i][c.ColumnName] != null && !string.IsNullOrEmpty(_dt.Rows[i][c.ColumnName].ToString())) { Names += (string.IsNullOrEmpty(Names) ? "" : ",") + c.ColumnName; if (IsType(c.DataType, "System.Nullable`1[System.Int16]") || IsType(c.DataType, "System.Nullable`1[System.Int32]") || IsType(c.DataType, "System.Nullable`1[System.Int64]") || IsType(c.DataType, "System.Nullable`1[System.Double]") || IsType(c.DataType, "System.Nullable`1[System.Decimal]") || c.DataType == typeof(System.Int16) || c.DataType == typeof(System.Int32) || c.DataType == typeof(System.Int64) || c.DataType == typeof(System.Double) || c.DataType == typeof(System.Decimal)) { values += (string.IsNullOrEmpty(values) ? "" : ",") + _dt.Rows[i][c.ColumnName].ToString(); } if (IsType(c.DataType, "System.Nullable`1[System.DateTime]") || c.DataType == typeof(System.DateTime)) { values += (string.IsNullOrEmpty(values) ? "" : ",") + "DateTime(‘" + _dt.Rows[i][c.ColumnName].ToString() + "‘)"; } if (IsType(c.DataType, "System.String") || c.DataType == typeof(System.String)) { values += (string.IsNullOrEmpty(values) ? "" : ",") + "‘" + _dt.Rows[i][c.ColumnName].ToString() + "‘"; } } } if (!string.IsNullOrEmpty(Names) && !string.IsNullOrEmpty(values)) { sqlstring = string.Format(sqlString, Names, values); _List.Add(sqlstring); } } dbhelper.ExecuteSqlTran(_List); } catch (Exception ex) { throw ex; } finally { _List = null; } } #endregion #region 比较两个datatable,值不一样的相应的修改下载处理 public void CompareToDataTable(DataTable SourTable, DataTable TargetTable, string TableName) { string SelectString = string.Empty; List<string> _list = new List<string>(); DataTable dtInsert = null; DataTable drUpdate = null; try { dtInsert = SourTable.Clone(); drUpdate = SourTable.Clone(); foreach (DataRow dr in SourTable.Rows) { if (TableName == "t_sellworker") { SelectString = "serverpartcode=‘" + dr["serverpartcode"].ToString() + "‘ and sellworkercode=‘" + dr["sellworkercode"].ToString() + "‘"; } else if (TableName == "t_salespromote") { SelectString = "salespromote_id=" + dr["salespromote_id"].ToString() + ""; // SelectString = "salespromote_startdate=‘" + dr["salespromote_startdate"].ToString() + "‘ and salespromote_enddate=‘" + dr["salespromote_enddate"].ToString() + "‘ " + // " and salespromote_type=‘" + dr["salespromote_type"].ToString() + "‘ and salespromote_name=‘" + dr["salespromote_name"].ToString() + "‘ and commodity_code=‘" + dr["commodity_code"].ToString() + "‘"; } else if (TableName == "t_commodityex") { SelectString = "commodity_code=‘" + dr["commodity_code"].ToString() + "‘ and commodity_barcode=‘" + dr["commodity_barcode"].ToString() + "‘ "; // and serverpartshop_id=" + dr["serverpartshop_id"].ToString() + " } DataRow[] dr2 = TargetTable.Select(SelectString); if (dr2 != null && dr2.Length > 0) { bool flag = false; foreach (DataRow dr3 in dr2) { foreach (DataColumn c in SourTable.Columns) { if (dr3[c.ColumnName] != null && dr[c.ColumnName] != null && dr3[c.ColumnName].ToString() != dr[c.ColumnName].ToString()) { flag = true; break; } } } if (flag) { drUpdate.Rows.Add(dr.ItemArray); } } else { dtInsert.Rows.Add(dr.ItemArray); //添加数据行 } } if (drUpdate != null && drUpdate.Rows.Count > 0) { if(TableName=="t_sellworker") { UpdateData(drUpdate, "t_sellworker", new string[] { "serverpartcode", "sellworkercode" }, TargetDb); } else if (TableName == "t_salespromote") { UpdateData(drUpdate, "t_salespromote", new string[] { "salespromote_startdate", "salespromote_enddate", "salespromote_type", "salespromote_name", "commodity_code"}, TargetDb); } else if (TableName == "t_commodityex") { UpdateData(drUpdate, "t_commodityex", new string[] { "serverpartcode", "commodity_barcode", "serverpartshop_id" }, TargetDb); } MessageBox.Show("更新成功！"); } if (dtInsert != null && dtInsert.Rows.Count > 0) { DownDataInsert(dtInsert, TableName, TargetDb);//插入 MessageBox.Show("下载成功！"); } } catch (Exception ex) { MessageBox.Show(ex.Message); } finally { dtInsert = null; drUpdate = null; } } #endregion #region 下载时重构update语句(处理数据空的情况) public void UpdateData(DataTable table, string TableName, string[] keys,DBHelper dbhelper) { List<string> _List = null; Dictionary<string, string> keyList = null; try { if (_List == null) { _List = new List<string>(); } else { _List.Clear(); } if (table == null) { throw new Exception("行不可为空！"); } if (string.IsNullOrEmpty(TableName)) { throw new Exception("表名不可为空！"); } for (int i = 0; i < table.Rows.Count; i++) { if (keyList == null) { keyList = new Dictionary<string, string>(); } else { keyList.Clear(); } string sqlstring = string.Empty; string sqlString = "Update " + TableName + " set {0} where {1}"; string values = string.Empty; foreach (DataColumn c in table.Columns) { if (table.Rows[i][c.ColumnName] != null && !string.IsNullOrEmpty(table.Rows[i][c.ColumnName].ToString())) { if (IsType(c.DataType, "System.Nullable`1[System.Int16]") || IsType(c.DataType, "System.Nullable`1[System.Int32]") || IsType(c.DataType, "System.Nullable`1[System.Int64]") || IsType(c.DataType, "System.Nullable`1[System.Double]") || IsType(c.DataType, "System.Nullable`1[System.Decimal]") || c.DataType == typeof(System.Int16) || c.DataType == typeof(System.Int32) || c.DataType == typeof(System.Int64) || c.DataType == typeof(System.Double) || c.DataType == typeof(System.Decimal)) { values += ((string.IsNullOrEmpty(values) ? "" : ",") + c.ColumnName + "=" + table.Rows[i][c.ColumnName].ToString()); if (keys.Contains(c.ColumnName.ToUpper()) || keys.Contains(c.ColumnName.ToLower())) { keyList.Add(c.ColumnName, table.Rows[i][c.ColumnName].ToString()); } } if (IsType(c.DataType, "System.Nullable`1[System.DateTime]") || c.DataType == typeof(System.DateTime)) { values += ((string.IsNullOrEmpty(values) ? "" : ",") + c.ColumnName + "=" + "DateTime(‘" + table.Rows[i][c.ColumnName].ToString() + "‘)"); if (keys.Contains(c.ColumnName.ToUpper()) || keys.Contains(c.ColumnName.ToLower())) { keyList.Add(c.ColumnName, "DateTime(‘" + table.Rows[i][c.ColumnName].ToString() + "‘)"); } } if (IsType(c.DataType, "System.String") || c.DataType == typeof(System.String)) { values += (string.IsNullOrEmpty(values) ? "" : ",") + c.ColumnName + "=" + "‘" + table.Rows[i][c.ColumnName].ToString() + "‘"; if (keys.Contains(c.ColumnName.ToUpper()) || keys.Contains(c.ColumnName.ToLower())) { keyList.Add(c.ColumnName, "‘" + table.Rows[i][c.ColumnName].ToString() + "‘"); } } } } if (!string.IsNullOrEmpty(values) && keyList != null && keyList.Count == keys.Length) { string strKeys = string.Empty; foreach (KeyValuePair<string, string> kvp in keyList) { strKeys += ((string.IsNullOrEmpty(strKeys) ? "" : " AND ") + kvp.Key + " = " + kvp.Value); } if (!string.IsNullOrEmpty(strKeys)) { sqlstring = string.Format(sqlString, values, strKeys); _List.Add(sqlstring); } } } dbhelper.ExecuteSqlTran(_List); } catch (Exception ex) { throw ex; } finally { _List = null; keyList = null; } } #endregion #region 上传时重构目标数据表insert（数据中带null的处理） public void InsertTableData(DataTable dt, string TableName, DBHelper dbhelper) { try { List<string> _List = new List<string>(); if (dt == null) { throw new Exception("datatable不可为空！"); } if (string.IsNullOrEmpty(TableName)) { throw new Exception("表名不可为空！"); } for (int i = 0; i < dt.Rows.Count; i++) { string sqlstring = string.Empty; string sqlString = "insert into " + TableName + " ({0}) VALUES ({1})"; string Names = string.Empty; string values = string.Empty; foreach (DataColumn c in dt.Columns) { if (dt.Rows[i][c.ColumnName] != null && !string.IsNullOrEmpty(dt.Rows[i][c.ColumnName].ToString())) { Names += (string.IsNullOrEmpty(Names) ? "" : ",") + c.ColumnName; if (IsType(c.DataType, "System.Nullable`1[System.Int16]") || IsType(c.DataType, "System.Nullable`1[System.Int32]") || IsType(c.DataType, "System.Nullable`1[System.Int64]") || IsType(c.DataType, "System.Nullable`1[System.Double]") || IsType(c.DataType, "System.Nullable`1[System.Decimal]") || c.DataType == typeof(System.Int16) || c.DataType == typeof(System.Int32) || c.DataType == typeof(System.Int64) || c.DataType == typeof(System.Double) || c.DataType == typeof(System.Decimal)) { values += (string.IsNullOrEmpty(values) ? "" : ",") + dt.Rows[i][c.ColumnName].ToString(); } if (IsType(c.DataType, "System.Nullable`1[System.DateTime]") || c.DataType == typeof(System.DateTime)) { values += (string.IsNullOrEmpty(values) ? "" : ",") + "DateTime(‘" + dt.Rows[i][c.ColumnName].ToString() + "‘)"; } if (IsType(c.DataType, "System.String") || c.DataType == typeof(System.String)) { values += (string.IsNullOrEmpty(values) ? "" : ",") + "‘" + dt.Rows[i][c.ColumnName].ToString() + "‘"; } } } if (!string.IsNullOrEmpty(Names) && !string.IsNullOrEmpty(values)) { sqlstring = string.Format(sqlString, Names, values); _List.Add(sqlstring); } } dbhelper.ExecuteSqlTran(_List); } catch (Exception ex) { throw ex; } } #endregion
DBHelper SourceDb = new DBHelper("192.168.11.197", "pos1101", "dba", "sql");//源数据库 DBHelper TargetDb = new DBHelper("127.0.0.1", "pos012", "dba", "sql"); //目标
public class DBHelper { #region 构造函数 public DBHelper(string ConnStr) { connstring = ConnStr; } public DBHelper(string Host, string Server, string UserId, string Password) { connstring = "host=" + Host + ";server=" + Server + ";userid=" + UserId + ";password=" + Password + ";"; } public DBHelper() { } #endregion #region 属性信息 private string connstring = null; public string ConnStr { set { connstring = value; } get { return connstring; } } #endregion public DataSet QueryOdbc(string SqlString) { using (SAConnection conn = new SAConnection(connstring)) { SACommand cmd = new SACommand(SqlString, conn); try { conn.Open(); SADataAdapter adp = new SADataAdapter(cmd); DataSet ds = new DataSet(); adp.Fill(ds); conn.Close(); return ds; } catch (Exception ex) { throw new Exception(ex.Message); } } } /// <summary> /// 保存数据 /// </summary> /// <param name="SQLStringList"></param> public void ExecuteSqlTran(List<string> SQLStringList) { using (SAConnection conn = new SAConnection(connstring)) { conn.Open(); SACommand cmd = new SACommand { Connection = conn }; SATransaction tx = conn.BeginTransaction(); cmd.Transaction = tx; try { for (int i = 0; i < SQLStringList.Count; i++) { string strsql = SQLStringList[i].ToString(); if (strsql.Trim().Length > 1) { cmd.CommandText = strsql; cmd.ExecuteNonQuery(); } } tx.Commit(); } catch (Exception ex) { tx.Rollback(); throw new Exception(ex.Message); } finally { conn.Close(); } } } /// <summary> /// 保存数据 /// </summary> /// <param name="SQLStringList"></param> public void ExecuteSqlTran(string SQLString) { using (SAConnection conn = new SAConnection(connstring)) { conn.Open(); SACommand cmd = new SACommand { Connection = conn }; SATransaction tx = conn.BeginTransaction(); cmd.Transaction = tx; try { if (SQLString.Trim().Length > 1) { cmd.CommandText = SQLString; cmd.ExecuteNonQuery(); } tx.Commit(); } catch (Exception E) { tx.Rollback(); throw new Exception(E.Message); } finally { conn.Close(); } } } /// <summary> /// 获取最大主键ID /// </summary> /// <param name="SqlString"></param> /// <returns></returns> public int OdbcGetMaxPKID(string SqlString) { using (SAConnection conn = new SAConnection(connstring)) { SACommand cmd = new SACommand(SqlString, conn); try { conn.Open(); int max_id = cmd.ExecuteScalar().ToString().Equals("") ? 0 : int.Parse(cmd.ExecuteScalar().ToString()); conn.Close(); return max_id; } catch (Exception ex) { throw new Exception(ex.Message); } } } ///// <summary> ///// 测试连接 ///// </summary> //public static void TestConn() //{ // using (SAConnection Conn = new SAConnection(connstring)) // { // Conn.Open(); // SACommand cmd = new SACommand(); // cmd.Connection = Conn; // Conn.Close(); // } //} }
dbhelper类
以上是关于重构insert update 比较两个datatbale的主要内容，如果未能解决你的问题，请参考以下文章