欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

ibatis 批量添加数据

程序员文章站 2022-07-13 13:09:10
...
ibatis 批量添加数据
自己项目中用到的。


public void insertCiyt(final List<City> cityList) {
// TODO Auto-generated method stub
System.out.println("批量添加开始");

SqlMapClientCallback callback = new SqlMapClientCallback() {
public Object doInSqlMapClient(SqlMapExecutor executor)
throws SQLException {
int counter =1;
executor.startBatch();
for (City dto : cityList) {
//需要插入的语句
executor.insert("inserSql", dto);
counter++;
if (counter % 4000 == 0) {
executor.executeBatch();
executor.startBatch();
}
}
executor.executeBatch();
return null;//这里的返回值会被下面的Object接收到
}
};
//num 接受的是每次批量处理多少条数据
Object num = this.getSqlMapClientTemplate().execute(callback);

}


下面配置文件里面的

<sqlMap namespace="City">
<typeAlias alias="city" type="com.xxx.City" />
<resultMap class="city" id="cityMap">
<result property="cid" column="cid" />
<result property="name" column="name" />
</resultMap>

<insert id="insertSql" parameterClass="city">
<![CDATA[insert into u_city_copy(`cid`,`name`)
values(#cid#,#name#);]]>
</insert>
</sqlMap>


另一种方法也可以:

@Override
public void mergerLeagueRelation(final List<LeagueRelation> leagueRelation) {
this.getSqlMapClientTemplate().execute(new SqlMapClientCallback(){
public Object doInSqlMapClient(SqlMapExecutor executor)
throws SQLException {
executor.startBatch();
int counter = 0;
for (LeagueRelation temp : leagueRelation) {
executor.insert("mergerLeagueRelation",temp);
counter ++ ;
if(counter%10000==0){
executor.executeBatch();
executor.startBatch();
}
}
executor.executeBatch();
return null;
}

});
}
相关标签: ibatis 批量添加