8. Spring BootとMySQLの連携 〜 データを保存・取得しよう

		<dependency>
			<groupId>com.mysql</groupId>
			<artifactId>mysql-connector-j</artifactId>
			<scope>runtime</scope>
		</dependency>

package com.example.demo.model.dao;

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

/**
 * Daoクラス - 各daoの基底クラス データベースへの接続、切断、クエリ実行など各dao共通の機能を実装する
 * 
 * @author Say Consulting Group
 * @version 1.0.0
 */
public class SuperDao {

	/** DB接続オブジェクト */
	protected Connection con = null;

	/** DB接続情報 */
	private static final String DB_URI = "jdbc:mysql://localhost:3306/sip_a?characterEncoding=utf8&"
			+ "useSSL=false&serverTimezone=GMT%2B9&rewriteBatchedStatements=true";
	private static final String DB_USER = "newuser";
	private static final String DB_PASS = "0";

	/**
	 * connectメソッド データベースへの接続を開始する
	 */
	protected void connect() {
		try {
			// データベース接続用ドライバをロード
			// javaSE8から不要な処理となったが、Tomcatを利用する場合は必要なので、記述
			Class.forName("com.mysql.cj.jdbc.Driver");
			// ドライバを用いてデータベースへの接続を開く
			con = DriverManager.getConnection(DB_URI, DB_USER, DB_PASS);
			System.out.println("データベースへの接続に成功しました。");
		} catch (SQLException e) {
			String errMsg = "データベースへの接続時に問題が発生しました。";
			System.err.println(errMsg);
			System.err.println(e);
		} catch (ClassNotFoundException e) {
			String errMsg = "データベース接続用クラスが見つかりません。";
			System.err.println(errMsg);
			System.err.println(e);
		}
	}

	/**
	 * closeメソッド DBとの接続を切断する 各オブジェクトを再初期化する
	 */
	protected void close() {
		try {
			if (con != null) {
				con.close();
				con = null;
			}
			System.out.println("データベースからの切断に成功しました。");
		} catch (SQLException e) {
			String errMsg = "データベースからの切断時に問題が発生しました。";
			System.err.println(errMsg);
			System.err.println(e);
		}
	}
}

	public static void main(String[] args) {
		SuperDao superDao = new SuperDao();
		superDao.connect();
		superDao.close();
	}

package model.dao;

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

public class WithSuperClass extends SuperDao {

	private PreparedStatement ps;

	public int countCars() {

		int ret = 0;

		connect();

		String SQL = "SELECT count(*) FROM cars";
		try {
			ps = con.prepareStatement(SQL);

			ResultSet rs = ps.executeQuery();

			rs.next();

			ret = rs.getInt("count(*)");

		} catch (SQLException e) {
			System.err.println(e);
		} finally {
			close();
		}
		return ret;
	}

	public static void main(String[] args) {
		WithSuperClass wsc = new WithSuperClass();
		System.out.println(wsc.countCars());
	}
}

package com.example.demo.model.dao;

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


public class CarsDao extends SuperDao {

	// メソッドの開始：車の数をカウントするメソッド
	public int countCars() {

		// カウントした車の数を保持するための整数変数retを初期化
		int ret = 0;

		// データベースに接続するメソッドを呼び出し
		connect();

		// 車の総数を取得するためのSQLクエリを定義
		String sql = "SELECT count(*) FROM cars";

        // try-with-resources文を使用してPreparedStatementを作成
		try (PreparedStatement ps = con.prepareStatement(sql)) {

			// クエリを実行し、結果をResultSetに格納
			ResultSet rs = ps.executeQuery();

			// ResultSetの最初の行に移動
			rs.next();

			// ResultSetから車の総数を取得してretに代入
			ret = rs.getInt("count(*)");

		} catch (SQLException e) {
			// SQL例外が発生した場合の処理
			// エラーメッセージをコンソールに出力
			System.err.println(e);
		}

		close();

		// 車の総数を返す
		return ret;
	}
（以下のメソッドはこの後、順番に紹介します）

package com.example.demo.model.dto;

import java.io.Serializable; // オブジェクトのバイト列化（シリアライズ）を可能にするインターフェース
import java.time.LocalDateTime; // 日付と時刻を扱うためのクラス

public class CarDto implements Serializable {

