Servlet間のSQL実行結果の受け渡しについて知りたいです

Question

Java(Servlet/JSP)で練習用に家計簿アプリを作成しています。
動きとしては、JSPから受け取る値（id, date, storeName, productName, type, price)をサーブレット「BudgetTrackerSearchController.java」で受け取り、受け取った内容を「BudgetTrackerSearchLogic.java」に渡し、Select SQLを実行し、「BudgetTrackerSearchController.java」に戻し、事項結果を変数「SqlResult」に格納し、最終的にjspファイルにSQLの結果を戻したいのですが、SQLの結果の受け渡し（BudgetTrackerSearchController.javaとBudgetTrackerSearchLogic.javaの間）がうまくできません。
下記にコードを記述していますので、SQLの結果の受け渡しについてご回答できる方がおりましたら、解決方法についてご教授頂けますでしょうか。

package info.budget.budgettracker;

import java.io.IOException;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;

public class BudgetTrackerSearchController extends HttpServlet {
	
	private InitialContext ic;

    public void init() throws ServletException {
    	// 初期コンテキストを取得
    	try {
			ic = new InitialContext();
		} catch (NamingException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

    protected void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {

		// 文字コードの設定
		request.setCharacterEncoding("Windows-31J");

		// modeの取得
		String mode = request.getParameter("mode");

		// 実行ステータスの宣言
		String status = "Successful!";
		
		// データソースの取得
		DataSource ds = null;
		try {
			ds = (DataSource) ic.lookup("java:comp/env/jdbc/searchman");
		} catch (NamingException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		// JavaBeansの初期化
		BudgetTrackerSearchLogic btSearchLogic = BudgetTrackerSearchLogicFactory.createBudgetTrackerLogic(request, ds, mode);
		
		ResultSet rset = null;
		try {
			rset  = btSearchLogic.searchData();
		} catch (Exception e) {
			e.printStackTrace();
	        status = "Failed!";
		}
	
		
		// statusをセットして、result.jspに転送
        request.setAttribute("status", status);
        request.setAttribute("SqlResult", rset);
        request.getRequestDispatcher("/searchResult.jsp").forward(request, response);

	}
	
	protected void doGet(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {

		doPost(request, response);
	}

}

package info.budget.budgettracker;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import javax.naming.InitialContext;
import javax.servlet.ServletRequest;
import javax.servlet.http.HttpServletRequest;
import javax.sql.DataSource;

public abstract class BudgetTrackerSearchLogic {
	// private String yearMonth;
	private String id;
	private String date;
	private String storeName;
	private String productName;
	private String type;
	private String price;

	// DB関連の初期設定
	protected DataSource ds = null;
	ResultSet rset = null;

	// コンストラクタ
	public BudgetTrackerSearchLogic(HttpServletRequest request, DataSource ds) {

		setId(request.getParameter("id"));
		setDate(request.getParameter("date"));
		setStoreName(request.getParameter("storeName"));
		setProductName(request.getParameter("productName"));
		setType(request.getParameter("type"));
		setPrice(request.getParameter("price"));
		this.ds = ds;
	}

	// データベースへのアクション
	// データの追加を実施
	public ResultSet searchData() throws Exception {

		Connection conn = ds.getConnection();
		String tableNm = getTableName();
		StringBuilder sql = new StringBuilder();

		// sql文を表示
		sql.append("select id, Date, StoreName, ProductName, type, Price from " + tableNm + " where StoreName like '%'");
		//sql.append(storeName + "%'");
		System.out.println(sql);

		// if id is selected, add it
		if (id != "") {
			sql.append("and id ='" + this.getId() + "';");
		}

		// if Date is selected, add it
		if (date != "") {
			sql.append("and Date ='" + date + "'");
		}

		// if StoreName is selected, add it
		if (storeName != "") {
			sql.append("and StoreName ='" + storeName + "'");
		}

		// if ProductName is selected, add it
		if (productName != "") {
			sql.append("and ProductName ='" + productName + "'");
		}

		// if Type is selected, add it
		if (type != "") {
			sql.append("and Type ='" + type + "'");
		}

		// if Price is selected, add it
		if (type != "") {
			sql.append("and Price ='" + price + "'");
		}

		PreparedStatement pstmt = conn.prepareStatement(new String(sql));
		

		// sql文実行
		boolean res = pstmt.execute();
		rset = pstmt.executeQuery();
		
//		ServletRequest request = null;
//		request.setAttribute("SqlResult", rset);
		// 使用したオブジェクトを終了させる
		pstmt.close();
		
		return rset;
		
		

		// conn.close(); Webサーバー側のコネクションを使っているためコネクションはクローズしない
		

		//return res;
	}

	// サブクラスからテーブル名を返す
	protected abstract String getTableName();

	public String getId() {
		return id;
	}

	public void setId(String id) {
		this.id = id;
	}

	public String getDate() {
		return date;
	}

	public void setDate(String date) {
		this.date = date;
	}

	public String getStoreName() {
		return storeName;
	}

	public void setStoreName(String storeName) {
		this.storeName = storeName;
	}

	public String getProductName() {
		return productName;
	}

	public void setProductName(String productName) {
		this.productName = productName;
	}

	public String getType() {
		return type;
	}

	public void setType(String type) {
		this.type = type;
	}

	public String getPrice() {
		return price;
	}

	public void setPrice(String price) {
		this.price = price;
	}

	public DataSource getDs() {
		return ds;
	}

	public void setDs(DataSource ds) {
		this.ds = ds;
	}
}

package info.budget.budgettracker;

import javax.sql.DataSource;
import javax.servlet.http.HttpServletRequest;

public class BudgetTrackerSearchLogicFactory {
    
    public static BudgetTrackerSearchLogic createBudgetTrackerLogic(
        HttpServletRequest request, DataSource ds, String mode){
    	BudgetTrackerSearchLogic res = null;

        switch(mode) {
            case "searchJan2020":
                res = new Jan2020Search(request, ds);
                break;
                // クラスを増やすときにcaseを追加
            default:
                break;
        }

        return res;
    }
}

Comments

[dodox86]

「うまくいかない」とは具体的にどういう問題が起きているのでしょうか。そもそもSELECTを実行しているBudgetTrackerSearchLogicクラスのsearchDataメソッドも、結果として得たResultSetを使っていないように見えます。（//request.setAttribute("SqlResult", rset); とコメント化されてしまっています）

[dodox86]

「うまくできない」＝「適切なやり方が分からず、できない」と言うご質問ですね。

[Yakusugi]

ご返信ありがとうございます。
ご指摘通り、「("SqlResult", rset);」のコメントアウトを外し、下記の様に変更してみました。
ServletRequest request = null;
request.setAttribute("SqlResult", rset);

具体的に不明な点としては、この「SqlResult」をどのようにして、BudgetTrackerSearchController.javaへ戻し、最終的にJSPへ渡すかヒントがあればご教授頂けないでしょうか。

Answer 1

一番安直なのは、BudgetTrackerSearchLogic#searchData()の戻り値をResultSetにして、return rset;だと思います。
ただ、オブジェクト指向やセキュリティのの観点から、ぜひ以下も検討してください。

• 戻り値をArrayListなどにして、SQLの結果をリスト形式で返却する
• sql.append("and id ='" + this.getId() + "';");はSQLインジェクションの原因になるため、バインド変数を利用する
• インスタンス変数をif (id != "") {と直接参照している直後にthis.getId()とメソッド経由で参照しているのは意図しているか

Comments

[Yakusugi]

ご回答頂きありがとうございます。

ご回答いただいた内容を元に自分でもBudgetTrackerSearchLogicのsearchDataを修正してみたのですが、BudgetTrackerSearchLogicのsearchData内で例外が発生しているらしく、NULLがBudgetTrackerSearchControllerにわたっているようです。

BudgetTrackerSearchLogic/BudgetTrackerSearchControllerともに修正してみみましたので、お気付きのエラーがありましたら、お手数ですが、ご教授いただければ幸いです。

よろしくお願いいたします。

[jcs502ulf]

エラーメッセージを掲載してほしいです。

[Yakusugi]

下記エラーメッセージになります。

12 20, 2020 12:35:13 午後 org.apache.catalina.core.ApplicationDispatcher invoke
重大: サーブレット [jsp] のServlet.service()が例外を投げました
java.sql.SQLException: Operation not allowed after ResultSet closed
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:127)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:95)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:87)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:61)
at com.mysql.cj.jdbc.result.ResultSetImpl.checkClosed(ResultSetImpl.java:459)
at com.mysql.cj.jdbc.result.ResultSetImpl.next(ResultSetImpl.java:1688)
at org.apache.tomcat.dbcp.dbcp2.DelegatingResultSet.next(DelegatingResultSet.java:191)
at org.apache.tomcat.dbcp.dbcp2.DelegatingResultSet.next(DelegatingResultSet.java:191)
at org.apache.jsp.searchResult_jsp._jspService(searchResult_jsp.java:146)
at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:70)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:741)
at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:444)
at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:386)
at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:330)
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:53)
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.ApplicationDispatcher.invoke(ApplicationDispatcher.java:712)
at org.apache.catalina.core.ApplicationDispatcher.processRequest(ApplicationDispatcher.java:459)
at org.apache.catalina.core.ApplicationDispatcher.doForward(ApplicationDispatcher.java:384)
at org.apache.catalina.core.ApplicationDispatcher.forward(ApplicationDispatcher.java:312)
at info.budget.budgettracker.BudgetTrackerSearchController.doPost(BudgetTrackerSearchController.java:66)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:660)
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:53)
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:494)
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:137)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)
at org.apache.catalina.valves.AbstractAccessLogValve.invoke(AbstractAccessLogValve.java:651)
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:407)
at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:754)
at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1376)
at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
at java.lang.Thread.run(Unknown Source)

