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 = 'your_table_name'")
columns = oracle_cursor.fetchall()

# 生成MySQL表结构SQL语句
mysql_sql = f"CREATE TABLE your_table_name ("
for column in columns:
    mysql_sql += f"{column[0]} {convert_data_type(column[1])}, "
mysql_sql = mysql_sql.rstrip(', ') + ")"

# 执行MySQL表结构创建
mysql_cursor.execute(mysql_sql)

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

def convert_data_type(oracle_data_type):
    # 数据类型转换映射
    data_type_map = {
        'VARCHAR2': 'VARCHAR',
        'NUMBER': 'INT',
        'DATE': 'DATETIME',
        # 添加更多数据类型映射
    }
    return data_type_map.get(oracle_data_type, 'VARCHAR')