MySQL 到Oracle 实时数据同步实操分享，想提高开发效率的必看

-- MySQL到Oracle实时数据同步示例

-- 创建MySQL触发器，在数据插入时同步到Oracle
DELIMITER $$

CREATE TRIGGER `sync_to_oracle_after_insert` AFTER INSERT ON `your_mysql_table` FOR EACH ROW
BEGIN
  -- 调用存储过程，将数据插入到Oracle表中
  CALL sync_data_to_oracle('INSERT', NEW.id, NEW.column1, NEW.column2, ...);
END$$

DELIMITER ;

-- 在Oracle中创建存储过程，用于接收来自MySQL的数据操作
CREATE OR REPLACE PROCEDURE sync_data_from_mysql(
  p_operation IN VARCHAR2,
  p_id IN NUMBER,
  p_column1 IN VARCHAR2,
  p_column2 IN VARCHAR2,
  ...
) AS
BEGIN
  IF p_operation = 'INSERT' THEN
    INSERT INTO your_oracle_table (id, column1, column2, ...) VALUES (p_id, p_column1, p_column2, ...);
    COMMIT;
  -- 可以根据需要添加其他操作的处理逻辑，如UPDATE和DELETE
  END IF;
END;
/

-- 在Oracle中创建存储过程，用于MySQL数据同步的触发器或调用事件
CREATE OR REPLACE PROCEDURE sync_data_to_mysql(
  p_operation IN VARCHAR2,
  p_id IN NUMBER,
  p_column1 IN VARCHAR2,
  p_column2 IN VARCHAR2,
  ...
) AS
BEGIN
  -- 使用Oracle数据库的DBMS_SCHEDULER或DBMS_JOB来异步调用MySQL的存储过程
  DBMS_SCHEDULER.CREATE_JOB (
    job_name        => 'sync_to_mysql_job',
    job_type        => 'PLSQL_BLOCK',
    job_action      => 'BEGIN sync_data_to_mysql_remote(p_operation, p_id, p_column1, p_column2, ...); END;',
    number_of_arguments => 5,
    start_date      => SYSTIMESTAMP,
    repeat_interval => 'NULL',
    end_date        => 'NULL',
    enabled         => FALSE,
    comments        => 'Job to sync data to MySQL'
  );
  -- 调用DBMS_SCHEDULER.RUN_JOB立即执行作业
  DBMS_SCHEDULER.RUN_JOB('sync_to_mysql_job', USE_CURRENT_SESSION => TRUE, p_operation => p_operation, p_id => p_id, p_column1 => p_column1, p_column2 => p_column2, ...);
END;
/