MaBatis:动态SQL使用foreach进行批量删除

简介: MaBatis:动态SQL使用foreach进行批量删除

foreach可以在SQL语句中通过拼接的方式进行集合迭代。foreach元素的属性主要有collection,item,index,separator,open,close。

        1.  item属性:表示循环体中的具体对象,即集合中每一个元素进行迭代时的别名。

       具体说明:item支持属性的点路径访问,如item.age,item.info.details。在list和数组中是其中的对象,在map中是value。该参数为必选。

       2.  index属性:指定一个名字,用于表示在迭代过程中,每次迭代到的位置。

       具体说明:在list和数组中,index是元素的序号,在map中,index是元素的key,该参数可选。

       3.  separator属性:表示在每次进行迭代之间以什么符号作为分隔符。

       具体说明:例如在in()的时候,separator=","会自动在元素中间用“,“隔开,避免手动输入逗号导致sql错误,如in(1,2,)这样。该参数可选。

       4.  open属性:foreach代码的开始符号,表示该语句以什么开始。

       具体说明:一般是"(“和close=”)"合用。常用在in(),values()时。该参数可选。

       5.  close属性:foreach代码的结束符号,表示该语句以什么结束。

       具体说明:一般是")“和open=”("合用。常用在in(),values()时。该参数可选。

       6.  collection属性:foreach传入的对象参数。

       具体说明:该参数必选。在不同情况下,该属性的值是不一样的,主要有一下3种情况:

             a. 如果传入的是单参数且参数类型是一个List的时候,collection属性值为list ;

             b. 如果传入的是单参数且参数类型是一个array数组的时候,collection的属性值为array ;

             c. 如果传入的参数是多个的时候,我们就需要把它们封装成一个Map了,当然单参数也可以封装成map。实际上在传入参数的时候,框架也会把它封装成一个Map的,map的key就是参数名,这个时候collection属性值就是传入的List或array对象在自己封装的map里面的key。

使用foreach进行批量删除的映射文件示范如下:

常用的批量删除语句: in 语句

<delete id="deleteByIds"  parameterType="java.util.List">
        delete from STOREROOM_REPERTORY where UUID in
        <foreach collection="list" item="item" separator="," open="(" close=")">
            #{item.uuid}
        </foreach>
    </delete>

2.  遇到 某张表 是联合主键的,批量删除 用 in 就不合适了

解决办法:在 where 后面 用 or 循环拼装

<delete id="deleteByIds" parameterType="java.util.ArrayList">
    delete from STOREROOM_REPERTORY where
    <foreach collection="list" item="item" index="index" separator="or">
      ( id=#{item.uuid} and month = #{item.month} )
    </foreach>
  </delete>

DAO数据层

 

int deleteByIds(@Param("list") List<StoreroomRepertory> uuid);


service业务层

 

@Transactional(readOnly = false)
    @Override
    public int deleteByIds(List<StoreroomRepertory> uuid) {
        try {
            int batchCount = 50;//每批commit的个数
            int batchLastIndex = batchCount - 1;//每批最后一个的下标
            for(int index = 0; index < uuid.size()-0;){
                if(batchLastIndex > uuid.size()-1){
                    batchLastIndex = uuid.size();
                    storeroomRepertoryDao.deleteByIds(uuid.subList(index, batchLastIndex));
                    System.out.println("index:"+index+"     batchLastIndex:"+batchLastIndex);
                    break;//数据插入完成,退出循环
                }else{
                    storeroomRepertoryDao.deleteByIds(uuid.subList(index, batchLastIndex));
                    System.out.println("index:"+index+"     batchLastIndex:"+batchLastIndex);
                    index = batchLastIndex;//设置下一批下标
                    batchLastIndex = index + (batchCount - 1);
                    if(index==uuid.size()-1){
                        storeroomRepertoryDao.deleteByIds(uuid.subList(index, index+1));
                    }
                }
            }
        }catch(Exception e){
            //事务回滚
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            // 设置回滚点
            Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
            // 回滚到 savePoint
            TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
            log.error("批量异常捕获",e);
            e.printStackTrace();
        }
        return 1;
    }
 controller控制层
    @RequestMapping(value = "deleteByIds",method = RequestMethod.POST)
    @ApiOperation(value = "批删")
    public PmpResult deleteByIds(@RequestBody List<StoreroomRepertory> uuid){
        try {
            storeroomRepertoryService.deleteByIds(uuid);
            logger.info("删除成功");
            return PmpResult.success(uuid);
        } catch (Exception e) {
            logger.error(e.getMessage(), e);
            String errorMessage = "异常删除调用";
            if (isDev) {
                errorMessage = e.getMessage();
            }
            return PmpResult.paramError(errorMessage);
        }
    }
目录
相关文章
|
23天前
|
SQL Java 编译器
SQL 语言:嵌入式 SQL 和动态 SQL
SQL 语言:嵌入式 SQL 和动态 SQL
25 4
|
4天前
|
SQL XML 数据库
后端数据库开发高级之通过在xml文件中映射实现动态SQL
后端数据库开发高级之通过在xml文件中映射实现动态SQL
12 3
|
23天前
|
SQL XML Java
MyBatis第四课动态SQL
MyBatis第四课动态SQL
|
23天前
|
SQL 存储 关系型数据库
17. Mysql 动态SQL
17. Mysql 动态SQL
16 1
|
4天前
|
SQL Java 数据库连接
Mybatis动态SQL语句总结
Mybatis动态SQL语句总结
|
7天前
|
SQL Java 数据库连接
【MyBatis】MyBatis操作数据库(二):动态SQL、#{}与${}的区别
【MyBatis】MyBatis操作数据库(二):动态SQL、#{}与${}的区别
14 0
|
10天前
|
SQL Java 数据库连接
JavaWeb基础第三章(MyBatis的应用,基础操作与动态SQL)
JavaWeb基础第三章(MyBatis的应用,基础操作与动态SQL)
|
10天前
|
SQL IDE Java
Java连接SQL Server数据库的详细操作流程
Java连接SQL Server数据库的详细操作流程
|
18天前
|
SQL DataWorks NoSQL
DataWorks产品使用合集之如何将SQL Server中的数据转存到MongoDB
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
244 1
|
2天前
|
SQL 关系型数据库 分布式数据库
PolarDB产品使用问题之如何迁移SQL Server
PolarDB产品使用合集涵盖了从创建与管理、数据管理、性能优化与诊断、安全与合规到生态与集成、运维与支持等全方位的功能和服务,旨在帮助企业轻松构建高可用、高性能且易于管理的数据库环境,满足不同业务场景的需求。用户可以通过阿里云控制台、API、SDK等方式便捷地使用这些功能,实现数据库的高效运维与持续优化。