mybatis cursor游标查询
·
在大数量查询处理时,为了避免出现OOM,可以采用cursor查询
1、dao层
import org.apache.ibatis.cursor.Cursor; //导包
//接口
Cursor<ROIReport> queryROIReportsCursor(ROIReportQuery params);
<select id="queryROIReportsCursor" resultType="com.xxx.ROIReport">
xxxxxxxxx对应自己的查询语句
</select>
service层
//service接口
Cursor<ROIReport> queryROIReportsCursor(ROIReportQuery params);
//serviceImpl
@Override
public Cursor<ROIReport> queryROIReportsCursor(ROIReportQuery params) {
return salesMarketsMapper.queryROIReportsCursor(params);
}
controller层
//记得加上事务,不然游标在查询完就会关闭,报错
@ResponseBody
@PostMapping("roiReportExport")
@Transactional(readOnly = true)
public void roiReportCursor(@RequestBody @Valid ROIReportParams params) throws ParseException {
ROIReportQuery roiReportQuery = roiReportParams.toROIReportQuery();
try (Cursor<ROIReport> roiReports = salesMarketsReportService.queryROIReportsCursor(roiReportQuery)) {
Iterator<ROIReport> iterator = roiReports.iterator();
while (iterator.hasNext()) {
ROIReport next = iterator.next();
System.out.println(next.getMarketName());
System.out.println(next.getId());
//xxxx自己业务逻辑
}
} catch (Exception e) {
System.out.println(e);
}
}
使用cursor一定要加上事务,不然会报错:java.lang.IllegalStateException: A Cursor is already closed.
魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。
更多推荐


所有评论(0)