JSP+Servlet实现对数据库增编削查之进阶mvc架构

1.Bean层（Model层）​

• 脚色：就像餐厅里的“菜品”。
  
• ​功能：是纯数据对象（如Person类），封装属性和 getter/setter（比方用户名、密码）。
  
• ​示例：Person类
  

1. package com.bean;
3. public class Person {
4.     private int id;
5.     private String name;
6.     private String pwd;
8.     public int getId() {
9.         return id;
10.     }
12.     public void setId(int id) {
13.         this.id = id;
14.     }
16.     public String getName() {
17.         return name;
18.     }
20.     public void setName(String name) {
21.         this.name = name;
22.     }
24.     public String getPwd() {
25.         return pwd;
26.     }
28.     public void setPwd(String pwd) {
29.         this.pwd = pwd;
30.     }
31. }

复制代码

2.Dao层（Data Access Object）​

• 脚色：后厨的“厨师”，专注做菜（操纵数据）。
  
• ​功能：直接和数据库对话，实行增编削查（CRUD）。
  
• ​示例：UserDAO 类中的 saveUser(User user) 方法，负责把用户数据存入数据库。
  

接口

1. package com.dao;
3. import com.bean.Person;
5. import java.sql.SQLException;
6. import java.util.List;
8. public interface PersonDao {
10.     public List<Person> queryAll() throws SQLException;
11.     public  Boolean selectOne(Person person) throws SQLException;
12.     public int save(Person person) throws SQLException;
13. }

复制代码

实现接口

1. package com.dao.impl;
3. import com.bean.Person;
4. import com.dao.PersonDao;
5. import com.db.DB;
7. import java.sql.*;
8. import java.util.ArrayList;
9. import java.util.List;
11. public class PersonDaoImpl implements PersonDao {
12.     // ------------------------- 方法1：查询所有用户 -------------------------
13.     @Override
14.     public List<Person> queryAll() throws SQLException {
15.         Connection connection=new DB().getConnection(); //获取数据库连接
16.         Statement statement= connection.createStatement(); //创建SQL执行器
17.         ResultSet resultSet= statement.executeQuery("select * from person"); //执行查询SQL语句
19.         List list=new ArrayList(); //准备空集合装数据
21.         while (resultSet.next()){  //遍历查询结果（一行一行读）
23.             Person p=new Person(); //新建数据盒子
25.             p.setId(resultSet.getInt(1));  //取第一列（id）放入盒子
26.             p.setName(resultSet.getString(2));  //取第二列（name）放入
27.             p.setPwd(resultSet.getString(3));  //取第三列（pwd）放入
28.             list.add(p); //把盒子加入集合
29.         }
30.         resultSet.close();
31.         statement.close();
32.         connection.close();
33.         return list;
34.     }
35.     // ------------------------- 方法2：检查用户名是否存在 -------------------------
36.     @Override
37.     public Boolean selectOne(Person person) throws SQLException {
38.         //Connection connection=new DB().getConnection(); getConnection()为静态方法就可以之间如下:
39.         Connection connection= DB.getConnection(); //获取一个数据库连接
40.         PreparedStatement statement= connection.prepareStatement("select * from person where name=?");
42.         statement.setString(1,person.getName()); //设置参数（替换第一个问号）
43.         ResultSet resultSet= statement.executeQuery(); //执行查询
44.         if (resultSet.next()){
45.             return false;
46.         }else {
47.            return true;
48.        }
49.     }
50.     // ------------------------- 方法3：保存用户 -------------------------
51.     @Override
52.     public int save(Person person) throws SQLException {
53.         Connection connection= DB.getConnection();
54.         //  预编译SQL（提高性能，防止注入）
55.         PreparedStatement statement= connection.prepareStatement("insert into person(name,pwd) values(?,?)");
57.         statement.setString(1,person.getName()); //设置第一个参数（name）
58.         statement.setString(2,person.getPwd()); //设置第二个参数（pwd）
59.         int i= statement.executeUpdate(); //执行插入操作
60.         statement.close();
61.         connection.close();
62.         return i; //返回影响的行数（1=成功，0=失败）
63.     }
64. }

复制代码

3.DB（驱动连接数据库）

• ​脚色：餐厅的“仓库”，存储所有食材。
  
• ​功能：持久化生存数据（如 MySQL、PostgreSQL）
  

1. package com.db;
3. import java.sql.Connection;
4. import java.sql.DriverManager;
5. import java.sql.SQLException;
7. public  class  DB {
8.     public static Connection getConnection(){
9.         Connection connection=null;
10.         try {
11.             Class.forName("com.mysql.cj.jdbc.Driver");
12.             connection= DriverManager.getConnection("jdbc:mysql://localhost:3306/users?serverTimezone=GMT%2B8","root","123456");
13.         } catch (ClassNotFoundException e) {
14.             e.printStackTrace();
15.         } catch (SQLException e) {
16.             e.printStackTrace();
17.         }
18.         return connection;
19.     }
21. }

