批量更新數據（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();
}
}
}
}

總結

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

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