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操作的会话信息【实例】就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。