使用 JdbcTemplate 插入多行

Question

如何使用 JdbcTemplate 在 mySQL 上运行。在这种情况下，可扩展意味着：

1. 服务器上仅执行一个 SQL 语句
2. 在适用于任意数量行的

。语句如下：

INSERT INTO myTable (foo, bar) VALUES ("asdf", "asdf"), ("qwer", "qwer")

假设我有一个带有 foo 和 bar 字段的 POJO 列表。我意识到我可以迭代列表并执行：

jdbcTemplate.update("INSERT INTO myTable(foo, bar) VALUES (?, ?)", paramMap)

但这并没有达到第一个标准。

我相信我也可以执行：

jdbcTemplate.batchUpdate("INSERT INTO myTable(foo, bar) VALUES (?, ?)", paramMapArray)

但据我所知，这只会编译 SQL 一次并执行多次，再次失败第一个标准。

最后一种可能性，似乎同时满足了这两个标准，就是简单地用 StringBuffer 自己构建 SQL，但我想避免这种情况。

Answer 1

您可以像下面一样使用BatchPreparedStatementSetter。

public void insertListOfPojos(final List<MyPojo> myPojoList) {

    String sql = "INSERT INTO "
        + "MY_TABLE "
        + "(FIELD_1,FIELD_2,FIELD_3) "
        + "VALUES " + "(?,?,?)";

    getJdbcTemplate().batchUpdate(sql, new BatchPreparedStatementSetter() {

        @Override
        public void setValues(PreparedStatement ps, int i)
            throws SQLException {

            MyPojo myPojo = myPojoList.get(i);
            ps.setString(1, myPojo.getField1());
            ps.setString(2, myPojo.getField2());
            ps.setString(3, myPojo.getField3());

        }

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

}

Answer 2

在我看来，JdbcTemplate 的batchUpdate() 方法在这种情况下可能会有帮助（从这里复制 http://www.mkyong.com/spring/spring-jdbctemplate-batchupdate-example/）：

//insert batch example
public void insertBatch(final List<Customer> customers){

  String sql = "INSERT INTO CUSTOMER " +
    "(CUST_ID, NAME, AGE) VALUES (?, ?, ?)";

  getJdbcTemplate().batchUpdate(sql, new BatchPreparedStatementSetter() {

@Override
public void setValues(PreparedStatement ps, int i) throws SQLException {
    Customer customer = customers.get(i);
    ps.setLong(1, customer.getCustId());
    ps.setString(2, customer.getName());
    ps.setInt(3, customer.getAge() );
}

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

  });
 }

Answer 3

多行插入（使用“行值构造函数”）实际上是 SQL-92 标准的一部分。看
http://en.wikipedia.org/wiki/Insert_(SQL)#Multirow_inserts。

有些数据库不支持此语法，但许多数据库都支持。根据我的经验，Derby/Cloudscape、DB2、Postgresql 和较新的 Hypersonic 2.*+ 版本确实支持此功能。

您对使其作为PreparedStatement工作的担忧是可以理解的，但我见过类似的情况，其中Spring JDBC确实自动处理某些查询的项目集合（例如在（？）中的位置），但我不能保证这种情况。

我确实找到了一些可能有用的信息（无法在这篇文章中添加第二个链接）
这可能会有一些帮助。

我可以告诉您，从最严格的意义上讲，您的第二个要求（适用于任意数量的参数）可能不可能得到满足：我使用的每个数据库确实都会施加会发挥作用的查询长度限制。

Answer 4

您还可以尝试使用 jdbcInsert.executeBatch(sqlParamSourceArray)

   // define parameters
jdbcInsert = new SimpleJdbcInsert(jdbcTemplate);
jdbcInsert.withTableName("TABlE_NAME");
SqlParameterSource[] sqlParamSourceArray = new SqlParameterSource[apiConsumer
        .getApiRoleIds().size()];
for (int i = 0; i < myCollection.size(); i++) 
    {
  sqlParamSourceArray[i] = new MapSqlParameterSource().addValue("COL1");
      ......................
}
// execute insert
int[] keys = jdbcInsert.executeBatch(sqlParamSourceArray);