批量更新數據（BatchUpdate） /// <summary> /// 批量更新數據，注意：如果有timestamp列，要移除 /// </summary> /// <param name="sourceTable">源數據</param> /// <param name="targetTableName">目標table</param> /// <param name="primaryKeyName">主鍵，根據主鍵來更新數據,不是自增長</param> /// <param name="identity">自增長列</param> /// <param name="columnsName">列名</param> /// <param name="limitWhere">條件</param> /// <param name="batchNum">批量更新的數量</param> /// <returns></returns> public Boolean BatchUpdate(DataTable sourceTable, string targetTableName, string primaryKeyName, string identity, string[] columnsName, string limitWhere, int batchNum) { if (string.IsNullOrEmpty(targetTableName)) return false; if (string.IsNullOrEmpty(primaryKeyName)) return false; if (columnsName == null || columnsName.Length <= 0) return false; DataSet ds = new DataSet(); ds.Tables.Add(sourceTable); ds.Tables[0].TableName = targetTableName; using (SqlConnection conn = new SqlConnection(strConn)) { conn.Open(); using (SqlTransaction transaction = conn.BeginTransaction(IsolationLevel.ReadCommitted))//使用加強讀寫鎖事務，避免臟讀 { try { foreach (DataRow row in ds.Tables[0].Rows) { row.AcceptChanges(); row.SetModified();//所有行設置為可修改 } string cols = string.Join(",", columnsName); cols = "[" + cols.Replace(",", "],[") + "]"; SqlCommand cmd = new SqlCommand(string.Format("SELECT {2} FROM {0} WHERE {1}", targetTableName, limitWhere, cols), conn); cmd.Transaction = transaction; SqlDataAdapter adapter = new SqlDataAdapter(cmd); SqlCommandBuilder sqlCmdBuilder = new SqlCommandBuilder(adapter); adapter.AcceptChangesDuringFill = false; adapter.Fill(ds); string updateSQL = string.Empty; SqlParameter[] paras = new SqlParameter[columnsName.Length]; for (int i = 0; i < columnsName.Length; i++) { //去除自增長ID ，根據可控的自增Id進行更新 if (columnsName[i] != primaryKeyName && columnsName[i] != identity) { updateSQL += ("[" + columnsName[i] + "]" + "=@" + columnsName[i] + ","); } if (sourceTable.Columns[i].DataType.Name == "Int32") { paras[i] = new SqlParameter("@" + columnsName[i], SqlDbType.Int, 10, columnsName[i]); } else if (sourceTable.Columns[i].DataType.Name == "DateTime") { paras[i] = new SqlParameter("@" + columnsName[i], SqlDbType.DateTime, 23, columnsName[i]); } else if (sourceTable.Columns[i].DataType.Name == "Double") { paras[i] = new SqlParameter("@" + columnsName[i], SqlDbType.Decimal, 23, columnsName[i]); } else { paras[i] = new SqlParameter("@" + columnsName[i], SqlDbType.NVarChar, -1, columnsName[i]);//-1表示大于4000的長度 } } if (!string.IsNullOrEmpty(updateSQL)) { updateSQL = updateSQL.Trim(','); } string limitSql = ("[" + primaryKeyName + "]" + "=@" + primaryKeyName); SqlCommand updateCmd = new SqlCommand(string.Format("UPDATE {0} SET {1} WHERE {2}", targetTableName, updateSQL, limitSql)); //設置不修改源Table updateCmd.UpdatedRowSource = UpdateRowSource.None; adapter.UpdateCommand = updateCmd; adapter.UpdateCommand.Parameters.AddRange(paras); updateCmd.Transaction = transaction; adapter.UpdateCommand.CommandTimeout = 36000;//超時時間 adapter.UpdateBatchSize = batchNum; adapter.Update(ds, targetTableName); ds.AcceptChanges(); transaction.Commit(); return true; } catch (Exception ex) { transaction.Rollback(); return false; throw ex; } finally { conn.Close(); conn.Dispose(); } } } }

?

轉載于:https://www.cnblogs.com/hnzheng/p/9179090.html

總結

以上是生活随笔為你收集整理的批量更新数据（BatchUpdate）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。