	/** 車のID（データベースの主キーを想定） */
	private int carId;

	/** 車の名前またはモデル名 */
	private String name;

	/** 車の価格（整数型で金額を格納） */
	private int price;

	/**
	 * 論理削除された日時を文字列として格納。 DBのカラムが date/datetime であっても、 プログラム側で文字列として管理する場合がある。 null
	 * や空文字の場合は「未削除」を表す想定。
	 */
	private String deletedAt;

	/**
	 * デフォルトコンストラクタ（引数なし） JavaBeans ルールに従い、 new CarsDto() のように引数無しで生成可能にする。
	 */
	public CarDto() {
	}

	/**
	 * フィールドをまとめて初期化するコンストラクタ。
	 * 
	 * @param carId     車のID
	 * @param name      車の名前
	 * @param price     車の価格
	 * @param deletedAt 論理削除された日時（未削除の場合はnullや空文字）
	 */
	public CarDto(int carId, String name, int price, String deletedAt) {
		this.carId = carId;
		this.name = name;
		this.price = price;
		this.deletedAt = deletedAt;
	}

	/**
	 * 車のIDを取得するメソッド。
	 * 
	 * @return carId
	 */
	public int getCarId() {
		return carId;
	}

	/**
	 * 車のIDを設定するメソッド。
	 * 
	 * @param carId セットしたいID
	 */
	public void setCarId(int carId) {
		this.carId = carId;
	}

	/**
	 * 車の名前を取得するメソッド。
	 * 
	 * @return name
	 */
	public String getName() {
		return name;
	}

	/**
	 * 車の名前を設定するメソッド。
	 * 
	 * @param name セットしたい車の名称
	 */
	public void setName(String name) {
		this.name = name;
	}

	/**
	 * 車の価格を取得するメソッド。
	 * 
	 * @return price
	 */
	public int getPrice() {
		return price;
	}

	/**
	 * 車の価格を設定するメソッド。
	 * 
	 * @param price セットしたい価格
	 */
	public void setPrice(int price) {
		this.price = price;
	}

	/**
	 * 論理削除された日時を取得するメソッド。
	 * 
	 * @return deletedAt 物理削除されず、論理削除された場合は日時文字列を格納
	 */
	public String getDeletedAt() {
		return deletedAt;
	}

	/**
	 * 論理削除された日時を設定するメソッド。
	 * 
	 * @param deletedAt 論理削除した日時
	 */
	public void setDeletedAt(String deletedAt) {
		this.deletedAt = deletedAt;
	}

	/**
	 * デバッグやログ出力などでオブジェクト内容を簡単に把握できるよう、 フィールドの値を文字列として整形して返す。
	 * 
	 * @return CarsDtoのフィールド情報を整形した文字列
	 */
	@Override
	public String toString() {
		return "CarsDto [carId=" + carId + ", name=" + name + ", price=" + price + ", deletedAt=" + deletedAt + "]";
	}
}

	public ArrayList<CarDto> getCarList() {

	    // CarDtoのリストを作成
	    ArrayList<CarDto> carList = new ArrayList<>();

	    // データベースに接続するメソッドを呼び出し
	    connect();

	    // 'cars'テーブルから全てのデータを選択するSQLクエリを定義
	    String sql = "SELECT * FROM cars";

	    try (PreparedStatement ps = con.prepareStatement(sql)) {

	        // クエリを実行し、結果をResultSetに格納
	        ResultSet rs = ps.executeQuery();

	        // ResultSetを繰り返し処理し、各車のデータを取得
	        while (rs.next()) {
	            // CarDtoオブジェクトを生成
	            CarDto car = new CarDto();

	            // CarDtoにcar_id, name, price, deleted_atを設定
	            car.setCarId(rs.getInt("car_id"));
	            car.setName(rs.getString("name"));
	            car.setPrice(rs.getInt("price"));
	            car.setDeletedAt(rs.getString("deleted_at"));

	            // 取得した車のデータをリストに追加
	            carList.add(car);
	        }
	    } catch (SQLException e) {
	        // SQL例外が発生した場合の処理
	        System.err.println(e);
	    }
	    close();
	    
	    // 取得したリストを返す
	    return carList;
	}

