0

0

sqlalchemy 如何写“插入或更新”并返回受影响行数

冰川箭仙

冰川箭仙

发布时间:2026-01-25 19:51:08

|

311人浏览过

|

来源于php中文网

原创

PostgreSQL 中 insert().on_conflict_do_update() 不返回行数,需用 RETURNING 子句配合 fetchall() 计数;MySQL 依赖 rowcount(需 exec_driver_sql);SQLite 用 changes();ORM 中避免 merge(),应使用 returning()。

sqlalchemy 如何写“插入或更新”并返回受影响行数

SQLAlchemy 里 insert().on_conflict_do_update() 不返回行数

PostgreSQL 的 ON CONFLICT DO UPDATE 本身不直接返回“影响了多少行”,execute() 返回的 Result 对象默认也不暴露这个信息。你调用 result.rowcount 得到的往往是 -1(尤其在 psycopg2 异步或某些驱动配置下),不是真实受影响行数。

真正能拿到插入/更新行数的方式,是靠 RETURNING 子句 + 手动计数:

  • 对 PostgreSQL:用 INSERT ... ON CONFLICT DO UPDATE RETURNING id,然后统计 result.fetchall() 长度
  • 对 MySQL:原生不支持 ON DUPLICATE KEY UPDATERETURNING,得靠 rowcount —— 但必须确保使用 exec_driver_sql() 或显式设置 cursor.rowcount 可用(如关闭连接池预处理)
  • 对 SQLite:INSERT OR REPLACE 后查 connection.execute("SELECT changes()").scalar()

PostgreSQL 实操:用 RETURNING 精确统计

这是最可靠的方式,适用于需要区分“新插入”和“已存在但更新”的场景:

from sqlalchemy import text

stmt = text(""" INSERT INTO users (id, name, email) VALUES (:id, :name, :email) ON CONFLICT (id) DO UPDATE SET name = EXCLUDED.name, email = EXCLUDED.email RETURNING id """) result = conn.execute(stmt, {"id": 123, "name": "Alice", "email": "a@b.com"}) affected_count = len(result.fetchall()) # ✅ 真实行数

注意点:

  • RETURNING 必须指定至少一个列(哪怕只写 RETURNING 1),否则 fetchall() 为空,长度为 0
  • 不能混用 ORM 模型对象直接传入 text();要用原生参数绑定
  • 如果想同时知道是 insert 还是 update,可在 RETURNING 里加伪列:RETURNING CASE WHEN xmax = 0 THEN 'insert' ELSE 'update' END(PostgreSQL 内部机制)

MySQL / SQLite 的兼容性取舍

MySQL 的 ON DUPLICATE KEY UPDATE 会把“插入”和“更新”都算作“受影响行数”,但 SQLAlchemy 默认不透出这个值:

黑点工具
黑点工具

在线工具导航网站,免费使用无需注册,快速使用无门槛。

下载
  • exec_driver_sql()(SQLAlchemy 2.0+)可绕过 ORM 层限制:result = conn.exec_driver_sql("INSERT INTO t ... ON DUPLICATE KEY UPDATE ..."),之后 result.rowcount 通常可用
  • SQLite 的 INSERT OR REPLACE 本质是删+插,rowcount 不稳定;推荐改用 conn.exec_driver_sql("SELECT changes()").scalar() 获取最后操作变更行数
  • 跨数据库抽象时,别依赖 rowcount —— 它在不同方言、不同执行模式(如 execute vs executemany)下行为差异极大

ORM 层怎么写?别用 merge()

session.merge() 看似符合“插入或更新”语义,但它内部是先 SELECT 再决定 insert/update,无法原子化,且 rowcount 总是 1(不管实际是否写入)。

真要走 ORM 路线,只能手动控制:

  • session.execute(insert(...).on_conflict_do_update(...).returning(...))(SQLAlchemy 2.0+ 支持)
  • 避免混合 ORM 实例和原生语句;一旦用了 RETURNING,就老实用字典或元组接收结果
  • 别指望 session.commit() 后从 session 缓存里反推影响行数——缓存不记录底层 DML 统计

