openGauss 中负责慢 SQL 记录的线程有两个角色协同工作1. Statement Flush ThreadTRACK_STMT_WORKER- 入口函数: StatementFlushMain()instr_statement.cpp:997- 主循环: StatementFlush()instr_statement.cpp:960- 作用: 这是一个常驻后台线程周期性地将各会话中积累的慢 SQL 全量信息刷入 statement_history 表或 standby 上的 MemFileChain。- 清理触发: 每轮 flush 前调用 StartCleanWorker(count)第 981 行当连续计数达到 600 次即约 1 分钟maxCleanInterval 600时向 postmaster 发送PMSIGNAL_START_CLEAN_STATEMENT 信号由 postmaster 启动一个一次性 Clean 线程。// instr_statement.cpp:751-774 static void StartCleanWorker(int* count) { int maxCleanInterval 600; // 600 * 100ms 1min ... if (g_instance.stat_cxt.instr_stmt_is_cleaning) { return; } SendPostmasterSignal(PMSIGNAL_START_CLEAN_STATEMENT); ... }2. Clean Statement ThreadTRACK_STMT_CLEANER- 入口函数: CleanStatementMain()instr_statement.cpp:1076- 实际清理逻辑: CleanStatementTable()instr_statement.cpp:783- 清理实现: CleanStatementByIdx()instr_statement.cpp:730——根据slow_sql_retention_time慢 SQL 保留天数和 full_sql_retention_time全量 SQL保留秒数按时间范围扫描并 simple_heap_delete 过期记录。- 特点: 这是一个一次性进程执行完清理后直接 proc_exit(0) 退出。关键 GUC 参数参数说明track_stmt_retention_time控制保留时间格式 full_sql秒,slow_sql天track_stmt_stat_level控制追踪级别OFF/L0/L1/L2总结流程总结流程TRACK_STMT_WORKER (常驻后台线程)└─StatementFlush()每 100ms 执行一次循环├─ 收集各 session 的慢 SQL → 刷入 statement_history 表└─ 每 600 轮约 1 分钟触发一次清理└─ 发送PMSIGNAL_START_CLEAN_STATEMENT信号└─ Postmaster 启动TRACK_STMT_CLEANER一次性线程└─ 执行CleanStatementTable()删除过期记录└─ 清理完成线程退出
