如何检查PostgreSQL中NodeJs定时任务的特定查询是否运行？

方法1：查询PostgreSQL系统日志 #

PostgreSQL默认会根据配置记录执行的查询，你可以通过以下方式操作：

• 先确认日志配置：执行SHOW log_statement;，确保参数值为all（记录所有查询）或mod（仅记录修改类语句，如INSERT/UPDATE）。
• 直接查找数据库日志文件，搜索你的特定查询内容；如果日志目录可通过SQL访问，也可以查询pg_log下的日志文件内容。

方法2：使用pg_stat_statements扩展 #

这是PostgreSQL内置的语句统计扩展，能跟踪所有执行过的SQL语句：

1. 启用扩展（仅需执行一次）：

CREATE EXTENSION IF NOT EXISTS pg_stat_statements;

2. 查询目标语句的执行记录，替换'你的查询内容'为实际语句（支持模糊匹配）：

SELECT queryid, query, calls, last_execution_time, total_time
FROM pg_stat_statements
WHERE query LIKE '%你的查询内容%';

• calls：该语句的总执行次数
• last_execution_time：最后一次执行的时间，可通过对比当前时间判断执行频率是否符合预期
• 注意：如果查询使用参数化写法，需调整匹配规则以适配参数化后的语句模板

方法3：自定义审计日志表 #

如果系统日志或内置扩展无法满足需求，可以手动创建审计表记录执行情况：

1. 创建日志表：

CREATE TABLE query_execution_log (
    id SERIAL PRIMARY KEY,
    query_text TEXT NOT NULL,
    execution_time TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP
);

2. 修改NodeJS任务代码，在执行目标查询后插入日志记录：

// 示例（使用pg库）
const { Pool } = require('pg');
const pool = new Pool({ /* 你的数据库连接配置 */ });

async function runScheduledTask() {
    const targetQuery = '你的目标查询语句';
    await pool.query(targetQuery);
    // 插入审计日志
    await pool.query(
        'INSERT INTO query_execution_log (query_text) VALUES ($1)',
        [targetQuery]
    );
}

3. 查询日志表查看执行历史：

SELECT execution_time, query_text
FROM query_execution_log
WHERE query_text = '你的目标查询语句'
ORDER BY execution_time DESC;

方法4：实时检查pg_stat_activity #

如果想查看当前或最近的查询活动，可执行：

SELECT query, state, query_start
FROM pg_stat_activity
WHERE query LIKE '%你的查询内容%'
AND state = 'active';

该方法仅能查看正在运行或刚结束的查询，无法获取完整历史执行记录。

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