使用 DataAdapter 執行批次作業
適用於:.NET Framework .NET .NET Standard
ADO.NET 中的批次支援可讓 DataAdapter 針對從 DataSet 或 DataTable 至伺服器的 INSERT、UPDATE 與 DELETE 作業進行分組,而非一次傳送一個作業。 如此可降低往返於伺服器的次數,因此一般都能夠大幅提升作業效能。 Microsoft SqlClient Data Provider for SQL Server (Microsoft.Data.SqlClient) 支援批次更新。
在舊版 ADO.NET 中,以 DataSet 的變更更新資料庫時,Update
的 DataAdapter
方法會一次變更資料庫的一個資料列。 當它逐一查看指定之 DataTable 的資料列時,它會檢查每一個 DataRow,以查看是否已修改該資料列。 如果已修改資料列,則會根據該資料列的 UpdateCommand
屬性值,呼叫適當的 InsertCommand
、DeleteCommand
或 RowState。 更新每個資料列時,都必須透過網路與資料庫往來通訊。
在 Microsoft SqlClient Data Provider for SQL Server 中,SqlDataAdapter 會公開 UpdateBatchSize 屬性。 將 UpdateBatchSize
設為正整數值,可將資料庫更新當成所指定大小的批次傳送。 例如,將 UpdateBatchSize
設為 10,會分組 10 個不同的陳述式,並將它們當做單一批次送出。 將 UpdateBatchSize
設為 0,可讓 SqlDataAdapter 使用伺服器可處理的最大批次大小。 將其設定為 1 則可停用批次更新,此時一次只能傳送一個資料列。
注意
執行極大的批次可能會降低效能。 因此,您應該先測試理想的批次大小設定,再實作應用程式。
使用 UpdateBatchSize 屬性
啟用批次更新時,應該將 DataAdapter 的 UpdatedRowSource、UpdateCommand
和 InsertCommand
的 DeleteCommand
屬性值設為 None 或 OutputParameters。 執行批次更新時,命令之 UpdatedRowSource 或 FirstReturnedRecord 的 Both 屬性值無效。
下列程序示範 UpdateBatchSize
屬性的用法。 程序將採用兩個引數,一個是 DataSet 物件 (擁有可表示 Production.ProductCategory 資料表中 ProductCategoryID 和 Name 欄位的資料行),另一個是可表示批次大小的整數 (批次中的資料列數)。 程式碼會建立新的 SqlDataAdapter 物件,並設定其 UpdateCommand、InsertCommand 和 DeleteCommand 屬性。 程式碼假設 DataSet 物件具有已修改過的資料列。 它會設定 UpdateBatchSize
屬性並執行更新。
public static void BatchUpdate(DataTable dataTable, Int32 batchSize)
{
// Assumes GetConnectionString() returns a valid connection string.
string connectionString = GetConnectionString();
// Connect to the AdventureWorks database.
using (SqlConnection connection = new SqlConnection(connectionString))
{
// Create a SqlDataAdapter.
SqlDataAdapter adapter = new SqlDataAdapter();
// Set the UPDATE command and parameters.
adapter.UpdateCommand = new SqlCommand(
"UPDATE Production.ProductCategory SET "
+ "Name=@Name WHERE ProductCategoryID=@ProdCatID;",
connection);
adapter.UpdateCommand.Parameters.Add("@Name",
SqlDbType.NVarChar, 50, "Name");
adapter.UpdateCommand.Parameters.Add("@ProdCatID",
SqlDbType.Int, 4, "ProductCategoryID");
adapter.UpdateCommand.UpdatedRowSource = UpdateRowSource.None;
// Set the INSERT command and parameter.
adapter.InsertCommand = new SqlCommand(
"INSERT INTO Production.ProductCategory (Name) VALUES (@Name);",
connection);
adapter.InsertCommand.Parameters.Add("@Name",
SqlDbType.NVarChar, 50, "Name");
adapter.InsertCommand.UpdatedRowSource = UpdateRowSource.None;
// Set the DELETE command and parameter.
adapter.DeleteCommand = new SqlCommand(
"DELETE FROM Production.ProductCategory "
+ "WHERE ProductCategoryID=@ProdCatID;", connection);
adapter.DeleteCommand.Parameters.Add("@ProdCatID",
SqlDbType.Int, 4, "ProductCategoryID");
adapter.DeleteCommand.UpdatedRowSource = UpdateRowSource.None;
// Set the batch size.
adapter.UpdateBatchSize = batchSize;
// Execute the update.
adapter.Update(dataTable);
}
}
處理批次更新相關的事件與錯誤
DataAdapter 有兩個與更新相關的事件:RowUpdating 及 RowUpdated。 如需詳細資訊,請參閱處理 DataAdapter 事件 (英文)。
批次更新的事件行為變更
啟用批次處理時,會在單一資料庫作業中更新多個資料列。 因此,每個批次作業只會發生一個 RowUpdated
事件,而每個已處理的資料列則會發生 RowUpdating
事件。 停用批次處理時,會以一對一交錯的方式引發這兩個事件,即針對一個資料列引發一個 RowUpdating
事件和一個 RowUpdated
事件,再針對下一個資料列引發一個 RowUpdating
事件和一個 RowUpdated
事件,直到處理完所有資料列為止。
存取更新的資料列
停用批次處理後,就可以使用 Row 類別的 RowUpdatedEventArgs 屬性存取正在更新的資料列。
啟用批次處理時,會針對多個資料列產生單一 RowUpdated
事件。 因此,每個資料列的 Row
屬性值都是 null。 但仍會針對每個資料列產生 RowUpdating
事件。 您可以使用 CopyToRows 類別的 RowUpdatedEventArgs 方法,將處理的資料列參考複製至陣列,以存取這些資料列。 如果目前未處理任何資料列,則 CopyToRows
會擲回 ArgumentNullException。 呼叫 RowCount 方法前,請使用 CopyToRows 屬性傳回已處理的資料列數。
處理資料錯誤
批次執行與執行每個獨立陳述式具有相同的效果。 系統會以陳述式加入至批次的順序執行它們。 批次模式下所發生的錯誤,與停用批次模式所發生的錯誤,擁有相同的處理方式。 每個資料列是分開處理的。 在 DataRow 內的對應 DataTable 中,只會更新資料庫中已成功處理的資料列。
注意
Microsoft SqlClient Data Provider for SQL Server 及後端資料庫伺服器會判斷批次執行支援哪些 SQL 建構。 如果要求執行不受支援的陳述式,則可能擲回例外狀況。