	// 特定のIDを持つ車の情報をデータベースから取得するメソッド
	public CarBean getCar(int id) {

		// CarBeanの新しいインスタンスを生成
		CarBean car = new CarBean();

		// データベースへの接続を行う
		connect();

		// 指定されたcar_idに基づいて車の情報を取得するSQLクエリ
		String sql = "select * from cars where car_id = ?";

		try (PreparedStatement ps = con.prepareStatement(sql)) {

			// クエリのパラメータ（car_id）を設定する
			ps.setInt(1, id);

			// クエリを実行し、結果をResultSetに格納する
			ResultSet rs = ps.executeQuery();

			// 結果セットにデータが存在する場合のみ処理を行う
			if (rs.next()) {

				// ResultSetから車の情報を取得し、CarBeanにセットする
				car.setCarId(rs.getInt("car_id"));
				car.setName(rs.getString("name"));
				car.setPrice(rs.getInt("price"));
				car.setDeletedAt(rs.getString("deleted_at"));
			}

		} catch (SQLException e) {
			// SQL例外が発生した場合、エラーをコンソールに出力する
			System.err.println(e);
		}
		close();

		// 取得した車の情報を含むCarBeanを返す
		return car;
	}

package model.dao;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Scanner;

public class SQLInjection extends SuperDao {

	public static String SQL = "SELECT * FROM customers where customer_id = ";

	PreparedStatement ps = null;
	ResultSet rs = null;

	public void getACustomer() {

		try {
			connect();
			System.out.println("customer_idを整数値で指定してください");
			try (Scanner sc = new Scanner(System.in)) {
				String customer_id = sc.nextLine();
				SQL += customer_id;
			}

			ps = con.prepareStatement(SQL);

			rs = ps.executeQuery();
			while (rs.next()) {
				System.out.print(rs.getInt("customer_id") + ":");
				System.out.print(rs.getString("name") + ":");
				System.out.print(rs.getString("mail") + ":");
				System.out.print(rs.getString("mobile") + ":");
				System.out.println(rs.getString("pass"));
			}
		} catch (SQLException e) {
			System.err.println("データベースへの接続時に問題が発生しました。");
			System.err.println(e);
		} finally {
			close();
		}
	}

	public static void main(String[] args) {
		SQLInjection sqlInjection = new SQLInjection();
		sqlInjection.getACustomer();
	}
}

package model.dao;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Scanner;

public class Placeholder extends SuperDao {

	public static final String SQL = "SELECT * FROM customers where customer_id = ?";

	PreparedStatement ps = null;
	ResultSet rs = null;

	public void getACustomer() {

		try {
			connect();
			System.out.println("customer_idを整数値で指定してください");

			String customer_id;
			try (Scanner sc = new Scanner(System.in)) {
				customer_id = sc.nextLine();
			}

			ps = con.prepareStatement(SQL);
			ps.setString(1, customer_id);

			rs = ps.executeQuery();
			while (rs.next()) {
				System.out.print(rs.getInt("customer_id") + ":");
				System.out.print(rs.getString("name") + ":");
				System.out.print(rs.getString("mail") + ":");
				System.out.print(rs.getString("mobile") + ":");
				System.out.println(rs.getString("pass"));
			}
		} catch (SQLException e) {
			System.err.println("データベースへの接続時に問題が発生しました。");
			System.err.println(e);
		} finally {
			close();
		}
	}

	public static void main(String[] args) {
		Placeholder placeholder = new Placeholder();
		placeholder.getACustomer();
	}
}

