如何在Spring JDBC Template中禁用自动提交以统一批量插入版本号

你遇到的这个问题其实很典型——默认情况下，JdbcTemplate的批量更新如果没有事务包裹，每完成一批（比如你设置的50条）就会自动提交一次数据库事务，这就导致你的版本号生成逻辑（不管是应用内设置还是数据库侧的逻辑）因为多次提交而逐批变化。要让所有1000条记录的版本号都保持为1，核心就是把所有批量操作放进同一个事务里，统一提交。

下面给你两种常用的实现方式：

方法一：用声明式事务（@Transactional）快速解决 #

这是Spring项目里最常用的方式，Spring会帮你自动管理事务的开启、提交和回滚，几乎不用写额外的事务控制代码。

1. 先确保你的Spring项目已经开启了事务管理：如果是注解配置，在你的配置类上加上@EnableTransactionManagement；如果是XML配置，添加对应的事务管理器配置。

2. 在执行批量插入的业务方法上加上@Transactional注解，这样整个方法内的所有数据库操作都会处于同一个事务中：

import org.springframework.jdbc.core.BatchPreparedStatementSetter;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.stereotype.Service;
import java.util.List;

@Service
public class DataImportService {

    private final JdbcTemplate jdbcTemplate;

    // 构造注入JdbcTemplate
    public DataImportService(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    @Transactional // 关键：开启事务，方法结束时统一提交
    public void batchInsert(List<YourEntity> dataList) {
        String insertSql = "INSERT INTO your_table (content, version, create_time) VALUES (?, ?, ?)";

        jdbcTemplate.batchUpdate(insertSql, new BatchPreparedStatementSetter() {
            @Override
            public void setValues(java.sql.PreparedStatement ps, int index) throws java.sql.SQLException {
                YourEntity entity = dataList.get(index);
                ps.setString(1, entity.getContent());
                ps.setInt(2, 1); // 固定设置版本号为1
                ps.setTimestamp(3, entity.getCreateTime());
                // 其他字段按需设置
            }

            @Override
            public int getBatchSize() {
                return 50; // 保持你的批量大小设置
            }
        });
        // 方法正常执行完毕后，Spring会自动提交整个事务
    }
}

加上@Transactional之后，不管你分多少批执行插入，所有操作都会在同一个数据库事务里完成，不会有中间提交的情况，自然所有记录的版本号都会是你设置的1。

方法二：编程式事务（更灵活的控制） #

如果你的业务需要更灵活的事务控制（比如根据某些条件手动决定提交时机），可以用编程式事务：

import org.springframework.jdbc.core.BatchPreparedStatementSetter;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;
import java.util.List;

public class DataImportService {

    private final JdbcTemplate jdbcTemplate;
    private final PlatformTransactionManager transactionManager;

    public DataImportService(JdbcTemplate jdbcTemplate, PlatformTransactionManager transactionManager) {
        this.jdbcTemplate = jdbcTemplate;
        this.transactionManager = transactionManager;
    }

    public void batchInsert(List<YourEntity> dataList) {
        // 定义事务属性，这里用默认的配置即可
        TransactionDefinition transactionDef = new DefaultTransactionDefinition();
        // 开启事务
        TransactionStatus status = transactionManager.getTransaction(transactionDef);

        try {
            String insertSql = "INSERT INTO your_table (content, version, create_time) VALUES (?, ?, ?)";

            jdbcTemplate.batchUpdate(insertSql, new BatchPreparedStatementSetter() {
                @Override
                public void setValues(java.sql.PreparedStatement ps, int index) throws java.sql.SQLException {
                    YourEntity entity = dataList.get(index);
                    ps.setString(1, entity.getContent());
                    ps.setInt(2, 1);
                    ps.setTimestamp(3, entity.getCreateTime());
                }

                @Override
                public int getBatchSize() {
                    return 50;
                }
            });

            // 所有批量操作完成后，手动提交事务
            transactionManager.commit(status);
        } catch (Exception e) {
            // 出现异常时回滚事务
            transactionManager.rollback(status);
            // 抛出异常让上层处理
            throw new RuntimeException("批量插入失败", e);
        }
    }
}

这种方式你可以完全掌控事务的生命周期，同样能保证所有批量操作在同一个事务内执行，统一提交。

几个注意点 #

• 确保你的数据库支持事务：比如MySQL要用InnoDB引擎，MyISAM不支持事务，就算加了事务注解也没用。
• 如果版本号是数据库自动生成的（比如触发器、序列），那得调整数据库逻辑，否则就算在事务内，数据库还是会自动递增——不过根据你的需求，应该是插入时手动设置版本号为1，所以这块不用太担心。
• 批量大小保持50是合理的，既不会因为单次插入太多数据导致数据库压力过大，又能在事务内高效完成批量操作。

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