MySQL JDBC配置FetchSize 预防大数据量加载OOM错误

时间 2019-12-06

标签 mysql jdbc 配置 fetchsize 预防数据加载 oom 错误栏目 MySQL 繁體版

原文原文链接

JDBC API里在Connection、Statement和ResultSet上都有设置fetchSize的方法，可是默认状况下：MySQL的JDBC驱动都不支持，不管你怎么设fetchSize，ResultSet都会一次性从Server读取所有数据。java

要使得MySQL的JDBC在查询数据加载时是分批加载（而不是一次加载所有），首先MySQL的JDBC驱动版本至少5.0以上，而后有三种方法能够实现：mysql

方法1：sql

stmt = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY); 
stmt.setFetchSize(Integer.MIN_VALUE);

方法2：服务器

调用statement的enableStreamingResults方法，实际上enableStreamingResults()内部封装的就是【方法1】。fetch

stmt = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY); 
((com.mysql.jdbc.Statement)stmt).enableStreamingResults();

方法3：url

在url中设置链接属性useCursorFetch=true (>=5.0版驱动开始支持)，statement以TYPE_FORWARD_ONLY打开，再设置fetch size参数，表示采用服务器端游标，每次从服务器取fetch_size条数据。code

url = "jdbc:mysql://localhost:3306/db?useCursorFetch=true";

stmt = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY); 
stmt.setFetchSize(x);