如何在SQL Server中持续重复执行查询直至手动终止？

针对你需要重复执行查询、实时返回数据到仪表盘直到手动停止的场景，以下是几种实用的实现方式，按场景优先级排序：

1. 直接使用T-SQL WHILE循环（最便捷，无额外依赖） #

这是最轻量化的方案，无需任何外部工具，直接在SSMS或SQL客户端执行脚本即可。

基础版本（手动中断） #

适合临时测试或简单场景，直接手动点击停止按钮终止执行：

WHILE 1 = 1
BEGIN
    -- 替换为你的目标查询
    SELECT * FROM sys.databases;
    -- 控制查询间隔，比如1秒（按需调整）
    WAITFOR DELAY '00:00:01';
END

可控停止版本（支持远程终止） #

如果需要远程控制停止（比如仪表盘后台运行），可以用全局临时表做开关：

-- 先创建全局控制表（仅第一次执行需要）
IF NOT EXISTS (SELECT * FROM tempdb.sys.tables WHERE name LIKE '##Control_Stop%')
CREATE TABLE ##Control_Stop (Stop BIT DEFAULT 0);

DECLARE @Stop BIT;
WHILE 1 = 1
BEGIN
    -- 检查停止信号
    SELECT @Stop = Stop FROM ##Control_Stop;
    IF @Stop = 1 BREAK;

    -- 执行目标查询
    SELECT * FROM sys.databases;
    WAITFOR DELAY '00:00:01';
END

要停止时，在任意会话执行：

UPDATE ##Control_Stop SET Stop = 1;

优缺点：

• 优点：零依赖，快速实现，适合临时或简单场景
• 缺点：需要保持客户端连接，远程控制需额外配置

2. SQL Server Agent作业（适合长期后台运行） #

如果需要查询持续在后台运行，无需保持客户端连接，用SQL Server Agent作业是最优选择。

配置步骤： #

1. 打开SQL Server Management Studio，展开SQL Server Agent → 作业，右键新建作业
2. 在「步骤」中添加T-SQL脚本（用上面的WHILE循环脚本）
3. 调度设置为「重复执行」，间隔可设为1秒（或直接依赖脚本内的WAITFOR控制间隔）
4. 启动作业后，可通过禁用作业或终止作业来停止执行

优缺点：

• 优点：后台运行，不占用客户端连接，支持自动重启（如果作业失败）
• 缺点：需要Agent权限，配置稍复杂，日志会累积需定期清理

3. PowerShell脚本（适合跨平台/数据处理场景） #

如果需要对查询结果做进一步处理（比如转JSON推送到仪表盘API），PowerShell是灵活的选择。

示例脚本：

# 配置SQL连接参数
$serverInstance = "YourSQLServerName"
$database = "master"
$query = "SELECT * FROM sys.databases"
$intervalSeconds = 1

# 循环执行查询
while ($true) {
    # 执行SQL并输出结果
    Invoke-SqlCmd -ServerInstance $serverInstance -Database $database -Query $query
    
    # 等待指定间隔
    Start-Sleep -Seconds $intervalSeconds
}

停止时直接关闭PowerShell窗口或按Ctrl+C。如果需要推送数据到仪表盘，可以在循环内添加结果处理逻辑（比如ConvertTo-Json后调用Invoke-RestMethod）。

优缺点：

• 优点：跨平台支持，可灵活处理查询结果，易集成到自动化流程
• 缺点：需要安装SqlServer PowerShell模块，依赖环境配置

4. 自定义程序（适合深度集成仪表盘） #

如果仪表盘需要定制化的数据推送或复杂逻辑，用C#/.NET、Python等语言编写程序是最佳选择。

C#示例（控制台程序）： #

using System;
using System.Data.SqlClient;
using System.Threading;

namespace ContinuousSqlQuery
{
    class Program
    {
        static void Main(string[] args)
        {
            string connString = "Server=YourSQLServer;Database=master;Integrated Security=True;";
            string query = "SELECT * FROM sys.databases";
            int intervalMs = 1000;

            while (true)
            {
                using (var conn = new SqlConnection(connString))
                {
                    conn.Open();
                    using (var cmd = new SqlCommand(query, conn))
                    {
                        using (var reader = cmd.ExecuteReader())
                        {
                            // 这里可以将结果推送到仪表盘，比如调用API、写入消息队列等
                            while (reader.Read())
                            {
                                Console.WriteLine($"数据库名称：{reader["name"]}");
                            }
                        }
                    }
                }
                Thread.Sleep(intervalMs);
            }
        }
    }
}

优缺点：

• 优点：完全自定义，可无缝集成到仪表盘系统，支持复杂业务逻辑
• 缺点：需要开发能力，维护成本较高

方案选择建议 #

• 临时测试/快速实现：选T-SQL WHILE循环
• 长期后台运行：选SQL Server Agent作业
• 需要数据处理/跨平台：选PowerShell脚本
• 深度集成仪表盘：选自定义程序

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