在 SQLAlchemy 1.4 版本中，批量更新仍然是一个常见的需求。虽然 SQLAlchemy 1.4 引入了一些新功能和改进，但基本的批量更新策略与之前的版本相似。以下是一些在 SQLAlchemy 1.4 中执行批量更新的常见方法：
1. 使用 update() 语句
你可以使用 update() 语句结合 execute() 方法来执行批量更新。
from sqlalchemy import update
from sqlalchemy.orm import Session
# 假设你有一个名为 User 的模型类，以及一个名为 session 的会话对象
session = Session(engine)
# 构建更新语句
stmt = (
update(User)
.where(User.name == 'old_name')
.values(name='new_name')
)
# 执行更新
session.execute(stmt)
session.commit()
2. 使用原生 SQL 语句
你也可以直接使用原生 SQL 语句进行批量更新。
from sqlalchemy import text
# 构建原生 SQL 更新语句
update_stmt = text("UPDATE users SET name = :new_name WHERE name = :old_name")
# 执行更新
session.execute(update_stmt, {'new_name': 'new_name', 'old_name': 'old_name'})
session.commit()
3. 使用 bulk_update_mappings()
如果你需要基于对象或字典的映射进行批量更新，可以使用 bulk_update_mappings() 方法。
from sqlalchemy.orm import bulk_update_mappings
# 假设你有一个包含要更新的 User 对象的列表
users_to_update = [
{'id': user.id, 'name': 'new_name'}
for user in session.query(User).filter(User.name == 'old_name').all()
]
# 执行批量更新
bulk_update_mappings(session, User, users_to_update)
session.commit()
请注意，bulk_update_mappings() 方法不会触发 ORM 的事件，也不会加载任何对象到会话中。它直接执行 SQL 语句来更新数据库中的记录。
注意事项：
- 在执行批量更新之前，请确保你的更新条件是正确的，以避免意外修改或删除数据。
- 在使用原生 SQL 或构建复杂的更新逻辑时，请格外小心，以确保 SQL 注入等安全问题得到妥善处理。
- 在进行批量更新之前，最好先在一个安全的测试环境中验证你的代码和逻辑。
- 根据你的数据库和表的大小，批量更新可能会对性能产生影响。在生产环境中使用之前，建议进行性能测试。
- 如果是更低的版本，可能只会支持前两种方式
