SQL Server实现用触发器捕获DML操作的会话信息【实例】
需求背景
上周遇到了这样一个需求,维护人员发现一个表的数据经常被修改,由于历史原因;文档缺少;以及维护人员的经常变更,导致他们对系统也业务也不完全熟悉,他们也不完全清楚哪些系统和应用程序会对这个表的数据进行操作。现在他们想找出有哪些服务器,哪些应用程序会对这个表进行insert、update操作。那么问题来了,怎么去解决这个问题呢?
解决方案
由于数据库版本是标准版,我们选择了使用触发器来捕获进行dml操作的会话的相关信息,例如,host_name、program_name等 ,选择触发器是因为简单直接。我们先创建一个表名为test的表,假设我们想监控有哪些应用服务器,以及那些应用程序会对表test进行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'
那么我们接下来在表上面新增几个字段 [host_name]、[program_name]、login_name用来记录最后一次修改该记录的会话信息,另外创建触发器trg_test来更新这几个字段
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
接下来,我们来简单测试一下,如下所示,分布插入、更新一条记录
insert into dbo.test(object_id,name) select 3,'ken' update dbo.test set name='richard' where object_id=2;
如下所示,因为我只是用ssms更新,插入数据,所以捕获的是microsoft sql server management studio - query。
这这种方式还有一个弊端,那就是如果应用程序的sql,写得不够健壮的话,那么增加字段就会导致以前的应用程序出现问题,例如,应用程序有下面这样的sql,增加字段后,它就会报错。
insert into dbo.test select 3,'ken'
所以这种方案不太可行,会增加应用程序出现bug的风险。那么其实我们可以新建一个表,每当原表test有insert、update操作时,通过触发器捕获会话进程信息,然后插入该表(注意,新建的表包含源表的主键字段,例如这里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
在运行一小段时间后,如果已经找出了哪些服务器、哪些应用程序会对这些表操作后,那么就必须马上删除这些表和触发器,避免长时间运行,影响性能。
以上这篇sql server实现用触发器捕获dml操作的会话信息【实例】就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。