2. 程式人生 > >一次SQLSERVER觸發器編寫感悟

一次SQLSERVER觸發器編寫感悟

阿新 • • 發佈：2017-06-20
delet 自己的 角度 ins trac tope avi 插入 mic

背景：BOSS須要我寫一個工廠採集端到服務器端的數據同步觸發器，數據庫採用的是sqlserver2008

需求：將多臺採集機的數據同步到server中，假設採集端數據庫與server數據庫連接失敗則將數據保存到記錄表中

前期思路：從採集端創建server端的數據庫鏈接，通過採集端的insert,update觸發。同一時候往遠程表寫入

問題：因為初始接觸sqlserver。對sqlserver觸發器了解不深。查閱一些資料後寫出了滿足正常情況下（連接服務器數據庫正常）的觸發器。

create trigger trig_sensor_shengyang

on dbo.sensor_test

for insert,update as

begin

--假設原表沒有該記錄則插入該記錄

IF NOT EXISTS(SELECT * FROM deleted)

begin

set NOCOUNT ON;

begin tran

--insertopenrowset(‘sqloledb‘,‘XXX.XXX.XXX.XXX‘;‘DBUSER‘;‘DBPWD‘,bwdb.dbo.test)

--向server表插入該條數據

insert into shengyang.bwdb.dbo.test select * from inserted

--同一時候向記錄表中插入數據

insert into dbo.test_bak values((select unid from inserted),(select sensor_id from inserted),‘create‘)

commit tran

end

else

--假設原表存在該記錄則更新該記錄

begin

set NOCOUNT ON;

begin tran

--update openrowset(‘sqloledb‘,‘XXX.XXX.XXX.XXX‘;‘DBUSER‘;‘DBPWD‘,bwdb.dbo.test)

--更新server表記錄

update shengyang

.bwdb.dbo.test set unid = inserted.unid from inserted

--推斷假設記錄表中存在對該條數據的記錄，則更新記錄表中的記錄

--（針對記錄表中同一時候存在對同一條數據的create,update。僅僅須要記錄終於unid。

--假設有create終於仍然向server表create，假設是多次更新僅僅需記錄最後一次更新）

if exists(select * from dbo.test_bak where sensor_id=(select sensor_id from inserted))

begin

update dbo.test_bak set unid=i.unid from inserted i

end

--假設記錄表中不存在對該條數據的改動記錄，則在記錄標中插入該數據的update記錄

else

begin

insert into dbo.test_bak values ((select unid from inserted),(select sensor_id from inserted),‘update‘)

end

commit tran

end

end


可是因為須要考慮兩方網絡不通的情況，因此須要做異常處理。開始沒查找到推斷遠程數據庫連接的方法，因此想著直接通過try catch來實現（try塊裏面運行可能出現異常的——往遠程server端寫入的代碼，catch塊裏寫往採集端本地記錄表中的代碼）

create trigger trig_sensor_shengyang
on dbo.sensor_test after insert,update as
declare @unid varchar(20)
declare @sensor_id varchar(8)
declare @boolean varchar(1)
begin
set @unid = (select unid from inserted)
set @sensor_id = (select sensor_id from inserted)


--假設採集端原表沒有該記錄則插入該記錄
IF NOT EXISTS(SELECT * FROM deleted)
begin
set NOCOUNT ON;
begin try
-- BEGIN TRAN
--推斷server表中是否存在該記錄
--假設不存在向server表插入該條數據
print ‘1111111111‘
if not EXISTS(SELECT * FROM shengyang.bwdb.dbo.test where [email protected]_id)
begin
--insert openrowset(‘sqloledb‘,‘XXX.XXX.XXX.XXX‘;‘DBUSER‘;‘DBPWD‘,bwdb.dbo.test)
insert into shengyang.bwdb.dbo.test select * from inserted
end
--否則更新server表數據
else
begin
update shengyang.bwdb.dbo.test set unid = inserted.unid from inserted where test.sensor_id = @sensor_id
end
--COMMIT TRAN
end try

