JavaWeb:基于MVC设计模式的一个小案例(一)

时间:2021-09-16 16:38:44

(未经允许,请勿转载,谢谢。)

本案例的处理过程:

客户端发送一个请求给服务器,服务器把这个请求给Servlet,Servlet 获取请求信息,根据请求信息的情况去调用 model (在这里是一个普通的 Java 类),然后把返回结果给 Servlet ,然后Servlet 根据返回结果 转向一个 JSP,JSP是用来呈现数据的 (这里用的是Java 代码),生成一个HTML 页面显给客户。

使用到的技术:

MVC 设计模式:JSP、Servlet、POJO

数据库:MySQL

连接数据库使用 c3p0 数据库连接池

JDBC 工具使用 DBUtils

页面上的提示操作使用 jQuery

具体实现步骤:

1、建立数据表

代码:

Create table customer(
id int(10) primary key auto_increment,
name varchar(30) not null unique,
address varchar(30),
phone varchar(30)
);

为 name 字段添加唯一约束:
alter table customers add constraint name_uk unique(name);

2、底层实现

①、加入c3p0 数据源:导入两个 jar 包(c3p0 和 数据库驱动),在 src 下新建配置文件:c3p0-config.xml ,修改一下要有连接数据库的基本信息(driverClass、jdbcUrl、user、password)。

c3p0-config.xml 代码:

 <?xml version="1.0" encoding="UTF-8" ?>
<c3p0-config> <named-config name="mvcapp"> <!--指定连接数据源的基本信息 -->
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql:///javawebdb</property>
<property name="user">root</property>
<property name="password">root</property> <!-- 若数据库中连接不足时,一次性向数据库服务器申请多少个连接-->
<property name="acquireIncrement">5</property>
<!-- 初始化数据库连接池时连接的数量-->
<property name="initialPoolSize">10</property>
<!-- 数据库连接池中的最小的数据库连接数-->
<property name="minPoolSize">10</property>
<!-- 数据库连接池中的最大的数据库连接数-->
<property name="maxPoolSize">50</property> <!-- c3p0 数据库连接池可以维护的 Statement 的个数-->
<property name="maxStatements">20</property>
<!-- 每个连接同时可以使用的Statement 对象的个数-->
<property name="maxStatementsPerConnection">5</property> </named-config>
</c3p0-config>

②、编写DAO 工具类、JdbcUtils 工具类和 CustomerDao 接口(以下有具体说明和代码)

DAO 工具类:封装了基本的增删改查的方法,以供子类继承使用。当前DAO 没有事务,直接在方法中获取数据库连接。导入了DBUtils 的 jar 包,整个 DAO 采取 DBUtils 的解决方案。

实现方法:

update(封装了insert、delete、update)操作:public void update(String sql, Object...args){  }

查询 返回 T 对应的实体类的对象:public T get(String sql, Object...args){  }

查询 返回 T 对应的List :public List<T> getForList(String sql, Object...args){  }

查询 返回一个字段的值: public <E> E getForValue(String sql, Object...args){  }

