mysql 导入oracle

import mysql.connector
import cx_Oracle
import pandas as pd

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

# 执行查询
mysql_cursor.execute("SELECT * FROM mysql_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表（如果尚未存在）
create_table_sql = """
CREATE TABLE IF NOT EXISTS oracle_table (
    column1 NUMBER,
    column2 VARCHAR2(255),
    ...
)
"""
oracle_cursor.execute(create_table_sql)

# 将DataFrame数据插入Oracle表
for index, row in df.iterrows():
    insert_sql = f"INSERT INTO oracle_table (column1, column2, ...) VALUES ({row['column1']}, '{row['column2']}', ...)"
    oracle_cursor.execute(insert_sql)

# 提交事务并关闭连接
oracle_conn.commit()
mysql_cursor.close()
mysql_conn.close()
oracle_cursor.close()
oracle_conn.close()