SQLAlchemy批量更新

在 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 注入等安全问题得到妥善处理。
• 在进行批量更新之前，最好先在一个安全的测试环境中验证你的代码和逻辑。
• 根据你的数据库和表的大小，批量更新可能会对性能产生影响。在生产环境中使用之前，建议进行性能测试。
• 如果是更低的版本，可能只会支持前两种方式