mysql binary转oracle

from sqlalchemy import create_engine, MetaData, Table, Column, Integer, LargeBinary
from sqlalchemy.orm import sessionmaker

# 连接MySQL数据库
mysql_engine = create_engine('mysql+pymysql://user:password@host/dbname')
mysql_metadata = MetaData(bind=mysql_engine)
mysql_table = Table('your_table', mysql_metadata, autoload_with=mysql_engine)

# 连接Oracle数据库
oracle_engine = create_engine('oracle+cx_oracle://user:password@host:port/sid')
oracle_metadata = MetaData(bind=oracle_engine)
oracle_table = Table('YOUR_TABLE', oracle_metadata,
                     Column('ID', Integer, primary_key=True),
                     Column('DATA', LargeBinary))

# 创建Oracle表
oracle_metadata.create_all(oracle_engine)

# 迁移数据
Session = sessionmaker(bind=mysql_engine)
session = Session()
result = session.query(mysql_table).all()

Session = sessionmaker(bind=oracle_engine)
oracle_session = Session()
for row in result:
    insert_stmt = oracle_table.insert().values(ID=row.ID, DATA=row.DATA)
    oracle_session.execute(insert_stmt)

oracle_session.commit()

-- MySQL
CREATE TABLE your_table (
    ID INT PRIMARY KEY,
    DATA BINARY(100)
);

-- Oracle
CREATE TABLE YOUR_TABLE (
    ID NUMBER PRIMARY KEY,
    DATA BLOB
);