Rainbow Engine

IT技術を分かりやすく簡潔にまとめることによる学習の効率化、また日常の気付きを記録に残すことを目指します。

Java OracleDB

JavaのJDBC接続でjava.sql.SQLRecoverableException: Closed Connectionが発生した時の解決メモ

投稿日：2020年1月26日 更新日：

(０)目次＆概説

(１) エラー事象の概要
　(１-１) エラーの発生状況
　(１-２) エラーメッセージ全文
(２) エラーの原因
(３) エラーの対処方法
　(３-１) エラーの修正内容
　(３-２) 修正前ソース（Before Fix）
　(３-３) 修正前ソース実行結果
　(３-３) 修正後ソース（After Fix）
　(３-４) 修正後ソース解説
　(３-５) 修正後ソース実行結果
(４) 追加で考慮すべき点
　(４-１) finally句でclose処理をしていないと、クローズ漏れになる恐れがある
　　(４-１-１) 明示的にcloseした方が良い理由
　(４-２) finally句でclose処理をする場合、SQLExceptionの考慮が必要

(１) エラー事象の概要

(１-１) エラーの発生状況

JDBC接続でサーブレットからDBへの接続時に「java.sql.SQLRecoverableException: Closed Connection」が発生した際の対処方法について記載します。私のケースでは、１つに纏まっていたDB接続の処理を共通部品化するために複数メソッドに分割（Connection、Statement、ResultSet）しようとした所、このエラーに遭遇しました。 

java.sql.SQLRecoverableException: Closed Connection

 

（図１）

(１-２) エラーメッセージの全文

java.sql.SQLRecoverableException: Closed Connection
	at oracle.jdbc.driver.PhysicalConnection.createStatement(PhysicalConnection.java:3450)
	at oracle.jdbc.driver.PhysicalConnection.createStatement(PhysicalConnection.java:3425)
	at login.DbConnectTest3.DbStatement(DbConnectTest3.java:43)
	at login.DbConnectTest3.doGet(DbConnectTest3.java:72)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:634)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:741)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
	at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:199)
	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)
	at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:610)
	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:137)
	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:81)
	at org.apache.catalina.valves.AbstractAccessLogValve.invoke(AbstractAccessLogValve.java:660)
	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:87)
	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)
	at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:798)
	at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
	at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:808)
	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1498)
	at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
	at java.lang.Thread.run(Thread.java:748)
Jan 26, 2020 4:00:55 PM org.apache.catalina.core.StandardWrapperValve invoke
SEVERE: Servlet.service() for servlet [login.DbConnectTest3] in context with path [/LoginForms] threw exception
java.lang.NullPointerException
	at login.DbConnectTest3.DbQuery(DbConnectTest3.java:53)
	at login.DbConnectTest3.doGet(DbConnectTest3.java:73)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:634)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:741)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
	at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:199)
	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)
	at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:610)
	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:137)
	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:81)
	at org.apache.catalina.valves.AbstractAccessLogValve.invoke(AbstractAccessLogValve.java:660)
	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:87)
	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)
	at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:798)
	at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
	at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:808)
	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1498)
	at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
	at java.lang.Thread.run(Thread.java:748)

 

＞目次にもどる

(２) エラーの原因

「try-with-resources」文はそのスコープの範囲を抜ける際にcloseメソッドを自動で呼んでるために「Closed Connection」が発生していました（次の例１・例２）。なので「try-with-resources」の条件文に記載したような、ConnectionオブジェクトやStatementオブジェクトをインスタンス化する部分は、try文を抜けたタイミングでCloseされてしまい、次のメソッドで利用する時にはcloseされていた様です。

（例１）

