mybatis批量执行sql的处理 spring boot

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: mybatis批量执行sql的处理 spring boot

前言:

在实际工作中会用到批量执行sql的一些命令,比如说批量的查询处理,批量的插入处理、批量的更新处理处理等等,本次代码主要介绍几种实际工作当中的解决办法。

批量的查询:

关于循环查询的方式,使用in方式

<foreach collection="ids" item="id" open="and business_id in (" separator="," close=")">

  #{id}

</foreach>

里面的变量,ids代表是一个list的string类型的,id代表循环里面的自定义变量。and business_id代表的是查询语句里面的sql语句。

在可以确定查询的id是多条的情况下,比如说可能是10条以上的话,最好的方式进行in的方式进行查询,避免打开或者关闭数据库的时候浪费大量的时间。


<select id="queryExpandFormExtByBusinessIds" parameterType="java.util.Map" resultType="com.iss.cms.fdrb.common.dao.entity.ExpandFormExt">

  select

  <include refid="expandColumn"/>

  from t_fdrb_expand_form_ext${tableNo} expand

  <where>

     expand.tenant_id = #{tenantId}

     <!--         <if test="templateCode!=null and templateCode!=''">-->

     <!--            template_code = #{templateCode}-->

     <!--         </if>-->

     <foreach collection="ids" item="id" open="and business_id in (" separator="," close=")">

        #{id}

     </foreach>

  </where>

</select>


需要特别注意下,这个传参不是实体类而是一个Map类型的,所以在定义方法的时候,要定义这个类型的

/**

* @Project:根据业务id查询拓展字段数据

* @Module: com.iss.cms.tshd

* @Deion:

* @author: hycaid

* @date: 2021/4/22 10:22

*/

List queryExpandFormExtByBusinessIds(List ids);

具体的实现类型是这样的,使用Map进行参数的传值

@Override

public List<ExpandFormExt> queryExpandFormExtByBusinessIds(List<String> ids) {

  ExpandFormExt expandFormExt = new ExpandFormExt();

  Map map=new HashMap<>();

  map.put("ids",ids);

  map.put("tenantId",expandFormExt.getTenantId());

  map.put("tableNo",expandFormExt.getTableNo());

  return this.sqlSessionTemplate.selectList(NAMESPACE + "queryExpandFormExtByBusinessIds", map);

}

通过实现的方式可以看出来,这个map进行动态的赋值操作,比如说,进行三个参数的传参处理。

批量的插入处理:

批量插入的处理代码,sql语句如下:

<!-- 批量插入记录mysql -->

<insert id="insertBatchContractBalanceByMysql"  parameterType="java.util.Map" >

insert into t_fdrb_bl_contract_balance${tableNo}(

      id,

      create_by_code,

      create_by_name,

      create_time,

      update_by_code,

      update_by_name,

      update_time,

      data_version,

      data_status,

      contract_code,

      contract_id,

      loan_date,

      balance,

      contract_type,

     loan_org_id,

     loan_org_code,

     loan_org_name,

     currency_name,

     currency_type,

     tenant_id

)

