MyBatis 批量插入和批量删除
利用集合保存批处理数据,再利用批处理sql(使用foreach进行遍历)一次性完成操作。
- 无法获取插入数据的id,如果要通过id做后续处理就不合适了
- 批量生成的sql太长,可能会被服务器拒绝(解决方案:可以采用分段形式,比如要导入100w条数据,可以通过for循环二次嵌套完成,一次导入1w条)
批量新增
1,xml进行配置
<!-- INSERT INTO table-->
<!-- VALUES ("a1","a2","a3"),("b1","b2","b3"),(...)-->
<!--批量新增-->
<!--因为批处理是一次性导入多条,所以这里使用list-->
<!--foreach类似for循环 collection:迭代的数据源,固定写入list,表示从外界传入的list集合 ,item;循环中的迭代变量
,item:索引,类似于数字,seperator:分割符号-->
<insert id="batchInsert" parameterType="java.util.List">
insert into t_goods(title,sub_title,original_cost,current_price,discount,is_free_delivery,category_id)
values
<foreach collection="list" item="item" index="index" separator=",">
(#{item.title},#{item.subTitle},#{item.originalCost},#{item.currentPrice},#{item.discount},#{item.isFreeDelivery},#{item.categoryId})
</foreach>
</insert>
@Test
public void testBatchInsert() {
SqlSession sqlSession = null;
try {
sqlSession = MyBatisUtils.openSession();
List<Goods> good = new ArrayList<>();
for (int i = 0; i < 10000; i++) {
Goods goods = new Goods();
goods.setTitle("测试商品6");
goods.setSubTitle("测试商品666");
goods.setCategoryId(111);
goods.setOriginalCost(1000f);
goods.setIsFreeDelivery(1);
goods.setDiscount(2f);
goods.setCurrentPrice(300f);
good.add(goods);
}
sqlSession.insert("goods.batchInsert",good);
sqlSession.commit();
} catch (Exception e) {
if (sqlSession != null) {
sqlSession.rollback();
}
throw e;
} finally {
MyBatisUtils.closeSqlSession(sqlSession);
}
}
批量删除
在MySQL中使用ID从表中删除许多行
最好的方法是使用IN语句:
DELETE from tablename WHERE id IN (1,2,3,...,254);
BETWEEN如果您有连续的ID,也可以使用:
DELETE from tablename WHERE id BETWEEN 1 AND 254;
您当然可以使用其他WHERE子句来限制某些ID:
DELETE from tablename WHERE id BETWEEN 1 AND 254 AND id<>10;
<!-- DELETE FROM table where goods_id in(a,b)-->
<!--批量删除-->
<!--这里只需要传入item即可,因为它只是goods编号-->
<!--open和close指代删除语句in后面的左右括号-->
<delete id="batchDelete" parameterType="java.util.List">
delete from t_goods where goods_id in
<foreach collection="list" item="item" index="index" open="(" close=")" separator=",">
(#{item})
</foreach>
</delete>
@Test
public void testBatchDelete() {
List<Integer> good = new ArrayList<>();
good.add(32680);
good.add(32682);
good.add(32683);
good.add(32684);
try {
sqlSession.delete("goods.batchDelete",good);
sqlSession.commit();
} catch (Exception e) {
e.printStackTrace();
sqlSession.rollback();
}
}