	// 任意のフィールドで昇順または降順に並べ替えるメソッド
	public List<CarDto> getSortedCarList(String sortField, boolean isAscending) {
		ArrayList<CarDto> carList = new ArrayList<>();

		connect();

		// sortFieldが有効なフィールド名であるか確認
		if (!isValidSortField(sortField)) {
			throw new IllegalArgumentException("Invalid sort field: " + sortField);
		}

		String sortOrder = isAscending ? "ASC" : "DESC";
		String sql = "SELECT * FROM cars ORDER BY " + sortField + " " + sortOrder;

		try (PreparedStatement ps = con.prepareStatement(sql)) {

			// クエリを実行し、結果をResultSetに格納
			ResultSet rs = ps.executeQuery();

			// ResultSetを繰り返し処理し、各車のデータを取得
			while (rs.next()) {
				// 一時的に車の情報を保持するCarDtoオブジェクトのインスタンスを生成
				CarDto car = new CarDto();

				// CarDtoにcar_id, name, price, deleted_atを設定
				car.setCarId(rs.getInt("car_id"));
				car.setName(rs.getString("name"));
				car.setPrice(rs.getInt("price"));
				car.setDeletedAt(rs.getString("deleted_at"));

				// 取得した車のデータをリストに追加
				carList.add(car);
			}
		} catch (SQLException e) {
			// SQL例外が発生した場合の処理
			System.err.println(e);
		}
		close();

		// 取得したリストを返す
		return carList;
	}

	// キーワードに基づいて車を検索し、その結果をリストに格納して返すメソッド
	public List<CarDto> searchCarList(String keyword) {

	    // CarDtoのリストを生成
	    List<CarDto> carList = new ArrayList<>();

	    // データベースへの接続を行う
	    connect();

	    // 指定されたキーワードに基づいて車の情報を検索するSQLクエリ
	    String sql = "SELECT * FROM cars WHERE name LIKE ?";

	    try (PreparedStatement ps = con.prepareStatement(sql)) {

	        // クエリのパラメータ（nameの検索キーワード）をあいまい検索で設定する
	        ps.setString(1, "%" + keyword + "%");

	        // クエリを実行し、結果をResultSetに格納する
	        ResultSet rs = ps.executeQuery();

	        // 結果セットの各行を繰り返し処理し、車の情報を取得する
	        while (rs.next()) {
	            // 一時的に車の情報を保持するCarDtoの新しいインスタンスを生成
	            CarDto car = new CarDto();

	            // ResultSetから車の情報を取得し、CarDtoにセットする
	            car.setCarId(rs.getInt("car_id"));
	            car.setName(rs.getString("name"));
	            car.setPrice(rs.getInt("price"));
	            car.setDeletedAt(rs.getString("deleted_at"));

	            // 取得した車の情報をリストに追加する
	            carList.add(car);
	        }
	    } catch (SQLException e) {
	        // SQL例外が発生した場合、エラーをコンソールに出力する
	        System.err.println(e);
	    }
	    close();

	    // 検索結果を含むリストを返す
	    return carList;
	}

// 新しい車のデータをデータベースに追加するメソッド
public int addCar(CarDto car) {

    // 返り値として使用する整数型変数を初期化
    int ret = 0;

    // データベースへの接続を行う
    connect();

    // 新しい車を追加するためのSQL文を定義
    String sql = "INSERT INTO cars(name, price) VALUES(?, ?);";

    try (PreparedStatement ps = con.prepareStatement(sql)) {

        // PreparedStatementに車の名前と価格をセット
        ps.setString(1, car.getName());
        ps.setInt(2, car.getPrice());

        // SQL文を実行し、処理された行数をretに代入
        ret = ps.executeUpdate();

    } catch (SQLException e) {
        // SQL処理中に例外が発生した場合のエラーハンドリング
        System.err.println(e);
    }

    close();

    // 処理された行数を返す
    return ret;
}

// データベース内の特定の車の情報を更新するためのメソッド
public int updateCar(CarDto car) {
    // 更新に成功したレコードの数を保持する変数を初期化
    int ret = 0;

    // データベースに接続
    connect();

    // 車の情報を更新するSQL文を定義
    String sql = "UPDATE cars SET name = ?, price = ?, deleted_at = ? WHERE car_id = ?";

    try (PreparedStatement ps = con.prepareStatement(sql)) {

        // SQL文のパラメータを設定
        ps.setString(1, car.getName()); // 車の名前
        ps.setInt(2, car.getPrice()); // 価格
        ps.setString(3, car.getDeletedAt()); // 削除日時
        ps.setInt(4, car.getCarId()); // 車のID

        // SQL文を実行し、影響を受けたレコードの数を取得
        ret = ps.executeUpdate();

    } catch (SQLException e) {
        // SQL例外が発生した場合、エラーを出力
        System.err.println(e);
    }

    close();

    // 更新に成功したレコードの数を返す
    return ret;
}

package model.dao;

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

public class LoginDao extends SuperDao {

