欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

SQL Server实现用触发器捕获DML操作的会话信息【实例】

程序员文章站 2022-03-25 10:13:38
需求背景 上周遇到了这样一个需求,维护人员发现一个表的数据经常被修改,由于历史原因;文档缺少;以及维护人员的经常变更,导致他们对系统也业务也不完全熟悉,他们也不完全清楚...

需求背景

上周遇到了这样一个需求,维护人员发现一个表的数据经常被修改,由于历史原因;文档缺少;以及维护人员的经常变更,导致他们对系统也业务也不完全熟悉,他们也不完全清楚哪些系统和应用程序会对这个表的数据进行操作。现在他们想找出有哪些服务器,哪些应用程序会对这个表进行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 Server实现用触发器捕获DML操作的会话信息【实例】

这这种方式还有一个弊端,那就是如果应用程序的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操作的会话信息【实例】就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。