1. 使用模板方法设计模式优化oa项目 34
- 上面的注解解决了配置文件的问题。但是现在的oa项目仍然存在一个比较臃肿的问题。
- 一个单标的CRUD，就写了6个Servlet。如果一个复杂的业务系统，这种开发方式，显然会导致类爆炸。（类的数量太大。）
1.1 怎么解决这个类爆炸问题？34
可以使用模板方法设计模式。
怎么解决类爆炸问题？
- 以前的设计是一个请求一个Servlet类。1000个请求对应1000个Servlet类。导致类爆炸。
- 可以这样做：一个请求对应一个方法。一个业务对应一个Servlet类。
- 处理部门相关业务的对应一个DeptServlet。处理用户相关业务的对应一个UserServlet。处理银行卡卡片业务对应一个CardServlet。
代码在com.bjpowernode.oa.utils
工具类DBUtil
package com.bjpowernode.oa.utils;
import java.sql.*;
import java.util.ResourceBundle;
/**
* JDBC的工具类 27
*/
public class DBUtil {
// 静态变量：在类加载时执行。
// 并且是有顺序的。自上而下的顺序。
// 属性资源文件绑定
private static ResourceBundle bundle = ResourceBundle.getBundle("resources.jdbc");
// 根据属性配置文件key获取value
private static String driver = bundle.getString("driver");
private static String url = bundle.getString("url");
private static String user = bundle.getString("user");
private static String password = bundle.getString("password");
static {
// 注册驱动（注册驱动只需要注册一次，放在静态代码块当中。DBUtil类加载的时候执行。）
try {
// "com.mysql.jdbc.Driver" 是连接数据库的驱动，不能写死。因为以后可能还会连接Oracle数据库。
// 如果连接oracle数据库的时候，还需要修改java代码，显然违背了OCP开闭原则。
// OCP开闭原则：对扩展开放，对修改关闭。（什么是符合OCP呢？在进行功能扩展的时候，不需要修改java源代码。）
//Class.forName("com.mysql.jdbc.Driver");
Class.forName(driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
/**
* 获取数据库连接对象
* @return conn 连接对象
* @throws SQLException
*/
public static Connection getConnection() throws SQLException {
// 获取连接
Connection conn = DriverManager.getConnection(url, user, password);
return conn;
}
/**
* 释放资源
* @param conn 连接对象
* @param ps 数据库操作对象
* @param rs 结果集对象
*/
public static void close(Connection conn, Statement ps, ResultSet rs){
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (ps != null) {
try {
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}代码在com.bjpowernode.oa.web.action
DeptServlet
package com.bjpowernode.oa.web.action;
import com.bjpowernode.oa.utils.DBUtil;
import jakarta.servlet.ServletException;
import jakarta.servlet.annotation.WebServlet;
import jakarta.servlet.http.HttpServlet;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
//使用模板改造的单表的CRUD操作 34
// 模板类
@WebServlet({"/dept/list", "/dept/save", "/dept/edit", "/dept/detail", "/dept/delete", "/dept/modify"})
// 模糊匹配
// 只要请求路径是以"/dept"开始的，都走这个Servlet。
//@WebServlet("/dept/*")
public class DeptServlet extends HttpServlet {
// 模板方法
// 重写service方法（并没有重写doGet或者doPost）
@Override
protected void service(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
// 获取servlet path
String servletPath = request.getServletPath();
if("/dept/list".equals(servletPath)){
doList(request, response);
} else if("/dept/save".equals(servletPath)){
doSave(request, response);
} else if("/dept/edit".equals(servletPath)){
doEdit(request, response);
} else if("/dept/detail".equals(servletPath)){
doDetail(request, response);
} else if("/dept/delete".equals(servletPath)){
doDel(request, response);
} else if("/dept/modify".equals(servletPath)){
doModify(request, response);
}
}
private void doList(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException{
//获取应用的根路径
String contextPath = request.getContextPath();
//设置项响应的内容类型以及字符集，防止中文乱码问题
response.setContentType("text/html;charset=UTF-8");
PrintWriter out = response.getWriter();
out.print("<!DOCTYPE html>");
out.print("<html>");
out.print(" <head>");
out.print(" <meta charset='utf-8'>");
out.print(" <title>部门列表页面</title>");
//这部分是删除操作 28
out.print("<script type='text/javascript'>");
out.print(" function del(dno) {");
out.print(" if(window.confirm('请，删了恢复不了哦')){");
out.print(" document.location.href='"+contextPath+"/dept/delete?deptno='+dno");
out.print(" }");
out.print(" }");
out.print("</script>");
out.print(" </head>");
out.print(" <body>");
out.print(" <h1 align='center'>部门列表</h1>");
out.print(" <hr>");
out.print(" <table border='1px' align='center' width='50%'>");
out.print(" <tr>");
out.print(" <th>序号</th>");
out.print(" <th>部门编号</th>");
out.print(" <th>部门名称</th>");
out.print(" <th>操作</th>");
out.print(" </tr>");
//上一部分是死的
//连接数据库，查询所有的部门
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
//获取连接
conn = DBUtil.getConnection();
//编写sql语句
String sql = "select deptno as a,dname,loc from dept";
//获取预编译数据库操作对象
ps = conn.prepareStatement(sql);
//执行sql语句
rs = ps.executeQuery();
//处理结果集
int i = 0;
while(rs.next()){
String deptno = rs.getString("a");
String dname = rs.getString("dname");
String loc = rs.getString("loc");
//这一部分是动态的
out.print(" <tr>");
out.print(" <td>"+(++i)+"</td>");
out.print(" <td>"+deptno+"</td>");
out.print(" <td>"+dname+"</td>");
out.print(" <td>");
out.print(" <a href" +
"='javascript:void(0)' onclick='del("+deptno+")'>删除</a>");
out.print(" <a href" +
"='"+contextPath+"/dept/edit?deptno="+deptno+"'>修改</a>");
out.print(" <a href" +
"='"+contextPath+"/dept/detail?deptno="+deptno+"'>详情</a>");
out.print(" </td>");
out.print(" </tr>");
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
//关闭，释放资源
DBUtil.close(conn,ps,rs);
}
//下面一部分是死的
out.print(" </table>");
out.print(" <hr>");
out.print(" <a href='"+contextPath+"/add.html'>新增部门</a>");
out.print(" </body>");
out.print("</html>");
}
private void doSave(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException{
//获取部门信息
// 注意乱码问题（Tomcat10不会出现这个问题）
request.setCharacterEncoding("UTF-8");
String deptno = request.getParameter("deptno");
String dname = request.getParameter("dname");
String loc = request.getParameter("loc");
//连接数据库执行insert语句
Connection conn = null;
PreparedStatement ps = null;
int count = 0;
try {
conn = DBUtil.getConnection();
String sql = "insert into dept(deptno, dname, loc) values(?,?,?)";
ps = conn.prepareStatement(sql);
ps.setString(1,deptno);
ps.setString(2,dname);
ps.setString(3,loc);
count = ps.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
DBUtil.close(conn,ps,null);
}
if(count==1) {
//保存成功跳转到列表页面
//request.getRequestDispatcher("/dept/list").forward(request,response);
// 这里最好使用重定向（浏览器会发一次全新的请求。）
// 浏览器在地址栏上发送请求，这个请求是get请求。
response.sendRedirect(request.getContextPath()+"/dept/list");
}else{
//保存失败跳转到错误页面
//request.getRequestDispatcher("/error.html").forward(request,response);
//这里也建议使用重定向
response.sendRedirect(request.getContextPath()+"/error.html");
}
}
private void doEdit(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException{
//获取根路径
String contextPath = request.getContextPath();
response.setContentType("text/html");
PrintWriter out = response.getWriter();
out.print("<!DOCTYPE html>");
out.print("<html>");
out.print(" <head>");
out.print(" <meta charset='utf-8'>");
out.print(" <title>修改部门</title>");
out.print(" </head>");
out.print(" <body>");
out.print(" <h1>修改部门</h1>");
out.print(" <hr>");
out.print(" <form action='"+contextPath+"/dept/modify' method='post'>");
//获取部门编号
String deptno = request.getParameter("deptno");
//连接数据库,根据部门编号查询部门信息
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = DBUtil.getConnection();
String sql = "select dname,loc from dept where deptno=?";
ps = conn.prepareStatement(sql);
ps.setString(1,deptno);
rs = ps.executeQuery();
while(rs.next()){
String dname = rs.getString("dname");
String loc = rs.getString("loc");
//输出动态网页
out.print("部门编号<input type='text' name='deptno' value='"+deptno+"' readonly /><br> <!-- readonly代表部门编号不能修改 -->");
out.print("部门名称<input type='text' name='dname' value='"+dname+"'/><br>");
out.print("部门位置<input type='text' name='loc' value='"+loc+"'/><br>");
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
DBUtil.close(conn,ps,rs);
}
out.print(" <input type='submit' value='修改' /><br>");
out.print(" </form>");
out.print(" </body>");
out.print("</html>");
}
private void doDetail(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException{
//设置项响应的内容类型以及字符集，防止中文乱码问题
response.setContentType("text/html;charset=UTF-8");
PrintWriter out = response.getWriter();
out.print(" <!DOCTYPE html>");
out.print("<html>");
out.print(" <head>");
out.print(" <meta charset='utf-8'>");
out.print(" <title>部门详情</title>");
out.print(" </head>");
out.print(" <body>");
out.print(" <h1>部门详情</h1>");
out.print(" <hr>");
//上部分是死的
// 获取部门编号
// /oa/dept/detail?fdsafdsas=30
// 虽然是提交的30，但是服务器获取的是"30"这个字符串。
String deptno = request.getParameter("deptno");
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
//连接数据库,根部部门编号查询部门信息
conn = DBUtil.getConnection();
//编写sql语句
//获取预编译数据库操作对象
String sql = "select deptno,dname,loc from dept where deptno=?";
ps = conn.prepareStatement(sql);
ps.setString(1,deptno);
//执行
rs = ps.executeQuery();
//处理结果集,这个结果集只有一条记录
while(rs.next()){
String dname = rs.getString("dname");
String loc = rs.getString("loc");
//这部分是动态的
out.print(" 门编号："+deptno+" <br>");
out.print(" 部门名称："+dname+" <br>");
out.print(" 部门位置："+loc+" <br>");
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
//关闭资源
DBUtil.close(conn,ps,rs);
}
//下部分是死的
out.print(" <input type='button' value='后退' onclick='window.history.back()' />");
out.print(" </body>");
out.print("</html>");
}
private void doDel(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException{
//根据部门编号删除部门
//设置项响应的内容类型以及字符集，防止中文乱码问题
response.setContentType("text/html;charset=UTF-8");
PrintWriter out = response.getWriter();
// 获取部门编号
String deptno = request.getParameter("deptno");
Connection conn = null;
PreparedStatement ps = null;
int count = 0;
try {
//获取数据库连接
conn = DBUtil.getConnection();
//开启事务（自动提交机制关闭）
conn.setAutoCommit(false);
//编写sql语句
//获取预编译数据库操作对象
String sql = "delete from dept where deptno = ?";
ps = conn.prepareStatement(sql);
ps.setString(1,deptno);
// 返回值是：影响了数据库表当中多少条记录。
count = ps.executeUpdate();
//事务提交
conn.commit();
} catch (SQLException e) {
//遇到异常要回滚
if(conn!=null){
try {
conn.rollback();
} catch (SQLException ex) {
ex.printStackTrace();
}
}
e.printStackTrace();
} finally {
DBUtil.close(conn,ps,null);
}
//判断删除成功还是失败了
if (count == 1){
//删除成功
//仍然跳转到部门列表页面
//部门列表页面的显示需要执行另一个Servlet。怎么办？转发。
//request.getRequestDispatcher("/dept/list").forward(request,response);
//重定向
response.sendRedirect(request.getContextPath()+"/dept/list");
}else{
//删除失败
//request.getRequestDispatcher("/error.html").forward(request,response);
//重定向
response.sendRedirect(request.getContextPath()+"/error.html");
}
}
private void doModify(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException{
//解决请求体的中文乱码问题
request.setCharacterEncoding("UTF-8");
//获取表单数据
String deptno = request.getParameter("deptno");
String dname = request.getParameter("dname");
String loc = request.getParameter("loc");
//连接数据库执行更新语句
Connection conn = null;;
PreparedStatement ps = null;
int count = 0;
try {
conn = DBUtil.getConnection();
String sql = "update dept set dname = ?,loc = ? where deptno = ?";
ps = conn.prepareStatement(sql);
ps.setString(1,dname);
ps.setString(2,loc);
ps.setString(3,deptno);
count = ps.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
DBUtil.close(conn,ps,null);
}
if(count==1){
//更新成功
// 跳转到部门列表页面（部门列表页面是通过Java程序动态生成的，所以还需要再次执行另一个Servlet）
//request.getRequestDispatcher("/dept/list").forward(request,response);
//重定向
response.sendRedirect(request.getContextPath()+"/dept/list");
}else{
//更新失败
//request.getRequestDispatcher("/error.html").forward(request,response);
//重定向
response.sendRedirect(request.getContextPath()+"/error.html");
}
}
}
配置文件src.resources
jdbc.properties
driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/bjpowernode
user=root
password=lzlindex.html
<!-- 单表的CRUD操作
欢迎页面 26
-->
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>欢迎使用oa系统</title>
</head>
<body>
<!-- 前端超链接发送请求的时候，请求路径以“/”开始，并且带项目名 27-->
<a href="/oa/dept/list">查看部门列表</a>
</body>
</html>
add.html
<!-- 单表的CRUD操作
新增页面 26
-->
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>新增部门</title>
</head>
<body>
<h1>新增部门</h1>
<hr>
<form action="/oa/dept/save" method="post">
部门编号<input type="text" name="deptno"/><br>
部门名称<input type="text" name="dname"/><br>
部门位置<input type="text" name="loc"/><br>
<input type="submit" value="保存" /><br>
</form>
</body>
</html>
errot.html
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>error</title>
</head>
<body>
<h1>操作失败,<a href="javascript:void(0)" onclick="window.history.back()">返回</a></h1>
</body>
</html>
edit.html
<!-- 单表的CRUD操作
修改页面 26
-->
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>修改部门</title>
</head>
<body>
<h1>修改部门</h1>
<hr>
<form action="list.html" method="get">
部门编号<input type="text" name="deptno" value="20" readonly /><br> <!-- readonly代表部门编号不能修改 -->
部门名称<input type="text" name="dname" value="销售部"/><br>
部门位置<input type="text" name="loc" value="北京"/><br>
<input type="submit" value="修改" /><br>
</form>
</body>
</html>