javaweb--实验十 --期末复盘

实验十 JDBC连接MySQL

本次实验没有代码补全，以下都是完整过程，详细关注连接过程的问题

一、实验目的：

1、掌握JDBC连接数据库的一般操作。
2、理解JavaBean的基本作用。
3、理解分层设计的思想。

二、 实验内容：

实现学生信息的增删改查操作。

注：通过以下提供的实验步骤，最终得到的项目结构如下所示：

【实验步骤】

（1）将jar包“mysql-connector-java-5.0.8-bin.jar”拷贝到tomcat的lib文件夹中。

个人使用的是mysql8.0版本，若有相同，文末自提驱动

（2）在MySQL中，创建名为“my_db”的数据库，并在数据库中创建student表。

create database my_db;

use my_db;

create table student
(sno char(5) primary key,
sname varchar(50),
sage int);

insert into student 
values('99001','张三',20),('99002','李四',21);

（3）新建一个名为”web10”的项目（Web应用程序）。在项目中新建“Java包”，命名为“model”。
（4）在model包中新建“Java类”，命名为“Student”。Student.java为封装student表的JavaBean。

/**
 * 与学生表对应的实体类（封装数据的JavaBean），目的是方便数据传输以及代码维护。
 * JavaBean的要求： 
 * 1、是一个Java 类
 * 2、必须存在无参数构造方法 
 * 3、所有成员变量都是private 
 * 4、私有化的属性必须通过public类型的方法暴露给其它程序， 并且方法的命名也必须遵守一定的命名规范。
 * 即如果想private成员变量被外界访问，提供public的get和set方法。
 */
package model;

public class Student {

    private String sno;
    private String sname;
    private int sage;

    public Student(String sno, String sname, int sage) {
        this.sno = sno;
        this.sname = sname;
        this.sage = sage;
    }

    public Student() {
    }

    public String getSno() {
        return sno;
    }

    public void setSno(String sno) {
        this.sno = sno;
    }

    public String getSname() {
        return sname;
    }

    public void setSname(String sname) {
        this.sname = sname;
    }

    public int getSage() {
        return sage;
    }

    public void setSage(int sage) {
        this.sage = sage;
    }

}

（5）在项目中新建“Java包”，命名为“dal”（Data Access Layer）。该包中存储的文件主要用于数据库访问。
（6）在dal包中创建“Java类”，命名为“Dbutils”。该文件中定义了访问数据库的通用读写方法。

package dal;
import java.sql.*;
public class Dbutils {

    protected Connection conn = null;
    protected PreparedStatement pstmt = null;
    protected ResultSet rs = null;

    /**
     * 获取连接对象
     * @return 连接对象
     */
    public Connection getConnection() {
        try {
            //1、加载驱动类
            Class.forName("com.mysql.jdbc.Driver");
            //2、创建连接对象
            String url = "jdbc:mysql://localhost:3306/my_db?useUnicode=true&characterEncoding=utf-8";
            String user = "root";
            String password = "";
            conn = DriverManager.getConnection(url,user,password);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return conn;
    }

    /**
     * 关闭资源
     *
     * @param conn
     * @param pstmt
     * @param rs
     */
    public void closeAll(Connection conn, PreparedStatement pstmt, ResultSet rs) {
        try {
            if (rs != null) {
                rs.close();
            }
            if (pstmt != null) {
                pstmt.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 增删改操作
     *
     * @param sql
     * @param params
     * @return 
     */
    public int executeUpdate(String sql, Object[] params) {
        this.getConnection();
        int result = 0;
        try {
            //3、创建prepareStatement对象
            pstmt = conn.prepareStatement(sql);
            //4、为占位符赋值
            if (null != params) {
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i + 1, params[i]);
                }
            }
            //5、调用方法：执行sql语句
            result = pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            this.closeAll(conn, pstmt, null);
        }
        return result;
    }

    /**
     * 查询方法
     *
     * @param sql
     * @param params
     * @return
     */
    public ResultSet executeQuery (String sql, Object[] params) {
        this.getConnection();
        try {
            //3、创建prepareStatement对象
            pstmt = conn.prepareStatement(sql);
            //4、为占位符赋值
            if (null != params) {
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i + 1, params[i]);
                }
            }
            //5、调用方法：执行sql语句
            rs = pstmt.executeQuery();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        //后面具体的查询方法还需要用到rs ,所以此处最后不能关闭数据流
        return rs;
    }
}

（7）在dal包中创建“Java类”，命名为“StudentDAO”。该文件中定义了对Student表进行增删改查操作的方法。该类中，需使用model包中的Student类。

package dal;

import model.Student;
import java.util.List;
import java.util.ArrayList;
import java.sql.*;

/**
 * 对Student表进行增删改查的方法
 */
public class StudentDAO {

    Dbutils dbutils = new Dbutils();