DAO.java 代码:

 package com.hnust.mvcapp.dao;

 import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List; import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler; import com.hnust.mvcapp.utils.JdbcUtils; /**
* 封装了基本的增删改查的方法,以供子类继承使用。
* 当前DAO 直接在方法中获取数据库连接。
* 整个DAO 采取DBUtils 解决方案。
* @author User
*
* @param <T> 当前 DAO 处理的实体类的类型是什么
*/
public class Dao<T> { private QueryRunner queryRunner = new QueryRunner(); private Class<T> clazz; /**
* 需要确定 clazz
*/
public Dao(){
//由得到子类的 Class得到父类 带泛型的那个类型。
Type superClass = getClass().getGenericSuperclass();
//先判断是不是那个类型
if(superClass instanceof ParameterizedType){
//是的话,强转一下
ParameterizedType parameterizedType = (ParameterizedType) superClass;
//获取真正的泛型的参数
Type[] typeArgs = parameterizedType.getActualTypeArguments();
if(typeArgs != null && typeArgs.length >0){
if(typeArgs[0] instanceof Class){
clazz = (Class<T>) typeArgs[0];
}
}
}
} /**
* 查询,返回某一个字段的值
*/
public <E> E getForValue(String sql, Object...args){
Connection connection = null;
try {
connection = JdbcUtils.getConnection();
return (E) queryRunner.query(connection, sql, new ScalarHandler(), args);
} catch (SQLException e) {
e.printStackTrace();
}finally{
JdbcUtils.releaseConnection(connection);
}
return null;
} /**
* 查询,返回T 所对应的 List
*/
public List<T> getForList(String sql, Object...args){
Connection connection = null;
try {
connection = JdbcUtils.getConnection();
return queryRunner.query(connection, sql, new BeanListHandler<>(clazz), args);
} catch (SQLException e) {
e.printStackTrace();
}finally{
JdbcUtils.releaseConnection(connection);
}
return null;
} /**
* 查询,返回一个T 的实体类对象
*/
public T get(String sql, Object...args){
Connection connection = null; try {
connection = JdbcUtils.getConnection();
return queryRunner.query(connection, sql, new BeanHandler<>(clazz), args);
} catch (SQLException e) {
e.printStackTrace();
}finally{
JdbcUtils.releaseConnection(connection);
}
return null;
} /**
* 通用的 insert 、delete、update 方法
*/
public void update(String sql, Object...args){
Connection connection = null;
try {
connection = JdbcUtils.getConnection();
queryRunner.update(connection, sql, args);
} catch (Exception e) {
e.printStackTrace();
}finally{
JdbcUtils.releaseConnection(connection);
}
}
}

JdbcUtils 工具类:JDBC 操作的工具类。

实现方法:

返回数据源的一个 Connection 对象:public static Connection getConnection(){  }

释放 Connection 的连接:public static void releaseConnection(Connection connection){  }

注意:数据源的初始化一定要放在静态代码块中,数据源被创建一次就够了。写完一个可以用单元测试检验以下。

JdbcUtils.java 代码:

 package com.hnust.mvcapp.utils;

 import java.sql.Connection;
import java.sql.SQLException; import javax.sql.DataSource; import com.mchange.v2.c3p0.ComboPooledDataSource; /**
* JDBC 操作的工具类
* @author User
*
*/
public class JdbcUtils { /**
* 释放连接
*/
public static void releaseConnection(Connection connection){ try {
if(connection != null){
connection.close();
}
} catch (Exception e) {
e.printStackTrace();
}
} private static DataSource dataSource = null;
static{
dataSource = new ComboPooledDataSource("mvcapp"); //传入的是 configName
}
/**
* 获取连接
* @throws SQLException
*/
public static Connection getConnection() throws SQLException{ return dataSource.getConnection();
}
}

CustomerDao 接口:

实现的方法:

模糊查询 返回满足条件的List :public List<Customer> getForListWithCriteriaCustomer(CriteriaCustomer cc);

查询 返回List:public List<Customer> getAll();

添加:poublic void save(Customer customer);

修改时要根据id 的查询显示:public Customer get(Inreger id);

删除(根据 id):public void delete(Integer id);

查询 和这个名字一样的 记录数(根据 name):public long getCountWithName(String name);

CustomerDao.java 代码:

 package com.hnust.mvcapp.dao;

 import java.util.List;

 import com.hnuct.mvcapp.entity.Customer;

 public interface CustomerDao {

     /**
* 模糊查询 返回满足条件的List
* @param cc :封装了查询条件
* @return
*/
public List<Customer> getForListWithCriteriaCustomer(CriteriaCustomer cc); /**
* 查询 返回 List
*/
public List<Customer> getAll(); /**
* 增加
*/
public void save(Customer customer); /**
* 修改 更新时候的查询(根据id)显示
*/
public Customer get(Integer id); /**
* 删除
*/
public void delete(Integer id); /**
* 返回和name 相同的记录数
*/
public long getCountWithName(String name);
}

实体类 Customer:

Customer.java 代码:

 package com.hnuct.mvcapp.entity;

 public class Customer {

     private Integer id;
private String name;
private String address;
private String phone;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getAddress() {
return address;
}
public void setAddress(String address) {
this.address = address;
}
public String getPhone() {
return phone;
}
public void setPhone(String phone) {
this.phone = phone;
}
public Customer(Integer id, String name, String address, String phone) {
super();
this.id = id;
this.name = name;
this.address = address;
this.phone = phone;
}
public Customer() {
super();
} @Override
public String toString() {
return "Customers [id=" + id + ", name=" + name + ", address="
+ address + ", phone=" + phone + "]";
} }

