如何实现SQL链式执行：仅首个INSERT语句成功后执行第二个？

这是个很常见的原子性操作需求，咱们可以从三个层面来实现，保证只有第一条INSERT...ON DUPLICATE KEY语句执行成功时，才会触发第二条交易记录插入：

方案1：数据库事务（最推荐） #

利用数据库事务的原子性特性，把两条语句包裹在同一个事务中——只要第一条语句执行失败（比如主键冲突之外的错误、数据库异常），整个事务会回滚，第二条语句也不会生效；如果第一条执行成功（不管是插入新行还是更新已有行），两条语句会一起提交。

注意点：先修正第一条语句的小问题 #

你原语句里的value=VALUES(value + 10)是错误的，VALUES()函数是引用INSERT子句中对应列的传入值，正确写法应该是value = value + 10（直接累加现有值）或者value = VALUES(value) + 10（用传入的10加上现有值，效果和前者一致）。

事务示例（MySQL） #

-- 开启事务
BEGIN;
-- 第一条语句：插入或更新余额
INSERT INTO balance (_id, value) VALUES (1, 10) ON DUPLICATE KEY UPDATE value = value + 10;
-- 第二条语句：插入交易记录
INSERT INTO transaction (owner, value, type, description) VALUES (1, 10, 'CREDIT', 'User Deposit');
-- 提交事务（只有两条都成功才会持久化）
COMMIT;

⚠️ 前提：balance表的_id字段必须是主键或唯一索引，否则ON DUPLICATE KEY不会生效。

方案2：应用程序层条件判断 #

如果需要更灵活的逻辑（比如根据第一条语句是插入还是更新，调整第二条语句的内容），可以在应用代码中先执行第一条语句，检查执行结果后再决定是否执行第二条。

伪代码示例（Python + MySQL） #

import mysql.connector

# 建立数据库连接
db_conn = mysql.connector.connect(host="your_host", user="your_user", password="your_pwd", database="your_db")
cursor = db_conn.cursor()

try:
    # 执行第一条余额操作语句
    cursor.execute("INSERT INTO balance (_id, value) VALUES (1, 10) ON DUPLICATE KEY UPDATE value = value + 10")
    
    # 检查执行状态：MySQL中，插入成功返回1行受影响，更新成功返回2行受影响，都属于成功
    if cursor.rowcount > 0:
        # 第一条成功，执行第二条交易记录插入
        cursor.execute("INSERT INTO transaction (owner, value, type, description) VALUES (1, 10, 'CREDIT', 'User Deposit')")
    
    # 提交所有操作
    db_conn.commit()
except Exception as e:
    # 任何步骤失败，回滚所有操作
    db_conn.rollback()
    print(f"操作失败：{str(e)}")
finally:
    # 关闭资源
    cursor.close()
    db_conn.close()

这种方式的优势是可以自定义判断逻辑，比如如果是更新操作，把交易描述改成"User Balance Top-Up"，灵活性更高。

方案3：数据库触发器（谨慎使用） #

如果希望完全在数据库层实现自动触发，可以给balance表创建AFTER INSERT和AFTER UPDATE触发器，当余额行被插入或更新时，自动插入交易记录。

触发器示例（MySQL） #

-- 先修改分隔符，避免触发器内的分号冲突
DELIMITER //

-- 触发插入操作的触发器
CREATE TRIGGER after_balance_insert
AFTER INSERT ON balance
FOR EACH ROW
BEGIN
    -- 当插入新余额行时，插入交易记录
    INSERT INTO transaction (owner, value, type, description) VALUES (NEW._id, 10, 'CREDIT', 'User Deposit');
END //

-- 触发达成更新操作的触发器（需判断是否是目标更新）
CREATE TRIGGER after_balance_update
AFTER UPDATE ON balance
FOR EACH ROW
BEGIN
    -- 只在余额增加10时触发，避免其他更新操作误触发
    IF NEW.value = OLD.value + 10 THEN
        INSERT INTO transaction (owner, value, type, description) VALUES (NEW._id, 10, 'CREDIT', 'User Deposit');
    END IF;
END //

-- 恢复默认分隔符
DELIMITER ;

⚠️ 注意：触发器逻辑比较隐蔽，后续维护成本高；如果有其他业务操作会更新balance表，需要严格判断触发条件，避免生成无效的交易记录。

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