SQL Server實(shí)現(xiàn)用觸發(fā)器捕獲DML操作的會(huì)話信息【實(shí)例】
需求背景
上周遇到了這樣一個(gè)需求,維護(hù)人員發(fā)現(xiàn)一個(gè)表的數(shù)據(jù)經(jīng)常被修改,由于歷史原因;文檔缺少;以及維護(hù)人員的經(jīng)常變更,導(dǎo)致他們對(duì)系統(tǒng)也業(yè)務(wù)也不完全熟悉,他們也不完全清楚哪些系統(tǒng)和應(yīng)用程序會(huì)對(duì)這個(gè)表的數(shù)據(jù)進(jìn)行操作。現(xiàn)在他們想找出有哪些服務(wù)器,哪些應(yīng)用程序會(huì)對(duì)這個(gè)表進(jìn)行INSERT、UPDATE操作。那么問(wèn)題來(lái)了,怎么去解決這個(gè)問(wèn)題呢?
解決方案
由于數(shù)據(jù)庫(kù)版本是標(biāo)準(zhǔn)版,我們選擇了使用觸發(fā)器來(lái)捕獲進(jìn)行DML操作的會(huì)話的相關(guān)信息,例如,Host_Name、Program_Name等 ,選擇觸發(fā)器是因?yàn)楹?jiǎn)單直接。我們先創(chuàng)建一個(gè)表名為TEST的表,假設(shè)我們想監(jiān)控有哪些應(yīng)用服務(wù)器,以及那些應(yīng)用程序會(huì)對(duì)表TEST進(jìn)行INSERT、UPDATE操作。
USE [AdventureWorks2014] GO IF NOT EXISTS (SELECT 1 FROM sys.sysobjects WHERE id=object_id(N'[dbo].[TEST]') AND OBJECTPROPERTY(id, N'IsTable')=1 ) BEGIN CREATE TABLE [dbo].[TEST]( [OBJECT_ID] [INT] NOT NULL, [NAME] [VARCHAR](8) NULL, CONSTRAINT PK_TEST PRIMARY KEY (OBJECT_ID) ) END GO INSERT INTO dbo.TEST SELECT 1, 'kerry' UNION ALL SELECT 2, 'jimmy'
那么我們接下來(lái)在表上面新增幾個(gè)字段 [HOST_NAME]、[PROGRAM_NAME]、LOGIN_NAME用來(lái)記錄最后一次修改該記錄的會(huì)話信息,另外創(chuàng)建觸發(fā)器TRG_TEST來(lái)更新這幾個(gè)字段
ALTER TABLE TEST ADD [HOST_NAME] NVARCHAR(256)
ALTER TABLE TEST ADD [PROGRAM_NAME] NVARCHAR(256);
ALTER TABLE TEST ADD LOGIN_NAME NVARCHAR(256);
CREATE TRIGGER TRG_TEST ON dbo.TEST AFTER
INSERT,UPDATE
AS
IF (EXISTS(SELECT 1 FROM INSERTED))
BEGIN
UPDATE dbo.TEST
SET dbo.TEST.[HOST_NAME] = ( SELECT host_name
FROM sys.dm_exec_sessions
WHERE session_id = @@SPID
) ,
dbo.TEST.PROGRAM_NAME = ( SELECT program_name
FROM sys.dm_exec_sessions
WHERE session_id = @@SPID
) ,
dbo.TEST.LOGIN_NAME = ( SELECT login_name
FROM sys.dm_exec_sessions
WHERE session_id = @@SPID
)
FROM dbo.TEST t
INNER JOIN INSERTED i ON t.OBJECT_ID = i.OBJECT_ID
END
GO
接下來(lái),我們來(lái)簡(jiǎn)單測(cè)試一下,如下所示,分布插入、更新一條記錄
INSERT INTO dbo.TEST(OBJECT_ID,NAME) SELECT 3,'ken' UPDATE dbo.TEST SET NAME='Richard' WHERE OBJECT_ID=2;
如下所示,因?yàn)槲抑皇怯肧SMS更新,插入數(shù)據(jù),所以捕獲的是Microsoft SQL Server Management Studio - Query。
這這種方式還有一個(gè)弊端,那就是如果應(yīng)用程序的SQL,寫得不夠健壯的話,那么增加字段就會(huì)導(dǎo)致以前的應(yīng)用程序出現(xiàn)問(wèn)題,例如,應(yīng)用程序有下面這樣的SQL,增加字段后,它就會(huì)報(bào)錯(cuò)。
INSERT INTO dbo.TEST SELECT 3,'ken'
所以這種方案不太可行,會(huì)增加應(yīng)用程序出現(xiàn)Bug的風(fēng)險(xiǎn)。那么其實(shí)我們可以新建一個(gè)表,每當(dāng)原表TEST有INSERT、UPDATE操作時(shí),通過(guò)觸發(fā)器捕獲會(huì)話進(jìn)程信息,然后插入該表(注意,新建的表包含源表的主鍵字段,例如這里TEST的主鍵字段為OBJECT_ID,那么我們下面就包含OBJECT_ID)
USE [AdventureWorks2014]
GO
DROP TABLE dbo.[TRG_TEST_SESSION_INFO];
GO
IF NOT EXISTS (SELECT 1 FROM sys.sysobjects WHERE id=object_id(N'[dbo].[TRG_TEST_SESSION_INFO]') AND OBJECTPROPERTY(id, N'IsTable')=1 )
BEGIN
CREATE TABLE [TRG_TEST_SESSION_INFO](
[ID] INT NOT NULL IDENTITY(1,1),
[OBJECT_ID] INT,
[HOST_NAME] NVARCHAR(256),
[PROGRAM_NAME] NVARCHAR(256),
[LOGIN_NAME] NVARCHAR(256),
CONSTRAINT PK_TRG_TEST_SESSION_INFO PRIMARY KEY (ID)
)
END
GO
CREATE TRIGGER TRG_TEST_SESSION ON dbo.TEST
AFTER INSERT ,UPDATE
AS
IF (EXISTS(SELECT 1 FROM INSERTED))
BEGIN
/*
INSERT INTO dbo.[TRG_TEST_SESSION_INFO]
SELECT (SELECT I.OBJECT_ID FROM INSERTED I), HOST_NAME,program_name,login_name
FROM sys.dm_exec_sessions
WHERE session_id = @@SPID*/
INSERT INTO dbo.[TRG_TEST_SESSION_INFO]
SELECT I.OBJECT_ID, S.HOST_NAME,S.PROGRAM_NAME,S.LOGIN_NAME
FROM sys.dm_exec_sessions s,
Inserted i
WHERE session_id = @@SPID
END
GO
在運(yùn)行一小段時(shí)間后,如果已經(jīng)找出了哪些服務(wù)器、哪些應(yīng)用程序會(huì)對(duì)這些表操作后,那么就必須馬上刪除這些表和觸發(fā)器,避免長(zhǎng)時(shí)間運(yùn)行,影響性能。
以上這篇SQL Server實(shí)現(xiàn)用觸發(fā)器捕獲DML操作的會(huì)話信息【實(shí)例】就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持我們。
上一篇:解決Windows 10家庭版安裝SQL Server 2014出現(xiàn).net 3.5失敗問(wèn)題
欄 目:MsSql
下一篇:SQL Server2008 R2 數(shù)據(jù)庫(kù)鏡像實(shí)施手冊(cè)(雙機(jī))SQL Server2014同樣適用
本文標(biāo)題:SQL Server實(shí)現(xiàn)用觸發(fā)器捕獲DML操作的會(huì)話信息【實(shí)例】
本文地址:http://www.jygsgssxh.com/a1/MsSql/10501.html
您可能感興趣的文章
- 01-10SQLServer存儲(chǔ)過(guò)程實(shí)現(xiàn)單條件分頁(yè)
- 01-10SQL Server 2012降級(jí)至2008R2的方法
- 01-10SQLServer中防止并發(fā)插入重復(fù)數(shù)據(jù)的方法詳解
- 01-10SQL Server數(shù)據(jù)庫(kù)定時(shí)自動(dòng)備份
- 01-10SQL Server性能調(diào)優(yōu)之緩存
- 01-10實(shí)現(xiàn)SQL Server 原生數(shù)據(jù)從XML生成JSON數(shù)據(jù)的實(shí)例代碼
- 01-10Sql Server 死鎖的監(jiān)控分析解決思路
- 01-10SqlServer 在事務(wù)中獲得自增ID的實(shí)例代碼
- 01-10SqlServer快速檢索某個(gè)字段在哪些存儲(chǔ)過(guò)程中(sql 語(yǔ)句)
- 01-10SQLServer性能優(yōu)化--間接實(shí)現(xiàn)函數(shù)索引或者Hash索引


