8.Javaからデータベースを活用する

package dao;

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

public class SuperDAO {

	private static final String CONNECT_STRING 
	= "jdbc:mysql://localhost:3306/sip_a?characterEncoding=utf8&"
	+ "useSSL=false&serverTimezone=GMT%2B9&rewriteBatchedStatements=true";
	private static final String USER_ID = "newuser";
	private static final String PASSWORD = "0";
	protected Connection con = null;

	protected void connect() {
		try {
			con = DriverManager.getConnection(CONNECT_STRING, USER_ID, PASSWORD);
			System.out.println("データベースへの接続に成功しました。");
		} catch (SQLException e) {
			System.err.println("データベースへの接続時に問題が発生しました。");
			System.err.println(e);
		}
	}

	protected void close(PreparedStatement ps) {
		try {
			if (ps != null) {
				ps.close();
			}
			if (con != null) {
				con.close();
			}
			System.out.println("データベースからの切断に成功しました。");
		} catch (SQLException e) {
			System.err.println("データベースからの切断時に問題が発生しました。");
			System.err.println(e);
		}
	}
}

	public static void main(String[] args) {
		SuperDAO sd = new SuperDAO();
		PreparedStatement ps = null;
		sd.connect();
		sd.close(ps);
	}

package 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;

		this.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 {
			this.close(ps);
		}
		return ret;
	}

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

package dao;

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

public class WithoutSuperClass {

	private static final String CONNECT_STRING = "jdbc:mysql://localhost:3306/sip_a?characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B9&rewriteBatchedStatements=true";
	private static final String USER_ID = "newuser";
	private static final String PASSWORD = "0";
	private static Connection con = null;
	private static PreparedStatement ps = null;

	public int countCars() {
		try {
			con = DriverManager.getConnection(CONNECT_STRING, USER_ID, PASSWORD);
			System.out.println("データベースへの接続に成功しました。");
		} catch (SQLException e) {
			System.err.println("データベースへの接続時に問題が発生しました。");
			System.err.println(e);
		}

		int ret = 0;

		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 {
			try {
				if (ps != null) {
					ps.close();
				}
				if (con != null) {
					con.close();
				}
				System.out.println("データベースからの切断に成功しました。");
			} catch (SQLException e) {
				System.err.println("データベースからの切断時に問題が発生しました。");
				System.err.println(e);
			}
		}
		return ret;
	}

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

package dao;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.time.LocalDateTime;

import model.CarBean;
import model.CarsBean;

public class CarsDAO extends SuperDAO {

	private PreparedStatement ps;

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

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

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

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

		try {
			// トライブロックの開始
			// SQLクエリを準備するために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);
		} finally {
			// 最終処理
			// PreparedStatementを閉じてリソースを解放
			this.close(ps);
		}

		// 車の総数を返す
		return ret;
	}

// メソッドの開始：CarsBeanオブジェクトを取得するメソッド
public CarsBean getCarsBean() {

    // CarsBeanオブジェクトのインスタンスを生成
    CarsBean carsBean = new CarsBean();

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

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

    try {
        // トライブロックの開始
        // SQLクエリを準備するためにPreparedStatementを作成
        ps = con.prepareStatement(SQL);

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

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

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

            // 取得した車のデータをCarsBeanに追加
            carsBean.addCar(car);
        }
    } catch (SQLException e) {
        // SQL例外が発生した場合の処理
        // エラーメッセージをコンソールに出力
        System.err.println(e);
    } finally {
        // 最終処理
        // PreparedStatementを閉じてリソースを解放
        this.close(ps);
    }

    // 取得したCarsBeanを返す
    return carsBean;
}

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

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

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

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

		try {
			// SQLクエリを準備する
			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"));
			}

		} catch (SQLException e) {
			// SQL例外が発生した場合、エラーをコンソールに出力する
			System.err.println(e);
		} finally {
			// リソース（PreparedStatement）を安全に閉じる
			this.close(ps);
		}

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

package 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 {
			this.close(ps);
		}
	}

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

