1. 程式人生 > >Sql Server資料庫使用觸發器和sqlbulkcopy大批量資料插入更新

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 的目的是這樣就不用清臨時表操作了。