Mybatis如何使用游标呢?
下文笔者讲述Mybatis中使用游标的方法分享,如下所示
游标简介
游标(Cursor): 处理数据的一种方法 查看或处理结果集中的数据 游标提供在结果集中一次一行或 多行前进或向后浏览数据的能力例:
// 第一种 @Options(ResultSetType = ResultSetType.FORWARD_ONLY) @Select("SELECT * FROM users WHERE status = 0") list<UserEntity> queryUserAll(); // 第二种 在Mybatis-3.4.0版本中,不支持@select注解,在3.4.1版本中已经修复: @Options(resultSetType = ResultSetType.FORWARD_ONLY) @Select("SELECT * FROM users WHERE status = 0") Cursor<Employee> cursorQueryUserAll(); @Service public class UserServiceImpl implements UserService { private static final Logger LOG = LoggerFactory.getLogger(UserServiceImpl.class); @Autowired private UserDao userDao; @Autowired private SqlSessionTemplate sqlSessionTemplate; public List<UserDTO> getUserList(UserSearchParam param) { Cursor<Object> cursor = null; SqlSession sqlSession = null; try { sqlSession = sqlSessionTemplate.getSqlSessionFactory().openSession(); cursor = sqlSession.selectCursor(UserDao.class.getName() + ".queryUserAll"); cursor.forEach(e -> { // 处理逻辑 }); // 也可以使用迭代器:Iterator<Object> iterator = cursor.iterator(); } catch (Exception e) { e.printStackTrace(); } finally { if (null != cursor) { try { cursor.close(); } catch (Exception e) { LOG.error(e.getMessage(), e); } } if (null != sqlSession) { try { sqlSession.close(); } catch (Exception e) { LOG.error(e.getMessage(), e); } } } } }
各参数说明: ResultSet.TYPE_FORWORD_ONLY: 结果集的游标只能向下滚动。 ResultSet.TYPE_SCROLL_INSENSITIVE: 结果集的游标可以上下移动, 当数据库变化时,当前结果集不变 ResultSet.TYPE_SCROLL_SENSITIVE: 返回可滚动的结果集,当数据库变化时,当前结果集同步改变 注意事项: 游标是可以前后移动的 当resultSetType = TYPE_SCROLL_INSENSITIVE,就是设置游标就可以前后移动 Mybatis为了保证可以前后移动,Mybatis会把之前查询的数据一直保存在内存中 所以不能彻底解决OOM的异常,所以我们这里需要设置为@Options(resultSetType = ResultSetType.FORWARD_ONLY) (其实默认就是ResultSetType.FORWARD_ONLY) 来解决内存占用过大的问题
版权声明
本文仅代表作者观点,不代表本站立场。
本文系作者授权发表,未经许可,不得转载。