SQL Server中如何监控特定SQL查询并设置执行通知？

嘿，这个需求在SQL Server里有几种实用的实现方式，我给你逐一拆解，你可以根据自己的场景选最合适的：

这是SQL Server官方推荐的轻量级监控方案，性能开销极低，适合实时捕获特定查询。

步骤示例： #

首先创建一个事件会话，捕获执行完成的SQL语句，并过滤你要监控的特定查询：

CREATE EVENT SESSION [MonitorTargetQuery] ON SERVER 
ADD EVENT sqlserver.sql_statement_completed(
    -- 捕获额外信息：会话ID、执行的SQL文本、执行用户
    ACTION(sqlserver.session_id, sqlserver.sql_text, sqlserver.username)
    -- 过滤条件：匹配目标查询（用like_i忽略大小写，兼容空格差异）
    WHERE (sqlserver.like_i_sql_unicode_string(sqlserver.sql_text, N'%Select * from table where id = 1%'))
)
-- 将事件输出到文件，方便后续查看或处理
ADD TARGET package0.event_file(
    SET filename=N'C:\SQLMonitoring\MonitorTargetQuery.xel',
    max_file_size=(5), -- 每个文件最大5MB
    max_rollover_files=(2) -- 最多保留2个滚动文件
)
WITH (STARTUP_STATE=OFF); -- 服务器重启后不自动启动，按需调整

然后启动这个会话：

ALTER EVENT SESSION [MonitorTargetQuery] ON SERVER STATE = START;

实现通知： #

如果需要实时收到通知，可以结合SQL Server代理作业定期读取事件文件，或者写一个存储过程解析.xel文件，当发现匹配查询时，用sp_send_dbmail发送邮件，再把这个存储过程配置成代理作业，每分钟执行一次。

如果你的需求偏向合规审计，SQL Server Audit是更正式的选择，它会生成持久化的审计日志，适合需要留痕的场景。

步骤示例： #

首先创建服务器级审核：

CREATE SERVER AUDIT [TargetQueryAudit]
TO FILE (FILEPATH = N'C:\SQLAudits\') -- 日志存储路径
WITH (QUEUE_DELAY = 1000, ON_FAILURE = CONTINUE); -- 1秒延迟，失败时继续运行

ALTER SERVER AUDIT [TargetQueryAudit] WITH (STATE = ON);

然后创建数据库级审核规范，跟踪目标表的SELECT操作：

USE [YourDatabaseName]; -- 替换成你的数据库名
CREATE DATABASE AUDIT SPECIFICATION [TrackTargetTableSelect]
FOR SERVER AUDIT [TargetQueryAudit]
ADD (SELECT ON OBJECT::[dbo].[table] BY [public]) -- 监控对dbo.table的SELECT操作
WITH (STATE = ON);

注意： #

SQL Server Audit本身没法直接过滤WHERE id=1这样的条件，如果你需要精确匹配查询内容，可以结合扩展事件的谓词补充，或者定期查询审计日志，筛选出符合条件的记录再发送通知。

如果对实时性要求不高（比如允许几分钟的延迟），这个方案最容易上手，通过查询动态管理视图（DMV）来检测目标查询是否被执行。

步骤示例： #

首先创建一个检测并发送通知的存储过程：

CREATE PROCEDURE dbo.CheckTargetQueryExecution
AS
BEGIN
    SET NOCOUNT ON;
    DECLARE @TargetQuery NVARCHAR(MAX) = N'Select * from table where id = 1';
    DECLARE @Found BIT = 0;

    -- 查询最近执行的查询，匹配目标语句
    IF EXISTS (
        SELECT 1
        FROM sys.dm_exec_query_stats qs
        CROSS APPLY sys.dm_exec_sql_text(qs.sql_handle) st
        -- 用CHARINDEX忽略空格和大小写差异
        WHERE CHARINDEX(LOWER(@TargetQuery), LOWER(st.text)) > 0
    )
    BEGIN
        -- 发送邮件通知（需先配置Database Mail）
        EXEC msdb.dbo.sp_send_dbmail
            @profile_name = 'YourMailProfile', -- 替换成你的邮件配置文件
            @recipients = 'alert@yourdomain.com', -- 接收通知的邮箱
            @subject = '⚠️ 目标查询已执行',
            @body = '有人在SQL Server上执行了指定查询：Select * from table where id = 1';
    END
END

然后创建SQL Server代理作业，设置每隔5分钟执行一次这个存储过程，就能定期检测并发送通知了。

内容的提问来源于stack exchange，提问作者kalmanv