12 20, 2020 12:35:13 午後 org.apache.catalina.core.StandardWrapperValve invoke
重大: Servlet.service() for servlet [BTSeearchController] in context with path [/BudgetTracker] threw exception [An exception occurred processing [searchResult.jsp] at line [26]

23: <td><b>Modify</b></td>
24: </tr>
25: <%
26: while (rset.next()) {
27: %>
28: <tr>
29: <td><%=rset.getString(1)%></td>

Stacktrace:] with root cause
java.sql.SQLException: Operation not allowed after ResultSet closed
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:127)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:95)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:87)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:61)
at com.mysql.cj.jdbc.result.ResultSetImpl.checkClosed(ResultSetImpl.java:459)
at com.mysql.cj.jdbc.result.ResultSetImpl.next(ResultSetImpl.java:1688)
at org.apache.tomcat.dbcp.dbcp2.DelegatingResultSet.next(DelegatingResultSet.java:191)
at org.apache.tomcat.dbcp.dbcp2.DelegatingResultSet.next(DelegatingResultSet.java:191)
at org.apache.jsp.searchResult_jsp._jspService(searchResult_jsp.java:146)
at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:70)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:741)
at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:444)
at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:386)
at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:330)
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:53)
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.ApplicationDispatcher.invoke(ApplicationDispatcher.java:712)
at org.apache.catalina.core.ApplicationDispatcher.processRequest(ApplicationDispatcher.java:459)
at org.apache.catalina.core.ApplicationDispatcher.doForward(ApplicationDispatcher.java:384)
at org.apache.catalina.core.ApplicationDispatcher.forward(ApplicationDispatcher.java:312)
at info.budget.budgettracker.BudgetTrackerSearchController.doPost(BudgetTrackerSearchController.java:66)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:660)
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:53)
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:494)
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:137)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)
at org.apache.catalina.valves.AbstractAccessLogValve.invoke(AbstractAccessLogValve.java:651)
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:407)
at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:754)
at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1376)
at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
at java.lang.Thread.run(Unknown Source)

[jcs502ulf]

java.sql.SQLException: Operation not allowed after ResultSet closed
が原因ですね。

pstmt.close();
をコメントアウトすると動くと思います。

[Yakusugi]

ありがとうございます。
無事動く事確認出来ました。