mybatis批量操作
批量操作介绍
默认的 openSession() 方法没有参数,它会创建有如下特性的
- 会开启一个事务(也就是不自动提交)
- 连接对象会从由活动环境配置的数据源实例得到。
- 事务隔离级别将会使用驱动或数据源的默认设置。
- 预处理语句不会被复用,也不会批量处理更新。
openSession 方法的 ExecutorType 类型的参数,枚举类型:
- ExecutorType.SIMPLE: 这个执行器类型不做特殊的事情(这是默认装配的)。它为每个语句的执行创建一个新的预处理语句。
- ExecutorType.REUSE: 这个执行器类型会复用预处理语句。
- ExecutorType.BATCH: 这个执行器会批量执行所有更新语句
|
|
批量操作我们是使用MyBatis提供的BatchExecutor进行的,它的底层就是通过jdbc攒sql的方式进行的。我们可以让他攒够一定数量后发给数据库一次。
示例程序
|
|
注意:
- 批量操作是在session.commit()以后才发送sql语句给数据库进行执行的
- 如果我们想让其提前执行,以方便后续可能的查询操作获取数据,我们可以使用sqlSession.flushStatements()方法,让其直接冲刷到数据库进行执行。
运行结果:
|
|
我们使用批量操作BatchExecutor
|
|
运行结果:
|
|
对比:
-
非批量
预编译sql -> 设置参数 -> 数据库执行 各10000次 65秒
-
批量
预编译sql一次 -> 设置参数 10000次 -> 数据库执行(5秒)
与spring整合
与Spring整合中,我们推荐,额外的配置一个可以专门用来执行批量操作的SqlSession
|
|
需要用到批量操作的时候,我们可以注入配置的这个批量SqlSession。通过他获取到mapper映射器进行操作。
|
|
注意:DefaultSqlSession是线程不安全的,SqlSessionTemplate是线程安全的
-
DefaultSqlSession的内部没有提供像SqlSessionManager一样通过ThreadLocal的方式来保证线程的安全性;
-
SqlSessionManager是通过localSqlSession这个ThreadLocal变量,记录与当前线程绑定的SqlSession对象,供当前线程循环使用,从而避免在同一个线程多次创建SqlSession对象造成的性能损耗;
-
mybatis-spring框架中没有直接使用线程安全的SqlSessionManager(SqlSessionFactory它是线程安全的)而是使用DefaultSqlSession这个线程不安全的类,并通过动态代理的方式来保证DefaultSqlSession操作的线程安全性
-
SqlSessionManager和SqlSessionTemplate的区别
SqlSessionManager和SqlSessionTemplate都可以作SqlSession,并且在各自类里都对SqlSession做了动态代理。区别是SqlSessionTemplate的动态代理更高效(有SqlSession的引用计数),并且有对Spring框架的配合。动态代理的实现不容易复用,所以干脆分开,做到低耦合。