插入事务该如何控制

“插入事务该如何控制”这个问题可以从数据库事务机制和代码层面控制两个角度来回答。下面以常见的关系型数据库（MySQL / PostgreSQL / Oracle）和主流编程语言为例说明。

一、事务控制的基本原则

插入（INSERT）操作通常用事务保证：

• 原子性（Atomicity）：要么全部插入成功，要么全部回滚
• 一致性（Consistency）：插入后数据满足约束
• 隔离性（Isolation）：并发插入互不干扰
• 持久性（Durability）：提交后数据不丢失

二、SQL 层面的事务控制（通用写法）

1. 手动控制事务（最标准）

BEGIN;

INSERT INTO user (name, age) VALUES ('Alice', 20);
INSERT INTO user_log (user_id, action) VALUES (LAST_INSERT_ID(), 'create');

COMMIT;
-- 若出错
-- ROLLBACK;

2. 异常处理中回滚

BEGIN;

INSERT INTO orders (user_id, amount) VALUES (1, 100);

-- 假设此处发生错误
INSERT INTO order_item (order_id, item) VALUES (999, 'error');

COMMIT;

如果第二条失败，应执行：

ROLLBACK;

三、在代码中控制插入事务（常见语言）

1. Java（JDBC）

Connection conn = dataSource.getConnection();
try {
    conn.setAutoCommit(false);

    PreparedStatement ps1 = conn.prepareStatement(
        "INSERT INTO user(name) VALUES(?)");
    ps1.setString(1, "Tom");
    ps1.executeUpdate();

    PreparedStatement ps2 = conn.prepareStatement(
        "INSERT INTO user_log(user_id, action) VALUES(?, ?)");
    ps2.setInt(1, 1);
    ps2.setString(2, "insert");
    ps2.executeUpdate();

    conn.commit();
} catch (Exception e) {
    conn.rollback();
} finally {
    conn.close();
}

2. Spring（推荐方式）

使用注解（最常用）

@Transactional
public void createUser() {
    userMapper.insert(user);
    userLogMapper.insert(log);
}

• 方法抛异常 → 自动回滚
• 成功执行完 → 自动提交

指定回滚条件

@Transactional(rollbackFor = Exception.class)

3. MyBatis

SqlSession session = sqlSessionFactory.openSession(false);
try {
    session.insert("insertUser", user);
    session.insert("insertLog", log);
    session.commit();
} catch (Exception e) {
    session.rollback();
} finally {
    session.close();
}

4. Python（SQLAlchemy）

with session.begin():
    session.add(User(name="Alice"))
    session.add(UserLog(action="create"))

异常自动回滚。

四、批量插入的事务控制

场景：批量插入但部分失败要全部回滚

@Transactional
public void batchInsert(List<User> users) {
    for (User u : users) {
        userMapper.insert(u);
    }
}

⚠️ 注意：

• 批量过多可能导致事务过长
• 可按每 500–1000 条提交一次（视业务而定）

五、常见坑位提醒

1. 忘记关闭自动提交

   conn.setAutoCommit(false);
   

2. 异常被吞掉导致不回滚
3. Spring 事务方法必须是 public
4. 同一个类中调用 @Transactional 方法失效
5. 长事务锁表，影响插入性能

六、简要总结

如果你能告诉我使用什么数据库 / 框架 / 语言，我可以给你更精确的示例。