Java SQL 실행 메소드를 사용하지만 결과에 액세스 할 수 있음

Question

코드에서 복잡한 SQL 쿼리, 시도, 캐치 및 결선을 처리하는 것보다 execute(SQL, up to three inputs) 메서드가 있지만 결과 집합에 액세스하려고하면 실행 결과가 나옵니다. 오류 :

당신이 된 PreparedStatement를 닫을 때는 ResultsSetToo을 닫습니다 (그리고 주위에 방법이없는 것 같다) 때문이다

"Operation not allowed after ResultSet closed" 

.

해결 방법이 있습니까? 내가 생각할 수있는 유일한 방법은

Answer 1

나는 이전에 같은 문제가 발생했습니다.

public ArrayList<Map<String, String>> getListOfMapsFromSQL(String sql) throws SQLException { 
    con = DriverManager.getConnection(url,user,pass); 
    stmt = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE); 
    ArrayList<Map<String, String>> list = new ArrayList<Map<String, String>>(); 

    rs = stmt.executeQuery(sql); 
    ResultSetMetaData rsmd = rs.getMetaData(); 

    while(rs.next()){ 
     Map<String, String> fieldsMap = new HashMap<String, String>(); 
     for(int i=1; i<=rsmd.getColumnCount(); i++){ 
      fieldsMap.put(rsmd.getColumnLabel(i), rs.getObject(i).toString()); 
     } 
     list.add(fieldsMap); 
    } 

    list.trimToSize(); 
    stmt.close(); 
    con.close(); 
    return list; 
} 

가 대신 ResultSet을 반환하는이지도의 목록을 (1 개 행을 나타내는 각각의) 반환

: 지금은이 방법을 사용합니다. 첫 번째 String은 Label 열이고 두 번째 String은 열 값입니다. 나는 그것이 도움이되기를 바랍니다. :-)

Answer 2

when you close the PreparedStatement it closes the ResultsSetToo

수정, 당신의 시간을

많은 감사를 저장하는 배열로 변환되었다. 결과를 처리 할 때까지 PreparedStatement를 닫지 않을 수 있습니다.

인터페이스를 정의합니다. ResultConsumer 또는 execute()의 호출자가 구현할 수있는 것과 비슷한 것입니다. 그런 다음 execute() 메서드 내에서 결과 집합을 소비자에게 전달하면됩니다.

 
public Interface ResultConsumer 
{ 
    void processResult(ResultSet rs); 
} 

그런 다음 실행()이

 
public void execute(String SQL, ResultConsumer consumer, ... other parameters) 
{ 
    PreparedStatement stmt = ... 
    ResultSet rs = stmt.executeQuery(); 
    consumer.processResult(rs); 
    rs.close(); 
    stmt.close(); 
} 

(나는 명확성을 위해 처리하는 모든 오류 검사 및 예외를 제거, 물론 당신이 처리해야합니다)

Answer 3

처럼 보일 수 있습니다 잠시 뒤로 나는 똑같은 문제를 다루어야했다. 이 디자인에 대해 숙고 한 후에 우리는 아래처럼 그것을하기로 결정했습니다. 코드 아래 ExecuteRequest 클래스가 사용됩니다에서

private static ExecuteRequest er = new ExecuteRequest(); 

아래에 주어진 몇 가지 구체적인 이유

public static Properties execute(String string, String[] columnames) throws Exception { 

    Properties resulProperties = er.executeQuery(string, columnames); 

    return resulProperties; 

} 

, 나는 내 수업에서 필드를 만들었습니다.

public Properties executeQuery(String sqlstatement, String[] columnNames) throws Exception { 
    Properties prop = new Properties(); 
    try { 
     prop = creteProperty(sqlstatement, columnNames); 
    } catch (Exception e) { 
     mlogger.report("Error executing sql statement"); 
     throw (e); 
    } 

    return prop; 

} 

public Properties creteProperty(String sqlstatement, String[] columnNames) throws Exception { 
    Properties prop = new Properties(); 

    try { 
     PreparedStatement stmt = ConnectionManager.getInstance().prepareStatement(sqlstatement); 
     ResultSet rs = stmt.executeQuery(); 
     if (rs.next()) { 
      for (int i = 0; i < columnNames.length; i++) { 
       String key = columnNames[i]; 
       if (rs.getObject(key) != null) { 
        String value = (rs.getObject(key).toString()); 
        prop.setProperty(key, value); 
       } else { 
        String value = ""; 
        prop.setProperty(key, value); 
       } 

      } 
     } 
     rs.close(); 
    } catch (Exception e) { 
     mlogger.report("Error executing sql statement"); 
     throw (e); 
    } 
    return prop; 

} 

이 방법을 해결책으로 사용할 수 있습니다.