oracle数据迁移到mysql

import cx_Oracle
import mysql.connector

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

# 连接 MySQL 数据库
mysql_conn = mysql.connector.connect(user='username', password='password', host='hostname', database='database_name')
mysql_cursor = mysql_conn.cursor()

# 查询 Oracle 数据库中的表结构
oracle_cursor.execute("SELECT column_name, data_type FROM user_tab_columns WHERE table_name = 'table_name'")
columns = oracle_cursor.fetchall()

# 创建 MySQL 表结构
create_table_sql = f"CREATE TABLE table_name ("
for column in columns:
    create_table_sql += f"{column[0]} {column[1]}, "
create_table_sql = create_table_sql.rstrip(', ') + ")"
mysql_cursor.execute(create_table_sql)

# 迁移数据
oracle_cursor.execute("SELECT * FROM table_name")
rows = oracle_cursor.fetchall()
for row in rows:
    insert_sql = f"INSERT INTO table_name VALUES ({','.join(['%s']*len(row))})"
    mysql_cursor.execute(insert_sql, row)

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