JdbcTemplate batchUpdate的问题

Question

有一个简单的要求，我必须对更新查询的对象列表进行batchUpdate。

问题是，运行代码后，在数据库表中，我只看到第一行得到更新，其余的没有得到更新。下面是我为此使用的示例代码。

公共void更新(列表列表){

    String sql = "UPDATE table1 \\\r\n"
            + "SET col1 = ?, col2 = ?, modified_on = UTC_TIMESTAMP() \\\r\n"
            + "WHERE col3 = ? \\\r\n"
            + "AND col4 = ? \\\r\n"
            + "AND col5 = ? \\\r\n"
            + "AND col6 = ?" // col5 will be different for different records.

        int[] rowsArray = jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
            
            
            @Override
            public int getBatchSize() {
                return list.size();
            }
            @Override
            public void setValues(PreparedStatement ps, int index) throws SQLException {
                SampleClass sampleClass = list.get(index);
                
                ps.setString(1, sampleClass.getCol1());
                ps.setString(2, sampleClass.getCol2());
                ps.setString(3, sampleClass.getCol3());
                ps.setString(4, sampleClass.getCol4());
                ps.setString(5, sampleClass.getCol5());
                ps.setString(6, sampleClass.getCol6());
                
                
            }
        });

}

如果我的列表大小为 N，我什至可以确认 setValues（） 方法确实执行了 N 次。但是仍然执行批处理更新，在数据库中只更新第一行。我什至尝试更改列表中对象的顺序，结果仍然相同。但是，如果我在循环中对 N 个大小列表运行 JdbcTemplate.update（） 方法进行 N 次，则 N 条记录会在数据库中更新，但不会使用 JdbcTemplate.batchUpdat（） 更新。我什至也尝试了命名参数Jdbc模板的解决方案，但仍然是相同的问题。此外，我在同一数据库中的其他表中执行批处理更新具有相同的逻辑，并且此操作在同一代码流中编码。一切都很好。

为什么只有第一条记录被更新？

Answer 1

必须将每条记录添加到最终批次中。您的代码中缺少这一点。添加ps.addBatch（）将解决您的问题

String sql = "UPDATE table1 \\\r\n"
        + "SET col1 = ?, col2 = ?, modified_on = UTC_TIMESTAMP() \\\r\n"
        + "WHERE col3 = ? \\\r\n"
        + "AND col4 = ? \\\r\n"
        + "AND col5 = ? \\\r\n"
        + "AND col6 = ?" // col5 will be different for different records.

    int[] rowsArray = jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
        
        
        @Override
        public int getBatchSize() {
            return list.size();
        }
        @Override
        public void setValues(PreparedStatement ps, int index) throws SQLException {
            SampleClass sampleClass = list.get(index);
            
            ps.setString(1, sampleClass.getCol1());
            ps.setString(2, sampleClass.getCol2());
            ps.setString(3, sampleClass.getCol3());
            ps.setString(4, sampleClass.getCol4());
            ps.setString(5, sampleClass.getCol5());
            ps.setString(6, sampleClass.getCol6());
            
            ps.addBatch(); // Add this
        }
    });