用.NET SqlBulkCopy类执行批量复制
在不同數據源之間轉移數據是一個常見的開發任務。如果你應用過SQL Server，就會熟悉bcp（批量復制）命令。
它允許你快速將大型文件批量復制到SQL Server表或視圖中。在.NET Framework 1.1中，可以通過SqlCommand對象利用bcp，但.NET Framework 2.0中增加了SqlBulkCopy類來簡化這個繁瑣的過程。
SqlBulkCopy類
雖然你仍然可以使用t-splbcp命令，但SqlBulkCopy類具有很強的性能優勢。你只能使用這個類往SQL Server表中寫入數據，但可以使用任何數據源。唯一要注意的地方在于，數據源的內容必須能夠加載到一個DataTable對象中。
在詳細說明這個類的用法前，我們先簡單概括這個類的功能：
- 單獨批量復制操作，可將數據從一個數據源移動到SQL Server表中。
- 也可執行多個批量復制操作。
- 在數據庫事務中可執行批量復制操作。
MSDN提供更多關于SqlBulkCopy類的方法和屬性的細節。其最重要的屬性為Destination TableName，最重要的方法為WriteToServer。
DestinationTableName屬性指定接受復制記錄的表。由于它有一個由三部分組成的名稱（database.owningschema.name），因此它遵循SQL Server語法。你可以用它的數據庫和所有模式來限制表名稱。
數據庫通過在連接字符串中指定（通過Initial Catalog值）。另外，如果表名稱使用一個下劃線或任何其它特殊的字符，你必須使用方括號避免這類名稱，如[database.owningschema.name]。
實際上由這個超載的WriteToServer方法執行批量復制。它接受DataTable、DataRow和IDataReader對象為復制數據源。你還可以用DataTable對象包含一個DataRowState值，指定僅復制匹配的行。
下一個Windows控制臺應用程序說明從一個數據庫表向另一個數據庫表復制數據這種非常基本的操作。從它的Employees表往這個表的備份表Employees_bcp中復制數據時，它使用標準的SQL Server 2000 Northwind數據庫。
――――――――――――――――――――――――――――
?
查看列表A（列表B中為對應的VB.NET代碼）。基本上，這段代碼連接到數據庫，并將所有值從Employees表讀入SqlDataReader對象中。
設定目標表名稱后，則使用SqlDataReader對象執行批量復制操作（它作為唯一的參數提交）。你可以檢查服務器上的目標表，看數據是否被復制。
執行多次更新并無差異——你只需重復使用SqlDataReader對象即可。在同一個數據庫中從一個表往另一個表復制是對bcp的誤用。另一方面，從外部文件中輸入數據是一個常見的操作。
列表C在將一個文本文件輸入到前一個例子中用到的表中時就采用了這個方法。（列表D中是對應的VB.NET代碼。）這段代碼建立一個新的DataTable對象，為每種數據設立列。
每次讀入一行文件，并用逗號分列，每個數據值分配給DataTable中適當的列。接下來，SqlBulkCopy類的ColumnMappings屬性 允許你使用列名稱，將數據源中（我們的DataTable）的一個列映射到目的地。完成映射后，WriteToServer方法使用提交給它的 DataTable執行批量操作。
數據移植最佳實踐
雖然數據移植是開發者經常要執行的任務，但它并不是一個非常流行的任務。請在文后的討論部分與.NET社區分享你的最輕松（最糟糕）的數據移植經歷和最佳實踐。
―――――――――――――――――――――――――――
?
?
using System;using System.Collections.Generic;
using System.Text;
using System.Data.SqlClient;
namespace BCP {
class Program {
static void Main(){
string cString = "Data Source=(local);User ID=tester;Password=tester;Initial Catalog=Northwind;";
using (SqlConnectionconn = new SqlConnection(cString)) {
conn.Open();
SqlCommand comm = new SqlCommand("SELECT EmployeeID, FirstName, LastName, HomePhone FROM Employees;", conn);
SqlDataReader reader = comm.ExecuteReader();
using (SqlConnection conn2 = new SqlConnection(cString)){
conn2.Open();
using (SqlBulkCopy bcp = new SqlBulkCopy(conn2)) {
bcp.DestinationTableName = "dbo.Employees_bcp";
try {
bcp.WriteToServer(reader);
} catch (Exception ex) {
Console.WriteLine(ex.Message);
} finally {
reader.Close();
} } } } } } }
?
―――――――――――――――――――――――――――
Imports System.Data.SqlClientModule Module1
Sub Main()
Dim cString As String
cString = "Data Source=(local);User ID=tester;Password=tester;Initial Catalog=Northwind;"
Dim conn As New SqlConnection
conn = New SqlConnection(cString)
conn.Open()
Dim comm As SqlCommand
comm = New SqlCommand("SELECT EmployeeID, FirstName, LastName, HomePhone FROM Employees;", conn)
Dim reader As SqlDataReader
reader = comm.ExecuteReader()
Dim conn2 As SqlConnection
conn2 = New SqlConnection(cString)
conn2.Open()
Dim bcp As SqlBulkCopy
bcp = New SqlBulkCopy(conn2)
bcp.DestinationTableName = "dbo.Employees_bcp"
Try
bcp.WriteToServer(reader)
Catch ex As Exception
Console.WriteLine(ex.Message)
Finally
reader.Close()
End Try
End Sub
End Module
?
?
?
?
?
?
?
using System;using System.Collections.Generic;
using System.Text;
using System.Data.SqlClient;
using System.IO;
using System.Data;
namespace BCP {
class Program{
static void Main(){
string cString = "Data Source=(local);User ID=tester;Password=tester;Initial Catalog=Northwind;";
using (SqlConnectionconn = new SqlConnection(cString)) {
conn.Open();
SqlCommandcomm = new SqlCommand("SELECT FirstName, LastName, HomePhone, Title FROM Employees;", conn);
SqlDataReader reader = comm.ExecuteReader();
using (SqlConnection conn2 = new SqlConnection(cString)) {
conn2.Open();
using (SqlBulkCopybcp = new SqlBulkCopy(conn2)){
DataTabledt = new DataTable();
DataRowdr;
DataColumn dc;
bcp.DestinationTableName = "dbo.Employees_bcp";
dc = new DataColumn();
dc.ColumnName = "Last";
dt.Columns.Add(dc);
dc = new DataColumn();
dc.ColumnName = "First";
dt.Columns.Add(dc);
dc = new DataColumn();
dc.ColumnName = "HomePhone";
dt.Columns.Add(dc);
dc = new DataColumn();
dc.ColumnName = "Title";
dt.Columns.Add(dc);
StreamReadersr = new StreamReader(@"c:emp.txt");
string input;
while ((input = sr.ReadLine()) != null) {
string[] s = input.Split(new char[] );
dr = dt.NewRow();
dr["Last"] = s[0];
dr["First"] = s[1];
dr["HomePhone"] = s[2];
dr["Title"] = s[3];
dt.Rows.Add(dr);
}
sr.Close();
try {
bcp.ColumnMappings.Add("Last", "LastName");
bcp.ColumnMappings.Add("First", "FirstName");
bcp.ColumnMappings.Add("Title","Title");
bcp.ColumnMappings.Add("HomePhone","HomePhone");
bcp.WriteToServer(dt);
} catch (Exception ex){
Console.WriteLine(ex.Message);
} finally {
reader.Close();
} } } } } } }
?
?
?
?
Imports System.DataImports System.Data.SqlClient
Imports System.IO
Module Module1
Sub Main()
Dim cString As String
Dim comma As Char
comma = ","
cString = "Data Source=(local);User ID=tester;Password=tester;Initial Catalog=Northwind;"
Dim conn As New SqlConnection
conn = New SqlConnection(cString)
conn.Open()
Dim comm As SqlCommand
comm = New SqlCommand("SELECT EmployeeID, FirstName, LastName, HomePhone FROM Employees;", conn)
Dim reader As SqlDataReader
reader = comm.ExecuteReader()
Dim conn2 As SqlConnection
conn2 = New SqlConnection(cString)
conn2.Open()
Dim bcp As SqlBulkCopy
bcp = New SqlBulkCopy(conn2)
bcp.DestinationTableName = "dbo.Employees_bcp"
Try
Dim dt As DataTable
Dim dr As DataRow
Dim dc As DataColumn
dt = New DataTable()
bcp.DestinationTableName = "dbo.Employees_bcp"
dc = New DataColumn()
dc.ColumnName = "Last"
dt.Columns.Add(dc)
dc = New DataColumn()
dc.ColumnName = "First"
dt.Columns.Add(dc)
dc = New DataColumn()
dc.ColumnName = "HomePhone"
dt.Columns.Add(dc)
dc = New DataColumn()
dc.ColumnName = "Title"
dt.Columns.Add(dc)
Dim sr As StreamReader
sr = New StreamReader("c:emp.txt")
Dim input As String
input = sr.ReadLine()
While Not (input Is Nothing)
Dim s As String()
s = input.Split(comma)
dr = dt.NewRow()
dr("Last") = s(1)
dr("First") = s(2)
dr("HomePhone") = s(3)
dr("Title") = s(4)
dt.Rows.Add(dr)
input = sr.ReadLine()
End While
sr.Close()
bcp.ColumnMappings.Add("Last", "LastName")
bcp.ColumnMappings.Add("First", "FirstName")
bcp.ColumnMappings.Add("Title", "Title")
bcp.ColumnMappings.Add("HomePhone", "HomePhone")
bcp.WriteToServer(dt)
Catch ex As Exception
Console.WriteLine(ex.Message)
Finally
reader.Close()
End Try
End Sub End Module
轉載于:https://www.cnblogs.com/soundcode/archive/2012/09/26/2703642.html
總結
以上是生活随笔為你收集整理的用.NET SqlBulkCopy类执行批量复制的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： sqlserver Conversion
- 下一篇： 流水单号产生方法