Mybatis流式查询

Mybatis流式查询简介

流式查询简介:
   我们将MyBatis返回数据为一个迭代器，这种查询模式称之为“流式查询”
流式查询的返回值：
   使用迭代器逐条的遍历数据

流式查询注意事项:
   流式查询过程中
    数据库连接必须保持一直打开
     并且执行完查询后需要手动的关闭数据库连接

MyBatis流式查询接口

MyBatis提供了
org.apache.ibatis.cursor.Cursor 的接口类用于流式查询
此接口继承了 java.io.Closeable 和 java.lang.Iterable 接口
所以Cursor 是可关闭/遍历的。

 @Mapper
public interface TestMapper {
   @Select("select * from test limit #{limit}")
   Cursor<Test> scan(@Param("limit") int limit);
}


@GetMapping("test/1/{limit}")
public void testFun(@PathVariable("limit") int limit) throws Exception {
   try (
       SqlSession sqlSession = sqlSessionFactory.openSession();  // 1
       Cursor<Test> cursor =
             sqlSession.getMapper(TestMapper.class).scan(limit)   // 2
  ) {
       cursor.forEach(Test -> { });
  }
}
上述代码1位置
  开启一个SqlSession(实际上也代表了一个数据库连接)
  并保证它最后能关闭
  2位置
  使用 SqlSession 来获得 Mapper 对象
  采用以上模式能保证得到的 Cursor 对象是打开状态的。

2.事务控制 TransactionTemplate
在 Spring 中，可以用 TransactionTemplate 来执行一个数据库事务 

@GetMapping("test/2/{limit}")
public void testFun(@PathVariable("limit") int limit) throws Exception {
   TransactionTemplate transactionTemplate =
           new TransactionTemplate(transactionManager);  // 1

   transactionTemplate.execute(status -> {               // 2
       try (Cursor<Test> cursor = TestMapper.scan(limit)) {
           cursor.forEach(test -> { });
      } catch (IOException e) {
           e.printStackTrace();
      }
       return null;
  });
}
上面的代码中1处创建了一个 TransactionTemplate 对象
2处执行数据库事务
而数据库事务的内容则是调用Mapper对象的流式查询
注意这里的 Mapper 对象无需通过 SqlSession 创建

事务控制 @Transactional 注解
这个本质上和方案二一样，代码如下：

@GetMapping("test/3/{limit}")
@Transactional
public void test(@PathVariable("limit") int limit) throws Exception {
   try (Cursor<Test> cursor = TestMapper.scan(limit)) {
       cursor.forEach(test -> { });
  }
}