Sql Server資料庫使用觸發器和sqlbulkcopy大批量資料插入更新
需要了解的知識
1.觸發器
2.sqlbulkcopy
我的用途
開發資料庫同步的工具,需要大批量資料插入和資料更新。
方式
使用SqlBulkCopy類對資料進行資料批量複製,將需要同步資料的表新建一個結構相同的臨時表。然後在臨時表編寫觸發器用於對更新資料的表進行資料插入和更新;
觸發器要點
1.觸發器(trigger)是一種特殊的儲存過程,當你對一個表進行Insert、Delete或Update時進行觸發;
2.觸發器觸發時自動在系統建立inserted和deleted表,觸發器執行完成後自動刪除:
inserted存放,新增和更新的資料;
deleted表存放刪除和更新前的資料;
3.AFTER和INSTEAD OF是兩種觸發器:
AFTER是在完成執行Insert、Delete或Update才進行觸發;INSTEAD OF 觸發器的動作要早於表的約束處理;
觸發器內容參考 http://www.cnblogs.com/selene/p/4493311.html
SqlBulkCopy類
示例程式碼
1 /// <summary> 2 /// SqlBulkCopy 3 /// </summary> 4 /// <param name="connectionString">目標連線字元</param> 5 /// <param name="TableName">目標表</param> 6 /// <param name="dt">資料來源</param> 7 private void SqlBulkCopyByDatatable(string connectionString, string TableName, DataTable dt) 8 { 9 using (SqlConnection conn = new SqlConnection(connectionString)) 10 { 11 using (SqlBulkCopy sqlbulkcopy = new SqlBulkCopy(connectionString, SqlBulkCopyOptions.FireTriggers))12 { 13 try 14 { 15 sqlbulkcopy.DestinationTableName = TableName; 16 for (int i = 0; i < dt.Columns.Count; i++) 17 { 18 sqlbulkcopy.ColumnMappings.Add(dt.Columns[i].ColumnName, dt.Columns[i].ColumnName); 19 } 20 sqlbulkcopy.WriteToServer(dt); 21 } 22 catch (System.Exception ex) 23 { 24 throw ex; 25 } 26 } 27 } 28 }
MSDN介紹
特別說明的是
SqlBulkCopyOptions 屬性設定為FireTriggers,是來啟用對應表觸發器的;
例項
新建三張表,結構非常簡單;
SELECT Table_1.id , Table_1.name FROM dbo.Table_1; SELECT Table_2.id , Table_2.name FROM dbo.Table_2; SELECT Table_3.id , Table_3.name FROM dbo.Table_3;
建立表
CREATE TABLE [dbo].[Table_1] ( [id] [NCHAR](10) NULL , [name] [NCHAR](10) NULL ) ON [PRIMARY];
當向 Table_3 插入資料時,
判斷資料在 Table_1 是否存在相同 id 如果存在,更新 name 欄位;如果不存在新增資料到 Table_1。
表 Table_2 主要用於測試觸發器內的語句;
Table_3 的觸發器
CREATE TRIGGER [dbo].[tri_Insert] ON [dbo].[Table_3] INSTEAD OF INSERT AS --存在更新 UPDATE dbo.Table_1 SET id = INSERTED.id,name = INSERTED.NAME FROM Table_1 JOIN inserted ON Table_1.id = INSERTED.id --不存在新增 INSERT dbo.Table_1 ( id, name ) SELECT INSERTED.id,INSERTED.name FROM INSERTED LEFT OUTER JOIN Table_1 ON INSERTED.id = Table_1.id WHERE Table_1.ID IS NULL
這個觸發器實現了當向 Table_3 表插入資料時判斷 Table_1 是否存在這條資料,存在則更新,不存在則新增的目的;
對於新增更新這兩條語句,可以在Table_2 進行測試為何這樣寫,原理非常簡單;
FQA
SqlBulkCopy批量插入的DataTable要求:
插入的DataTable必須與目標表結構相同,我的做法是先 SELECT * FROM TableName WHERE 1=2 獲取的表結構;
SqlBulkCopy主鍵是否自動更新,相同主鍵是否更新:
我經過測試,主鍵標識列在Insert中置空後自動自增,相同主鍵也不會主動更新,而是新增;
同時當新增碰到標識約束時,插入相同標識時會返回異常;及時賦相同ID值也會新標識相同無法更新;
AFTER和INSTEAD OF兩種觸發器的不同
在向觸發器批量更新資料時,INSTEAD OF是將資料直接交給觸發器執行(動作要早於表的約束處理??),觸發器語句如果沒有對錶新增的語句則不會新增資料;(??理解是否有偏差??)
而AFTER是對錶操作完成後才執行觸發器;
大批量插入更新操作使用 INSTEAD OF 的目的是這樣就不用清臨時表操作了。