Java SQL查詢內存泄漏

Question

我有一個應用程序遍歷一定數量的resultSets並查詢來自其他表的每一行的附加信息。

粗糙的結構是這樣的：

public void main(String[] args) { 
    ResultSet result = database.connection.createStatement() 
          .executeQuery("SELECT * FROM entities"); 
    ArrayList<Entity> entities = new ArrayList<Entity>(); 
    while (result.next() { 
     Entity entity = EntityFactory.createById(result.getInt("id")); 
     entities.add(entity); 
    } 
} 

// EntityFactory 
public static Entity createById(int id) { 
    StringBuilder sql = new StringBuilder("SELECT * FROM sampling_data WHERE id = ") 
          .append(id); 
    ResultSet result = database.connection.createStatement() 
          .executeQuery(sql.toString()); 
    result.first(); 
    EntityData data = new EntityData(25); 

    for (int sample = 1; sample <= 25; sample++) { 
     String sample_R = new StringBuilder("sample_") 
           .append(sample).append("_R").toString(); 
     String sample_G = new StringBuilder("sample_") 
           .append(sample).append("_G").toString(); 
     String sample_B = new StringBuilder("sample_") 
           .append(sample).append("_B").toString(); 

     int r = resultSet.getInt(sample_R); 
     int g = resultSet.getInt(sample_G); 
     int b = resultSet.getInt(sample_B); 

     data.add(r, g, b); 
    } 

    return new Entity(data); 
} 

這會導致OutOfMemoryException異常。

我該如何讓循環（或整個方法）更高效地存儲內存？

Answer 1

最大的問題是（我認爲）createById沒有關閉結果集和語句。 此外，沒有nx1查詢是有意義的。

try { 
     Statement stmt = database.connection.createStatement(); 
     ResultSet result = stmt.executeQuery("SELECT * FROM sampling_data d" 
      + " WHERE EXISTS(SELECT * FROM entities e WHERE e.id = d.id)"); 
     List<Entity> entities = new ArrayList<Entity>(); 
     while (result.next()) { 
      Entity entity = EntityFactory.createById(result); 
      entities.add(entity); 
     } 
     result.close(); 
     stmt.close(); 
    } catch (SQLException ex) { 
     Logger.getLogger(Test1.class.getName()).log(Level.SEVERE, null, ex); 
    } 

而且

// EntityFactory 
public static Entity createById(ResultSet resultSet) { 
    EntityData data = new EntityData(25); 
    for (int sample = 1; sample <= 25; sample++) { 
     String sample_R = new StringBuilder("sample_").append(sample).append("_R").toString(); 
     String sample_G = new StringBuilder("sample_").append(sample).append("_G").toString(); 
     String sample_B = new StringBuilder("sample_").append(sample).append("_B").toString(); 
     int r = resultSet.getInt(sample_R); 
     int g = resultSet.getInt(sample_G); 
     int b = resultSet.getInt(sample_B); 

     data.add(r, g, b); 
    } 

    return new Entity(data); 
} 

Answer 2

從代碼的瞥見中有點難以分辨，但我認爲它與完全獲取的行數過多有關。

您應該在Statement上使用setFetchSize(int rows)，其行數合理（可能爲100）。

private static int FETCH_SIZE = 100; 
    ... 
    Statement stmt = databaseConnection.createStatement() 
    stmt.setFetchSize(); 
    ResultSet result = stmt.executeQuery("SELECT * FROM sampling_data"); 

Answer 3

似乎調用getInt（）方法在循環中執行 時使用了大量的存儲器。

這是不正確的。 getInt()沒有什麼特別的，會導致你的問題。

您的模式破壞了關係數據庫的第一範式。看到sample_1_R, sample_1_G, sample_1_B也讓我質疑你的其他決定。這顯然是1:m的關係。像數字25一樣的幻數。

我想知道爲什麼你要用String builder和int來做所有這些事情。我將這些RGB值封裝到一個有意義的對象中，如java.awt.Color。

我們在這裏談論的數據量是多少？

25*3*32*2500 ~ 5.7 MB 

這對於您的2500行並不多，每行有75個整數值。還有其他一些事情正在發生，從您的代碼中看不清楚。

更新：

你讓這段代碼的經典(n+1)查詢錯誤。你得到所有的實體，然後遍歷它們以獲得RGB值。我建議做一個JOIN並將它們一次全部帶回。這可能無法解釋你的記憶問題，但這是一個問題。

當您查詢RGB值時，您重複建立列名稱。這完全是浪費。將它們作爲數組中的static final String實例。