使用SQLAlchemy更新PostgreSQL数据库中某列的单个值

没问题，我来帮你补全这段更新id列值的代码。基于你已有的SQLAlchemy连接代码，这里提供两种常用的实现方式：

方式一：执行原生SQL（简单直接） #

这是最直观的方式，直接编写UPDATE语句执行：

from sqlalchemy import create_engine

# Connection with DB
engine = create_engine('postgresql://xxx')
connection = engine.connect()

try:
    # 执行更新语句：将id=70的记录替换为15
    update_stmt = "UPDATE batch SET id = 15 WHERE id = 70;"
    result = connection.execute(update_stmt)
    # 提交事务（如果你的引擎没有自动提交的话）
    connection.commit()
    print(f"成功更新了 {result.rowcount} 条记录")
except Exception as e:
    # 出错时回滚事务
    connection.rollback()
    print(f"更新失败：{str(e)}")
finally:
    # 关闭连接
    connection.close()

方式二：使用SQLAlchemy的Core API（更具ORM风格） #

如果想避免直接写原生SQL，也可以用SQLAlchemy的表达式语言来构建更新语句：

from sqlalchemy import create_engine, Table, MetaData

# Connection with DB
engine = create_engine('postgresql://xxx')
metadata = MetaData()
# 映射batch表
batch_table = Table('batch', metadata, autoload_with=engine)

with engine.connect() as connection:
    # 构建更新语句
    update_stmt = batch_table.update().where(batch_table.c.id == 70).values(id=15)
    result = connection.execute(update_stmt)
    connection.commit()
    print(f"成功更新了 {result.rowcount} 条记录")

重要提示 #

• 一定要加上WHERE id = 70这个条件！如果漏掉的话，会把表中所有记录的id都改成15，这绝对是你不想看到的。
• 记得处理事务的提交和回滚，确保数据操作的安全性。

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