Oracle和Postgres之间的数据复制

在Oracle和Postgres之间进行数据复制的解决方法有多种，下面是一种基于触发器和外部表的解决方案的示例代码：

1. 首先，创建一个触发器来捕获Oracle表的变更，并将变更记录到一个外部表中：

CREATE TABLE oracle_changes (
    change_id NUMBER,
    change_type VARCHAR2(10),
    table_name VARCHAR2(100),
    column_values VARCHAR2(4000),
    change_date TIMESTAMP
);

CREATE OR REPLACE TRIGGER oracle_table_trigger
AFTER INSERT OR UPDATE OR DELETE ON oracle_table
FOR EACH ROW
DECLARE
    change_type VARCHAR2(10);
BEGIN
    IF INSERTING THEN
        change_type := 'INSERT';
    ELSIF UPDATING THEN
        change_type := 'UPDATE';
    ELSIF DELETING THEN
        change_type := 'DELETE';
    END IF;

    INSERT INTO oracle_changes (change_id, change_type, table_name, column_values, change_date)
    VALUES (:NEW.id, change_type, 'oracle_table', :NEW.column1 || '|' || :NEW.column2, SYSTIMESTAMP);
END;
/

2. 然后，创建一个外部表来连接到Postgres数据库，并将外部表与Oracle外部表进行关联，以便将变更记录插入Postgres表中：

-- 在Postgres中创建相应的表
CREATE TABLE postgres_table (
    change_id SERIAL,
    change_type VARCHAR(10),
    table_name VARCHAR(100),
    column_values VARCHAR(4000),
    change_date TIMESTAMP
);

-- 在Oracle中创建外部表
CREATE DATABASE LINK postgres_link CONNECT TO postgres_user IDENTIFIED BY postgres_password USING 'postgres_connection_string';

CREATE TABLE postgres_external_table (
    change_id NUMBER,
    change_type VARCHAR2(10),
    table_name VARCHAR2(100),
    column_values VARCHAR2(4000),
    change_date TIMESTAMP
)
ORGANIZATION EXTERNAL
( 
    TYPE ORACLE_LOADER 
    DEFAULT DIRECTORY external_directory 
    ACCESS PARAMETERS
    ( 
        RECORDS DELIMITED BY NEWLINE
        FIELDS TERMINATED BY '|' 
        MISSING FIELD VALUES ARE NULL
        ( 
            change_id,
            change_type,
            table_name,
            column_values,
            change_date CHAR(19) DATE_FORMAT TIMESTAMP MASK "YYYY-MM-DD HH24:MI:SS"
        )
    )
    LOCATION ('oracle_changes.txt')
)
REJECT LIMIT UNLIMITED;

-- 创建一个定时任务，将外部表的数据插入到Postgres表中
CREATE OR REPLACE PROCEDURE replicate_changes AS
BEGIN
    EXECUTE IMMEDIATE 'INSERT INTO postgres_table (change_id, change_type, table_name, column_values, change_date)
                      SELECT change_id, change_type, table_name, column_values, change_date
                      FROM postgres_external_table@postgres_link';
END;
/

通过上述代码示例，当Oracle表发生插入、更新或删除操作时，变更记录会被触发器捕获并插入到外部表中。然后，定时任务会将外部表的数据插入到Postgres表中，实现了Oracle和Postgres之间的数据复制。