JDBC RowSets utilisant singleton Connexion

Question

J'utilise javax.sql.rowset.JdbcRowSet et com.sun.rowset.JdbcRowSetImpl pour manipuler des données. Tout fonctionne bien, mais je reçois un avertissement que je pourrais avoir une fuite de ressources.

En outre, j'utilise singleton Connexion dans le constructeur JdbcRowSet qui est toujours ouvert, mais quand j'utilise JdbcRowSet close() je ne peux pas l'utiliser dans la méthode suivante.

Voici le code.

public static Connection conn = DBConnection.getInstance() 
     .getConnection(); 



(not the exact work, only a sample code) 
private static void function1() { 

    try { 
     JdbcRowSet myrs = new JdbcRowSetImpl(conn); 
     myrs.setCommand("SELECT * FROM `table1`"); 
     myrs.execute(); 

     //result iteration 

     myrs.close(); 
    } catch (SQLException e) { 
     e.printStackTrace(); 
    } 
} 
private static void function2() { 
    same as function1 (for example, not really important here) 
} 

public static void start(){ 
    function1(); 
    function2(); 
} 

Quand il arrive à exécuter dans myrsfunction2() je reçois une erreur:

at com.sun.rowset.JdbcRowSetImpl.execute(Unknown Source)

Tout le monde sait comment le résoudre?

Answer 1

est ici la mise en œuvre JdbcRowSetImpl de près

public void close() throws SQLException { 
    if (rs != null) 
     rs.close(); 
    if (ps != null) 
     ps.close(); 
    if (conn != null) 
     conn.close(); 
} 

Depuis le JdbcRowSetImpl.close() fermera la connexion, la meilleure façon d'adapter à votre architecture actuelle pourrait être de créer un singleton membre ou une instance JdbcRowSet qui est fermé lorsque vous attendez que la connexion soit classée. Votre fonction1 et fonction2 ressemblerait à ceci

public static Connection conn = DBConnection.getInstance() 
    .getConnection(); 
//Implementation of DBRowSet left as an exercise for the ambitious. 
public static JdbcRowSet myrs = DBRowSet.getInstance(); 

private static void function1() { 
    try { 
     myrs.setCommand("SELECT * FROM `table1`"); 
     myrs.execute(); 
     //result iteration 
    } catch (SQLException e) { 
     e.printStackTrace(); 
    } 
} 
private static void function2() { 
    try { 
     myrs.setCommand("SELECT * FROM `table2`"); 
     myrs.execute(); 
     //result iteration 
    } catch (SQLException e) { 
     e.printStackTrace(); 
    } 
}