	// ログインメソッド。ユーザーIDとパスワードを受け取り、ログイン成功かどうかを返す
	public boolean login(String id, String pass) {
		boolean isSuccess = false;

		// ユーザーIDとパスワードに一致するレコードが存在するかをカウントするクエリ
		String query = "SELECT COUNT(*) FROM login_user WHERE login_id = ? AND password = ?";

		// データベースに接続する
		connect();

		// try-with-resourcesを使用してPreparedStatementとResultSetを自動的にクローズ
		try (PreparedStatement ps = con.prepareStatement(query)) {

			// クエリの最初のプレースホルダーにユーザーIDをセット
			ps.setString(1, id);
			// クエリの二番目のプレースホルダーにパスワードをセット
			ps.setString(2, pass);

			// クエリを実行して結果セットを取得
			ResultSet rs = ps.executeQuery();

			// 結果セットが存在し、最初のカラムの値が0より大きければログイン成功
			if (rs.next()) {
				isSuccess = rs.getInt("COUNT(*)") > 0;
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			// データベース接続を閉じる
			close();
		}

		// ログイン成功または失敗を返す
		return isSuccess;
	}
}

package com.example.demo.controller;

import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;

import com.example.demo.dao.LoginDao;

import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpSession;

@Controller
public class LoginController {

    @GetMapping("/")
    public String showLoginPage() {
        return "login"; // `login.html` を表示
    }

    @PostMapping("/login")
    public String login(
            @RequestParam("id") String id,
            @RequestParam("pass") String pass,
            HttpServletRequest request,
            Model model) {

        // DAOを手動でインスタンス化
        LoginDao loginDao = new LoginDao();

        // 入力チェック
        if (id.isEmpty() || pass.isEmpty()) {
            model.addAttribute("error", "ユーザーIDまたはパスワードを入力してください");
            return "login-error"; // `login-error.html` に遷移
        }

        // 認証処理
        if (loginDao.login(id, pass)) {
            HttpSession session = request.getSession();
            session.setAttribute("id", id); // セッションにユーザーIDを保存

            return "redirect:/member-only2"; // ログイン成功時、メンバー専用ページへリダイレクト
        } else {
            model.addAttribute("error", "ユーザーIDまたはパスワードが間違っています");
            return "login-error"; // `login-error.html` に遷移
        }
    }

    @GetMapping("/logout")
    public String logout(HttpServletRequest request) {
        HttpSession session = request.getSession(false);
        if (session != null) {
            session.invalidate(); // セッションを無効化
        }
        return "redirect:/login"; // ログアウト後にログインページへ
    }
}

package com.example.demo.controller;

import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.GetMapping;

import jakarta.servlet.http.HttpSession;

@Controller
public class MemberController {

	@GetMapping("/member-only2")
	public String memberPage(HttpSession session, Model model) {
		// セッションがない場合、またはIDがない場合はログインページへリダイレクト
		if (session.getAttribute("id") == null) {
			return "redirect:/login";
		}

		return "member-only2"; // `member-only2.html` を表示
	}

	@GetMapping("/video")
	public String videoPage(HttpSession session, Model model) {
		// セッションがない場合、またはIDがない場合はログインページへリダイレクト
		if (session.getAttribute("id") == null) {
			return "redirect:/login";
		}
		
		return "video"; // `video.html` を表示
	}
}