    //返回所有的学生信息
    public List<Student> findAllStudents() {
        String sql = "select sno,sname,sage from student";
        Object[] params = null;
        List<Student> list = new ArrayList<>();
        ResultSet rs = dbutils.executeQuery (sql, params);
        try {
            if (null != rs) {
                while (rs.next()) {
                    Student student = new Student();
                    student.setSno(rs.getString("sno"));
                    student.setSname(rs.getString("sname"));
                    student.setSage(rs.getInt("sage"));
                    list.add(student);
                }
            }
        } catch (SQLException ex) {
            ex.printStackTrace();
        } finally {
            dbutils.closeAll(dbutils.conn, dbutils.pstmt, dbutils.rs);
        }
        return list;
    }

    //根据学号查找学生信息
    public Student findBySno(String sno) {
        Student student = new Student();
        String sql = "select sno,sname,sage from student where sno=?";
        Object[] params = {sno};
        ResultSet rs = dbutils.executeQuery (sql, params);
        try {
            if (null != rs) {
                if (rs.next()) {
                    student.setSno(rs.getString("sno"));
                    student.setSname(rs.getString("sname"));
                    student.setSage(rs.getInt("sage"));
                }
            }
        } catch (SQLException ex) {
            ex.printStackTrace();
        } finally {
            dbutils.closeAll(dbutils.conn, dbutils.pstmt, dbutils.rs);
        }
        return student;
    }

    //判断学号在student表中是否存在
    public boolean isSnoExist(String sno) {
        boolean flag = false;
        String sql = "select sno,sname,sage from student where sno=?";
        Object[] params = {sno};
        ResultSet rs = dbutils.executeQuery (sql, params);
        try {
            if (rs != null && rs.next()) {
                flag = true;
            }
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return flag;
    }

    //插入一条学生记录
    public boolean insert(Student student) {
        boolean flag = false;
        String sql = "insert into student(sno,sname,sage) values(?,?,?)";
        Object[] params = {student.getSno(), student.getSname(), student.getSage()};
        return (dbutils.executeUpdate(sql, params) == 1);
    }

    //根据学号，更新该生的其他属性
    public boolean update(Student student) {
        String sql = "update student set sname=?,sage=? WHERE sno=?";
        Object[] params = {student.getSname(), student.getSage(), student.getSno()};
        return dbutils.executeUpdate(sql, params) == 1;
    }

    //根据学号删除学生信息
    public boolean deleteBySno(String sno) {
        String sql = "delete from student where sno=?";
        Object[] params = {sno};
        return dbutils.executeUpdate(sql, params) == 1;
    }
}

（8）在项目中新建“JSP文件”，命名为“student”。该文件为“学生信息管理”的首页。
在该文件中，使用了model包中的Student类，以及dal包中的StudentDAO类。其中，通过dal.StudentDAO类的findAllStudents()方法，返回了student表中的全部记录。

<%@page import="dal.StudentDAO"%>
<%@page import="java.util.List"%>
<%@page import="model.Student"%>
<%@page contentType="text/html" pageEncoding="UTF-8"%>
<!DOCTYPE html>
<html>
    <head>
        <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
        <title>学生信息管理</title>
    </head>
    <body>
        <div align="center">
            <h1>学生信息管理</h1>
            <%
                StudentDAO studentDAO = new StudentDAO();
                //获取所有学生信息
                List<Student> students = studentDAO.findAllStudents();
            %>
            <table border='1' width="80%" >
                <tr><th width="20%">编号</th>
                    <th width="20%">学生学号</th>
                    <th width="20%">姓名</th>
                    <th width="20%">年龄</th>
                    <th width="20%">操作</th>
                </tr>
                <%
                    int rowNum = 0;//行编号
                    for (int i = 0; i < students.size(); i++) {
                        rowNum++;
                        String sno = students.get(i).getSno();
                        String sname = students.get(i).getSname();
                        int sage = students.get(i).getSage();
                        String deleteLink = "delete?sno=" + sno;
                        String editLink = "editPage.jsp?sno=" + sno;
                %>
                <tr>
                    <td><%= rowNum%></td>
                    <td><%= sno%></td>
                    <td><%= sname%></td>
                    <td><%= sage%></td>
                    <!--点击“删除”链接，使用javascript脚本弹出确认对话框，单击“确定”后，才执行删除操作-->
                    <td><a href="<%=deleteLink%>" onClick="return confirm('您确定要删除吗？');">删除</a>
                        <a href='<%=editLink%>'>修改</a></td>               
                </tr>
                <%
                    }
                %>