--假設出錯則向採集端記錄表中插入數據
begin catch
print ‘fail to insert this data to server‘
rollback
-- print @@TRANCOUNT
-- IF @@TRANCOUNT > 0---------------推斷有沒有事務
-- BEGIN
-- ROLLBACK TRANSACTION ts----------回滾事務
-- END
insert into dbo.test_bak values (@unid,@sensor_id,‘insert‘)
set @boolean = ‘1‘

--EXEC insert_sensor_shengyang @unid,@sensor_id
end catch
-- if @boolean=‘1‘
-- begin
-- print ‘boolean‘+@boolean
-- insert into dbo.test_bak values (@unid,@sensor_id,‘insert‘)
-- end
end
else
--假設採集端原表存在該記錄則更新該記錄
begin
set NOCOUNT ON;
begin try
--update openrowset(‘sqloledb‘,‘XXX.XXX.XXX.XXX‘;‘DBUSER‘;‘DBPWD‘,bwdb.dbo.test)
--更新server表記錄
update shengyang.bwdb.dbo.test set unid = inserted.unid from inserted where test.sensor_id = @sensor_id
end try
--假設出錯，推斷假設記錄表中存在對該條數據的記錄。則更新記錄表中的記錄
--（針對記錄表中同一時候存在對同一條數據的create,update。僅僅須要記錄終於unid，
--假設有create終於仍然向server表create，假設是多次更新僅僅需記錄最後一次更新）
begin catch
if exists(select * from dbo.test_bak where [email protected]_id)
begin
update dbo.test_bak set unid=i.unid from inserted i
end
--假設記錄表中不存在對該條數據的改動記錄，則在記錄標中插入該數據的update記錄
else
begin
insert into dbo.test_bak values (@unid,@sensor_id,‘update‘)
end
end catch
end
end

可是不管如何，僅僅要出現異常，就會強制回滾。此時假設在catch塊之前提交，觸發的仍然時候就會報錯，而且無法將錯誤的記錄插入異常記錄表（運行不到），觸發的原表記錄能夠寫入。假設在catch塊中rollback，然後將該記錄插入異常記錄表能夠，可是同一時候回滾後觸發的原記錄也回滾丟失了。假設在catch塊中commit，也不行（catch塊中默認回滾了全部事務），包含嘗試了使用記錄回滾點進行分段事務提交回滾還是無法解決。

既不能commit,又不能rollback，這如何是好。。。

。。

。

隨後BOSS提了個建議。通過存儲過程中先做異常處理。推斷server數據庫是否連接成功。隨即寫了個存儲過程，在存儲過程中訪問遠程數據庫。定義一個變量初始值，catch塊中改動這個值，然後把這個值作為存儲過程返回值進行推斷。

觸發器：

create trigger trig_sensor_shengyang
on dbo.sensor_test after insert,update as
declare @unid varchar(20)
declare @sensor_id varchar(8)
declare @boolean varchar(1)
declare @ifconnected varchar(2)
begin
set @unid = (select unid from inserted)
set @sensor_id = (select sensor_id from inserted)