Dao 接口的实现:

CustomerDaoJdbcImpl.java 代码:

 package com.hnuct.mvcapp.dao.impl;

 import java.util.List;

 import com.hnuct.mvcapp.entity.Customer;
import com.hnust.mvcapp.dao.CriteriaCustomer;
import com.hnust.mvcapp.dao.CustomerDao;
import com.hnust.mvcapp.dao.Dao; public class CustomerDaoJdbcImpl extends Dao<Customer> implements CustomerDao{ @Override
public List<Customer> getAll() {
String sql = "select * from customer";
return getForList(sql);
} @Override
public void save(Customer customer) {
String sql = "insert into customer(name,address,phone) values (?,?,?)";
update(sql, customer.getName(), customer.getAddress(), customer.getPhone());
} @Override
public Customer get(Integer id) {
String sql = "select * from customer where id = ?";
return get(sql, id);
} @Override
public void delete(Integer id) {
String sql = "delete from customer where id = ? ";
update(sql, id);
} @Override
public long getCountWithName(String name) {
String sql = "select count(id) from customer where name = ?";
return getForValue(sql, name);
} @Override
public List<Customer> getForListWithCriteriaCustomer(CriteriaCustomer cc) {
String sql = "SELECT id,name,address,phone FROM customer WHERE name LIKE ? AND "
+ "address LIKE ? AND phone LIKE ?";
//注意:修改了 CriteriaCustomer 的 getter 方法,使其返回的字符串中有 "%%",
//若返回值为 null 则返回 "%%" ,若不为 null, 则返回 "% " + 字段本身的值 + " %"
return getForList(sql, cc.getName(), cc.getAddress(), cc.getPhone());
} }

ps:注意因为查询条件很多时候 和 实体类 并不相同,所以要做成一个单独的类,这里是 CriteriaCustomer 类,其中里面的getter 方法做了修改,是为了正确的填充占位符。

CriteriaCustomer.java 代码:

 package com.hnust.mvcapp.dao;

 public class CriteriaCustomer {

     private String name;
private String address;
private String phone;
public String getName() {
if(name == null)
name = "%%";
else
name = "%" + name + "%";
return name;
}
public void setName(String name) {
this.name = name;
}
public String getAddress() {
if(address == null)
address = "%%";
else
address = "%" + address + "%";
return address;
}
public void setAddress(String address) {
this.address = address;
}
public String getPhone() {
if(phone == null)
phone = "%%";
else
phone = "%" + phone + "%";
return phone;
}
public void setPhone(String phone) {
this.phone = phone;
} public CriteriaCustomer() {
super();
}
public CriteriaCustomer(String name, String address, String phone) {
super();
this.name = name;
this.address = address;
this.phone = phone;
} }

3、Servlet 的实现:获取请求信息的参数,根据请求信息调用 DAO 的对应的方法。

先写了一个 test.jsp 页面 放了三个超链接。

test.jsp 代码:

 <%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Insert title here</title>
</head>
<body>
<%--
<a href="customerServlet?method=add">add</a>
<br><br>
<a href="customerServlet?method=query">query</a>
<br><br>
<a href="customerServlet?method=delete">delete</a>
--%> <a href="addCustomer.do">add</a>
<br><br>
<a href="query.do">query</a>
<br><br>
<a href="delete.do">delete</a>
<br><br> </body>
</html>

注意你的 web.xml 里的 url-pattern:<url-pattern>*.do</url-pattern>

然后 创建了CustomerServlet :去响应服务器的请求,调用对应的model,返回结果(我这里暂时实现了 模糊查询和 删除的功能)。

CustomerServlet.java 代码:

 package com.hnust.mvcapp.servlet;

 import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.util.List; import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import com.hnuct.mvcapp.dao.impl.CustomerDaoJdbcImpl;
