我正在使用 python 中的 sqlalchemy 将一些数据从一个数据库传输到另一个数据库。我想直接快速转账。
我不知道如何使用bulk_insert_mappings()来自 SQLAlchemy的功能。（在字段方面，两个表是相同的）
这是我到目前为止所尝试的。
from sqlalchemy import create_engine, Column, Integer, String, Date
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
engine_old = create_engine('mysql+pymysql://<id>:<pw>@database_old.amazonaws.com:3306/schema_name_old?charset=utf8')
engine_new = create_engine('mysql+pymysql://<id>:<pw>@database_new.amazonaws.com:3306/schema_name_new?charset=utf8')
data_old = engine_before.execute('SELECT * FROM table_old')
session = sessionmaker()
session.configure(bind=engine_after)
s = session()
如何处理“s.bulk_insert_mappings(????, data_old)”？**
有人可以帮助我吗？
谢谢你。