try(Connection conn_temp = dbms.getConn();){

 

（例２）

try(Statement stmt = conn.createStatement();){

 

＞目次にもどる

(３) エラーの対処方法

(３-1) エラーの修正内容

応急対処として、通常の「try-catch」文で記述すればエラーは消えました。

（図２）修正例
左側が「修正前」で、右側が「修正後」です。修正はいずれも「try-with-resources」の条件文に記載していたConnectionオブジェクトやStatementオブジェクトのインスタンス化を、try{ }文の内部に移すという内容です。

No 修正前 修正後
1 try(Connection conn_temp = dbms.getConn();){
   conn = conn_temp;		 try{
   conn = dbms.getConn();
2 try(Statement stmt = conn.createStatement();){
   stmt = stmt_tmp;		 try{
   stmt = conn.createStatement();

 

(３-２) 修正前ソース（Before Fix）

package login;

import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import database.DBMS;

/**
 * Servlet implementation class DbConnectTest1
 */
@WebServlet("/DbConnectTest3")
public class DbConnectTest3 extends HttpServlet {
	private static final long serialVersionUID = 1L;
    public DbConnectTest3() {super();}    
	public Connection DbConnect (HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		Connection conn = null;
		DBMS dbms = new DBMS();
		try(Connection conn_temp = dbms.getConn();){
			conn = conn_temp;
		} catch (ClassNotFoundException e1) {
			e1.printStackTrace();
		} catch (SQLException e2) {
			e2.printStackTrace();
		}
		return conn;
	}
	public Statement DbStatement (HttpServletRequest request, HttpServletResponse response, Connection conn) throws ServletException, IOException {
		Statement stmt = null;
		try(Statement stmt_tmp = conn.createStatement();){
			stmt = stmt_tmp;
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return stmt;
	}
	public ResultSet DbQuery (HttpServletRequest request, HttpServletResponse response, Statement stmt, String sql) throws ServletException, IOException {
		ResultSet rs = null;
		try{
			rs = stmt.executeQuery(sql);
		} 
		catch (SQLException e) {
			e.printStackTrace();
		}
		return rs;
	}
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {		
		
    	response.setContentType("text/html; charset=UTF-8");
		PrintWriter out = response.getWriter();
		out.println("<html><body> Hello Test !!!<br />");
    	String select1 = "SELECT * FROM ACCOUNT";
    	
    	Connection conn1 = null;
    	Statement stmt1 = null;
    	ResultSet rs1 = null;
    	
    	conn1 = DbConnect(request,response);
    	stmt1 = DbStatement(request,response,conn1);
    	rs1 = DbQuery(request,response,stmt1,select1);
		try {
			while (rs1.next()) {
				out.println("AC= "+rs1.getInt("ACCOUNT_ID")+" BAL= "+rs1.getInt("AVAIL_BALANCE")+"<br />");
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				if(rs1 != null) rs1.close(); 
				if(stmt1 != null) stmt1.close();
				if(conn1 != null) conn1.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		out.println("</body></html>");
	}
    
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		doGet(request, response);
	}
}

 

(３-３) 修正前ソース実行結果

（図３）冒頭のエラーが発生

（図４）画面もSQLの結果が表示されず・・

＞目次にもどる

(３-４) 修正後ソース（After Fix）

package login;

import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import database.DBMS;

/**
 * Servlet implementation class DbConnectTest1
 */
@WebServlet("/DbConnectTest2")
public class DbConnectTest2 extends HttpServlet {
	private static final long serialVersionUID = 1L;
    public DbConnectTest2() {super();}    
	public Connection DbConnect (HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		Connection conn = null;
		DBMS dbms = new DBMS();
		try{
			conn = dbms.getConn();
		} catch (ClassNotFoundException e1) {
			e1.printStackTrace();
		} catch (SQLException e2) {
			e2.printStackTrace();
		}
		return conn;
	}
	public Statement DbStatement (HttpServletRequest request, HttpServletResponse response, Connection conn) throws ServletException, IOException {
		Statement stmt = null;
		try{
			stmt = conn.createStatement();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return stmt;
	}
	public ResultSet DbQuery (HttpServletRequest request, HttpServletResponse response, Statement stmt, String sql) throws ServletException, IOException {
		ResultSet rs = null;
		try{
			rs = stmt.executeQuery(sql);
		} 
		catch (SQLException e) {
			e.printStackTrace();
		}
		return rs;
	}
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {		
		
    	response.setContentType("text/html; charset=UTF-8");
		PrintWriter out = response.getWriter();
		out.println("<html><body> Hello Test !!!<br />");
    	String select1 = "SELECT * FROM ACCOUNT";
    	
    	Connection conn1 = null;
    	Statement stmt1 = null;
    	ResultSet rs1 = null;
    	
    	conn1 = DbConnect(request,response);
    	stmt1 = DbStatement(request,response,conn1);
    	rs1 = DbQuery(request,response,stmt1,select1);
		try {
			while (rs1.next()) {
				out.println("AC= "+rs1.getInt("ACCOUNT_ID")+" BAL= "+rs1.getInt("AVAIL_BALANCE")+"<br />");
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				if(rs1 != null) rs1.close(); 
				if(stmt1 != null) stmt1.close();
				if(conn1 != null) conn1.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		out.println("</body></html>");
	}
    
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		doGet(request, response);
	}
}

 

(３-４) 修正後ソース解説

行数 処理概要 備考
24行～35行目 DBMSオブジェクトをインスタンス化し、それを使いConnectionオブジェクトもインスタンス化しています。またtry-catchで例外処理をしており、特にtryには条件文をしてせずに記述しています。 メソッドの設計方針として、後にcloseしやすいように、Connectionオブジェクトを返り値として返却しています。
（Connection～Statement～ResultSetまで全て行ってしまうと各々を個別にCloseできなくなってしまうため、メソッドを分けている）
36行～44行目 ステートメントを作成するメソッドです。
引数にConnectionオブジェクトを貰う形式にしています（メソッドの中でDbConnectを呼ぶのではなく、引数としてConnectionオブジェクトを貰っている）。
この理由は上記と被りますが、後にcloseしやすいようにDbConnectは内部では呼ばず、実際に使うタイミングで直接呼んで、使い終わったらその場で即座にCloseできるようにするためです（内部に埋め込まれているとcloseしにくい）。		  
45行～54行目 ResultSet（クエリの結果）を取得するメソッドです。こちらも同様にtry-catchで例外処理をしており、特にtryには条件文をしてせずに記述しています。
そして上記２メソッドと同じく、引数にStatementオブジェクトを受け取る事で必要な時に呼んでその場でcloseしやすい形式にしました。		  
55行～85行目 doGetメソッドです。
62行～68行目でConnection/Statement/ResultSetの初期化し、メソッドを呼んでインスタンス化しています。
69行～85行目ではtry-catch-finally句でResultSetからSQLの結果を取得しています。Finally句の中で使い終わったConnection/Statement/ResultSetをクローズしています。クローズ時もSQLExceptionの例外発生の可能性があるため、try-catchで囲んでいます。		  

＞目次にもどる

(３-５) 修正後ソース実行結果

（図５）エラーは解消

（図６）SQL結果も表示！

＞目次にもどる

(４) 追加で考慮すべき点

上記の方法でエラー自体は消えるものの、他にも考慮すべき点を記載します。

(４-１) finally句でclose処理をしていないと、クローズ漏れになる恐れがある

基本はConnectionオブジェクト、Statementオブジェクト、ResultSetオブジェクトを全てリリースします。なので「try-with-resources」を使わない場合は明示的にclose()を行う必要があります。

(４-１-１) 明示的にcloseした方が良い理由

Statementを作成するとDBによってはカーソルがOpenになりますが、Closeされるまではメモリが確保され続け、DB側でもカーソルが開きっぱなしになってしまうので閉じる必要があります。

通常は上位オブジェクトを閉じれば、下位オブジェクトも自動的に閉じられる機能があるものの(Connection＞Statement＞ResultSet　左に記載ほど上位）、以前OracleでConnectionを閉じたにも関わらずカーソル(ResultSet)が開いたままになり「Maximum open cursors exceeded.」のようなエラーが発生する事象があったため、ResultSetやStatementも明示的に閉じる方が安全と認識されるようになりました。

(４-２) finally句でclose処理をする場合、SQLExceptionの考慮が必要

finally句でclose処理をする場合、クローズ不可時の例外としてSQLExceptionをスローするため、クローズの処理もtry、catchで囲む必要があります。

＞目次にもどる

Adsense審査用広告コード


Adsense審査用広告コード


-Java, OracleDB

執筆者：

comment

メールアドレスが公開されることはありません。 ※ が付いている欄は必須項目です

関連記事

WARファイルの作成方法について（Eclipse利用あり、なしの２パターン）

  ＜目次＞ (１) WARファイルの作成方法について（Eclipse利用あり、なしの２パターン） 　(１-１) 方法①：Eclipseを使ってWARファイルを作る方法 　(１-２) 方法② …

Javaのswitch-case文の構文や使い方を紹介＋UFOキャッチャーの座標移動プログラムも紹介

＜目次＞ (１) Javaのswitch-case文の構文や使い方を紹介 　(１-１) switch-caseの構文 　(１-２) else-if文との比較 (２) サンプルプログラムの紹介 　(２- …

ORA-03113 end-of-file on communication channelエラーの対処

”ORA-03113 end-of-file on communication channel”の対処法について記述します。 (０) 目次 (１) 解析 (２) 原因 (３) 対策 (４) 解説 　( …

JFreeChartを使ってJavaで様々なグラフを簡単に描画する方法

(０)目次＆概説 (１) 記事の目的 　(１-１) 目的 (２) JFreeChartの概要 　(２-１) JFreeChartとは？ 　(２-２) JFreeChartのアーキテクチャについて (３ …

オープンアドレス法のアルゴリズムについて図を使ってご紹介

＜目次＞ (１) オープンアドレス法のアルゴリズムについて図を使ってご紹介 　(１-１) オープンアドレス法とは？ 　(１-２) オープンアドレス法のアルゴリズム 　(１-３) オープンアドレス法の利 …

PREV
PythonにOpenCVを導入して画像を読込み＆表示＆拡大縮小してみる
NEXT
JSP/Servletで画面毎のアクセスカウンターを作成してみた（パート１：仕様説明編）

言語 / Language

  • English (United States)
  • 日本語

検索

最新記事

アーカイブ

カテゴリー

Top