finallyの処理する中身をメソッドでまとめて出力したい

Question

登録以外の処理をする際に利用できるようにcloseメソッドでまとめようと考えています。
closeメソッドのConnectionとPreparedStatementをnullではなく実際に利用しているinsertメソッドからConnectionとPreparedStatementを持ってきてクローズしたいのですがどのように持ってくるのかがわかりません。
ご教授頂ければ幸いです。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class Dao {
    private static final String URL = "jdbc:mysql://localhost:3306/aaa?characterEncoding=UTF-8&serverTimezone=JST";
    private static final String USER = "bbb";
    private static final String PASS = "ccc";
    private static final String DRIVE = "com.mysql.cj.jdbc.Driver";

    private Connection getConnection() throws SQLException, ClassNotFoundException {
        Connection con = null;
        Class.forName(DRIVE);
        con = DriverManager.getConnection(URL, USER, PASS);
        con.setAutoCommit(false);
        return con;
    }

	void close() throws SQLException, ClassNotFoundException {
//ここのConnectionとPreparedStatementの部分です。
		Connection con = null;
		PreparedStatement ps = null;
			try {
				if (ps != null) {
					ps.close();
				}
			} catch (SQLException e) {
　　　　　　　　　e.printStackTrace();
			}
			try {
				if (con != null) {
					con.close();
				}
			} catch (SQLException e) {
　　　　　　　　　e.printStackTrace();
			}
		}
    public void insert(Dto dto) throws SQLException {
             PreparedStatement ps = null;
        Connection con = null;
        try {
          con = getConnection();

StringBuilder INSERT_SQL = new StringBuilder();
            INSERT_SQL.append("INSERT INTO aaa (");
            INSERT_SQL.append("ID,");
            INSERT_SQL.append("name,");
            INSERT_SQL.append("remarks)");
            INSERT_SQL.append("VALUES (?,?,?)");
            String sql = INSERT_SQL.toString();
            ps = con.prepareStatement(sql);
            ps.setInt(1, dto.getID());
            ps.setString(2, dto.getName());
            ps.setString(3, dto.getRemarks());
            ps.executeUpdate();
            con.commit();
        } catch (ClassNotFoundException | SQLException e) {
            con.rollback();
        } finally {
           close();
        }
    }
}

Comments

[dodox86]

> finallyの処理する中身をメソッドでまとめて出力したい

言いまわしが少し謎(?)なので確認です。close()メソッドにConnectionとPreparedStatementの引数を増やせばよいと思うのですが、そういう話ではなくて？　でしょうか。

[ai_atoz]

説明がわかりにくく申し訳ありません。
引数を増やすというのはclose()メソッドにどのような処理を記述すればよろしいのでしょうか？

Answer 1

closeメソッドのConnectionとPreparedStatementをnullではなく実際に利用しているinsertメソッドからConnectionとPreparedStatementを持ってきてクローズしたいのですがどのように持ってくるのかがわかりません。

最低限、質問者さんの現状のコードとやりたいことに沿うかたちにするならば、insert()メソッド内で生成したConnectionとPreparedStatementをclose()メソッドの引数にすることが考えられます。以下はそのようにしたコード例です。closeAnyway()メソッドをご覧ください。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class Dao {
    private static final String URL = "jdbc:mysql://localhost:3306/aaa?characterEncoding=UTF-8&serverTimezone=JST";
    private static final String USER = "bbb";
    private static final String PASS = "ccc";
    private static final String DRIVE = "com.mysql.cj.jdbc.Driver";

    private Connection getConnection() throws SQLException, ClassNotFoundException {
        Connection con = null;
        Class.forName(DRIVE);
        con = DriverManager.getConnection(URL, USER, PASS);
        con.setAutoCommit(false);
        return con;
    }

    void close() throws SQLException, ClassNotFoundException {
//ここのConnectionとPreparedStatementの部分です。
        Connection con = null;
        PreparedStatement ps = null;
            try {
                if (ps != null) {
                    ps.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                if (con != null) {
                    con.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    // SQLExceptionもClassNotFoundExceptionもthrowしないので、throws...は不要。
    // インスタンスメソッドである必要もないので、staticなクラスメソッドで十分。
    private static void closeAnyway(Connection con, PreparedStatement ps) {
        try {
            if (ps != null) {
                ps.close();
            }
        } catch (SQLException e) {
           e.printStackTrace();
        }

        try {
            if (con != null) {
                con.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public void insert(Dto dto) throws SQLException {
        PreparedStatement ps = null;
        Connection con = null;
        try {
            con = getConnection();

            StringBuilder INSERT_SQL = new StringBuilder();
            INSERT_SQL.append("INSERT INTO aaa (");
            INSERT_SQL.append("ID,");
            INSERT_SQL.append("name,");
            INSERT_SQL.append("remarks)");
            INSERT_SQL.append("VALUES (?,?,?)");
            String sql = INSERT_SQL.toString();
            ps = con.prepareStatement(sql);
            ps.setInt(1, dto.getID());
            ps.setString(2, dto.getName());
            ps.setString(3, dto.getRemarks());
            ps.executeUpdate();
            con.commit();
        } catch (ClassNotFoundException | SQLException e) {
            if (con != null) {
                con.rollback();
            }
        } finally {
            //close();
            // とにかく可能な限りcloseする、と言う意味を込めて:
            closeAnyway(con, ps);
        }
    }
}

SQL実行中の例外(Exception)関連のハンドリングは意外と難しく、様々なやり方が提案されています。上記例はtry～catchやif文だらけで仕方が無いとは言え、コードとして見た目が不格好ですよね。上記の例にこだわらず、他の良質なサンプルコードなどを見、理解した上で必要に応じて改善していくのも良いことだと思います。

Comments

[ai_atoz]

質問にお答えくださりありがとうございました。
コードを参考にさせていただきました。
理解できていないところも多々ありましたので学習しながら理解を深めていきたいと思います。

Answer 2

try {

      con = getConnection();

これは入れ替えておかないと、catchのときに、ヌルポになりますよ

Comments

[ai_atoz]

そうなのですね。
ご指摘ありがとうございます。

[y_waiwai]

getConnection() の実行で例外でたら、ってことですね