SqlBulkCopy.WriteToServer 方法
定義
重要
部分資訊涉及發行前產品，在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊，不做任何明確或隱含的瑕疵擔保。
多載
| WriteToServer(DbDataReader) |
將提供之 DbDataReader 陣列中的所有資料列複製到 SqlBulkCopy 物件之 DestinationTableName 屬性所指定的目的資料表。 |
| WriteToServer(DataRow[]) |
將提供之 DataRow 陣列中的所有資料列複製到 SqlBulkCopy 物件之 DestinationTableName 屬性所指定的目的資料表。 |
| WriteToServer(DataTable) |
將所提供 DataTable 中的所有資料列複製到 SqlBulkCopy 物件 DestinationTableName 屬性所指定目的地資料表。 |
| WriteToServer(IDataReader) |
將所提供 IDataReader 中的所有資料列複製到 SqlBulkCopy 物件 DestinationTableName 屬性所指定目的地資料表。 |
| WriteToServer(DataTable, DataRowState) |
只會將提供的 DataTable 中符合提供的資料列狀態之資料列複製到 SqlBulkCopy 物件之 DestinationTableName 屬性所指定的目的資料表。 |
WriteToServer(DbDataReader)
將提供之 DbDataReader 陣列中的所有資料列複製到 SqlBulkCopy 物件之 DestinationTableName 屬性所指定的目的資料表。
public:
void WriteToServer(System::Data::Common::DbDataReader ^ reader);public void WriteToServer (System.Data.Common.DbDataReader reader);member this.WriteToServer : System.Data.Common.DbDataReader -> unitPublic Sub WriteToServer (reader As DbDataReader)參數
- reader
- DbDataReader
DbDataReader，其資料列會複製到目的資料表。
例外狀況
SqlBulkCopyColumnOrderHint未指定有效的目的地資料行名稱。
適用於
WriteToServer(DataRow[])
將提供之 DataRow 陣列中的所有資料列複製到 SqlBulkCopy 物件之 DestinationTableName 屬性所指定的目的資料表。
public:
void WriteToServer(cli::array <System::Data::DataRow ^> ^ rows);public void WriteToServer (System.Data.DataRow[] rows);member this.WriteToServer : System.Data.DataRow[] -> unitPublic Sub WriteToServer (rows As DataRow())參數
例外狀況
SqlBulkCopyColumnOrderHint未指定有效的目的地資料行名稱。
範例
下列主控台應用程式示範如何從 DataRow 陣列大量載入資料。 目的地資料表是 AdventureWorks 資料庫中的資料表。
在此範例中， DataTable 會在執行時間建立 。 從 DataTable 選取要複製到目的地資料表的單一資料列。
重要
除非您已建立如 大量複製範例安裝程式中所述的工作資料表，否則不會執行此範例。 這個程式碼僅是為了示範使用 SqlBulkCopy 的語法而提供。 如果來源和目的地資料表位於相同的SQL Server實例中，使用 Transact-SQL INSERT … SELECT 語句來複製資料會比較簡單且更快速。
備註
當大量複製作業正在進行時，相關聯的目的地 SqlConnection 正忙於提供服務，而且無法對連線執行任何其他作業。
集合 ColumnMappings 會從 DataRow 資料行對應至目的地資料庫資料表。
適用於
WriteToServer(DataTable)
將所提供 DataTable 中的所有資料列複製到 SqlBulkCopy 物件 DestinationTableName 屬性所指定目的地資料表。
public:
void WriteToServer(System::Data::DataTable ^ table);public void WriteToServer (System.Data.DataTable table);member this.WriteToServer : System.Data.DataTable -> unitPublic Sub WriteToServer (table As DataTable)參數
例外狀況
SqlBulkCopyColumnOrderHint未指定有效的目的地資料行名稱。
範例
下列主控台應用程式示範如何從 DataTable 大量載入資料。 目的地資料表是 AdventureWorks 資料庫中的資料表。
在此範例中，會在執行時間建立 ， DataTable 而 是作業的來源 SqlBulkCopy 。
重要
除非您已建立如 大量複製範例安裝程式中所述的工作資料表，否則不會執行此範例。
這個程式碼僅是為了示範使用 SqlBulkCopy 的語法而提供。 如果來源和目的地資料表位於相同的SQL Server實例中，使用 Transact-SQL INSERT … SELECT 語句來複製資料會比較簡單且更快速。
using Microsoft.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = GetConnectionString();
// Open a connection to the AdventureWorks database.
using (SqlConnection connection =
new SqlConnection(connectionString))
{
connection.Open();
// Perform an initial count on the destination table.
SqlCommand commandRowCount = new SqlCommand(
"SELECT COUNT(*) FROM " +
"dbo.BulkCopyDemoMatchingColumns;",
connection);
long countStart = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Starting row count = {0}", countStart);
// Create a table with some rows.
DataTable newProducts = MakeTable();
// Create the SqlBulkCopy object.
// Note that the column positions in the source DataTable
// match the column positions in the destination table so
// there is no need to map columns.
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
{
bulkCopy.DestinationTableName =
"dbo.BulkCopyDemoMatchingColumns";
try
{
// Write from the source to the destination.
bulkCopy.WriteToServer(newProducts);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
}
// Perform a final count on the destination
// table to see how many rows were added.
long countEnd = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Ending row count = {0}", countEnd);
Console.WriteLine("{0} rows were added.", countEnd - countStart);
Console.WriteLine("Press Enter to finish.");
Console.ReadLine();
}
}
private static DataTable MakeTable()
// Create a new DataTable named NewProducts.
{
DataTable newProducts = new DataTable("NewProducts");
// Add three column objects to the table.
DataColumn productID = new DataColumn();
productID.DataType = System.Type.GetType("System.Int32");
productID.ColumnName = "ProductID";
productID.AutoIncrement = true;
newProducts.Columns.Add(productID);
DataColumn productName = new DataColumn();
productName.DataType = System.Type.GetType("System.String");
productName.ColumnName = "Name";
newProducts.Columns.Add(productName);
DataColumn productNumber = new DataColumn();
productNumber.DataType = System.Type.GetType("System.String");
productNumber.ColumnName = "ProductNumber";
newProducts.Columns.Add(productNumber);
// Create an array for DataColumn objects.
DataColumn[] keys = new DataColumn[1];
keys[0] = productID;
newProducts.PrimaryKey = keys;
// Add some new rows to the collection.
DataRow row = newProducts.NewRow();
row["Name"] = "CC-101-WH";
row["ProductNumber"] = "Cyclocomputer - White";
newProducts.Rows.Add(row);
row = newProducts.NewRow();
row["Name"] = "CC-101-BK";
row["ProductNumber"] = "Cyclocomputer - Black";
newProducts.Rows.Add(row);
row = newProducts.NewRow();
row["Name"] = "CC-101-ST";
row["ProductNumber"] = "Cyclocomputer - Stainless";
newProducts.Rows.Add(row);
newProducts.AcceptChanges();
// Return the new DataTable.
return newProducts;
}
private static string GetConnectionString()
// To avoid storing the connection string in your code,
// you can retrieve it from a configuration file.
{
return "Data Source=(local); " +
" Integrated Security=true;" +
"Initial Catalog=AdventureWorks;";
}
}
備註
中的所有 DataTable 資料列都會複製到目的地資料表，但已刪除的資料列除外。
當大量複製作業正在進行時，相關聯的目的地 SqlConnection 正忙於提供服務，而且無法對連線執行任何其他作業。
集合 ColumnMappings 會從 DataTable 資料行對應至目的地資料庫資料表。
另請參閱
適用於
WriteToServer(IDataReader)
將所提供 IDataReader 中的所有資料列複製到 SqlBulkCopy 物件 DestinationTableName 屬性所指定目的地資料表。
public:
void WriteToServer(System::Data::IDataReader ^ reader);public void WriteToServer (System.Data.IDataReader reader);member this.WriteToServer : System.Data.IDataReader -> unitPublic Sub WriteToServer (reader As IDataReader)參數
- reader
- IDataReader
IDataReader，其資料列會複製到目的資料表。
例外狀況
SqlBulkCopyColumnOrderHint未指定有效的目的地資料行名稱。
範例
下列主控台應用程式示範如何從 SqlDataReader 大量載入資料。 目的地資料表是 AdventureWorks 資料庫中的資料表。
重要
除非您已建立如 大量複製範例安裝程式中所述的工作資料表，否則不會執行此範例。 這個程式碼僅是為了示範使用 SqlBulkCopy 的語法而提供。 如果來源和目的地資料表位於相同的SQL Server實例中，使用 Transact-SQL INSERT … SELECT 語句來複製資料會比較簡單且更快速。
using Microsoft.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = GetConnectionString();
// Open a sourceConnection to the AdventureWorks database.
using (SqlConnection sourceConnection =
new SqlConnection(connectionString))
{
sourceConnection.Open();
// Perform an initial count on the destination table.
SqlCommand commandRowCount = new SqlCommand(
"SELECT COUNT(*) FROM " +
"dbo.BulkCopyDemoMatchingColumns;",
sourceConnection);
long countStart = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Starting row count = {0}", countStart);
// Get data from the source table as a SqlDataReader.
SqlCommand commandSourceData = new SqlCommand(
"SELECT ProductID, Name, " +
"ProductNumber " +
"FROM Production.Product;", sourceConnection);
SqlDataReader reader =
commandSourceData.ExecuteReader();
// Set up the bulk copy object using a connection string.
// In the real world you would not use SqlBulkCopy to move
// data from one table to the other in the same database.
using (SqlBulkCopy bulkCopy =
new SqlBulkCopy(connectionString))
{
bulkCopy.DestinationTableName =
"dbo.BulkCopyDemoMatchingColumns";
try
{
// Write from the source to the destination.
bulkCopy.WriteToServer(reader);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
finally
{
// Close the SqlDataReader. The SqlBulkCopy
// object is automatically closed at the end
// of the using block.
reader.Close();
}
}
// Perform a final count on the destination
// table to see how many rows were added.
long countEnd = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Ending row count = {0}", countEnd);
Console.WriteLine("{0} rows were added.", countEnd - countStart);
Console.WriteLine("Press Enter to finish.");
Console.ReadLine();
}
}
private static string GetConnectionString()
// To avoid storing the sourceConnection string in your code,
// you can retrieve it from a configuration file.
{
return "Data Source=(local); " +
" Integrated Security=true;" +
"Initial Catalog=AdventureWorks;";
}
}
備註
複製作業會從讀取器中的下一個可用資料列開始。 大部分時候，讀取器只會由 ExecuteReader() 或類似呼叫傳回，因此下一個可用的資料列是第一個資料列。 若要處理多個結果，請在資料讀取器上呼叫 NextResult() ，然後再呼叫 WriteToServer 一次。
請注意，使用 WriteToServer 會修改讀取器的狀態。 方法會呼叫 Read() 直到傳回 false、中止作業或發生錯誤為止。 這表示當作業完成時 WriteToServer ，資料讀取器會處於不同的狀態，可能是在結果集的結尾。
當大量複製作業正在進行時，相關聯的目的地 SqlConnection 正忙於提供服務，而且無法對連線執行任何其他作業。
集合 ColumnMappings 會從資料讀取器資料行對應至目的地資料庫資料表。
適用於
WriteToServer(DataTable, DataRowState)
只會將提供的 DataTable 中符合提供的資料列狀態之資料列複製到 SqlBulkCopy 物件之 DestinationTableName 屬性所指定的目的資料表。
public:
void WriteToServer(System::Data::DataTable ^ table, System::Data::DataRowState rowState);public void WriteToServer (System.Data.DataTable table, System.Data.DataRowState rowState);member this.WriteToServer : System.Data.DataTable * System.Data.DataRowState -> unitPublic Sub WriteToServer (table As DataTable, rowState As DataRowState)參數
- rowState
- DataRowState
DataRowState 列舉中的值。 只將符合資料列狀態的資料列複製到目的端。
例外狀況
SqlBulkCopyColumnOrderHint未指定有效的目的地資料行名稱。
範例
下列主控台應用程式示範如何只大量載入符合指定狀態的資料 DataTable 列。 在此情況下，只會新增未變更的資料列。 目的地資料表是 AdventureWorks 資料庫中的資料表。
在此範例中，會在執行時間建立 ， DataTable 並將三個數據列加入其中。 WriteToServer在執行 方法之前，會編輯其中一個資料列。
使用 WriteToServer 引數呼叫 方法，因此只有兩個 DataRowState.UnchangedrowState 未變更的資料列會大量複製到目的地。
重要
除非您已建立如 大量複製範例安裝程式中所述的工作資料表，否則不會執行此範例。 這個程式碼僅是為了示範使用 SqlBulkCopy 的語法而提供。 如果來源和目的地資料表位於相同的SQL Server實例中，使用 Transact-SQL INSERT … SELECT 語句來複製資料會比較簡單且更快速。
using Microsoft.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = GetConnectionString();
// Open a connection to the AdventureWorks database.
using (SqlConnection connection =
new SqlConnection(connectionString))
{
connection.Open();
// Perform an initial count on the destination table.
SqlCommand commandRowCount = new SqlCommand(
"SELECT COUNT(*) FROM " +
"dbo.BulkCopyDemoMatchingColumns;",
connection);
long countStart = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Starting row count = {0}", countStart);
// Create a table with some rows.
DataTable newProducts = MakeTable();
// Make a change to one of the rows in the DataTable.
DataRow row = newProducts.Rows[0];
row.BeginEdit();
row["Name"] = "AAA";
row.EndEdit();
// Create the SqlBulkCopy object.
// Note that the column positions in the source DataTable
// match the column positions in the destination table so
// there is no need to map columns.
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
{
bulkCopy.DestinationTableName =
"dbo.BulkCopyDemoMatchingColumns";
try
{
// Write unchanged rows from the source to the destination.
bulkCopy.WriteToServer(newProducts, DataRowState.Unchanged);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
}
// Perform a final count on the destination
// table to see how many rows were added.
long countEnd = System.Convert.ToInt32(
commandRowCount.ExecuteScalar());
Console.WriteLine("Ending row count = {0}", countEnd);
Console.WriteLine("{0} rows were added.", countEnd - countStart);
Console.WriteLine("Press Enter to finish.");
Console.ReadLine();
}
}
private static DataTable MakeTable()
// Create a new DataTable named NewProducts.
{
DataTable newProducts = new DataTable("NewProducts");
// Add three column objects to the table.
DataColumn productID = new DataColumn();
productID.DataType = System.Type.GetType("System.Int32");
productID.ColumnName = "ProductID";
productID.AutoIncrement = true;
newProducts.Columns.Add(productID);
DataColumn productName = new DataColumn();
productName.DataType = System.Type.GetType("System.String");
productName.ColumnName = "Name";
newProducts.Columns.Add(productName);
DataColumn productNumber = new DataColumn();
productNumber.DataType = System.Type.GetType("System.String");
productNumber.ColumnName = "ProductNumber";
newProducts.Columns.Add(productNumber);
// Create an array for DataColumn objects.
DataColumn[] keys = new DataColumn[1];
keys[0] = productID;
newProducts.PrimaryKey = keys;
// Add some new rows to the collection.
DataRow row = newProducts.NewRow();
row["Name"] = "CC-101-WH";
row["ProductNumber"] = "Cyclocomputer - White";
newProducts.Rows.Add(row);
row = newProducts.NewRow();
row["Name"] = "CC-101-BK";
row["ProductNumber"] = "Cyclocomputer - Black";
newProducts.Rows.Add(row);
row = newProducts.NewRow();
row["Name"] = "CC-101-ST";
row["ProductNumber"] = "Cyclocomputer - Stainless";
newProducts.Rows.Add(row);
newProducts.AcceptChanges();
// Return the new DataTable.
return newProducts;
}
private static string GetConnectionString()
// To avoid storing the connection string in your code,
// you can retrieve it from a configuration file.
{
return "Data Source=(local); " +
" Integrated Security=true;" +
"Initial Catalog=AdventureWorks;";
}
}
備註
DataTable只有 處於 引數中所 rowState 指出狀態且尚未刪除的資料列會複製到目的地資料表。
當大量複製作業正在進行時，相關聯的目的地 SqlConnection 正忙於提供服務，而且無法對連線執行任何其他作業。
集合 ColumnMappings 會從 DataTable 資料行對應至目的地資料庫資料表。