--調用存儲過程推斷遠程連接server以及同步事務開啟是否成功。返回1則表示失敗
--sp_testlinkedserver [ @servername ] = servername
EXEC @ifconnected = [boolean_if_connected]
print @ifconnected
--假設遠程連接成功
IF @ifconnected != 1
--假設採集端原表沒有該記錄則插入該記錄
IF NOT EXISTS(SELECT * FROM deleted)
begin
set NOCOUNT ON;
begin try
--推斷server表中是否存在該記錄
--假設不存在向server表插入該條數據
if not EXISTS(SELECT * FROM shengyang.bwdb.dbo.test where [email protected]_id)
begin
insert into shengyang.bwdb.dbo.test select * from inserted
end
--否則更新server表數據
else
begin
update shengyang.bwdb.dbo.test set unid = inserted.unid from inserted where test.sensor_id = @sensor_id
end
end try
begin catch
print ‘failed to insert this data to server‘
rollback
end catch
end
else
--假設採集端原表存在該記錄則更新該記錄
begin
set NOCOUNT ON;
begin try
--更新server表記錄
update shengyang.bwdb.dbo.test set unid = inserted.unid from inserted where test.sensor_id = @sensor_id
end try
begin catch
print ‘failed to update this date to server‘
rollback
end catch
end
else
if exists(select * from dbo.test_bak where [email protected]_id)
begin
begin tran
update dbo.test_bak set unid=i.unid from inserted i
commit tran
end
--假設記錄表中不存在對該條數據的改動記錄，則在記錄標中插入該數據的update記錄
else
begin
begin tran
insert into dbo.test_bak values (@unid,@sensor_id,‘....‘)
commit tran
end
end

觸發器：（非常easy，測試就是通過一個遠程查詢語句推斷）

CREATE PROCEDURE boolean_if_connected
AS
BEGIN
declare @flag varchar(1)
begin try
set @flag=‘0‘
select * from shengyang.bwdb.dbo.test;
end try
begin catch
set @flag=‘1‘
print @flag
end catch
return @flag
end

這樣的方法作為推斷是可行的。可是。。。。

。。在觸發器中調用的時候，假設遠程server數據庫連接不上了（測試關閉數據庫服務），觸發的時候直接就報錯了,

技術分享 技術分享 技術分享 技術分享

其它的代碼根本就沒有運行。

終於。

。

。

找到了推斷遠程鏈接的方法（此時的心情是激動的。）

sp_testlinkedserver (Transact-SQL)

https://msdn.microsoft.com/zh-cn/library/ms189809(v=sql.90).aspx
通過該方法可直接推斷創建的遠程server連接是否有效。

。

終於觸發器測試代碼例如以下：

create trigger trig_sensor_shengyang

on dbo.sensor_test after insert,update as

declare @unid varchar(20)

declare @sensor_id varchar(8)

declare @boolean varchar(1)

declare @ifconnected varchar(2)

begin

set @unid =(select unid from inserted)

set @sensor_id =(select sensor_id from inserted)

--調用存儲過程推斷遠程連接server以及同步事務開啟是否成功，返回則表示失敗

--sp_testlinkedserver[ @servername ] = servername

EXEC @ifconnected = [sp_testlinkedserver]shengyang

print @ifconnected

--假設遠程連接成功

IF @ifconnected != 1

--假設採集端原表沒有該記錄則插入該記錄

IF NOTEXISTS(SELECT * FROM deleted)

begin

set NOCOUNT ON;

begin try

--推斷server表中是否存在該記錄

--假設不存在向server表插入該條數據

if not EXISTS(SELECT * FROM shengyang.bwdb.dbo.test where sensor_id=@sensor_id)

begin

insert into shengyang.bwdb.dbo.test select * from inserted

end

--否則更新server表數據

else

begin

update shengyang.bwdb.dbo.test set unid = inserted.unid from inserted where test.sensor_id = @sensor_id

end

end try

begin catch

print ‘failed to insert to server‘

rollback

end catch

end

else

--假設採集端原表存在該記錄則更新該記錄

begin

set NOCOUNT ON;

begin try

--更新server表記錄

update shengyang.bwdb.dbo.test set unid = inserted.unid from inserted where test.sensor_id = @sensor_id

end try

begin catch

print ‘failed to update to server‘

rollback

end catch

end

else

if exists(select * from dbo.test_bak where sensor_id=@sensor_id)

begin

begin tran

update dbo.test_bak set unid=i.unid from inserted i

commit tran

end

--假設記錄表中不存在對該條數據的改動記錄，則在記錄標中插入該數據的update記錄

else

begin

begin tran

insert into dbo.test_bak values (@unid,@sensor_id,‘....‘)

commit tran

end

end

