JDBCのコネクションがうまくいきません

Question

JDBCを使用して簡素なCUIベースのDB家計簿アプリを作成しています。
DTO/DAOパターンで作成しているのですが、下記DAOクラスでDBとのコネクションでエラーが起きてしまっております。
"this.myConn" is nullと記載があるのですが、当該BudgetTrackerDaoクラスの中で「myConn = BudgetTrackerDao.getConnection();」を指定しているので、myConnが何故nullになっているかが掴みきれていません。
解決のため、ご助力頂けますと幸いです。

エラー内容

Exception in thread "main" java.lang.NullPointerException: Cannot invoke "java.sql.Connection.prepareStatement(String)" because "this.myConn" is null
	at BudgetTrackerCui/com.jdbc.budgettracker.dao.BudgetTrackerDao.insertIntoTable(BudgetTrackerDao.java:83)
	at BudgetTrackerCui/com.jdbc.budgettracker.main.BudgetTrackerMain.main(BudgetTrackerMain.java:124)

BudgetTrackerDao.java

package com.jdbc.budgettracker.dao;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Time;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

import com.jdbc.budgettracker.core.BudgetTrackerDto;

public class BudgetTrackerDao {
	BudgetTrackerDto btd;
	private Connection myConn;
	private Statement mySmt;

	private static final String SQL = "select * from budget_table;";

	private static Connection getConnection() {

		try {
			// get db properties
			Properties props = new Properties();
			props.load(new FileInputStream(
					"/home/yosuke/git/BudgetTrackerCui/BudgetTrackerCui/sql/config_budgettracker.properties"));

			String user = props.getProperty("user");
			String password = props.getProperty("password");
			String dburl = props.getProperty("dburl");
//			Class.forName(RDB_DRIVE);
			Connection con = DriverManager.getConnection(dburl, user, password);
			return con;
		} catch (Exception e) {
			throw new IllegalStateException(e);
		}
	}

	public List<BudgetTrackerDto> selectAll() throws FileNotFoundException, IOException {
		List<BudgetTrackerDto> budgetList = new ArrayList<>();

		try (Connection conn = BudgetTrackerDao.getConnection(); PreparedStatement ps = conn.prepareStatement(SQL)) {

			try (ResultSet rs = ps.executeQuery()) {
				while (rs.next()) {
					btd = new BudgetTrackerDto();
					btd.setId(rs.getInt("ID"));
					btd.setDate(rs.getDate("Date"));
					btd.setStoreName(rs.getString("StoreName"));
					btd.setProductName(rs.getString("ProductName"));
					btd.setProductType(rs.getString("ProductType"));
					btd.setPrice(rs.getInt("Price"));

					budgetList.add(btd);
				}
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
		}
		return budgetList;
	}

	// Insert
	public int insertIntoTable(BudgetTrackerDto budgetTrackerDto) throws SQLException {
		int rowsCount = 0;
		btd = new BudgetTrackerDto();
		Statement pstmt;
		try {
			// DBに接続
			myConn = BudgetTrackerDao.getConnection();
			pstmt = myConn.createStatement();

//		String sql = "INSERT INTO budget_table(id,Date,StoreName, ProductName, ProductType, Price) " + "VALUE('"
//				+ btd.getId() + "','" + btd.getDate() + "','" + btd.getStoreName() + "','" + btd.getProductName() + "','" + btd.getProductType()
//				+ "','" + btd.getPrice() + "')";

			String sql = "INSERT INTO budget_table(id,Date,StoreName, ProductName, ProductType, Price) "
					+ "VALUE (?,?,?,?,?,?)";
			pstmt = myConn.prepareStatement(sql);
			((PreparedStatement) pstmt).setInt(1, btd.getId());
			((PreparedStatement) pstmt).setTime(2, (Time) btd.getDate());
			((PreparedStatement) pstmt).setString(3, btd.getStoreName());
			((PreparedStatement) pstmt).setString(4, btd.getProductName());
			((PreparedStatement) pstmt).setString(5, btd.getProductType());
			((PreparedStatement) pstmt).setInt(6, btd.getPrice());
			pstmt.executeUpdate(sql);
			pstmt.close();

			// SQL文発行
			rowsCount = pstmt.executeUpdate(sql);
		} catch (SQLException e) {
			System.out.println("Errorが発生しました！\n" + e + "\n");
		} finally {
			// リソースの開放
			if (mySmt != null) {
				try {
					mySmt.close();
				} catch (SQLException ignore) {
				}
			}
			if (myConn != null) {
				try {
					myConn.close();
				} catch (SQLException ignore) {
				}
			}
		}

		return 0;

	}

}

Comments

[jimbe]

「myConn のエラーだから発生した個所の myConn だけ」を見るような視点をもう少し広く、もしくは (「DTO/DAOパターン」といった"応用"より前に) "基本"的な java でのオブジェクトの使い方、さらにはプログラムが動作するとはどういうことか(フロー)そのものまで戻って考え直されたほうがよいのではないでしょうか。

プログラムはコードが書かれている順に実行され、オブジェクトは生成→使用→破棄という順に行う(行われる)ということが分かっていれば、「オブジェクトの生成より前に使用が書かれているコード」となっていることに気が付いても良いように思います。

Answer 1

エラー文では BudgetTrackerDao.java:83 と83 行目で例外がでているようなのですが、
貼っていただいたコードでは79行目に相当するのでずれているかもしれませんが

insertIntoTable の以下の部分で例外がでているようです。

    PreparedStatement pstmt = myConn.prepareStatement(sql);

その下の try 句でコネクションを取得しようとしていますが、
取得する前に呼び出している myCon が初期化されておらずに null になっているのではないでしょうか

Comments

[Yakusugi]

ご回答頂きありがとうございます。
確かに、ご指摘通り、処理の順序を変えた所、SQL文を発行できるところまではたどり着きました。