oracle增量同步到mysql

import cx_Oracle
import pymysql
import time

# Oracle连接配置
oracle_conn = cx_Oracle.connect('username/password@hostname:port/service_name')
oracle_cursor = oracle_conn.cursor()

# MySQL连接配置
mysql_conn = pymysql.connect(host='hostname', port=port, user='username', password='password', db='database')
mysql_cursor = mysql_conn.cursor()

def sync_data():
    # 读取Oracle的归档日志
    oracle_cursor.execute("SELECT * FROM V$ARCHIVED_LOG WHERE STATUS = 'A'")
    logs = oracle_cursor.fetchall()

    for log in logs:
        # 解析日志，获取数据变更
        # 这里假设解析逻辑已经实现
        changes = parse_log(log)

        # 同步数据到MySQL
        for change in changes:
            if change['type'] == 'INSERT':
                mysql_cursor.execute(f"INSERT INTO table_name (column1, column2) VALUES ('{change['value1']}', '{change['value2']}')")
            elif change['type'] == 'UPDATE':
                mysql_cursor.execute(f"UPDATE table_name SET column1 = '{change['value1']}', column2 = '{change['value2']}' WHERE id = {change['id']}")
            elif change['type'] == 'DELETE':
                mysql_cursor.execute(f"DELETE FROM table_name WHERE id = {change['id']}")

    mysql_conn.commit()

while True:
    sync_data()
    time.sleep(60)  # 每分钟同步一次

oracle_cursor.close()
oracle_conn.close()
mysql_cursor.close()
mysql_conn.close()