第一个也是显而易见的解决方案是使用dblink假设两台服务器都是 postgres。
但是,您可以编写自己的部分复制守护程序。下面是一个将表用户复制到 SQlite 数据库的简单示例。
我们在 postgres usersdb数据库中有表用户:
create table users (
id serial primary key,
name text);
为用户创建日志表:
create table users_log (
id serial primary key,
action text);
在表用户上创建触发器:
create or replace function users_trigger ()
returns trigger language plpgsql as $$
declare
newaction text;
begin
if (TG_OP = 'UPDATE') then
newaction:= 'update users set
name = '''||new.name||''' where id = '||old.id::text;
elsif (TG_OP = 'INSERT') then
newaction:= 'insert into users values
('||new.id::text||', '''||new.name||''')';
elsif (TG_OP = 'DELETE') then
newaction:= 'delete from users where id = '||old.id::text;
end if;
insert into users_log (action) values (newaction);
return null;
end; $$;
create trigger users_trigger
after insert or update or delete
on users
for each row
execute procedure users_trigger();
在其中创建 SQlite3 数据库users.db和表users:
create table users (
id integer primary key,
name text);
守护程序脚本每 2 秒检查 users_log。如果有新动作,那么脚本会在 SQlite 数据库中将它们一一生成并从 users_log 中删除:
<?php
$postgres = new PDO('pgsql:host=localhost port=5432 dbname=usersdb');
$sqlite = new PDO('sqlite:users.db');
$sql = 'select * from users_log order by id limit 1';
while (true) {
sleep(2);
while ($row = $postgres->query($sql)->fetch()) {
$sqlite->query($row[1]);
echo $row[1]. "\n";
$postgres->query("delete from users_log where id = $row[0]");
}
}
?>
为简单起见,该脚本绝对是极简的,应该配备必要的异常处理。