最易被忽略的是:RETURNING 在 PostgreSQL 中要求目标表有主键或唯一约束才能触发 ON CONFLICT,否则语法报错;而 MySQL 的 ON DUPLICATE KEY UPDATE 则强制依赖已有 UNIQUE/PRIMARY KEY 索引 —— 约束缺失时,所谓“插入或更新”会静默变成纯插入,且无提示。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
mysql修改数据表名
mysql修改数据表名

MySQL修改数据表:1、首先查看数据库中所有的表,代码为:‘SHOW TABLES;’;2、修改表名,代码为:‘ALTER TABLE 旧表名 RENAME [TO] 新表名;’。php中文网还提供MySQL的相关下载、相关课程等内容,供大家免费下载使用。

667

2023.06.20

MySQL创建存储过程
MySQL创建存储过程

存储程序可以分为存储过程和函数,MySQL中创建存储过程和函数使用的语句分别为CREATE PROCEDURE和CREATE FUNCTION。使用CALL语句调用存储过程智能用输出变量返回值。函数可以从语句外调用(通过引用函数名),也能返回标量值。存储过程也可以调用其他存储过程。php中文网还提供MySQL创建存储过程的相关下载、相关课程等内容,供大家免费下载使用。

247

2023.06.21

mongodb和mysql的区别
mongodb和mysql的区别

mongodb和mysql的区别:1、数据模型;2、查询语言;3、扩展性和性能;4、可靠性。本专题为大家提供mongodb和mysql的区别的相关的文章、下载、课程内容,供大家免费下载体验。

281

2023.07.18

mysql密码忘了怎么查看
mysql密码忘了怎么查看

MySQL是一个关系型数据库管理系统,由瑞典MySQL AB 公司开发,属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一,在 WEB 应用方面,MySQL是最好的 RDBMS 应用软件之一。那么mysql密码忘了怎么办呢?php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

515

2023.07.19

mysql创建数据库
mysql创建数据库

MySQL是一个关系型数据库管理系统,由瑞典MySQL AB 公司开发,属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一,在 WEB 应用方面,MySQL是最好的 RDBMS 应用软件之一。那么mysql怎么创建数据库呢?php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

256

2023.07.25

mysql默认事务隔离级别
mysql默认事务隔离级别

MySQL是一种广泛使用的关系型数据库管理系统,它支持事务处理。事务是一组数据库操作,它们作为一个逻辑单元被一起执行。为了保证事务的一致性和隔离性,MySQL提供了不同的事务隔离级别。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

386

2023.08.08

sqlserver和mysql区别
sqlserver和mysql区别

SQL Server和MySQL是两种广泛使用的关系型数据库管理系统。它们具有相似的功能和用途,但在某些方面存在一些显著的区别。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

532

2023.08.11

mysql忘记密码
mysql忘记密码

MySQL是一种关系型数据库管理系统,关系数据库将数据保存在不同的表中,而不是将所有数据放在一个大仓库内,这样就增加了速度并提高了灵活性。那么忘记mysql密码我们该怎么解决呢?php中文网给大家带来了相关的教程以及其他关于mysql的文章,欢迎大家前来学习阅读。

601

2023.08.14

拼多多赚钱的5种方法 拼多多赚钱的5种方法
拼多多赚钱的5种方法 拼多多赚钱的5种方法

在拼多多上赚钱主要可以通过无货源模式一件代发、精细化运营特色店铺、参与官方高流量活动、利用拼团机制社交裂变,以及成为多多进宝推广员这5种方法实现。核心策略在于通过低成本、高效率的供应链管理与营销,利用平台社交电商红利实现盈利。

31

2026.01.26

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
MySQL 教程
MySQL 教程

共48课时 | 1.9万人学习

MySQL 初学入门(mosh老师)
MySQL 初学入门(mosh老师)

共3课时 | 0.3万人学习

简单聊聊mysql8与网络通信
简单聊聊mysql8与网络通信

共1课时 | 811人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号