閱讀排行
- 1C語(yǔ)言 while語(yǔ)句的用法詳解
- 2java 實(shí)現(xiàn)簡(jiǎn)單圣誕樹(shù)的示例代碼(圣誕
- 3利用C語(yǔ)言實(shí)現(xiàn)“百馬百擔(dān)”問(wèn)題方法
- 4C語(yǔ)言中計(jì)算正弦的相關(guān)函數(shù)總結(jié)
- 5c語(yǔ)言計(jì)算三角形面積代碼
- 6什么是 WSH(腳本宿主)的詳細(xì)解釋
- 7C++ 中隨機(jī)函數(shù)random函數(shù)的使用方法
- 8正則表達(dá)式匹配各種特殊字符
- 9C語(yǔ)言十進(jìn)制轉(zhuǎn)二進(jìn)制代碼實(shí)例
- 10C語(yǔ)言查找數(shù)組里數(shù)字重復(fù)次數(shù)的方法
本欄相關(guān)
- 01-10SQLServer存儲(chǔ)過(guò)程實(shí)現(xiàn)單條件分頁(yè)
- 01-10SQLServer中防止并發(fā)插入重復(fù)數(shù)據(jù)的方
- 01-10SQL Server 2012降級(jí)至2008R2的方法
- 01-10SQL Server性能調(diào)優(yōu)之緩存
- 01-10SQL Server數(shù)據(jù)庫(kù)定時(shí)自動(dòng)備份
- 01-10Sql Server 死鎖的監(jiān)控分析解決思路
- 01-10實(shí)現(xiàn)SQL Server 原生數(shù)據(jù)從XML生成JSON數(shù)
- 01-10SqlServer快速檢索某個(gè)字段在哪些存儲(chǔ)
- 01-10SqlServer 在事務(wù)中獲得自增ID的實(shí)例代
- 01-10SQLServer性能優(yōu)化--間接實(shí)現(xiàn)函數(shù)索引或
隨機(jī)閱讀
- 01-10delphi制作wav文件的方法
- 08-05DEDE織夢(mèng)data目錄下的sessions文件夾有什
- 08-05織夢(mèng)dedecms什么時(shí)候用欄目交叉功能?
- 04-02jquery與jsp,用jquery
- 01-11Mac OSX 打開(kāi)原生自帶讀寫NTFS功能(圖文
- 01-10SublimeText編譯C開(kāi)發(fā)環(huán)境設(shè)置
- 01-11ajax實(shí)現(xiàn)頁(yè)面的局部加載
- 01-10C#中split用法實(shí)例總結(jié)
- 08-05dedecms(織夢(mèng))副欄目數(shù)量限制代碼修改
- 01-10使用C語(yǔ)言求解撲克牌的順子及n個(gè)骰子


