Spring Boot JDBC客户端中Batch Size与Fetch Size的配置方法

优先通过配置文件设置 #

1. 全局Fetch Size配置（基于HikariCP） #

Spring Boot默认使用HikariCP作为连接池，可通过配置文件传递底层JDBC属性来设置全局fetch size：

# application.properties
spring.datasource.hikari.data-source-properties.fetchSize=1000
# MySQL需额外开启游标抓取才能让fetch size生效
spring.datasource.hikari.data-source-properties.useCursorFetch=true

2. 全局Batch Size配置 #

Spring Boot没有直接的全局batch size配置项，但可以通过配置文件定义参数，再自定义JdbcTemplate Bean统一设置：

# application.properties
app.jdbc.batch-size=500

@Configuration
public class JdbcConfiguration {
    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource, 
                                     @Value("${app.jdbc.batch-size}") int batchSize) {
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        jdbcTemplate.setBatchSize(batchSize);
        return jdbcTemplate;
    }
}

代码层面灵活设置（针对特定操作） #

如果需要为单个查询/批量操作单独设置参数，可直接在代码中指定：

1. 单个查询设置Fetch Size #

jdbcTemplate.query("SELECT * FROM large_dataset_table", 
    new PreparedStatementSetter() {
        @Override
        public void setValues(PreparedStatement ps) throws SQLException {
            ps.setFetchSize(2000); // 仅对本次查询生效
        }
    },
    rs -> {
        // 处理结果集逻辑
        while (rs.next()) {
            // 读取数据
        }
    });

2. 单个批量操作设置Batch Size #

List<YourEntity> entityList = // 待批量插入的数据集
int batchSize = 300;

for (int i = 0; i < entityList.size(); i += batchSize) {
    int endIndex = Math.min(i + batchSize, entityList.size());
    List<YourEntity> batch = entityList.subList(i, endIndex);
    
    jdbcTemplate.batchUpdate(
        "INSERT INTO your_table (col1, col2) VALUES (?, ?)",
        new BatchPreparedStatementSetter() {
            @Override
            public void setValues(PreparedStatement ps, int index) throws SQLException {
                YourEntity entity = batch.get(index);
                ps.setString(1, entity.getCol1());
                ps.setString(2, entity.getCol2());
            }

            @Override
            public int getBatchSize() {
                return batch.size();
            }
        }
    );
}

关键说明 #

• fetchSize：控制JDBC驱动每次从数据库拉取的行数，避免大结果集占用过多内存，不同数据库驱动的支持逻辑有差异（如MySQL需开启游标抓取）。
• batchSize：控制批量操作时单次提交的记录数，减少数据库交互次数，提升写入/更新效率。

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