Print Friendly, PDF & Email

前回は、JDBCについて学びました。

今回は、DAOパターンについて学びます。

なぜ、DAOパターンが必要なのか?

<JDBCServlet.java>

package p09;

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 javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet(name = "JDBCServlet", urlPatterns = {"/JDBCServlet"})
public class JDBCServlet extends HttpServlet {

    public static final String CONNECT_STRING
            = "jdbc:mysql://localhost:3306/sip_a?characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B9&rewriteBatchedStatements=true";
    public static final String USERID = "newuser";
    public static final String PASSWORD = "0";
    public static final String SQL = "SELECT count(*) FROM customers";

    public static Connection con = null;
    public static PreparedStatement ps = null;
    public static ResultSet rs = null;

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

        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            con = DriverManager.getConnection(CONNECT_STRING, USERID, PASSWORD);

            ps = con.prepareStatement(SQL);
            System.out.println("データベースへの接続に成功しました。");

            rs = ps.executeQuery();

            rs.next();

            request.setAttribute("numOfCustomers", rs.getInt("count(*)"));

            request.getRequestDispatcher("09JDBC/select.jsp").forward(request, response);

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

<select.jsp>

<%@page contentType="text/html" pageEncoding="UTF-8"%>
<!DOCTYPE html>
<html>
    <head>
        <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
        <title>JSP Page</title>
    </head>
    <body>
        現在${numOfCustomers}人のお客様がいます。
    </body>
</html>

DAOクラスとは何か?

package p09;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import p06.CustomerBean;
import p06.CustomersBean;

public class CustomersDAO extends SuperDAO {

    private PreparedStatement ps;

    public int countCustomersBean() {
        
        int ret=0;

        this.open();

        String SQL = "SELECT count(*) FROM customers";
        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;
    }
}

<GoodJDBCServlet>

package p09;

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;

@WebServlet(name = "GoodJDBCServlet", urlPatterns = {"/GoodJDBCServlet"})
public class GoodJDBCServlet extends HttpServlet {

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

        CustomersDAO cd = new CustomersDAO();
        
        request.setAttribute("numOfCustomers", cd.countCustomersBean());

        request.getRequestDispatcher("09JDBC/select.jsp").forward(request, response);

    }
}

<select.jsp> は同じものを使用しています。

WebアプリケーションでJDBCを扱う

SELECT文

INSERT文

UPDATE文

DELETE文

例題1

データベースに格納されたユーザーのIDとパスワードを使い、ログインできるシステムを作成しなさい。

なお、 member_only2.jsp とlogin_error3.jspは以前作成したものを使ってよい。

また、ログイン画面は過去のものをコピーして流用してよい。

1.データベースのイメージ

2.新規作成クラス

<LoginDAO.java>

継承するクラス:SuperDAO

属性

属性名可視性static初期値説明
SQLprivateStringlogin_idとpassword がテーブルに存在するかどうかを問い合わせる
psprivatePreparedStatementnull PreparedStatement インターフェースのオブジェクト

操作

操作名可視性引数リスト返却値static説明
loginpublicString id, String passwordbooleanSQL を実行して、レコードが0件を超えていたらtrueを返す、超えていなければfalseを返す。

<LoginServlet.java>

継承するクラス:HttpServlet

urlPatterns:/LoginServlet

属性:なし

操作

操作名可視性引数リスト返却値static説明
doPostprotectedHttpServletRequest request, HttpServletResponse responsevoidフォームから送信されたidとpassを元に、LoginDAOを使ってログインを試みる。ログインできた場合は、member_only2.jspにフォワードする。ログインできなかった場合はlogin_error3.jspにリダイレクトする。

まとめ

JavaWebアプリケーション目次に戻る