            </table>
            <br/>
            <form action="add" method = "get">
                学号 <input name="sno">
                姓名 <input name="sname">
                年龄 <input name="sage">
                <input type="submit" value="增加"></br>
            </form>
        </div>
    </body>
</html>

（9）在项目中新建“JSP文件”，命名为“editPage”。该文件为编辑文件的页面。
该文件中，同样使用了model包的Student类以及dal包的StudentDAO类。其中，通过调用dal.studentDAO类的findBySno(Sring sno)方法，返回被选中的学生的基本信息。

<%@page import="model.Student"%>
<%@page import="dal.StudentDAO"%>
<%@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>
        <h1>编辑学生信息</h1>
        <%            
            StudentDAO studentDAO = new StudentDAO();
            String sno = request.getParameter("sno");
            Student student = studentDAO.findBySno(sno);
            String sname = student.getSname();
            int sage = student.getSage();          
        %>
        <form action="edit" method = "get">
            <!--通过readonly="true"，设置学号文本框不能修改-->
            学号 <input name="sno" readonly="true" value=<%=sno%>><br/>
            姓名 <input name="sname" value=<%=sname%>><br/>
            年龄 <input name="sage" value=<%=sage%>><br/><br/>
            <input type="submit" value="提交"></br>
        </form>
    </body>
</html>

（10）在项目中新建“Java包”，命名为“servlet”。该包中存储项目的servlet文件。
（11）在“servlet”包中新建“Java类”，命名为“AddServlet”，实现学生记录的添加。
如果用户输入的学号在学生表存在，则提示“学号重复，添加失败”；否则将学生记录插入到学生表中，并提示“添加成功”。最后，跳转到首页“student.jsp”中。
该文件中调用了dal.StudentDAO类的insert(Student student)方法，实现学生记录的添加。

package servlet;

import dal.StudentDAO;
import java.io.IOException;
import javax.servlet.*;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.*;
import model.Student;

@WebServlet("/add")
public class AddServlet extends HttpServlet {

    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        //设置请求对象的编码方案为utf-8
        req.setCharacterEncoding("utf-8");
        //设置响应对象以及浏览器的字符方案为utf-8
        resp.setContentType("text/html;charset=utf-8");
        StudentDAO studentDAO = new StudentDAO();
        //获取用户输入的学号,判断学号在学生表中是否存在
        String sno = req.getParameter("sno");
        if (studentDAO.isSnoExist(sno)) {
              resp.getWriter().println("<script>alert('学号重复，添加失败');window.location.href='student.jsp'</script>");
        } else {
            //获取用户输入的姓名、年龄
            String sname = req.getParameter("sname");
            String sageStr = req.getParameter("sage");
            Integer sage = Integer.parseInt(sageStr);
            Student student = new Student(sno, sname, sage);
            studentDAO.insert(student);
            //使用javascript脚本输出提示对话框，并跳转到student.jsp页面中
            resp.getWriter().println("<script>alert('添加成功');window.location.href='student.jsp'</script>");
        }
        //不能使用resp.sendRedirect("student.jsp");否则，javascript对话框无法显示。
    }
}

（12）在“serlvet”包中新建“Java类”，命名为“DeleteServlet”。
该文件通过调用dal.StudentDAO类的deleteBySno(String sno)，实现根据学号删除学生记录的操作。

package servlet;

import dal.StudentDAO;
import java.io.IOException;
import javax.servlet.*;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.*;

@WebServlet("/delete")
public class DeleteServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        StudentDAO studentDAO = new StudentDAO();
        String sno = req.getParameter("sno");
        //根据用户输入的学号，删除学生记录
        studentDAO.deleteBySno(sno);
        //重定向到首页student.jsp
        resp.sendRedirect("student.jsp");
    }
}

（13）在“serlvet”包中新建“Java类”，命名为“EditServlet”。
该文件通过调用dal.StudentDAO类的update(Student student)，实现了根据学号修改学生记录的操作。

package servlet;

import dal.StudentDAO;
import java.io.IOException;
import javax.servlet.*;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.*;
import model.Student;

@WebServlet("/edit")
public class EditServlet extends HttpServlet {

    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        req.setCharacterEncoding("utf-8");
        resp.setContentType("text/html;charset=utf-8");
        StudentDAO studentDAO = new StudentDAO();
        String sno = req.getParameter("sno");
        String sname = req.getParameter("sname");
        String sageStr = req.getParameter("sage");
        int sage = Integer.parseInt(sageStr);
        Student student = new Student(sno, sname, sage);
        if (studentDAO.update(student)) {
            resp.getWriter().println("<script>alert('修改成功');window.location.href='student.jsp'</script>");
        } else {
            resp.getWriter().println("<script>alert('程序发生了未知的错误，修改失败');window.location.href='student.jsp'</script>");
        }
    }
}

三、先看实验效果

四、具体连接时的错误（只提供mysql8.0的问题–>个人使用的是MySQL8.0）

1、先提供mysql-connector-java-8.0.11 jar包

链接：https://pan.baidu.com/s/1I_iES9J2EmjRfYjr3ujlOA?pwd=2vyg
提取码：2vyg

