在SQLAlchemy (sqlite)中从较大的数据库创建较小的数据库

from sqlalchemy import create_engine, MetaData, Table
from sqlalchemy.orm import sessionmaker

# 连接到原始数据库
source_engine = create_engine('sqlite:///source_database.db')
source_metadata = MetaData(bind=source_engine)
source_metadata.reflect()

# 连接到目标数据库
target_engine = create_engine('sqlite:///target_database.db')
target_metadata = MetaData(bind=target_engine)

# 假设我们要迁移的表名为 'large_table'
source_table = Table('large_table', source_metadata, autoload_with=source_engine)

# 创建目标表结构（如果尚不存在）
target_table = source_table.tometadata(target_metadata)
target_table.create(bind=target_engine, checkfirst=True)

# 创建会话
Session = sessionmaker(bind=target_engine)
session = Session()

# 查询原始数据库并插入到目标数据库
for row in source_engine.execute(source_table.select().where(source_table.c.some_column > 100)):
    session.execute(target_table.insert().values(**row._asdict()))

# 提交事务
session.commit()