实验十 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 {@Overrideprotected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {//设置请求对象的编码方案为utf-8req.setCharacterEncoding("utf-8");//设置响应对象以及浏览器的字符方案为utf-8resp.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 {@Overrideprotected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {StudentDAO studentDAO = new StudentDAO();String sno = req.getParameter("sno");//根据用户输入的学号，删除学生记录studentDAO.deleteBySno(sno);//重定向到首页student.jspresp.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 {@Overrideprotected 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，最终的修改的代码就是👆的，若还有其他问题请留言。