WebSphere/DB2/ResultSet close/Exception

Question

WebSphereを使って、Listenerで取得したデータソースを利用していますが、

String sql1 = "SELECT A1 FROM TEST1";
String sql2 = "SELECT B2 FROM TEST2 WHERE B1 = ?";
Connection conn = datasource.getConnection();
PreparedStatement ps1 = conn.preparedStatement(sql1);
ResultSet rs1 = ps1.executeQuery();
while(rs1.next()){
PreparedStatement ps2 = conn.preparedStatement(sql2);
ps2.setString(1,rs1.getString("A1"));
ResultSet rs2 = ps2.executeQuery();
ps2.close();
}

このロジックで、ps2をクローズすると、ps1で取得したResultSet rs1がクローズされるというExceptionが発生してしまいます。
(ループして戻ったときにrs1.next()でexceptionが起こる)
なにか対処方法があるかご存知の方いらっしゃいましたら、よろしくお願いいたします。

braver_2004 · Accepted Answer

申し訳ないです。いただいたExceptionでは少しもわかりませんでした。
ただ、ソースを見ないとなんともいえませんが、NO2さんがおっしゃるとおり呼び出し先でconnectionかstatementをcloseしている可能性がありそうですね。


脱線しますが…。

Java入門書などでBeanを作成する際に、そのBean内部でConnectionをcommit,closeするソースをよく見ます。
そのように作ってしまうと、トランザクション管理が出来なくなります。特にテーブル毎にBeanを作っていて複数のテーブルにinsert、updateなどするときは困ります。今回の場合それが問題かどうかはわかりませんからここまでにします。

>そっか。。まとめてpreparedStatementの配列を先に作っておいて、
>使うときに一個ずつとるようにすればよいのですね。でも最大ネスト数決まってしまうのはつらいかな。。。。って感じです。

『最大ネスト数が決まる』とはどのようなことを想定されているのでしょうか？申し訳ありません。
preparedStatementを使用することでつらいことってなかったものですから、アドバイスが間違って理解されると心配で…。

pcbeginner · Answer

サンプルの様に1度に実行するのではなく、
以下の様に分けてみてはどうでしょうか？
----------------------------------------
String sql1 = "SELECT A1 FROM TEST1";
String sql2 = "SELECT B2 FROM TEST2 WHERE B1 = ?";
Connection conn = datasource.getConnection();
PreparedStatement ps1 = conn.preparedStatement(sql1);
ResultSet rs1 = ps1.executeQuery();
while(rs1.next()){
　　PreparedStatement ps2 = conn.preparedStatement(sql2);
　　ps2.setString(1,rs1.getString("A1"));
　　ResultSet rs2 = ps2.executeQuery();
　　ps2.close();
}

String sql1 = "SELECT A1 FROM TEST1";
String sql2 = "SELECT B2 FROM TEST2 WHERE B1 = ?";
Connection conn = datasource.getConnection();

//まずSELECT A1 FROM TEST1の実行と結果の取得
PreparedStatement ps = conn.prepareStatement(sql1);
ResultSet rs = ps.executeQuery();
ArrayList a1 = new ArrayList();　　//sql1の実行結果格納用
while(rs.next()){
　　a1.add(rs.getString("A1"));
}
rs.close();
ps.close();

//次にSELECT B2 FROM TEST2 WHERE B1 = ?の実行と結果の取得
ps = conn.prepareStatement(sql2);
ArrayList[] a2 = new ArrayList[a1.size()];　　//sql2の実行結果格納用
for(int i = 0;i < a1.size();i++){
　　ps.setString(1,(String)a1.get(i));
　　rs = ps.exequteQuery();
　　a2[i] = new ArrayList();
　　while(rs.nest()){
　　　　a2[i].add(rs.getString("B2"));
　　}
　　rs.close();
}
ps.close();
conn.close();
----------------------------------------

また、
>実際には取得したBEANの結果によって、呼び出しクラスを変える処理になっています。
>呼び出されたクラス内でpreparedしていまして、必要であればさらにそのクラスが下位クラスを。。。という構成です。
とありますが、PreparedStatementやResultSetを参照渡ししていて、
呼び先でcloseしているため、呼び元で実行すると既にcloseされている
ということはないでしょうか？

braver_2004 · Answer

どのようなExceptionが出力されているのでしょうか。
差し支えなければ提示していただけると、詳しい回答ができるかもしれません。

関係ないかもしれませんが、一点だけアドバイスを。
while中のPreparedStatement をnewしていますが、もともとPreparedStatementはSQL文をプリコンパイルし、それを再利用することでSQLの文法チェックを最小にすることを可能にするものです。

ですので、
PreparedStatement ps2 = conn.preparedStatement(sql2);
をwhileより前に、
ps2.close();
をwhileから抜けたあとにコーディングすると、パフォーマンスは向上します。
（このときrs2をcloseすることは忘れずに）

WebSphere/DB2/ResultSet close/Exception

申し訳ないです。

サンプルの様に1度に実行するのではなく、

どのようなExceptionが出力されているのでしょうか。

この回答への補足

関連するカテゴリからQ&Aを探す

デイリーランキングこのカテゴリの人気デイリーQ&Aランキング

マンスリーランキングこのカテゴリの人気マンスリーQ&Aランキング