SQLAlchemy 高级批量插入笔记（标量子查询 + 显式参数绑定）

一、背景：笨办法的痛点

我们要做的事

给用户插入邮箱地址，需要先知道用户的user_id。

笨办法（分两步）

python

运行

# 第1步：先查用户ID user_id = conn.execute(select(user_table.c.id).where(user_table.c.name == "spongebob")).scalar() # 第2步：用查到的ID插地址 conn.execute(insert(address_table).values(user_id=user_id, email="sponge@example.com"))

痛点

1. 两次交互：先查再插，慢；
2. 批量更慢：插 100 个地址要查 100 次 ID；
3. 代码啰嗦。

二、核心概念拆解

1.bindparam("参数名")：显式预留参数坑位

作用

在 SQL 表达式里预留一个 “坑位”，执行时通过字典传值，靠名字匹配（不是靠顺序）。

代码示例

python

运行

from sqlalchemy import bindparam # 1. 留坑：name == bindparam("username") stmt = select(user_table.c.id).where(user_table.c.name == bindparam("username")) # 2. 填坑：传字典 {"username": "spongebob"}，key 匹配坑位名 result = conn.execute(stmt, {"username": "spongebob"})

2. 标量子查询 +.scalar_subquery()：把查询结果当值用

核心概念

• 标量：单个值（如数字1）；
• 标量子查询：一个只返回单个值的SELECT，可以直接当成 “值” 用在另一个 SQL 里。

代码示例

python

运行

# 1. 写一个普通查询 subq = select(user_table.c.id).where(user_table.c.name == "spongebob") # 2. 标记为“标量子查询”（保证只返回单个值） scalar_subq = subq.scalar_subquery() # 3. 直接当值用！user_id 执行这个子查询去查 stmt = insert(address_table).values(user_id=scalar_subq, email="sponge@example.com")

三、完整流程：两者结合实现高级批量插入

步骤 1：构造带参数坑位的标量子查询

python

运行

from sqlalchemy import select, bindparam # 留坑：bindparam("username") subq = select(user_table.c.id).where(user_table.c.name == bindparam("username")) # 标记为标量子查询 scalar_subq = subq.scalar_subquery()

步骤 2：写 INSERT 语句，user_id 用子查询

python

运行

# 意思：user_id 执行 scalar_subq 去查，email 从参数里拿 stmt = insert(address_table).values( user_id=scalar_subq, email_address=bindparam("email_address") # 邮箱也留坑（可省略，SQLAlchemy 自动识别） )

步骤 3：准备批量参数列表

python

运行

# 每个字典对应一行数据： # - "username" 填到子查询的坑里 # - "email_address" 填到邮箱坑里 params_list = [ {"username": "spongebob", "email_address": "sponge@example.com"}, {"username": "sandy", "email_address": "sandy@example.com"}, ]

步骤 4：执行！

python

运行

with engine.connect() as conn: conn.execute(stmt, params_list) # 自动批量执行 conn.commit()

数据库实际执行的 SQL

sql

INSERT INTO address (user_id, email_address) VALUES ( (SELECT id FROM user_account WHERE name = ?), -- 子查询查 user_id ? -- email_address );

四、核心价值总结

1. 减少查询次数：一条 SQL 完成 “查 ID + 插地址”，不用分两步；
2. 原子性更强：整个操作在一个事务里，避免竞态条件；
3. 更安全：显式参数绑定防 SQL 注入，靠名字匹配防顺序错误；
4. ORM 更简单：大多数时候用 ORM（如User.addresses），SQLAlchemy 自动处理关联插入。

五、一句话速记

用bindparam留坑，用scalar_subquery把查询当值，传字典列表批量填坑，一条 SQL 完成查 ID + 插地址。

本笔记由豆包生成,上传只为方便查找