Insertar varias filas usando JdbcTemplate

Question

¿Cómo puedo ejecutar el siguiente SQL de forma escalable usando JdbcTemplate ejecutándose en mySQL. En este caso, los medios escalables:

1. Sólo una declaración SQL se ejecuta en el servidor
2. funciona para cualquier número de filas.

Aquí está la declaración:

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

Supongamos que tengo una lista de POJO de foo con bar y campos. Soy consciente de que solo yo podría iterar sobre la lista y ejecutar:

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

pero eso no significa no cumple con el primer criterio.

creo que yo también podría ejecutar:

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

pero por lo que puedo decir, que se acaba de compilar el SQL de una vez y ejecutarlo varias veces, en su defecto el primer criterio de nuevo.

La última posibilidad, que parece superar ambos criterios, sería simplemente construir el SQL yo mismo con un StringBuffer, pero me gustaría evitar eso.

Answer 1

Las inserciones de Multirow (que usan "constructores de valores de fila") son de hecho parte del estándar SQL-92. Ver http://en.wikipedia.org/wiki/Insert_(SQL)#Multirow_inserts.

Algunas bases de datos no son compatibles con esta sintaxis, pero muchas sí. En mi experiencia, Derby/Cloudscape, DB2, Postgresql y las versiones más nuevas de Hypersonic 2. * + Sí lo admiten.

Su preocupación por hacer que esto funcione como un estado preparado es comprensible, pero he visto casos similares en los que Spring JDBC maneja automáticamente una colección de elementos para ciertas consultas (como dónde en (?)), Pero no puedo responder para este caso.

Encontré información posiblemente útil en (no puedo agregar un segundo enlace a esta publicación) que podría ser de alguna ayuda.

Puedo decirle que probablemente no sea posible cumplir con su segundo requisito (funciona para cualquier cantidad de argumentos) en el sentido más estricto: cada base de datos que he usado impone limitaciones de longitud de consulta que entrarían en juego .

Answer 2

No puede hacer esto en JDBC, punto. En MySQL solo se trata de azúcar sintáctica, pero el efecto de la declaración será el mismo que emitir varias instrucciones INSERT. Entonces puedes usar batchUpdate y tendrá el mismo efecto.

Answer 3

Puede usar BatchPreparedStatementSetter como a continuación.

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 4

también puedes probar con 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); 

Answer 5

A mi me parece que batchUpdate() método de JdbcTemplate podría ser útil en este caso (copiado de aquí):

//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(); 
} 

    }); 
}