Python sqlite3使用IF EXISTS实现更新插入报语法错误的解决方法

• SQLite的SQL方言不支持SQL Server/MySQL风格的IF EXISTS (...) BEGIN ... END嵌入式流程控制块语法，普通SQL执行上下文里没有IF这个流程控制关键字，解析器读到IF后面的EXISTS时无法识别合法语法结构，直接抛出语法错误。
• 原代码还存在隐藏逻辑bug：就算IF语法可以正常执行，内部的UPDATE语句没有写匹配条件的WHERE子句，会直接更新Cart表中所有行的对应字段，造成全表数据错误。
• 原代码参数传递冗余：相同的uid、商品id、价格参数重复传递了两次，很容易出现参数顺序对应错误的问题。

优先使用SQLite原生支持的INSERT ... ON CONFLICT（即Upsert）语法实现需求，这是性能最高、最安全的实现方式，SQLite 3.24.0及以上版本（Python 3.6+自带的sqlite3均满足该版本要求）都支持该语法。

1. 首先确保Cart表对判断条件对应的字段(UID, Status)建立了唯一约束，保证同一个用户对应open状态的购物车记录全局唯一，建表示例如下：

   CREATE TABLE IF NOT EXISTS Cart (
       ID INTEGER PRIMARY KEY AUTOINCREMENT,
       UID INTEGER NOT NULL,
       Products TEXT,
       Price REAL NOT NULL DEFAULT 0,
       Status TEXT NOT NULL,
       Expire INTEGER,
       -- 建立组合唯一约束，是ON CONFLICT语法生效的前提
       UNIQUE(UID, Status)
   );
   

2. 替换原有执行逻辑为原生Upsert写法，不需要手动编写事务和分支判断，参数也无需重复传递：

   DbCursor.execute(
       """
       INSERT INTO Cart(UID, Products, Price, Status, Expire)
       VALUES(?, ?, ?, 'open', 10*60)
       ON CONFLICT(UID, Status) DO UPDATE SET
           Price = Cart.Price + excluded.Price,
           Products = Cart.Products || excluded.Products,
           Expire = 10*60
       """,
       (uid, f"{product_id},", price)
   )
   database.commit()
   

   语法说明：excluded是ON CONFLICT子句中的特殊关键字，代表本次INSERT操作原本尝试写入的字段值，不需要重复传参即可引用。

如果你使用的SQLite版本极低、不支持ON CONFLICT语法，可以在Python代码侧做分支判断，注意UPDATE语句必须加WHERE条件：

# 开启即时事务，避免并发下的读写冲突
DbCursor.execute("BEGIN IMMEDIATE;")
# 先查询目标记录是否存在
DbCursor.execute("SELECT ID FROM Cart WHERE UID = ? AND Status = 'open' LIMIT 1;", (uid,))
target_cart = DbCursor.fetchone()
if target_cart:
    # 存在则执行更新，必须加WHERE条件匹配目标行
    DbCursor.execute(
        "UPDATE Cart SET Price = Price + ?, Products = Products || ?, Expire = 10*60 WHERE UID = ? AND Status = 'open';",
        (price, f"{product_id},", uid)
    )
else:
    # 不存在则插入新记录
    DbCursor.execute(
        "INSERT INTO Cart(UID, Products, Price, Status, Expire) VALUES(?, ?, ?, 'open', 10*60);",
        (uid, f"{product_id},", price)
    )
database.commit()

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