免费的网站,公司网站asp后台维护,软件开发的工作,市场营销策划报告PostgreSQL 没有内置的 binlog#xff08;binary log#xff09;机制像 MySQL 那样。它使用 Write-Ahead Logging (WAL) 来记录数据库的变更。要将这些变更记录到某张表中#xff0c;通常可以使用逻辑复制#xff08;Logical Replication#xff09;和触发器#xff08;T…PostgreSQL 没有内置的 binlogbinary log机制像 MySQL 那样。它使用 Write-Ahead Logging (WAL) 来记录数据库的变更。要将这些变更记录到某张表中通常可以使用逻辑复制Logical Replication和触发器Triggers来实现。以下是一个实现的思路
1. 启用逻辑复制
首先确保 PostgreSQL 已启用逻辑复制 在 postgresql.conf 文件中设置以下参数
# 启用逻辑复制
wal_level logical# 设置允许的最大同步槽数量
max_replication_slots 4# 设置允许的最大订阅数量
max_wal_senders 4然后重启 PostgreSQL 服务
sudo systemctl restart postgresql2. 创建发布和订阅
1. 创建发布
在数据库中创建一个发布
CREATE PUBLICATION my_publication FOR TABLE my_table;这样my_table 的变更将会被记录并可以被订阅。
2. 创建订阅
在另一个数据库中创建一个订阅
CREATE SUBSCRIPTION my_subscription
CONNECTION dbnamemydb hostlocalhost usermyuser passwordmypassword
PUBLICATION my_publication;这样my_table 的变更将会被传输到本地的订阅数据库。
3. 使用触发器记录变更
如果你希望将变更记录到特定的表中你可以创建触发器。以下是一个简单的示例
创建日志表
CREATE TABLE my_table_log (id SERIAL PRIMARY KEY,operation TEXT,old_data JSONB,new_data JSONB,changed_at TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP
);创建触发器函数
CREATE OR REPLACE FUNCTION log_my_table_changes() RETURNS TRIGGER AS $$
BEGININSERT INTO my_table_log (operation, old_data, new_data)VALUES (TG_OP,row_to_json(OLD),row_to_json(NEW));RETURN NEW;
END;
$$ LANGUAGE plpgsql;创建触发器
CREATE TRIGGER my_table_changes
AFTER INSERT OR UPDATE OR DELETE ON my_table
FOR EACH ROW
EXECUTE FUNCTION log_my_table_changes();这样每当 my_table 表中的数据发生变化时触发器会将这些变更记录到 my_table_log 表中。这种方法可以记录数据库表中的变更并进行审计。
