Spring Batch实现DB间动态插入更新的问题求助

需实现DB到DB的数据加载，若目标系统已存在对应数据则更新，否则插入。

当前实现采用JdbcBatchItemWriter，但仅插入功能生效：

@Bean
ItemWriter<Student> onosItemWriter1() {
    JdbcBatchItemWriter<Student> databaseItemWriter = new JdbcBatchItemWriter<>();
    databaseItemWriter.setDataSource(dataSource);
    databaseItemWriter.setJdbcTemplate(namedParameterJdbcTemplate);
    databaseItemWriter.setSql(INSERT_QUERY);
   ItemPreparedStatementSetter<Student> valueSetter = new ItemPreparedStatementSetter<Student>() {

        @Override
        public void setValues(Student student, PreparedStatement statement) throws SQLException {
            if (Student.getId() < 0) {
                log.info("Inserting!");
                databaseItemWriter.setSql(INSERT_QUERY);
                statement.setString(1, student.getName());
                statement.setString(2, student.getEmail());
            } else {
                log.info("updateing!!!!");
                databaseItemWriter.setSql(UPDATE_QUERY);
                statement.setString(1, student.getName());
                statement.setString(2, student.getEmail());
            }
        }
    };
    databaseItemWriter.setItemPreparedStatementSetter(valueSetter);
    return databaseItemWriter;
}

问题：如何通过单个JdbcBatchItemWriter实现批处理（chunk）中数据的动态插入与更新？

你当前代码的核心问题在于：JdbcBatchItemWriter是为整个chunk批次预编译SQL语句的，在ItemPreparedStatementSetter的setValues方法中修改writer的SQL完全无效——因为此时批处理的预编译语句已经初始化完成，而且这种修改会引发线程安全问题（多线程批处理时SQL会被频繁覆盖）。

方案一：使用数据库原生的"插入或更新"语法（推荐） #

这是最简洁高效的方式，利用数据库自身的语法实现单条SQL的插入/更新逻辑，无需在代码中动态切换SQL，完美适配JdbcBatchItemWriter的批处理特性。

示例（MySQL）

假设Student表的主键是id，定义UPSERT_QUERY：

INSERT INTO student (id, name, email) 
VALUES (?, ?, ?) 
ON DUPLICATE KEY UPDATE 
name = VALUES(name), 
email = VALUES(email)

然后修改Writer配置，直接使用这条SQL，ItemPreparedStatementSetter只需统一设置所有参数：

@Bean
ItemWriter<Student> onosItemWriter1() {
    JdbcBatchItemWriter<Student> databaseItemWriter = new JdbcBatchItemWriter<>();
    databaseItemWriter.setDataSource(dataSource);
    databaseItemWriter.setSql(UPSERT_QUERY); // 使用原生UPSERT语法
    
    ItemPreparedStatementSetter<Student> valueSetter = (student, statement) -> {
        statement.setLong(1, student.getId()); // 无论插入还是更新都要设置id
        statement.setString(2, student.getName());
        statement.setString(3, student.getEmail());
    };
    
    databaseItemWriter.setItemPreparedStatementSetter(valueSetter);
    return databaseItemWriter;
}

其他数据库对应语法

• PostgreSQL：INSERT INTO student (id, name, email) VALUES (?, ?, ?) ON CONFLICT (id) DO UPDATE SET name = EXCLUDED.name, email = EXCLUDED.email
• Oracle：MERGE INTO student t USING DUAL ON (t.id = ?) WHEN MATCHED THEN UPDATE SET t.name = ?, t.email = ? WHEN NOT MATCHED THEN INSERT (id, name, email) VALUES (?, ?, ?)

方案二：自定义Writer扩展（仅当无法使用数据库原生语法时考虑） #

如果因为数据库限制不能用原生UPSERT，可以自定义JdbcBatchItemWriter的扩展逻辑：重写write方法，对每个item判断是插入还是更新，分别收集参数后执行对应的批量操作。不过这种方式会失去预编译SQL的性能优势，且实现复杂，不如方案一高效。

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