values

  <foreach collection ="list" item="item" separator =",">

     (#{item.id},

     #{item.createByCode},

     #{item.createByName},

     #{item.createTime},

     #{item.updateByCode},

     #{item.updateByName},

     #{item.updateTime},

     #{item.dataVersion},

     #{item.dataStatus},

     #{item.contractCode},

     #{item.contractId},

     #{item.loanDate},

     #{item.balance},

     #{item.contractType},

     #{item.loanOrgId},

     #{item.loanOrgCode},

     #{item.loanOrgName},

     #{item.currencyName},

     #{item.currencyType},

     #{item.tenantId})

  </foreach >


</insert>

对应的接口定义如下:

@Override

public void insertBatchContractBalanceByMysql(List<ContractBalance> list) {

  ContractBalance contractBalance = new ContractBalance();

  Map map = new HashMap<>();

  map.put("tableNo",contractBalance.getTableNo());

  map.put("list",list);

  this.sqlSessionTemplate.insert(NAMESPACE + "insertBatchContractBalanceByMysql", map);

}

批量的更新处理:

这一部分的内容,可以参考批量的查询处理,由于更新都是根据多个条件进行更新的。

最后总结:

通过上面的两段代码可以看出来,整个map的集合,然后map的第二个key、value传值的是一个list的集合,而不是实体类的形式,这样通过sql拼接的方式实现插入的处理,避免存在多条插入语句异常导致的部分插入失败的情况。

通过上面的两个例子可以延申出来,更新的时候也可以使用拼接sql的形式进行批量更新的操作。

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
19天前
|
SQL Java 数据库连接
对Spring、SpringMVC、MyBatis框架的介绍与解释
Spring 框架提供了全面的基础设施支持,Spring MVC 专注于 Web 层的开发,而 MyBatis 则是一个高效的持久层框架。这三个框架结合使用,可以显著提升 Java 企业级应用的开发效率和质量。通过理解它们的核心特性和使用方法,开发者可以更好地构建和维护复杂的应用程序。
109 29
|
30天前
|
SQL Java 数据库连接
【潜意识Java】MyBatis中的动态SQL灵活、高效的数据库查询以及深度总结
本文详细介绍了MyBatis中的动态SQL功能,涵盖其背景、应用场景及实现方式。
99 6
|
30天前
|
前端开发 Java 数据库连接
Java后端开发-使用springboot进行Mybatis连接数据库步骤
本文介绍了使用Java和IDEA进行数据库操作的详细步骤,涵盖从数据库准备到测试类编写及运行的全过程。主要内容包括: 1. **数据库准备**:创建数据库和表。 2. **查询数据库**:验证数据库是否可用。 3. **IDEA代码配置**:构建实体类并配置数据库连接。 4. **测试类编写**:编写并运行测试类以确保一切正常。
55 2
|
1月前
|
SQL JavaScript Java
Spring Boot 3 整合 Mybatis-Plus 实现数据权限控制
本文介绍了如何在Spring Boot 3中整合MyBatis-Plus实现数据权限控制,通过使用MyBatis-Plus提供的`DataPermissionInterceptor`插件,在不破坏原有代码结构的基础上实现了细粒度的数据访问控制。文中详细描述了自定义注解`DataScope`的使用方法、`DataPermissionHandler`的具体实现逻辑,以及根据用户的不同角色和部门动态添加SQL片段来限制查询结果。此外,还展示了基于Spring Boot 3和Vue 3构建的前后端分离快速开发框架的实际应用案例,包括项目的核心功能模块如用户管理、角色管理等,并提供Gitee上的开源仓库
247 11
|
2月前
|
SQL XML Java
mybatis实现动态sql
MyBatis的动态SQL功能为开发人员提供了强大的工具来应对复杂的查询需求。通过使用 `<if>`、`<choose>`、`<foreach>`等标签,可以根据不同的条件动态生成SQL语句,从而提高代码的灵活性和可维护性。本文详细介绍了动态SQL的基本用法和实际应用示例,希望对您在实际项目中使用MyBatis有所帮助。
102 11
|
2月前
|
缓存 Java 数据库连接
深入探讨:Spring与MyBatis中的连接池与缓存机制
Spring 与 MyBatis 提供了强大的连接池和缓存机制,通过合理配置和使用这些机制,可以显著提升应用的性能和可扩展性。连接池通过复用数据库连接减少了连接创建和销毁的开销,而 MyBatis 的一级缓存和二级缓存则通过缓存查询结果减少了数据库访问次数。在实际应用中,结合具体的业务需求和系统架构,优化连接池和缓存的配置,是提升系统性能的重要手段。
147 4
|
2月前
|
SQL Java 数据库连接
spring和Mybatis的各种查询
Spring 和 MyBatis 的结合使得数据访问层的开发变得更加简洁和高效。通过以上各种查询操作的详细讲解,我们可以看到 MyBatis 在处理简单查询、条件查询、分页查询、联合查询和动态 SQL 查询方面的强大功能。熟练掌握这些操作,可以极大提升开发效率和代码质量。
166 3
|
3月前
|
SQL Java 数据库连接
canal-starter 监听解析 storeValue 不一样,同样的sql 一个在mybatis执行 一个在数据库操作,导致解析不出正确对象
canal-starter 监听解析 storeValue 不一样,同样的sql 一个在mybatis执行 一个在数据库操作,导致解析不出正确对象
|
3月前
|
Java 数据库连接 数据库
spring和Mybatis的逆向工程
通过本文的介绍,我们了解了如何使用Spring和MyBatis进行逆向工程,包括环境配置、MyBatis Generator配置、Spring和MyBatis整合以及业务逻辑的编写。逆向工程极大地提高了开发效率,减少了重复劳动,保证了代码的一致性和可维护性。希望这篇文章能帮助你在项目中高效地使用Spring和MyBatis。
112 1
|
3月前
|
SQL 缓存 Java
【详细实用のMyBatis教程】获取参数值和结果的各种情况、自定义映射、动态SQL、多级缓存、逆向工程、分页插件
本文详细介绍了MyBatis的各种常见用法MyBatis多级缓存、逆向工程、分页插件 包括获取参数值和结果的各种情况、自定义映射resultMap、动态SQL
【详细实用のMyBatis教程】获取参数值和结果的各种情况、自定义映射、动态SQL、多级缓存、逆向工程、分页插件