ExecutorType 批量执行

MyBatis 提供三种执行器类型，合理选择执行器可以显著提升批量操作性能。本文对比三种执行器的差异，重点讲解 BATCH 批量执行器的使用。

三种 ExecutorType 对比

注意：默认执行器是 SIMPLE。可通过 defaultExecutorType 全局设置，或在获取 SqlSession 时单独指定。

SIMPLE 执行器

// 默认使用 SIMPLE
SqlSession session = sqlSessionFactory.openSession();
for (int i = 0; i < 1000; i++) {
    mapper.insertUser(new User("user" + i, "user" + i + "@test.com"));
}
session.commit();
session.close();

SIMPLE 模式下，每次调用 insertUser 都会：

1. 创建新的 PreparedStatement
2. 设置参数
3. 执行 executeUpdate()
4. 释放资源

1000 次插入 = 1000 次网络往返 + 1000 次语句编译。

REUSE 执行器

SqlSession session = sqlSessionFactory.openSession(ExecutorType.REUSE);
for (int i = 0; i < 1000; i++) {
    mapper.insertUser(new User("user" + i, "user" + i + "@test.com"));
}
session.commit();
session.close();

REUSE 模式下，相同的 SQL 语句只编译一次，复用 PreparedStatement。减少了编译开销，但每次执行仍然是独立的网络往返。

BATCH 执行器

基本用法

SqlSession session = sqlSessionFactory.openSession(ExecutorType.BATCH);
try {
    UserMapper mapper = session.getMapper(UserMapper.class);
    for (int i = 0; i < 1000; i++) {
        mapper.insertUser(new User("user" + i, "user" + i + "@test.com"));
    }
    session.commit();
} finally {
    session.close();
}

BATCH 模式下：

1. mapper.insertUser() 不会立即发送 SQL 到数据库
2. SQL 被加入批处理队列
3. commit() 时统一调用 executeBatch()

1000 次插入 = 1 次网络往返 + 批量执行。

Mapper XML 配置

BATCH 模式下的 Mapper 写法与普通插入相同：

<insert id="insertUser" parameterType="User">
    INSERT INTO user (username, email) VALUES (#{username}, #{email})
</insert>

注意：BATCH 模式使用的是 executeBatch()，不需要在 XML 中使用 foreach 拼接 SQL。

批量更新

SqlSession session = sqlSessionFactory.openSession(ExecutorType.BATCH);
try {
    UserMapper mapper = session.getMapper(UserMapper.class);
    for (User user : users) {
        mapper.updateUser(user);
    }
    session.commit();
} finally {
    session.close();
}

分批提交

当数据量极大时，避免在 BATCH 队列中堆积过多语句：

public void batchInsertInChunks(List<User> users) {
    int batchSize = 500;
    SqlSession session = sqlSessionFactory.openSession(ExecutorType.BATCH);
    try {
        UserMapper mapper = session.getMapper(UserMapper.class);
        for (int i = 0; i < users.size(); i++) {
            mapper.insertUser(users.get(i));
            // 每 500 条执行一次 commit
            if ((i + 1) % batchSize == 0) {
                session.commit();
                session.clearCache();
            }
        }
        // 提交剩余数据
        session.commit();
    } finally {
        session.close();
    }
}

注意：BATCH 模式下调用 commit() 后必须 clearCache() 清理缓存，避免内存泄漏。

全局配置 ExecutorType

MyBatis 配置文件

<settings>
    <setting name="defaultExecutorType" value="BATCH"/>
</settings>

Spring 集成配置

<bean id="batchSqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate">
    <constructor-arg ref="sqlSessionFactory"/>
    <constructor-arg value="BATCH"/>
</bean>

@Configuration
public class MyBatisConfig {
    @Bean
    public SqlSessionTemplate batchSqlSessionTemplate(SqlSessionFactory factory) {
        return new SqlSessionTemplate(factory, ExecutorType.BATCH);
    }
}

性能对比

注意：BATCH 模式下，MySQL 默认无法获取每条记录的自增主键，因为 executeBatch() 不返回 individual generated keys。如需要回填主键，考虑使用 foreach 方式。

BATCH 模式的限制

要点总结

• SIMPLE：每次执行创建新 PreparedStatement，适合单次操作
• REUSE：复用 PreparedStatement，减少重复编译
• BATCH：批处理模式，SQL 加入队列后统一 executeBatch()，批量写入性能最高
• BATCH 模式注意每批 commit 后 clearCache()，避免内存泄漏
• BATCH 模式无法获取自增主键，动态 SQL 不生效
• 大批量数据分批提交，控制单次 BATCH 队列大小