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類

示例代碼

/// <summary>
/// SqlBulkCopy
/// </summary>
/// <param name="connectionString">目標連接字符</param>
/// <param name="TableName">目標表</param>
/// <param name="dt">數據源</param>
private void SqlBulkCopyByDatatable(string connectionString, string TableName, DataTable dt)
{
    using (SqlConnection conn = new SqlConnection(connectionString))
    {
        using (SqlBulkCopy sqlbulkcopy = new SqlBulkCopy(connectionString, SqlBulkCopyOptions.FireTriggers))
        {
            try
            {
                sqlbulkcopy.DestinationTableName = TableName;
                for (int i = 0; i < dt.Columns.Count; i++)
                {
                    sqlbulkcopy.ColumnMappings.Add(dt.Columns[i].ColumnName, dt.Columns[i].ColumnName);
                }
                sqlbulkcopy.WriteToServer(dt);
            }
            catch (System.Exception ex)
            {
                throw ex;
            }
        }
    }
}

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