复制代码

4.Service层

• 脚色：餐厅的“经理”，和谐复杂流程。
  
• ​功能：处理业务逻辑（比方注册时检查用户名是否重复 + 加密密码）。
  
• ​示例：UserService 的 registerUser() 方法会调用 DAO 的多个操纵，并处理事件。
  

接口

1. package com.service;
3. import com.bean.Person;
5. import java.sql.SQLException;
6. import java.util.List;
8. public interface PersonSercie {
9.     public List<Person> AllPerson() throws SQLException;
11.     public boolean register(Person person) throws SQLException;
12. }

复制代码

实现接口

1. package com.service.impl;
3. import com.bean.Person;
4. import com.dao.PersonDao;
5. import com.dao.impl.PersonDaoImpl;
6. import com.service.PersonSercie;
8. import java.sql.SQLException;
9. import java.util.List;
11. public class PersonServiceImpl implements PersonSercie {
12.     @Override
13.     public List<Person> AllPerson() throws SQLException {
14.         PersonDao dao=new PersonDaoImpl(); // 1. 创建DAO对象，准备访问数据库
15.         return dao.queryAll();  // 2. 调用DAO查询所有用户
16.     }
17.     @Override
18.     public boolean register(Person person) throws SQLException {
19.         PersonDao dao=new PersonDaoImpl();
20.         //检查用户名是否已存在
21.         if(dao.selectOne(person)){  //调用DAO查询是否存在同名用户
22.             dao.save(person); //无重复 → 保存用户
23.             return true; //返回注册成功
24.         }else {
25.             return false; //返回注册失败
26.         }
27.     }
28. }

复制代码

5.Servlet（Controller层）​

• 脚色：餐厅的“服务员”，欢迎客人并传递需求。
  
• ​功能：接收 HTTP 请求（如 POST /login），调用 Service 处理，返反响应（跳转页面或 JSON）。
  
• ​示例：LoginServlet 获取表单参数，交给 UserService 验证登录。
  

删除

1. package com.servlet;
3. import javax.servlet.ServletException;
4. import javax.servlet.annotation.WebServlet;
5. import javax.servlet.http.HttpServlet;
6. import javax.servlet.http.HttpServletRequest;
7. import javax.servlet.http.HttpServletResponse;
8. import java.io.IOException;
9. import java.sql.*;
11. @WebServlet(name = "DeleteServlet",urlPatterns = "/del")
12. public class DeleteServlet extends HttpServlet {
13.     protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
15.     }
17.     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
20.         String id=request.getParameter("id");
21.         try {
22.         Class.forName("com.mysql.cj.jdbc.Driver");
23.         Connection connection= DriverManager.getConnection("jdbc:mysql://localhost:3306/users?serverTimezone=GMT%2B8","root","123456");
24.         //Statement statement= connection.createStatement();
25.            PreparedStatement statement= connection.prepareStatement("delete  from person where id=?");
26.            statement.setInt(1,Integer.parseInt(id));
27.            int i=statement.executeUpdate();
28.            if(i>0){
29.                response.sendRedirect("listall");
30.            }else {
31.                response.getWriter().println("Error");
32.            }
33.         statement.close();
34.         connection.close();
36.     } catch (ClassNotFoundException e) {
37.         e.printStackTrace();
38.     } catch (SQLException e) {
39.         e.printStackTrace();
40.     }
43.     }
44. }

复制代码

查看

1. package com.servlet;
3. import com.bean.Person;
4. import com.service.PersonSercie;
5. import com.service.impl.PersonServiceImpl;
7. import javax.servlet.ServletException;
8. import javax.servlet.annotation.WebServlet;
9. import javax.servlet.http.HttpServlet;
10. import javax.servlet.http.HttpServletRequest;
11. import javax.servlet.http.HttpServletResponse;
12. import java.io.IOException;
13. import java.sql.*;
14. import java.util.List;
16. @WebServlet(name = "ListAllServlet",urlPatterns = "/listall")
17. public class ListAllServlet extends HttpServlet {
18.     protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
20.     }
22.     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
23.         PersonSercie personSercie=new PersonServiceImpl();
24.         try {
25.             List<Person> list=personSercie.AllPerson();
26.             request.setAttribute("persons",list);
27.             request.getRequestDispatcher("listall.jsp").forward(request,response);
30.         } catch (SQLException e) {
31.             e.printStackTrace();
32.         }
35.     }
36. }

复制代码

增加