總結（用BOSS的語錄）：問題總是能找到解決方式的，僅僅要你摸清楚設計者的思路，所以一定要多想為什麽，人家為啥要這麽設計 ！

遇到問題能夠嘗試用不同的方法解決，但不能一味的依照自己的思路走，從問題的根源。從設計者的角度考慮解決方案，總會尋找到的！

一次SQLSERVER觸發器編寫感悟

相關推薦

一次SQLSERVER觸發器編寫感悟

delet 自己的 角度 ins trac tope avi 插入 mic 背景：BOSS須要我寫一個工廠採集端到服務器端的數據同步觸發器，數據庫採用的是sqlserver2008 需求：將多臺採集機的數據同步到server中，假設採集端數據庫與server數據庫

記一次SqlServer騷操作——遞歸

ble where 需要 ins clas sel 並排 更新 all 目錄 記一次SqlServer騷操作——遞歸 創建一個測試表，並灌入一些數據 兼容MSSQL2008以下的版本 正向查找 反向查找 MSSQL2008以後的版本 正向查找 反向查找 記一次Sq

一次SQLServer資料庫修復經歷

資料庫損壞情況 資料庫有多個數據檔案及日誌檔案，其中一個數據檔案損壞丟失，後通過檔案恢復工具恢復出來，但是有錯誤，導致資料庫無法啟動。 修復步驟 1.首先嚐試“附加資料庫”  根據網上的資料，如果資料庫損壞不嚴重的話，可以直接通過“附加資料庫”的方式恢復，但是很不幸，嘗試

記一次SQLSERVER 長期寫日誌強制中斷後的處理以及反思

        因一個表中的資料從26號之後，因儲存過程的問題，資料一直抽取抽取，導致資料重複量超過有的超過了900多條。 所以，計劃刪除表中26號之後的資料，再重新抽取。        表中有一個聚集索引，一個非聚集索引。刪除之前收縮了下日誌，且停止了全部作業。刪除

記一次SqlServer大表查詢語句優化和執行計劃分析

