spring jdbctemplate batch 批处理

int len = p_id.length;

 

String l_sql = "update email_filter e set e.pri = ? where e.id = ? ";

 

 

final List<DynaBean> list = new ArrayList<DynaBean>();

for(int i=0;i<p_id.length;i++) {

DynaBean bean = new LazyDynaBean();

bean.set("pri", new Long(len - i));

bean.set("id", new Long(p_id[i]));

list.add(bean);

}

 

 

//批处理

BatchPreparedStatementSetter set = new BatchPreparedStatementSetter(){

public int getBatchSize() {

return list.size();

}

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

DynaBean bean = list.get(i);

ps.setLong(1, ((Long)bean.get("pri")).longValue());

ps.setLong(2, ((Long)bean.get("id")).longValue());

}};

 

new JdbcTemplate(dataSource).batchUpdate(l_sql, set);

<!--EndFragment-->