在Mybatis中一条SQL插入多行数据

由于批量插入时用一个sql比在一个事务中用多个sql要快，因为这样可以减少web服务器和数据库服务器的网络通信时间， 假设entity如下：
class Entity {
private int id;
private String name;
private java.util.Date date;
}
在mybatis的mapper 文件中，我的代码如下
<insert id="insert" >
insert into xEntity values
<foreach collection="list" item="item" separator=",">
(#{id},#{name}, #{date})
</foreach>
</insert>

由于我们使用mybatis的#{}语义，它会生成预编译的sql,然后填充值
insert into xEntity values(?,?,?),(?,?,?)...
对于这种一个sql插入多条数据的sql预编译是没有任何好处的，每次插入的长度都不一样，没有机会使用预编译带来的好处

将mapper中的sql 改为：
<insert id="insert" >
insert into xEntity values
<foreach collection="list" item="item" separator=",">
(${id},${name}, ${date})
</foreach>
</insert>

使用${}语义进行文本替换，产生的sql如下：
insert into xEntity values(1,ssss,Fri Aug 22 08:51:45 CST 2014),(2,wwww,Fri Aug 22 08:51:45 CST 2014)...
Mysql报错，说sql格式错误，查看产生的sql发现是string 和date 域都错误，

最后的解决方案，获取Connection对象使用原始的sql操作：
在SqlSessionDaoSupport 的子类中：
public int execute(String sql) {
int affectedCount = 0;
Connection conn = null;
Statement stm = null;
try {
conn = getSqlSession().getConnection();
stm = conn.createStatement();
stm.execute(sql);
affectedCount = stm.getUpdateCount();
} catch (SQLException e) {
throw new RuntimeException("execute[" + sql + "] failed");
} finally {
try{
if(stm != null && !stm.isClosed()) {
stm.close();
}
//conn will be released by mybatis framework
} catch(SQLException e) {
}
}
return affectedCount;
}

唯一要注意的时不要尝试关闭Connection 对象，因为mybatis 会自动关闭，如果你关闭了会报错

Posted in: Mybatis practise