我們經常要在一個表中將數據遷移到另一個表，當然，用的方法十分多了。在.net 2.0中，提供了一個sqlbulkcopy類，也可以實現如下的操作，下面簡單介紹下。比如一個表如下
CREATE TABLE Person3
(

PersonID int IDENTITY(1,1) PRIMARY KEY,
Name nvarchar(200),
Email nvarchar(200),
Picture image

)

INSERT INTO Person3(Name,Email,Picture)
SELECT Name,Email,Picture FROM Person

假設person表已經存在了，則上面的語句可以往person3表中插入數據(在sql server 2005中執行）。現在我們使用下面的代碼來實現
string connectionString = ConfigurationManager.ConnectionStrings["MyDatabase"].ConnectionString;
SqlConnection myConnection = new SqlConnection(connectionString);

SqlCommand myCommand = new SqlCommand("SELECT * FROM Person", myConnection);

myConnection.Open();

SqlDataReader dr = myCommand.ExecuteReader();

SqlConnection myNewConnection = new SqlConnection(connectionString);

myNewConnection.Open();

SqlBulkCopy bulk = new SqlBulkCopy(myNewConnection);

bulk.DestinationTableName = "[Person3]";

try

{

bulk.WriteToServer(dr);

}

catch (Exception ex)

{

Response.Write(ex.Message);

}

finally

{

myNewConnection.Close();

dr.Close();

myConnection.Close();

bulk.Close();

}


下面來解析下。首先，新建一個數據庫連接，之后是很經典的代碼了，從person表中拿出數據，當到datareader中去。之后，我們又新建立了個數據連接，之后，使用

SqlBulkCopy bulk = new SqlBulkCopy(myNewConnection);

bulk.DestinationTableName = "[Person3]";

其中，將mynewconnection作為參數傳到 sqlbulkcopy類的構造參數中去，并指定目標遷移的表名是person3.
之后，再使用bulk.WriteToServer(dr);就可以遷移了。
而上面的person表和person3的結構是完全相同的，那么如果結構不同的，怎么辦呢？下面舉例子說明，創建一個表person2
CREATE TABLE Person2
(
PersonID int IDENTITY(1,1) PRIMARY KEY,
FirstName nvarchar(200),
LastName nvarchar(200),
Email nvarchar(200),
Picture image
)
如果我們按上面將person表遷移到person2表中去，將會出錯，因為字段不同，而我們將采用下面的代碼
string connectionString = ConfigurationManager.ConnectionStrings["MyDatabase"].ConnectionString;
SqlConnection myConnection = new SqlConnection(connectionString);

SqlCommand myCommand = new SqlCommand("SELECT * FROM Person", myConnection);

myConnection.Open();

SqlDataReader dr = myCommand.ExecuteReader();

SqlConnection myNewConnection = new SqlConnection(connectionString);

myNewConnection.Open();

SqlBulkCopy bulk = new SqlBulkCopy(myNewConnection);

bulk.DestinationTableName = "[Person2]";

bulk.ColumnMappings.Add("Name", "LastName");

bulk.ColumnMappings.Add("Email", "Email");

bulk.ColumnMappings.Add("Picture", "Picture");

try

{

bulk.WriteToServer(dr);

}

catch (Exception ex)

{

Response.Write(ex.Message);

}

finally

{

myNewConnection.Close();

dr.Close();

myConnection.Close();

bulk.Close();

}

可以看到，這里使用bulk.ColumnMappings.Add（“。。。”，“。。。”）來強制規定，源目標字段和哪一個目標表的字段相匹配了。
據說用sqlbulkcopy類，在數據多的情況下，性能是十分好的，呵呵。



posted on 2005-08-29 19:22 jackyrong的世界 閱讀(579) 評論(1) 編輯 收藏 引用 收藏至365Key 所屬分類: .NET

Feedback
# re: 在asp.net 2.0中使用SqlBulkCopy類遷移數據 2006-06-13 16:39 antony.net
寫的很明白，但我有一個問題，你的PersonID 是自增列吧，你用SqlBulkCopy bulk = new SqlBulkCopy(myNewConnection);
那么導數據沒有問題，PersonID 會自增，但你用這個：SqlBulkCopy bulk = new SqlBulkCopy(myNewConnection, SqlBulkCopyOptions.KeepIdentity+ SqlBulkCopyOptions.UseInternalTransaction)也就是放在一個事務里，就有主鍵沖突的問題。不知道你有沒有遇到過這個問題。我覺得很奇怪的哦。你有什么看法？

轉載于:https://www.cnblogs.com/tlnature/archive/2009/02/26/1398835.html

總結

以上是生活随笔為你收集整理的在asp.net 2.0中使用SqlBulkCopy类迁移数据[转]的全部內容，希望文章能夠幫你解決所遇到的問題。

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