Mybatis游标查询

通常对一张表中大量数据处理时由于数据量太大都要使用分页分批查询处理，否则数据量太大会导致OOM等问题，但是如果不能使用分页时怎么进行处理，这是后就要使用Mybatis游标Cursor查询

原理

Cursor实现了Closeable和Iterable接口，我们可以通过迭代器来获取数据进行处理

示例

查询语句

在Mapper上写上对应的查询语句

//PriceIndexEntity是查出的实体对象
//ResultSetType表示游标的滚动模式 resultSetType = ResultSetType.FORWARD_ONLY 只能向前滚动
//fetchSize表示每次执行的记录数 fetchSize = Integer.MIN_VALUE
public interface CursorDemoMapper extends BaseMapper<PriceIndexEntity> {@Options(resultSetType = ResultSetType.FORWARD_ONLY, fetchSize = Integer.MIN_VALUE)@Select("select * from t_scf_price_index ")Cursor<PriceIndexEntity> scrollResult();
}

业务处理

public class DemoService implements IBusinessService{@ResourceSqlSessionFactory sqlSessionFactory;@Overridepublic void doVerify(ServiceHandlerContext context) {}@Overridepublic void doWork(ServiceHandlerContext context) {try(    //对应mysql数据库不会自动开启连接  所以需要手动开启连接，执行完成后自动关闭连接SqlSession sqlSession=sqlSessionFactory.openSession();//2、在连接中开启游标查询Cursor<PriceIndexEntity> priceIndexEntities = sqlSession.getMapper(CursorDemoMapper.class).scrollResult();) {//buffer的大小建议设置在1000左右。AtomicInteger index= new AtomicInteger(1);int bufferSize=1000;List<PriceIndexEntity> buffer =new ArrayList<>(bufferSize);priceIndexEntities.forEach(priceIndexEntity -> {//将查出的数据放到buffer中buffer.add(priceIndexEntity);if(index.getAndIncrement() ==bufferSize){//业务处理doPartWork(buffer);buffer.clear();index.set(1);}});//处理最后不足1000的数据if(buffer.size()>0){doPartWork(buffer);}} catch (IOException e) {log.error("XXX查询异常：【{}】",e.getMessage(),e);}ServiceHandlerContextExt.createSuccessResponseWithMsg(this,context,"sd");}public void doPartWork(List<PriceIndexEntity> buffer){//业务处理       System.out.println("================================="+buffer.size());}

Mybatis游标Cursor查询相关推荐

mybatis 游标查询_数据库游标(示例代码)
游标实际上是一种能从包括多条数据记录的结果集中每次提取一条记录的机制.游标充当指针的作用.尽管游标能遍历结果中的所有行,但他一次只指向一行. 概括来讲,SQL的游标是一种临时的数据库对象,即可以用来存 ...
还在用分页？你out了！试试 MyBatis 流式查询，真心强大！
欢迎关注方志朋的博客,回复"666"获面试宝典基本概念流式查询指的是查询成功后不是返回一个集合而是返回一个迭代器,应用每次从迭代器取一条查询结果.流式查询的好处是能够降低内存使 ...
还在用分页？太Low ！试试 MyBatis 流式查询，真心强大！
以下文章来源方志朋的博客,回复"666"获面试宝典基本概念流式查询指的是查询成功后不是返回一个集合而是返回一个迭代器,应用每次从迭代器取一条查询结果.流式查询的好处是能够降低内 ...
强大：MyBatis 流式查询
点击上方蓝色"方志朋",选择"设为星标" 回复"666"获取独家整理的学习资料! ‍基本概念流式查询指的是查询成功后不是返回一个集合而是返 ...
mongodb3.2系统性学习——5、游标模糊查询 findAndModify函数
1首先介绍查询结果返回的过程: 进行查询的时候mongodb 并不是一次哪个返回结果集合的所有文档,而是以多条文档的形式分批返回查询的结果,返回文档到内存中. 好处: 减少了客户端与服务器端的查询负 ...
MyBatis 流式查询
基本概念流式查询指的是查询成功后不是返回一个集合而是返回一个迭代器,应用每次从迭代器取一条查询结果.流式查询的好处是能够降低内存使用. 如果没有流式查询,我们想要从数据库取 1000 万条记录而又没 ...
SQL Server 数据库的维护(四)__游标(cursor)
--维护数据库-- --游标(cursor)-- --概述: 注:使用select语句查询结果的结果集是一个整体,如果想每次处理一行或一部分行数据,游标可以提供这种处理机制.可以将游标理解为指针.指针 ...
mybatis删除成功返回0_你还在用分页？试试 MyBatis 流式查询，真心强大！
转自:捏造的信仰 segmentfault.com/a/1190000022478915 基本概念流式查询指的是查询成功后不是返回一个集合而是返回一个迭代器,应用每次从迭代器取一条查询结果.流式查询 ...
PLSQL 循环游标 cursor loop fetch into
PLSQL 循环游标 cursor 的一点心得体会 set serveroutput on---------------打印输出信息,默认是FALSE declare ---------------- ...
Oracle中游标Cursor介绍
转自:http://zohan.group.iteye.com/group/wiki/2278-cursor Oracle中游标Cursor介绍一概念游标是SQL的一个内存工作区,由系统或用户 ...

Mybatis游标Cursor查询

Mybatis游标查询

原理

示例

查询语句

业务处理

Mybatis游标Cursor查询相关推荐

最新文章

热门文章