MyBatis流式查询的示例分析

　　介绍

这篇文章主要介绍MyBatis流式查询的示例分析,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!

导读:流式查询指的是查询成功后不是返回一个集合而是返回一个迭代器,应用每次从迭代器取一条查询结果。流式查询的好处是能够降低内存使用

如果没有流式查询,我们想要从数据库取1000年万条记录而又没有足够的内存时,就不得不分页查询,而分页查询效率取决于表设计,如果设计的不好,就无法执行高效的分页查询。因此流式查询是一个数据库访问框架必须具备的功能。
流式查询的过程当中,数据库连接是保持打开状态的,因此要注意的是:执行一个流式查询后,数据库访问框架就不负责关闭数据库连接了,需要应用在取完数据后自己关闭。

MyBatis流式查询接口

MyBatis提供了一个叫org.apache.ibatis.cursor。光标的接口类用于流式查询,这个接口继承了io。Closeable和. lang。Iterable接口,由此可知:

<李>

光标是可关闭的。实际上当关闭光标时,也一并将数据库连接关闭了;

<李>

光标是可遍历的。

除此之外,光标还提供了三个方法:

<李>

isOpen():用于在取数据之前判断光标对象是否是打开状态。只有当打开时光标才能取数据;

<李>

isConsumed():用于判断查询结果是否全部取完;

<李>

getCurrentIndex():返回已经获取了多少条数据。

因为光标实现了迭代器接口,因此在实际使用当中,从游标取数据非常简单:

尝试(Cursor  Cursor =, mapper.querySomeData ()), { 　　,,,cursor.forEach (rowObject →, { 　　,,,,,,,//,… 　　,,,}); 　　}

使用try-resource方式可以令光标自动关闭。
但构建光标的过程不简单
我们举个实际例子。下面是一个Mapper类:

@Mapper 　　public  interface  FooMapper  { 　　,,,@Select (“select  *,得到foo  limit  #{极限}“) 　　,,,Cursor,扫描(@Param (“limit"), int 限制); 　　}

方法扫描()是一个非常简单的查询。我们在定义这个方时,指定返回值为游标类型,MyBatis就明白这个查询方法是一个流式查询。

然后我们再写一个SpringMVC控制器方法来调用映射器(无关的代码已经省略):

@GetMapping (“foo/扫描/0/{极限}“) 　　public  void  scanFoo0 (@PathVariable (“limit"), int 限制),throws  Exception  { 　　,,,try  (Cursor

假设fooMapper是@ autowired进来的。注释1处是获取光标对象并保证它能最后关闭,2处则是从游标中取数据。
上面的代码看上去没什么问题,但是执行scanFoo0 (int)时会报错:

. lang。IllegalStateException:光标已经关闭。

这是因为我们前面说了在取数据的过程中需要保持数据库连接,而Mapper方法通常在执行完后连接就关闭了,因此Cusor也一并关闭了。
所以,解决这个问题的思路不复杂,保持数据库连接打开即可。我们至少有三种方案可选。

方案一:SqlSessionFactory

我们可以用SqlSessionFactory来手工打开数据库连接,将控制器方法修改如下:

@GetMapping (“foo/扫描/1/{极限}“) 　　public  void  scanFoo1 (@PathVariable (“limit"), int 限制),throws  Exception  { 　　,,,try  ( 　　,,,,,,,SqlSession  SqlSession =, sqlSessionFactory.openSession ();,,//1 　　,,,,,,,Cursor, cursor =, 　　,,,,,,,,,,,,,sqlSession.getMapper (FooMapper.class) .scan(限制),,,//2 　　,,,),{ 　　,,,,,,,cursor.forEach (foo →, {,}); 　　,,,} 　　}

上面的代码中,1处我们开启了一个SqlSession(实际上也代表了一个数据库连接),并保证它最后能关闭,2处我们使用SqlSession来获得映射器对象。这样才能保证得到的光标对象是打开状态的。

方案二:TransactionTemplate

在春天中,我们可以用TransactionTemplate来执行一个数据库事务,这个过程中数据库连接同样是打开的。代码如下:

@GetMapping (“foo/扫描/2/{极限}“) 　　public  void  scanFoo2 (@PathVariable (“limit"), int 限制),throws  Exception  { 　　,,,TransactionTemplate  TransactionTemplate =, 　　,,,,,,,,,,,new  TransactionTemplate (transactionManager);,,//1 　　,,,transactionTemplate.execute (status →, {,,,,,,,,,,,,,,//, 2 　　,,,,,,,try  (Cursor

MyBatis流式查询的示例分析