Merge(在一條語句中使用Insert,Update,Delete) 對兩個表進行同步數據


SQL Server 2008提供了一個增強的SQL命令Merge,用法參看MSDN:http://msdn.microsoft.com/zh-cn/library/bb510625.aspx

功能:根據與源表聯接的結果,對目標表執行插入、更新或刪除操作。例如,根據在另一個表中找到的差異在一個表中插入、更新或刪除行,可以對兩個表進行同步。

我們看一個例子,假如,有一總產品列表,一個分店產品列表,需要從分店添加產品時更新總產品列表。

總產品表,分店產品表結構完全一致:

復制代碼
  
  
  
          
if OBJECT_ID ( ' Demo_AllProducts ' ) is not null
drop table Demo_AllProducts
go
Create table Demo_AllProducts
(PKID
int not null identity ( 1 , 1 ) primary key
,DName
Nvarchar ( 20 ) null
,DCode
NVarchar ( 30 ) null
,DDate
datetime null
)
go

-- this SQL is only for SQL Server 2008
Insert into Demo_AllProducts
(DName,DCode,DDate)
values
(
' DemoA ' , ' AAA ' , GETDATE ()),
(
' DemoB ' , ' BBB ' , GETDATE ()),
(
' DemoC ' , ' CCC ' , GETDATE ()),
(
' DemoD ' , ' DDD ' , GETDATE ()),
(
' DemoE ' , ' EEE ' , GETDATE ())

select * from Demo_AllProducts

-- PKID DName DCode DDate
--
1 DemoA AAA 2010-10-12 20:33:54.417
--
2 DemoB BBB 2010-10-12 20:33:54.417
--
3 DemoC CCC 2010-10-12 20:33:54.417
--
4 DemoD DDD 2010-10-12 20:33:54.417
--
5 DemoE EEE 2010-10-12 20:33:54.417
復制代碼
復制代碼
  
  
  
          
if OBJECT_ID ( ' Demo_Shop1_Product ' ) is not null
drop table Demo_Shop1_Product
go

Create table Demo_Shop1_Product
(PKID
int not null identity ( 1 , 1 ) primary key
,DName
Nvarchar ( 20 ) null
,DCode
NVarchar ( 30 ) null
,DDate
datetime null
)
go

-- this SQL is only for SQL Server 2008
Insert into Demo_Shop1_Product
(DName,DCode,DDate)
values
(
' DemoA ' , ' AAA ' , GETDATE ()),
(
' DemoB ' , ' CCC ' , GETDATE ()),
(
' DemoF ' , ' FFF ' , GETDATE ())

select * from Demo_Shop1_Product

-- PKID DName DCode DDate
--
1 DemoA AAA 2010-10-17 20:19:32.767
--
2 DemoB CCC 2010-10-17 20:19:32.767
--
3 DemoF FFF 2010-10-17 20:19:32.767
復制代碼

假定現在需要將分店數據完全合並到總產品表中,以編碼字段為依據,如果產品名稱不致,則用分店的產品名稱替換總產品名稱。

如果總產品表中不存在,則添加。

可選項:如果分店表中不存在,則從總產品表中刪除分店中沒有的行。如果這樣,總產品表和分店表就完全同步了。實際操作中可能不需要刪除目標表的行。

語句如下:

復制代碼
  
  
  
          
-- 確定目標表
Merge Into Demo_AllProducts p
-- 從數據源查找編碼相同的產品
using Demo_Shop1_Product s on p.DCode = s.DCode
-- 如果編碼相同,則更新目標表的名稱
When Matched and P.DName <> s.DName Then Update set P.DName = s.DName
-- 如果目標表中不存在,則從數據源插入目標表
When Not Matched By Target Then Insert (DName,DCode,DDate) values (s.DName,s.DCode,s.DDate)
-- 如果數據源的行在源表中不存在,則刪除源表行
When Not Matched By Source Then Delete ;
復制代碼

