mysql数据同步到oracle

-- 示例：将MySQL的INT类型转换为Oracle的NUMBER类型
CREATE TABLE oracle_table (
    id NUMBER,
    name VARCHAR2(100)
);

-- 示例：设置MySQL和Oracle的字符集为AL32UTF8
ALTER DATABASE CHARACTER SET AL32UTF8;
ALTER SYSTEM SET NLS_CHARACTERSET=AL32UTF8 SCOPE=BOTH;

-- 示例：使用Python脚本进行批量同步
import pymysql
import cx_Oracle

# 连接MySQL
mysql_conn = pymysql.connect(host='mysql_host', user='user', password='password', db='db')
mysql_cursor = mysql_conn.cursor()

# 连接Oracle
oracle_conn = cx_Oracle.connect('user/password@oracle_host:port/service_name')
oracle_cursor = oracle_conn.cursor()

# 执行同步操作
mysql_cursor.execute("SELECT * FROM mysql_table")
rows = mysql_cursor.fetchall()
for row in rows:
    oracle_cursor.execute("INSERT INTO oracle_table (id, name) VALUES (:1, :2)", row)

# 提交事务
oracle_conn.commit()

# 关闭连接
mysql_cursor.close()
mysql_conn.close()
oracle_cursor.close()
oracle_conn.close()