2、将下载好的jar包放在tomcat的lib文件夹中

3、遇到的问题：

1、数据库连接问题

主要原因是 ：在Dbutils类中的mysql密码配置中没有正确填写你自己的所对应的数据库连接密码。

解决方法：正确填写密码

修改后的代码

package dal;

import java.sql.*;

/**
 * @Auther zg
 * @Date 2023/12/26
 * @Version 1.0
 */
public class Dbutils {

    protected Connection conn = null;
    protected PreparedStatement pstmt = null;
    protected ResultSet rs = null;

    /**
     * 获取连接对象
     * @return 连接对象
     */
    public Connection getConnection() {
        try {
            //1、加载驱动类
            Class.forName("com.mysql.jdbc.Driver");
            //2、创建连接对象
            String url = "jdbc:mysql://localhost:3306/my_db_web10?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai";
            String user = "root";
            String password = "root";  // 修改处
            conn = DriverManager.getConnection(url,user,password);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return conn;
    }

    /**
     * 关闭资源
     *
     * @param conn
     * @param pstmt
     * @param rs
     */
    public void closeAll(Connection conn, PreparedStatement pstmt, ResultSet rs) {
        try {
            if (rs != null) {
                rs.close();
            }
            if (pstmt != null) {
                pstmt.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 增删改操作
     *
     * @param sql
     * @param params
     * @return
     */
    public int executeUpdate(String sql, Object[] params) {
        this.getConnection();
        int result = 0;
        try {
            //3、创建prepareStatement对象
            pstmt = conn.prepareStatement(sql);
            //4、为占位符赋值
            if (null != params) {
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i + 1, params[i]);
                }
            }
            //5、调用方法：执行sql语句
            result = pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            this.closeAll(conn, pstmt, null);
        }
        return result;
    }

    /**
     * 查询方法
     *
     * @param sql
     * @param params
     * @return
     */
    public ResultSet executeQuery (String sql, Object[] params) {
        this.getConnection();
        try {
            //3、创建prepareStatement对象
            pstmt = conn.prepareStatement(sql);
            //4、为占位符赋值
            if (null != params) {
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i + 1, params[i]);
                }
            }
            //5、调用方法：执行sql语句
            rs = pstmt.executeQuery();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        //后面具体的查询方法还需要用到rs ,所以此处最后不能关闭数据流
        return rs;
    }
}

2、mysql8.0在创建连接对象的时候，需要配置时区

错误原因： 主要是没有在url中配置时区

解决方法：添加时区配置

修改好的代码

package dal;

import java.sql.*;

/**
 * @Auther zg
 * @Date 2023/12/26
 * @Version 1.0
 */
public class Dbutils {

    protected Connection conn = null;
    protected PreparedStatement pstmt = null;
    protected ResultSet rs = null;

    /**
     * 获取连接对象
     * @return 连接对象
     */
    public Connection getConnection() {
        try {
            //1、加载驱动类
            Class.forName("com.mysql.jdbc.Driver");
            //2、创建连接对象
            String url = "jdbc:mysql://localhost:3306/my_db_web10?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai"; // 修改处
            String user = "root";
            String password = "root";
            conn = DriverManager.getConnection(url,user,password);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return conn;
    }

    /**
     * 关闭资源
     *
     * @param conn
     * @param pstmt
     * @param rs
     */
    public void closeAll(Connection conn, PreparedStatement pstmt, ResultSet rs) {
        try {
            if (rs != null) {
                rs.close();
            }
            if (pstmt != null) {
                pstmt.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 增删改操作
     *
     * @param sql
     * @param params
     * @return
     */
    public int executeUpdate(String sql, Object[] params) {
        this.getConnection();
        int result = 0;
        try {
            //3、创建prepareStatement对象
            pstmt = conn.prepareStatement(sql);
            //4、为占位符赋值
            if (null != params) {
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i + 1, params[i]);
                }
            }
            //5、调用方法：执行sql语句
            result = pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            this.closeAll(conn, pstmt, null);
        }
        return result;
    }

    /**
     * 查询方法
     *
     * @param sql
     * @param params
     * @return
     */
    public ResultSet executeQuery (String sql, Object[] params) {
        this.getConnection();
        try {
            //3、创建prepareStatement对象
            pstmt = conn.prepareStatement(sql);
            //4、为占位符赋值
            if (null != params) {
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i + 1, params[i]);
                }
            }
            //5、调用方法：执行sql语句
            rs = pstmt.executeQuery();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        //后面具体的查询方法还需要用到rs ,所以此处最后不能关闭数据流
        return rs;
    }
}

4、总结

以上就是这个实验的我所遇到的连接错误，两个错误都出现在Dbutils，最终的修改的代码就是👆的，若还有其他问题请留言。