MySQL JDBC配置FetchSize 預防大數據量加載OOM錯誤

    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);
相關文章
相關標籤/搜索