如何捕获指定时间段内的查询，排查用户重复active=1记录问题

1. 优先排查并发冲突（最常见诱因） #

你的操作流程是先更新旧记录为active=0，再插入新记录为active=1，这两步并非原子操作。如果同一userId同时触发多个请求，就会出现以下场景：

• 请求A、B同时查询到该用户存在active=1的记录
• 两者先后执行UPDATE将旧记录设为0
• 接着两者都插入新的active=1记录，最终导致重复
• 验证方法：查看重复记录的创建时间，若两条记录时间差在毫秒级，基本可以锁定是并发问题。

2. 检查代码/存储过程的逻辑漏洞 #

• 确认更新与插入是否在同一个事务内？如果未加事务，中间可能被其他操作打断；即便加了事务，若隔离级别设置不当（如读未提交、读已提交），仍会出现脏读/不可重复读，引发并发问题。
• 核对更新语句的条件：是否严格写为UPDATE table SET active=0 WHERE userId=? AND active=1？漏写active=1虽不直接导致重复，但如果userId参数传递错误，会导致旧记录未被更新，新记录又插入。
• 排查是否存在绕过更新步骤的插入操作：比如紧急调试代码、第三方工具直接写表、或其他模块未走统一逻辑，直接插入active=1的记录。

3. 核查夜间作业与自动化任务 #

• 导出夜间作业的执行日志，确认作业执行时段是否与重复记录出现时间重合，作业中是否有针对该表的插入/更新逻辑。
• 检查作业是否有重试机制：若作业失败后自动重试，可能导致重复插入；或作业逻辑未遵循“先更新再插入”的规则，直接写入active=1的记录。

1. 利用数据库自带审计工具 #

MySQL #

• 临时开启通用查询日志：执行SET GLOBAL general_log = 'ON';，用SHOW VARIABLES LIKE 'general_log_file';查看日志路径，指定时间段后执行SET GLOBAL general_log = 'OFF';关闭。
• 或调整慢查询日志阈值：设置long_query_time = 0，让所有查询都被记录，注意此操作会占用较多磁盘空间，用完及时恢复配置。

SQL Server #

• 使用SQL Server Profiler：创建跟踪任务，选择SQL:BatchCompleted、RPC:Completed等事件，设置数据库名、表名过滤条件和时间范围，启动跟踪后等待指定时段，停止后导出日志分析。
• 或使用Extended Events：创建会话捕获sql_statement_completed事件，添加object_name = '你的表名'过滤条件，启动会话收集数据，停止后查看结果（比Profiler性能损耗更低）。

PostgreSQL #

• 修改配置开启日志：编辑postgresql.conf，设置log_statement = 'all'、log_min_duration_statement = 0，执行SELECT pg_reload_conf();重载配置；指定时段后改回原配置，避免影响性能。

2. 临时添加触发器记录操作 #

在涉事表上创建触发器，捕获所有针对active字段的插入/更新操作，记录到日志表中。示例（MySQL）：

-- 创建操作日志表
CREATE TABLE operation_log (
    id INT AUTO_INCREMENT PRIMARY KEY,
    user_id INT,
    operation_type VARCHAR(20),
    operate_time DATETIME DEFAULT CURRENT_TIMESTAMP,
    db_user VARCHAR(50),
    connection_id INT
);

-- 插入触发器
DELIMITER //
CREATE TRIGGER after_insert_active
AFTER INSERT ON your_table
FOR EACH ROW
BEGIN
    IF NEW.active = 1 THEN
        INSERT INTO operation_log (user_id, operation_type, db_user, connection_id)
        VALUES (NEW.userId, 'INSERT', USER(), CONNECTION_ID());
    END IF;
END //
DELIMITER ;

-- 更新触发器
DELIMITER //
CREATE TRIGGER after_update_active
AFTER UPDATE ON your_table
FOR EACH ROW
BEGIN
    IF OLD.active = 1 AND NEW.active = 0 THEN
        INSERT INTO operation_log (user_id, operation_type, db_user, connection_id)
        VALUES (OLD.userId, 'UPDATE', USER(), CONNECTION_ID());
    END IF;
END //
DELIMITER ;

通过日志表可以精准定位触发重复记录的操作来源。

• 原子化操作：使用INSERT ... ON DUPLICATE KEY UPDATE（MySQL）或MERGE语句（SQL Server/PostgreSQL），将更新与插入合并为原子操作。示例（MySQL）：

INSERT INTO your_table (userId, active, ...其他字段)
VALUES (?, 1, ...)
ON DUPLICATE KEY UPDATE active=0, ...其他字段=VALUES(...);

• 添加数据库层面约束：创建部分唯一索引（如MySQL 8.0+）：ALTER TABLE your_table ADD UNIQUE KEY idx_user_active (userId, active) WHERE active=1;，直接阻止重复的active=1记录插入。

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