JavaでSQL接続時に例外が発生する

Question

###前提・実現したいこと
DBに接続して読み書きする際に、このクラスだけで接続から切断までの処理を一括で行いと考えています。
他のクラスから利用する際、connect → sql実行 → close だけのシンプルな処理にしたいのです。
ResultSetがclose後に取得出来ないのは分かるのですが、それを回避する方法が分かりません。
###発生している問題・エラーメッセージ

重大: null
java.sql.SQLException: Operation not allowed after ResultSet closed
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:964)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:897)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:886)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:860)
	at com.mysql.jdbc.ResultSetImpl.checkClosed(ResultSetImpl.java:743)
	at com.mysql.jdbc.ResultSetImpl.next(ResultSetImpl.java:6301)
	at dao.DbConnection.main(DbConnection.java:99)

###該当のソースコード（質問後に修正しています。）

public class DbConnection {
    private Connection con;
    private Statement stmt;
    private ResultSet result;
    
    private String url = "jdbc:mysql://localhost:3306/database?useSSL=false";
    private String drv = "com.mysql.jdbc.Driver";
    private String id = "root";
    private String pass = "";
    
    static{
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException ex) {
            ex.printStackTrace();
        }
    }
    
    public DbConnection(){
        try {
            con = DriverManager.getConnection(url, id, pass);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    
    public ResultSet executeQuery(String sql){
        if(con != null){
            try{
                stmt = con.createStatement();
                result = stmt.executeQuery(sql);
            }catch(SQLException ex){
                return null;
            }
        }
        return result;
    }
    
    public int executeUpdate(String sql){
        int i = 0;
        if(con != null){
            try{
                stmt = con.createStatement();
                i = stmt.executeUpdate(sql);
            }catch(SQLException ex){
                System.out.print(ex.getLocalizedMessage());
                return -1;
            }
        }
        return i;
    }
    
    public boolean close(){
        try{
            stmt.close();
            con.close();
        }catch(SQLException ex){
            ex.printStackTrace();
            return false;
        }
        return true;
    }
    
    public static void main(String[] args){

        try {
            DbConnection con = new DbConnection();
            Cart cart = new Cart();
            ResultSet result = con.executeQuery("SELECT * FROM PRODUCTS");
            while(result.next()){
                Product p = new Product(result.getInt(1),result.getString(2),result.getString(3),result.getString(4));
                cart.addItem(p,10);
            }
            con.close();        //StatementとConnectionをクローズ
            con.result.close(); //ResultSetをクローズ（不要になった時点で閉じる）
            cart.show();
                
        } catch (SQLException ex) {
            Logger.getLogger(DbConnection.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
}

Answer 1

例外が発生しているのはcloseのところではなく、mainメソッド内のnext()を呼んでいるところですよね。これは、例外になります。

ResultSetというのは、問い合わせ結果を全部保持しているわけではないと考えてください。だからArrayListみたいなオブジェクトとはちょっと違うのです。
ではどういうオブジェクトなのかというと、DBから順次飛んでくる結果を受け取るバッファです。100件や1000件のデータなら結果は一瞬で取れるでしょうが、DBの仕事は数千万件、数十億件といったデータを扱うこと。そういうデータは取り出そうにも一瞬では取り出せませんし、結果として取り出すために全部メモリに格納しようとしたらメモリが足りません。
だから、DBが結果を出力し始めたらアプリも先頭から順次処理していくということができないといけず、その窓口がResultSetなのです。

ResultSetからデータを読み出す前に窓口であるResultSetを閉じてしまっては、もう読み出せなくて当然です。もしやりたいような「シンプルな」クラスインターフェースにしたいなら、ResultSetからArrayListにデータを全部抜き出してからcloseしてArrayListを返す形にしてみてください。無論、前述のような巨大データには対応できないプログラムになります。

Comments

[syabon]

ご回答ありがとうございます。
DbConnection クラスを使う側で閉じるように修正しましたが、これでよいのでしょうか。

[yuba]

良さげに見えます。

[syabon]

ありがとうございます！！