package 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を整数値で指定してください");

			int id = 0;
			try (Scanner sc = new Scanner(System.in)) {
				String customer_id = sc.nextLine();
				id = Integer.parseInt(customer_id);
			}

			ps = con.prepareStatement(SQL);
			ps.setInt(1, 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 {
			this.close(ps);
		}
	}

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

	public CarsBean getSortedCarsBean(String sortField, boolean isAscending) {
		CarsBean carsBean = new CarsBean();
		this.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 {
	        // トライブロックの開始
	        // SQLクエリを準備するためにPreparedStatementを作成
	        ps = con.prepareStatement(SQL);

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

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

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

	            // 取得した車のデータをCarsBeanに追加
	            carsBean.addCar(car);
	        }
	    } catch (SQLException e) {
	        // SQL例外が発生した場合の処理
	        // エラーメッセージをコンソールに出力
	        System.err.println(e);
	    } finally {
	        // 最終処理
	        // PreparedStatementを閉じてリソースを解放
	        this.close(ps);
	    }

	    // 取得したCarsBeanを返す
	    return carsBean;
	}

	// 指定されたフィールド名が有効かどうかをチェックするメソッド
	private boolean isValidSortField(String field) {
		// 許可されたフィールド名の配列
		String[] validFields = { "car_id", "name", "price", "created_at", "updated_at", "deleted_at" };

		// 与えられたフィールド名が配列内に存在するかどうかを確認
		for (String validField : validFields) {
			if (validField.equals(field)) {
				return true;
			}
		}
		return false;
	}

	// キーワードに基づいて車を検索し、その結果をCarsBeanに格納して返すメソッド
	public CarsBean searchCarsBean(String keyword) {

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

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

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

		try {
			// SQLクエリを準備する
			ps = con.prepareStatement(SQL);

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

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

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

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

				// 取得した車の情報をCarsBeanに追加する
				carsBean.addCar(car);
			}
		} catch (SQLException e) {
			// SQL例外が発生した場合、エラーをコンソールに出力する
			System.err.println(e);
		} finally {
			// リソース（PreparedStatement）を安全に閉じる
			this.close(ps);
		}

		// 検索結果を含むCarsBeanを返す
		return carsBean;
	}

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

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

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

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

    try {
        // トライブロックの開始
        // SQL文をデータベースに送るためのPreparedStatementを作成
        ps = con.prepareStatement(SQL);

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

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

    } catch (SQLException e) {
        // SQL処理中に例外が発生した場合のエラーハンドリング
        System.err.println(e);
    } finally {
        // 最終処理としてPreparedStatementを安全に閉じる
        this.close(ps);
    }

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

//	データベース内の特定の車の情報を更新するためのメソッド	
	public int updateACar(CarBean aCar) {
		// 更新に成功したレコードの数を保持する変数を初期化
		int ret = 0;
		// データベースに接続
		this.connect();
		// 車の情報を更新するSQL文を定義
		String SQL 
		= "UPDATE cars SET name = ?, price = ?, deleted_at = ? WHERE car_id = ?";

		try {
			// SQL文を準備
			ps = con.prepareStatement(SQL);

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

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

		} catch (SQLException e) {
			// SQL例外が発生した場合、エラーを出力
			System.err.println(e);
		} finally {
			// 最後にデータベース接続を閉じる
			this.close(ps);
		}
		// 更新に成功したレコードの数を返す
		return ret;
	}

<%@page contentType="text/html" pageEncoding="UTF-8"%>
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>ログイン画面</title>
<style>
#center {
	height: 200px;
	width: 300px;
	position: absolute;
	left: 50%;
	top: 50%;
	margin-top: -100px;
	margin-left: -150px;
	text-align: center;
}
</style>
</head>
<body>
	<div id="center">
		<form action="/03_JavaWebText/LoginServlet" method="post">
			ユーザーID：<input type="text" name="id" required><br>
			パスワード：<input type="password" name="pass" required><br>
			<input type="submit" value="ログイン"><br>
		</form>
	</div>
</body>
</html>

package p08.dao;

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

public class LoginDAO extends SuperDAO {

	private final String SQL 
    = "SELECT * FROM login_user where login_id = ? and password = ?";
	private PreparedStatement ps = null;

	public boolean login(String id, String password) {

		try {
			this.connect();

			ps = con.prepareStatement(SQL);

			ps.setString(1, id);
			ps.setString(2, password);

			ResultSet rs = ps.executeQuery();

			int cnt = 0;

			while (rs.next()) {
				cnt++;
			}

			if (cnt > 0) {
				return true;
			}
		} catch (SQLException e) {
			System.err.println(e);
		} finally {
			this.close();
		}
		return false;
	}
}

package p08;

import java.io.IOException;

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 javax.servlet.http.HttpSession;

import p08.dao.LoginDAO;

@WebServlet(urlPatterns = { "/LoginServlet" })
public class LoginServlet extends HttpServlet {

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

        String id = request.getParameter("id");
        String pass = request.getParameter("pass");

        HttpSession session = request.getSession();

        session.setAttribute("id", id);
        session.setAttribute("message",
                "こんにちは" + id + "さん。");

        LoginDAO ld = new LoginDAO();

        if (ld.login(id, pass)) {
            request.getRequestDispatcher(
                    "/05Login/member_only2.jsp")
                    .forward(request, response);
        } else {
            response.sendRedirect(
                    "/03_JavaWebText/05Login/login_error3.jsp");
        }
    }
}