此時,執行完成后,兩個表的行均如下:

  
  
  
          
-- PKID DName DCode DDate
--
1 DemoA AAA 2010-10-17 20:31:00.827
--
2 DemoB CCC 2010-10-17 20:31:00.827
--
3 DemoF FFF 2010-10-17 20:31:00.827
如果不刪除,語句如下:
復制代碼
  
  
  
          
-- 確定目標表
Merge Into Demo_AllProducts p
-- 從數據源查找編碼相同的產品
using Demo_Shop1_Product s on p.DCode = s.DCode
-- 如果編碼相同,則更新目標表的名稱
When Matched and P.DName <> s.DName Then Update set P.DName = s.DName
-- 如果目標表中不存在,則從數據源插入目標表
When Not Matched By Target Then Insert (DName,DCode,DDate) values (s.DName,s.DCode,s.DDate);
復制代碼
執行后結果:
復制代碼
  
  
  
          
-- PKID DName DCode DDate
--
1 DemoA AAA 2010-10-17 20:30:28.350
--
2 DemoB BBB 2010-10-17 20:30:28.350
--
3 DemoB CCC 2010-10-17 20:30:28.350
--
4 DemoD DDD 2010-10-17 20:30:28.350
--
5 DemoE EEE 2010-10-17 20:30:28.350
--
6 DemoF FFF 2010-10-17 20:31:00.827

-- PKID DName DCode DDate
--
1 DemoA AAA 2010-10-17 20:31:00.827
--
2 DemoB CCC 2010-10-17 20:31:00.827
--
3 DemoF FFF 2010-10-17 20:31:00.827
復制代碼

如果需要記錄Merge語句影響的行,可以用Output子句,如果僅僅需要知道影響的行數,可以使用@@ROWCOUNTROWCOUNT_BIG(),修改后的示例如下:

復制代碼
  
  
  
          
-- 定義表變量以存儲輸出
Declare @tableVarRecord Table
(MPKID
int not null identity ( 1 , 1 ) primary key
,PKID
int null
,DName
Nvarchar ( 20 ) null
,DCode
NVarchar ( 30 ) null
,DDate
datetime null
)

-- 確定目標表
Merge Into Demo_AllProducts p
-- 從數據源查找編碼相同的產品
using Demo_Shop1_Product s on p.DCode = s.DCode
-- 如果編碼相同,則更新目標表的名稱
When Matched and P.DName <> s.DName Then
Update set P.DName = s.DName

-- 如果目標表中不存在,則從數據源插入目標表
When Not Matched By Target Then
Insert (DName,DCode,DDate) values (s.DName,s.DCode,s.DDate)

-- 如果數據源的行在源表中不存在,則刪除源表行
When Not Matched By Source Then
Delete OUTPUT deleted. * INTO @tableVarRecord ;
-- --Delete OUTPUT Inserted.* INTO @tableVarRecord;

-- 返回上個Merge語句影響的行數
select @@ROWCOUNT as Count1,ROWCOUNT_BIG() as Count2

select * from @tableVarRecord ;
復制代碼
結果:
復制代碼
  
  
  
          
-- 影響的行數
--
Count1 Count2
--
5 5

-- Deleted表的行
--
MPKID PKID DName DCode DDate
--
1 NULL NULL NULL NULL
--
2 2 DemoB BBB 2010-10-17 21:42:30.700
--
3 3 DemoC CCC 2010-10-17 21:42:30.700
--
4 4 DemoD DDD 2010-10-17 21:42:30.700
--
5 5 DemoE EEE 2010-10-17 21:42:30.700
復制代碼

關於@@ROWCOUNTROWCOUNT_BIG()的更多說明,請查閱MSDN:

http://technet.microsoft.com/zh-tw/library/ms187316.aspx 

http://msdn.microsoft.com/en-us/library/ms181406.aspx

如果影響的結果超過20億,即整型的最大范圍,請使用后者。

 

【轉】邀月工作室

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM