2

我有一个具有用户成员资格并使用 postgresql 的系统,现在我正在开发另一个迷你电子商务应用程序,它将使用与 postgresql 用户应用程序相同的用户凭据。当新用户注册 postgresql 用户应用程序时,从 postgres 到电子商务网站的数据将自动更新。

请注意:将为两个不同的应用程序使用 2 个不同的数据库,但在两个应用程序上使用相同的用户表。电子商务应用程序上不会有注册或注册。原始(主数据库)肯定是 postgresql 8.4,但另一个可能是 mysql 或类似的 postgresql 尚未真正决定,因为电子商务应用程序可能在 php 中,而主应用程序在 grails(java)中

4

1 回答 1

2

第一个也是显而易见的解决方案是使用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]");
    }
}
?>

为简单起见,该脚本绝对是极简的,应该配备必要的异常处理。

于 2013-02-08T12:31:40.233 回答