mybatis cursor

MyBatis中的Cursor是一种特殊的查询方式，它可以逐行地从数据库中获取查询结果，而不是一次性将所有结果加载到内存中。这样可以减少内存的占用，特别适用于查询大量数据时。

在使用Cursor进行查询时，只需要在映射接口中标明返回值类型是Cursor<T>即可。例如，可以使用Cursor<User> queryUserBySchoolName(User user)方法来查询用户信息。

CursorStatus是一个枚举类，用于表示游标的状态。它具有四个值：CREATED（新创建，结果集尚未消费）、OPEN（正在被使用中，结果集正在被消费）、CLOSED（已经被关闭，但结果集未被完全消费）、CONSUMED（结果集已被完全消费）。这些状态可以帮助我们了解游标的当前状态。

DefaultCursor是MyBatis中默认的游标实现类。它继承了Cursor接口，并实现了Closeable和Iterable接口。因此，DefaultCursor必须实现这三个接口定义的所有方法。

总之，MyBatis的Cursor功能可以帮助我们逐行处理大量的查询结果，减少内存占用，提高查询性能。

相关问题

mybatis cursor 异常

MyBatis中的Cursor异常通常是由于查询结果集较大而导致的。当我们使用Cursor方式获取结果时，查询结果并不会立即全部加载到内存中，而是通过游标逐条获取，这样可以减少内存的占用。但是，如果结果集过大或者数据库连接不稳定，就可能导致Cursor异常。

常见的Cursor异常包括IO异常、资源关闭异常等。这些异常通常是由于网络连接中断、数据库连接超时等原因引起的。当出现异常时，MyBatis会尝试关闭相关资源，但有时候可能没有完全成功，导致资源泄漏或其他异常。

解决Cursor异常可以采取以下方法：
1. 增加数据库连接超时时间，可以通过在MyBatis配置文件中设置合理的timeout属性来实现。
2. 检查网络连接是否稳定，确保与数据库的网络连接正常。
3. 优化查询语句，尽量减少返回结果集的大小，可以通过限制查询条件、使用分页查询等方式来减小结果集大小。
4. 检查代码中是否正确关闭了数据库连接和游标，确保资源在使用完毕后正确释放。
5. 更新MyBatis版本，可能某些版本中已经修复了Cursor相关的bug。

总之，MyBatis Cursor异常是在处理大数据量查询时可能遇到的问题，需要注意配置和编码规范，保证数据库连接稳定性和资源释放的正确性，以解决该异常。

Mybatis Cursor fetchSize

### MyBatis 中使用 Cursor 的 `fetchSize` 属性

为了优化查询性能，在 MyBatis 中可以配置 `fetchSize` 参数来控制数据库驱动程序每次从服务器获取的数据行数。对于大规模数据集，适当设置此参数能够显著减少内存占用并提高效率。

#### 设置 Fetch Size 方法

当定义 SQL 映射语句时，可以通过 XML 或者注解方式指定 `fetchSize` 值：

- **XML 方式**

通过 `<select>` 标签中的属性直接设定:

<select id="findUsers" parameterType="int" resultMap="userResultMap" fetchSize="100">
    SELECT * FROM users WHERE status = #{status}
</select>

- **注解方式**

利用 Java 注解的形式应用到接口方法上:

@Select("SELECT * FROM users WHERE status=#{status}")
@Options(fetchSize=100)
List<User> findUsers(@Param("status") int userStatus);

以上两种情况下都将 `fetchSize` 设定为 100 行记录[^4]。

#### 流式查询与游标的结合

除了简单的批量读取外，还可以采用更高效的流式处理模式——即基于 JDBC 游标的实现。这允许逐条而不是一次性加载全部结果集进入 JVM 内存空间内。具体做法如下所示：

// Mapper 接口声明
public interface UserMapper {
    @Select("SELECT * FROM users ORDER BY id")
    @Options(fetchSize=Integer.MIN_VALUE, useCache=false, flushCache=true)
    Cursor<User> selectAllAsStream();
}

// Service 实现类调用
try (Cursor<User> cursor = mapper.selectAllAsStream()) {
    while (cursor.hasNext()) {
        User user = cursor.next();
        process(user); // 处理单个对象逻辑
    }
} catch (Exception e) {
    log.error(e.getMessage(), e);
}

这里特别指出的是将 `fetchSize` 赋予最小整数值 (`Integer.MIN_VALUE`) 可触发某些数据库连接器启用游标机制[^3]。

#### 性能优化建议

- 对于非常大的表操作，推荐优先尝试调整合适的 `fetchSize` 数值；
- 如果遇到内存溢出等问题，则应考虑改用游标形式做增量迭代访问；
- 尽可能避免不必要的字段检索，仅选取所需列可降低网络传输开销；
- 合理规划索引结构有助于加速特定条件下的扫描速度。