import com.hnuct.mvcapp.entity.Customer;
import com.hnust.mvcapp.dao.CriteriaCustomer;
import com.hnust.mvcapp.dao.CustomerDao; public class CustomerServlet extends HttpServlet {
private static final long serialVersionUID = 1L; private CustomerDao customerDao = new CustomerDaoJdbcImpl(); protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException { this.doPost(request, response);
} @Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException { //1、获取servletPath
String servletPath = req.getServletPath();
//System.out.println(servletPath); //得到的是 /addCustomer.do //2、去除 / 和 .do ,得到 addCustomer 这样的字符串
String methodName = servletPath.substring(1);
methodName = methodName.substring(0, methodName.length() - 3);
//System.out.println(methodName); // 得到的是 addCustomer try {
//3、利用反射,根据获取的 方法名,获取对应的方法。
Method method = getClass().getDeclaredMethod(methodName, HttpServletRequest.class,
HttpServletResponse.class);
//4、利用反射调用对应的方法
method.invoke(this, req, resp); } catch (Exception e) {
e.printStackTrace();
//可以有一些响应
resp.sendRedirect("error.jsp");
} } private void delete(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
//1、获取 id
String idStr = request.getParameter("id");
int id = 0;
//为了避免输入的 id 是不 合法的。 idStr 不能转为 int 类型。若不能转,则 id 为0,无法执行任何的操作。
try {
id = Integer.parseInt(idStr);
//2、调用 CustomerDAO 的 delete 方法
customerDao.delete(id);
//3、页面的重定向
response.sendRedirect("query.do");
} catch (Exception e) {
e.printStackTrace();
}
} private void query(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
//1、获取模糊查询的请求参数
String name = request.getParameter("name");
String address = request.getParameter("address");
String phone = request.getParameter("phone"); //2、把请求参数封装为 CriteriaCustomer 对象
CriteriaCustomer cc = new CriteriaCustomer(name, address, phone); //3、再调用CustomerDao 的 getForListWithCriteriaCustomer() 方法
List<Customer> customers = customerDao.getForListWithCriteriaCustomer(cc); //调用CustomerDao 的 getAll() 方法 查询。
//List<Customer> customers = customerDao.getAll(); //4、把查询到的结果集放入 request 中
request.setAttribute("customers", customers);
//5、请求的转发
request.getRequestDispatcher("/index.jsp").forward(request, response); } private void addCustomer(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException { System.out.println("add");
} }

4、返回结果 的 JSP 页面:获取返回结果,遍历显示。

index.jsp 代码:

 <%@page import="com.hnuct.mvcapp.entity.Customer"%>
<%@page import="java.util.List"%>
<%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Insert title here</title>
<script type="text/javascript" src="Scripts/jquery-1.7.2.js"></script>
<script type="text/javascript">
$(function(){
$(".delete").click(function(){
var content = $(this).parent().parent().find("td:eq(1)").text();
var flag = confirm("确定要删除 " + content + " 的信息吗?");
return flag;
});
})
</script>
</head>
<body>
<form action="query.do" method="post">
<table>
<tr>
<td>name:</td>
<td><input type="text" name="name"/></td>
</tr>
<tr>
<td>address:</td>
<td><input type="text" name="address"/></td>
</tr>
<tr>
<td>phone:</td>
<td><input type="text" name="phone"/></td> <tr>
<td><input type="submit" value="Query"/></td>
<td><a href="">Add new Customer</a></td>
</tr>
</table>
</form>
<br><br> <%
List<Customer> customers = (List<Customer>) request.getAttribute("customers");
if(customers != null && customers.size() > 0){
%>
<hr>
<br><br>
<table border="1" cellpadding="10" cellspacing="0">
<tr>
<th>ID</th>
<th>NAME</th>
<th>ADDRESS</th>
<th>PHONE</th>
<th>UPDATE/DELETE</th>
</tr>
<% for(Customer cust : customers){ %>
<tr>
<td><%= cust.getId() %></td>
<td><%= cust.getName() %></td>
<td><%= cust.getAddress() %></td>
<td><%= cust.getPhone() %></td>
<td>
<a href="">Update</a>
<a href="delete.do?id=<%=cust.getId() %>" class="delete">Delete</a>
</td>
</tr>
<%
}
%>
</table>
<%
}
%>
</body>
</html> 

最后结果:

JavaWeb:基于MVC设计模式的一个小案例(一)

点击query

JavaWeb:基于MVC设计模式的一个小案例(一)

可以实现模糊查询,和删除的功能。

这是今天的学习内容。