如何实例化表对象以使用Alembic/SQLAlchemy执行bulk_insert

你完全不用在迁移脚本里重复写表结构！核心思路是用SQLAlchemy的**反射（reflection）**功能，直接从数据库里加载已有的services表的元数据，这样就能直接用它来执行bulk_insert了。

你之前的代码里sa.MetaData().Services()写法不对，因为空的MetaData对象不会自动知道数据库里有哪些表，得主动去反射加载。

下面是正确的实现步骤和代码：

正确的迁移脚本代码 #

from alembic import op
import sqlalchemy as sa

def upgrade():
    """Up migration."""
    # 1. 创建元数据对象，并绑定到当前迁移的数据库连接
    meta = sa.MetaData()
    meta.bind = op.get_bind()

    # 2. 反射加载指定的表（这里是services），如果表属于特定schema可以加上schema参数
    # 如果你只想加载这一张表，用only参数更高效，避免加载所有表
    meta.reflect(only=['services'])
    services = meta.tables['services']

    # 3. 执行bulk_insert，注意布尔值直接用Python的True/False，不用字符串
    op.bulk_insert(services, [
        {
            'id': 88,
            'name': 'Test 1',
            'is_active': True,
            'include_in_broker_fee': True,
            'is_domestic': True,
            'is_international': True
        },
        {
            'id': 89,
            'name': 'Test 2',
            'is_active': True,
            'include_in_broker_fee': True,
            'is_domestic': True,
            'is_international': True
        }
    ])

def downgrade():
    """Down migration."""
    # 记得写回滚逻辑，比如删除插入的这两条数据
    op.execute("DELETE FROM services WHERE id IN (88, 89);")

关键细节说明 #

• meta.bind = op.get_bind()：把元数据和当前Alembic使用的数据库连接绑定，这样才能正确反射表结构
• meta.reflect(only=['services'])：只反射services这一张表，比默认加载所有表更快，也更安全
• 布尔值使用True/False：Postgres的boolean类型对应Python的布尔值，用字符串'true'虽然可能被自动转换，但直接用布尔值更规范，避免潜在问题
• 回滚逻辑：迁移脚本一定要写downgrade，不然执行downgrade时会出错，这里直接删除插入的两条数据即可

这样你就不用重复定义表结构，直接复用数据库里已有的表来执行批量插入啦！

内容的提问来源于stack exchange，提问作者PanczerTank