資料庫： sqlserver2008r2  表： device_data 資料量：2000w行左右 表結構 CREATE TABLE [dbo].[device_data]( [Id] [int] IDENTITY(1,1) NOT NULL, [DeviceId] [nvarc

一次針對多臺服務器交互式主機命令采集Python腳本編寫

.py 數據庫版本 toad 監控主機 pro efault 分享 多臺 linux 【環境介紹】 系統環境：Linux + Python 2.7.10（監控主機） 【背景描述】 需求:每次節假日或者重要時間時，需要對數據庫主機信息進行檢查，比如主機空間使用率之類。

記一次8086彙編除錯 關於編寫 7ch 中斷例程輸出字串亂碼

記一次8086彙編除錯 關於編寫 7ch 中斷例程輸出字串亂碼 輸出welcome to asm data segment DB 'welcome to asm ','$' data ends code segment start: mov ah,2 ;置游標 mo

記錄一次 .Net 框架 Bug 發現和提交過程：SmtpClient一處程式碼編寫錯誤導致非同步傳送郵件時DeliveryFormat配置項無法正確工作

問題已經發到了開發者社群 developercommunity.visualstudio.com/content/pro… 涉及到的Github倉庫： github.com/xiangyuecn/… .Net開發者社群富文字編輯器太難用了，還是簡書的編輯器好用，然後掘金的版面好看，最後還是喜歡cnb

手動編寫jar包依賴關係，記對於Maven中jar包依賴錯誤問題的一次解決

專案中需要使用<c:**>標籤，因此需要引入jstl庫，而jstl庫又依賴於standard庫，所以可以從maven中加入jar包依賴。但是我加入後確是出現了波浪線，標籤依然不能引用。這樣的狀況碰見了n次，尤其是對於剛學習maven的小白來說，總是不能正確的從maven倉庫中下載ja

WPF資料爬取小工具－某寶推廣位批量生成，及訂單爬取 記：接單最痛一次的感悟

專案由來：上月閒來無事接到接到一個單子，自動登入　X寶平臺，然後重定向到指定頁面批量生成推廣位資訊；與此同時自動定時同步訂單資料到需求提供方的Java服務。 當然期間遇到一個小小的問題就是介面樣式的問題，起初使用的ｗｉｎｆｏｒｍ開發，但是樣式，你懂的，所以後來索性直接使用ｗｐｆ． 先宣告：這裡只做經驗分享

一個數組中只有兩個數字是出現一次的，其他的數字都出現了兩次，找出這兩個數字，編寫程式。

本題的最關鍵之處就是巧用兩個數異或得到的二進位制中“1”單位位數程式碼如下：方法一：#include<stdio.h> int main() { int arr[] = { 1, 2, 3, 4, 1, 2, 3, 4, 5, 6 }; int i = 0;

一次面試後的人生感悟,是什麼促進了我開始寫部落格的決心

最近突然想到想寫部落格了,雖然在老男孩培訓的時候,老師說到每個技術人員都要寫部落格,當初還不以為然,直到這次面試,深有感觸 說起這次面試,是我有史以來印象最深刻的一次.平時面試,大同小異,問你會做什麼,做過哪些,這些有什麼技巧,再問一些深一點的問題,就結束了.然面試官也是在

Ubuntu系統編寫shell指令碼程式一次安裝多個軟體包

#!/bin/sh sudo apt-get install gcc g++ python -y sudo apt-get install gcc g++ python python-dev -y sudo apt-get install mercurial -y sudo apt-get install b

【譯】Android 上一次編寫，隨處測試

原文地址：Write Once, Run Everywhere Tests on Android 原文作者：Jonathan Gerrish 譯文出自：掘金翻譯計劃 本文永久連結：github.com/xitu/gold-m… 譯者：Rickon 校對者：xiaxi

【SQLServer】記一次資料遷移-標識重複的簡單處理

今天在資料遷移的時候因為手賤遇到一個坑爹問題，發來大家樂樂，也傳授新手點經驗 遷移慣用就是臨時表或者新庫，經常用的語法有很多，這次主要說的是這個：select * into 資料庫名..表名 from xxx 先不扯了，先看錯誤： 趕緊看看是不是資料重複~事實證明，木有重複資料。。。 有人

一次查詢sqlserver死鎖的經歷

查詢bug是程式設計師的家常便飯，我身邊的人喜歡讓使用者來重現問題。當然他們也會從正式伺服器上下載錯誤log，然後嘗試分析log，不過當錯誤不是那種不經思考就可識別的情況，他們就會將問題推向使用者，甚至怪罪程式依賴的平臺。他們常用的藉口就是“這個問題很難重現，需要持續監控

記一次獨立開發APP的感悟

前言 第一次接觸Android開發大約是去年八月份，是在大一的暑假，感覺這個學起來挺簡單的，還能夠放在手機上執行，感覺美滋滋。 於是學了兩個月之後，一個朋友要我做一個功能，說能不能在鎖屏介面上彈出一個框框，然後可以在上面記錄一下今天要做的事情，這樣就可以每次

sqlserver觸發器：若插入的事實值超過預警值則向預警表中插入一條預警資料

--建立insert插入型別觸發器 create trigger tgr_data_insert on DATA_RECORD_HISTORY for insert --插入觸發 as --定義變數 declare @tempValue int;

oracle資料轉入到sqlserver的一次記錄

首先把oracle的資料查詢出來，資料比較多的話需要分頁，plsql查詢超過12W條就會卡主，所以本次使用分頁查詢，每次查詢10W條，  然後將資料複製到excel當中。 SELECT /*+ FIRST_ROWS */ * FROM ( SELECT A.*,

sqlserver快取計劃-清除只使用一次的快取計劃

plan cache很大，將只使用一次的快取計劃清除，而不用清除整個cache. declare @sid varbinary(64) declare cur01 cursor for select