mysql 数据导入oracle

import mysql.connector
import cx_Oracle

# MySQL连接配置
mysql_config = {
    'user': 'mysql_user',
    'password': 'mysql_password',
    'host': 'mysql_host',
    'database': 'mysql_db'
}

# Oracle连接配置
oracle_config = {
    'user': 'oracle_user',
    'password': 'oracle_password',
    'dsn': 'oracle_dsn'
}

# 连接到MySQL数据库
mysql_conn = mysql.connector.connect(**mysql_config)
mysql_cursor = mysql_conn.cursor()

# 连接到Oracle数据库
oracle_conn = cx_Oracle.connect(**oracle_config)
oracle_cursor = oracle_conn.cursor()

# 查询MySQL中的数据
mysql_cursor.execute("SELECT * FROM mysql_table")
rows = mysql_cursor.fetchall()

# 插入数据到Oracle
for row in rows:
    # 根据需要转换数据类型
    converted_row = [convert_data_type(item) for item in row]
    oracle_cursor.execute("INSERT INTO oracle_table VALUES (:1, :2, :3)", converted_row)

# 提交事务
oracle_conn.commit()

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

def convert_data_type(value):
    # 根据需要实现数据类型转换逻辑
    if isinstance(value, str):
        return value.encode('utf-8').decode('utf-8')
    return value