1. package com.servlet;
3. import com.bean.Person;
4. import com.service.PersonSercie;
5. import com.service.impl.PersonServiceImpl;
7. import javax.servlet.ServletException;
8. import javax.servlet.annotation.WebServlet;
9. import javax.servlet.http.HttpServlet;
10. import javax.servlet.http.HttpServletRequest;
11. import javax.servlet.http.HttpServletResponse;
12. import java.io.IOException;
13. import java.sql.SQLException;
15. @WebServlet(name = "RegServlet",urlPatterns = "/reg")
16. public class RegServlet extends HttpServlet {
17.     protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
18.         String name=request.getParameter("uname");
19.         String pwd=request.getParameter("upwd");
20.         Person person=new Person();
21.         person.setName(name);
22.         person.setPwd(pwd);
23.         //调用模型中注册业务逻辑实现
24.         PersonSercie personSercie = new PersonServiceImpl(); // 创建服务层对象（业务逻辑处理者）
25.         try {
26.             if(personSercie.register(person)){  // 调用服务层的注册方法
27.                 response.sendRedirect("login.jsp");   // 注册成功：跳转到登录页
28.             }else {
29.                 response.sendRedirect("reg.jsp");// 注册失败：返回注册页
30.             };
31.         } catch (SQLException e) {
32.             e.printStackTrace();
33.         }
34.     }
35.     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
37.     }
38. }

复制代码

改1

1. package com.servlet;
3. import javax.servlet.ServletException;
4. import javax.servlet.annotation.WebServlet;
5. import javax.servlet.http.HttpServlet;
6. import javax.servlet.http.HttpServletRequest;
7. import javax.servlet.http.HttpServletResponse;
8. import java.io.IOException;
9. import java.sql.Connection;
10. import java.sql.DriverManager;
11. import java.sql.PreparedStatement;
12. import java.sql.SQLException;
14. @WebServlet(name = "UpdateDoServlet",urlPatterns = "/updateDo")
15. public class UpdateDoServlet extends HttpServlet {
16.     protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
19.         String id=request.getParameter("id");
20.         String name=request.getParameter("username");
21.         String pwd=request.getParameter("userpwd");
22.         try {
23.             Class.forName("com.mysql.cj.jdbc.Driver");
24.             Connection connection= DriverManager.getConnection("jdbc:mysql://localhost:3306/users?serverTimezone=GMT%2B8","root","123456");
25.             //Statement statement= connection.createStatement();
26.             PreparedStatement statement= connection.prepareStatement("update person set name=?,pwd=? where  id=?");
27.             statement.setString(1,name);
28.             statement.setString(2,pwd);
29.             statement.setInt(3,Integer.parseInt(id));
30.             int i=statement.executeUpdate();
31.             if(i>0){
32.                 response.sendRedirect("listall");
33.             }else {
34.                 response.getWriter().println("Error");
35.             }
36.             statement.close();
37.             connection.close();
39.         } catch (ClassNotFoundException e) {
40.             e.printStackTrace();
41.         } catch (SQLException e) {
42.             e.printStackTrace();
43.         }
46.     }
48.     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
50.     }
51. }

复制代码

改2

1. package com.servlet;
3. import com.bean.Person;
5. import javax.servlet.ServletException;
6. import javax.servlet.annotation.WebServlet;
7. import javax.servlet.http.HttpServlet;
8. import javax.servlet.http.HttpServletRequest;
9. import javax.servlet.http.HttpServletResponse;
10. import java.io.IOException;
11. import java.sql.*;
13. @WebServlet(name = "UpdateServlet",urlPatterns = "/update")
14. public class UpdateServlet extends HttpServlet {
15.     protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
17.     }
19.     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
20.         String id=request.getParameter("id");
21.         try {
22.             Class.forName("com.mysql.cj.jdbc.Driver");
23.             Connection connection= DriverManager.getConnection("jdbc:mysql://localhost:3306/users?serverTimezone=GMT%2B8","root","123456");
25.             PreparedStatement statement= connection.prepareStatement("select *  from person where id=?");
26.             statement.setInt(1,Integer.parseInt(id));
27.             ResultSet resultSet=statement.executeQuery();
29.             Person p=new Person();
31.         if (resultSet.next()){
32.             p.setId(resultSet.getInt(1));
33.             p.setName(resultSet.getString(2));
34.            p.setPwd(resultSet.getString(3));
37.         }
38.         request.setAttribute("user",p);
39.         resultSet.close();
40.             statement.close();
41.             connection.close();
42.             request.getRequestDispatcher("update.jsp").forward(request,response);
44.         } catch (ClassNotFoundException e) {
45.             e.printStackTrace();
46.         } catch (SQLException e) {
47.             e.printStackTrace();
48.         }
51.     }
52. }

复制代码

总结

大概流程：就像网购流程：JSP→ 你下单（Servlet收件）→ 调度中心检查（Service处理）→ 仓库存取（DAO操纵→仓库DB）→ 终极收到包裹（响应结果）

• ​用户填写表单