摘要: 这篇文章展示了如何利用 PostgreSQL 原生日志功能，轻松捕获并查询数据库对象的 DDL 与 DML 变更。无需繁琐触发器或第三方 通过配置日志、使用文件 FDW 读取 CSV 日志，再创建视图即可像查询普通表一样查看历史变更。

痛点洞察

在实际运维中。常见的问题包括：

• 合规审计要求记录所有结构与数据改动，但传统手工记录费时费力。
• 触发器实现往往导致写入延迟、查询性能下降。
• 第三方 安装复杂且安全性难以评估。
• 缺乏统一视图让 DBA 难还有时发现未授权改动。

解决这些痛点的关键是：用最小化配置即可获得完整可查询的变更日志，并保持程序性能不受影响。

DDL 与 DML 简介

DDL 包括创建、修改或删除数据库对象的语句。如 CREATE TABLE,DROP INDEX,ALTER COLUMN 等；DML 则是对数据本身操作的语句，包括 INSERT,UPDATE。DELETE,还有查询语句如 SELECT.

为什么不用触发器？

触发器会在每一次写操作时执行自定义代码，增加 I/O 负担；如果业务量大，很容易成为性能瓶颈。相比之下利用 PostgreSQL 的内置日志只需一次配置。即可持续捕获所有变更，而不会额外消耗写入资源。

从记录一切来看，开启 PostgreSQL 日志功能

要想完整追踪 DDL/DML。必须先把日志级别调高：

• log_destination = 'csvlog'

• logging_collector = on

• log_statement = 'mod'

*提示*: 参数改动后请重启 PostgreSQL，以便生效。老实说，

再看模拟业务，用 pgbench 产生事务示例

Create a simple benchmark and generate traffic.

# 初始化 benchmark 数据库 benchpgbench:
pgbench -i benchpgbench -c 10 -T 60
# 执行后会自动产生 INSERT/UPDATE/DELETE 操作并写入日志.

查看生成的日志片段

// 示例 CSV 行:
// :: UTC。
"postgres","bench"，"",6037dd19.，"UPDATE",-- :: UTC,/，LOG,...,duration: ms statement: UPDATE pgbench_tellers SET tbalance = tbalance +?WHERE tid =，;

用 FDW 把 CSV 当成表来读取日志数据

CREATE EXTENSION IF NOT EXISTS file_fdw;CREATE SERVER pglog FOREIGN DATA WRAPPER file_fdw;说起来，CREATE FOREIGN TABLE pglog (
log_time timestamp with time zone,user_name text,database_name text,process_id integer,connection_from text,session_id text,session_line_num bigint,command_tag text,session_start_time timestamp with time zone。virtual_transaction_id text,transaction_id bigint,error_severity text,sql_state_code text,message text
) SERVER pglog OPTIONS (
filename '/usr/local/pgsql/data/log/postgresql-Thu.csv',format 'csv'
);

至于注意事项，

• 方法须指向当前实例产生的 csv 日志文件；如果有多文件，可按日期分隔后再创建多个 foreign table 并 UNION ALL 查询。
• 如果 log_statement 为 “mod”，则仅能捕获 INSERT/UPDATE/DELETE/DDL；若需全部命令请改为 “all”。

建立 DDL 视图——一眼看出所有结构变更记录

CREATE VIEW ddl AS
SELECT
log_time,database_name,user_name,split_part AS command。-- create / drop / alter / truncate
CASE
WHEN message ~* ' access method ' THEN 'access method'
WHEN message ~* ' aggregate ' THEN 'aggregate'
WHEN message ~* ' cast ' THEN 'cast'
WHEN message ~* ' collation ' THEN 'collation'
WHEN message ~* ' conversion ' THEN 'conversion'
WHEN message ~* ' database ' THEN 'database'
WHEN message ~* ' domain ' THEN 'domain'
WHEN message ~* ’ event trigger ’ THEN ‘event trigger’
/*…按理说，省略其它类型匹配…*/
ELSE NULL
END AS object_type,regexp_replace AS query
FROM pglog
WHERE error_severity='LOG' AND message LIKE 'statement:%'
AND split_part IN;

从举个例子来看，查询表 `pgbench_tellers` 的所有结构改动：

SELECT * FROM ddl
WHERE object_type='table'
AND database_name='bench'
AND query ILIKE '%pgbench_tellers%';

log_time | database_name | user_name | command | object_type | query |
--------------------------+---------------+-----------+---------+-------------+------------------------------------------------------------------------------------------------------------------
2026-07-31 12:15:03+08 | bench | postgres | drop | table | DROP TABLE IF EXISTS pgbench_tellers;2026-07-31 12:15:04+08 | bench | postgres | create | table | CREATE TABLE pgbench_tellers;2026-07-31 12:15:05+08 | bench | postgres | alter | table | ALTER TABLE pgbench_tellers ADD PRIMARY KEY;...

建立 DML 视图——快速定位数据更新轨迹
CREATE VIEW dml AS
SELECT
log_time,database_name,user_name,CASE
WHEN message~*' insert' THEN ‘insert’
WHEN message~*' update' THEN ‘update’
WHEN message~*' delete' THEN ‘delete’
END AS command,-- 提取目标表名
CASE
WHEN message~*' insert into '+' THEN regexp_replace。' insert into '),'\s.*','')
WHEN message~*' update '+' THEN regexp_replace,' update '),'\s.*','')
WHEN message~*' delete from '+'THEN regexp_replace,' delete from '),'\s.*','')
ELSE NULL
END AS table_name,regexp_replace AS query
FROM pglog
WHERE error_severity='LOG'
AND lower )) IN;

查询某张表最近 N 条变更记录：

SELECT * FROM dml
WHERE database_name='bench'
AND table_name='pgbench_tellers'
ORDER BY log_time DESC
LIMIT 20;Result will list INSERT/UPDATE/DELETE statements along with timestamps.

P.S.
若想恢复默认无日志模式，只需在数据库级别关闭：