mysql导入到oracle

import pandas as pd
import mysql.connector
import cx_Oracle

# 连接MySQL数据库
mysql_conn = mysql.connector.connect(user='mysql_user', password='mysql_password', host='mysql_host', database='mysql_db')
mysql_cursor = mysql_conn.cursor()

# 执行SQL查询
mysql_cursor.execute("SELECT * FROM source_table")
data = mysql_cursor.fetchall()

# 将数据转换为DataFrame
df = pd.DataFrame(data, columns=[i[0] for i in mysql_cursor.description])

# 连接Oracle数据库
oracle_conn = cx_Oracle.connect('oracle_user/oracle_password@oracle_host:oracle_port/oracle_sid')
oracle_cursor = oracle_conn.cursor()

# 创建目标表
oracle_cursor.execute("""
CREATE TABLE target_table (
    column1 NUMBER,
    column2 VARCHAR2(100),
    ...
)
""")

# 插入数据
for index, row in df.iterrows():
    oracle_cursor.execute("""
    INSERT INTO target_table (column1, column2, ...)
    VALUES (:1, :2, ...)
    """, tuple(row))

# 提交事务
oracle_conn.commit()

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