使用MVC三层架构实现对数据库表的增删改查操作(全部代码)
Posted qq_46026355
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用MVC三层架构实现对数据库表的增删改查操作(全部代码)相关的知识,希望对你有一定的参考价值。
使用MVC三层架构实现对数据库表的增删改查操作(全部代码)
一.环境:
1.idea:2021
2.jdk:1.8
3.maven:apache-maven-3.6.1
4.tomcat:tomcat 8.5.4
二.项目结构
三.编写的思路
1.准备工作:
2.实现增删改查思路:
3:提供一个看懂的思路
(1)创建一个工程/模块(webapp);
(2)准备一个数据库db1,里面有一张表brand(上面图那样的);
(3)创建三层架构的包结构:mapper(dao)数据库
service
web
以及实体类包(pojo)和工具类包(util),并且将代码复制进去(下面有源代码)
(4)配置mybatis的环境(上面有张图)
(5)开始查询操作:页面上有一个超链接"查询所有",点进去后在另一个界面的表单上显示查询到的表
怎么写呢?
思路如下:
1.在BrandMapper写查询方法,用注解的方式;
2.在BrandService里面实现这个方法;
3.在SelectAllServlet里面用service调用查询方法,转到查询后的界面(其中包括几个jsp页面数据的接收)
其他逻辑比它稍微复杂一点点,大差不差!
(6)需要注意的部分:
1.乱码的处理;
2.命名结构不一致;
3.除了查询,其他事务都需要提交;
(7)效果:(放在最后啦)
(8)看不懂的话:联系我!!!
四.代码
BrandMapper
package com.itheima.mapper;
import com.itheima.pojo.Brand;
import org.apache.ibatis.annotations.*;
import java.util.List;
public interface BrandMapper
/**
* 查询所有
* @return
*/
@Select("select * from tb_brand")
@ResultMap("brandResultMap")//解决不同名问题
List<Brand> selectAll();
/**
* 插入
* @param brand
*/
@Insert("insert into tb_brand values(null,#brandName,#companyName,#ordered,#description,#status)")
void add( Brand brand);
/**
* 根据id查
* @param id
* @return
*/
@Select("select * from tb_brand where id=#id")
@ResultMap("brandResultMap")//解决不同名问题
Brand selectById(int id);
/**
* 修改
* @param brand
*/
@Update("update tb_brand set brand_name = #brandName,company_name = #companyName,ordered = #ordered,description = #description,status = #status where id = #id")
void update(Brand brand);
/**
* 根据id删除
*/
@Delete("delete from tb_brand where id=#id")
void deleteById(int id);
**Brand **
package com.itheima.pojo;
/**
* 品牌实体类
*/
public class Brand
// id 主键
private Integer id;
// 品牌名称
private String brandName;
// 企业名称
private String companyName;
// 排序字段
private Integer ordered;
// 描述信息
private String description;
// 状态:0:禁用 1:启用
private Integer status;
public Brand()
public Brand(Integer id, String brandName, String companyName, String description)
this.id = id;
this.brandName = brandName;
this.companyName = companyName;
this.description = description;
public Brand(Integer id, String brandName, String companyName, Integer ordered, String description, Integer status)
this.id = id;
this.brandName = brandName;
this.companyName = companyName;
this.ordered = ordered;
this.description = description;
this.status = status;
public Integer getId()
return id;
public void setId(Integer id)
this.id = id;
public String getBrandName()
return brandName;
public void setBrandName(String brandName)
this.brandName = brandName;
public String getCompanyName()
return companyName;
public void setCompanyName(String companyName)
this.companyName = companyName;
public Integer getOrdered()
return ordered;
public void setOrdered(Integer ordered)
this.ordered = ordered;
public String getDescription()
return description;
public void setDescription(String description)
this.description = description;
public Integer getStatus()
return status;
public void setStatus(Integer status)
this.status = status;
@Override
public String toString()
return "Brand" +
"id=" + id +
", brandName='" + brandName + '\\'' +
", companyName='" + companyName + '\\'' +
", ordered=" + ordered +
", description='" + description + '\\'' +
", status=" + status +
'';
**BrandService **
package com.itheima.service;
import com.itheima.mapper.BrandMapper;
import com.itheima.pojo.Brand;
import com.itheima.util.SqlSessionFactoryUtils;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import java.util.List;
public class BrandService
SqlSessionFactory factory= SqlSessionFactoryUtils.getSqlSessionFactory();
/**
* 查询所有
* @return
*/
public List<Brand> selectAll()
//调用BrandMapper的selectAll()
//2.获取 sqlSession对象
SqlSession sqlSession=factory.openSession();
//3.获取BrandMapper
BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);
//4.调用方法
List<Brand> brands = mapper.selectAll();
sqlSession.close();
return brands;
/**
* 新增
* @param brand
*/
public void add(Brand brand)
SqlSession sqlSession = factory.openSession();
BrandMapper mapper=sqlSession.getMapper(BrandMapper.class);
mapper.add(brand);
sqlSession.commit();
sqlSession.close();
/**
* 根据id查
* @param id
* @return
*/
public Brand selectById(int id)
SqlSession sqlSession = factory.openSession();
BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);
Brand brand = mapper.selectById(id);
sqlSession.close();
return brand;
/**
* 修改
* @param brand
*/
public void update(Brand brand)
SqlSession sqlSession = factory.openSession();
BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);
mapper.update(brand);
sqlSession.commit();
sqlSession.close();
public void deleteById(int id)
SqlSession sqlSession = factory.openSession();
BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);
mapper.deleteById(id);
sqlSession.commit();
sqlSession.close();
**SqlSessionFactoryUtils **
package com.itheima.util;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import java.io.IOException;
import java.io.InputStream;
public class SqlSessionFactoryUtils
private static SqlSessionFactory sqlSessionFactory;
static
//静态代码块会随着类的加载而自动执行,且只执行一次
try
String resource = "mybatis-config.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
catch (IOException e)
e.printStackTrace();
public static SqlSessionFactory getSqlSessionFactory()
return sqlSessionFactory;
**AddServlet **
package com.itheima.web;
import com.itheima.pojo.Brand;
import com.itheima.service.BrandService;
import javax.servlet.*;
import javax.servlet.http.*;
import javax.servlet.annotation.*;
import java.io.IOException;
import java.util.List;
@WebServlet("/addServlet")
public class AddServlet extends HttpServlet
private BrandService service=new BrandService();
@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
//处理post请求乱码问题
request.setCharacterEncoding("utf-8");
//1.接收表单提交的数据
String brandName = request.getParameter("brandName");
String companyName = request.getParameter("companyName");
String ordered = request.getParameter("ordered");
String description = request.getParameter("description");
String status = request.getParameter("status");
Brand brand=new Brand();
brand.setBrandName(brandName);
brand.setCompanyName(companyName);
brand.setOrdered(Integer.parseInt(ordered));
brand.setDescription(description);
brand.setStatus(Integer.parseInt(status));
//2.调用service完成添加
service.add(brand);
//3.转发到查询所有的servlet
request.getRequestDispatcher("/selectAllServlet").forward(request,response);
@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
this.doGet(request, response);
**DeleteByIdServlet **
package com.itheima.web;
import com.itheima.pojo.Brand;
import com.itheima.service.BrandService;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.List;
@WebServlet("/deleteByIdServlet")
public class DeleteByIdServlet extends HttpServlet
private BrandService service=new BrandService();
@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
//1.接收数据id
String id = request.getParameter("id");
//2.调用service方法
service.deleteById(Integer.parseInt(id));
List<Brand> brands = service.selectAll();
request.setAttribute("brands",brands);
request.getRequestDispatcher("/brand.jsp").forward(request,response);
@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
this.doGet(request, response);
**SelectAllServlet **
package com.itheima.web;
import com.itheima.pojo.Brand;
import com.itheima.service.BrandService;
import javax.servlet.*;
import javax.servlet.http.*;
import javax.servlet.annotation.*;
import java.io.IOException;
import java.util.List;
@WebServlet("/selectAllServlet")
public class SelectAllServlet extends HttpServlet
BrandService service = new BrandService();
@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
//1.调用BrandService完成查询
List<Brand> brands = service.selectAll();
//2.存入request中
request.setAttribute("brands",brands);
//3.转发到brands.jsp
request.getRequestDispatcher("/brand.jsp").forward(request,response);
@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
this.doGet(request, response);
**SelectByIdServlet **
package com.itheima.web;
import com.itheima.pojo.Brand;
import com.itheima.service.BrandService;
import javax.servlet.*;
import javax.servlet.http.*;
import javax.servlet.annotation.*;
import java.io.IOException;
@WebServlet("/selectByIdServlet")
public class SelectByIdServlet extends HttpServlet
private BrandService service=new BrandService();
@Override
protected void 🍬JDBC:从CRUD开始,理解JDBC中的各个对象作用,掌握Druid的使用
JSP
今日目标:
- 理解
MVC模式
和 三层架构
- 能完成品牌数据的增删改查功能
文章目录
一、MVC模式和三层架构
MVC 模式和三层架构是一些理论的知识,将来我们使用了它们进行代码开发会让我们代码维护性和扩展性更好。
1.1 MVC模式
MVC 是一种分层开发的模式,其中:
-
M:Model,业务模型,处理业务
-
V:View,视图,界面展示
-
C:Controller,控制器,处理请求,调用模型和视图
控制器(serlvlet)用来接收浏览器发送过来的请求,控制器调用模型(JavaBean)来获取数据,比如从数据库查询数据;控制器获取到数据后再交由视图(JSP)进行数据展示。
MVC 好处:
-
职责单一,互不影响。每个角色做它自己的事,各司其职。
-
有利于分工协作。
-
有利于组件重用
2.2 三层架构
三层架构是将我们的项目分成了三个层面,分别是 表现层
、业务逻辑层
、数据访问层
。
- 数据访问层:对数据库的CRUD基本操作
- 业务逻辑层:对业务逻辑进行封装,组合数据访问层层中基本功能,形成复杂的业务逻辑功能。例如
注册业务功能
,我们会先调用 数据访问层
的 selectByName()
方法判断该用户名是否存在,如果不存在再调用 数据访问层
的 insert()
方法进行数据的添加操作 - 表现层:接收请求,封装数据,调用业务逻辑层,响应数据
而整个流程是,浏览器发送请求,表现层的Servlet接收请求并调用业务逻辑层的方法进行业务逻辑处理,而业务逻辑层方法调用数据访问层方法进行数据的操作,依次返回到serlvet,然后servlet将数据交由 JSP 进行展示。
三层架构的每一层都有特有的包名称:
- 表现层:
com.itheima.controller
或者 com.itheima.web
- 业务逻辑层:
com.itheima.service
- 数据访问层:
com.itheima.dao
或者 com.itheima.mapper
后期我们还会学习一些框架,不同的框架是对不同层进行封装的
3.3 MVC 和 三层架构
通过 MVC 和 三层架构 的学习,有些人肯定混淆了。那他们有什么区别和联系?
如上图上半部分是 MVC 模式,上图下半部分是三层架构。 MVC 模式
中的 C(控制器)和 V(视图)就是 三层架构
中的表现层,而 MVC 模式
中的 M(模型)就是 三层架构
中的 业务逻辑层 和 数据访问层。
可以将 MVC 模式
理解成是一个大的概念,而 三层架构
是对 MVC 模式
实现架构的思想。 那么我们以后按照要求将不同层的代码写在不同的包下,每一层里功能职责做到单一,将来如果将表现层的技术换掉,而业务逻辑层和数据访问层的代码不需要发生变化。
二、案例
需求:完成品牌数据的增删改查操作
这个功能我们之前一直在做,而这个案例是将今天学习的所有的内容(包含 MVC模式 和 三层架构)进行应用,并将整个流程贯穿起来。
2.1 环境准备
环境准备工作,我们分以下步骤实现:
-
创建新的模块 brand_demo,引入坐标
-
创建三层架构的包结构
-
数据库表 tb_brand
-
实体类 Brand
-
MyBatis 基础环境
-
Mybatis-config.xml
-
BrandMapper.xml
-
BrandMapper接口
2.1.1 创建工程
创建新的模块 brand_demo,引入坐标。我们只要分析出要用到哪儿些技术,那么需要哪儿些坐标也就明确了
- 需要操作数据库。mysql的驱动包
- 要使用mybatis框架。mybaits的依赖包
- web项目需要用到servlet和jsp。servlet和jsp的依赖包
- 需要使用 jstl 进行数据展示。jstl的依赖包
pom.xml
内容如下:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>brand-demo</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>war</packaging>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
</properties>
<dependencies>
<!-- mybatis -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.5.5</version>
</dependency>
<!--mysql-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.34</version>
</dependency>
<!--servlet-->
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>3.1.0</version>
<scope>provided</scope>
</dependency>
<!--jsp-->
<dependency>
<groupId>javax.servlet.jsp</groupId>
<artifactId>jsp-api</artifactId>
<version>2.2</version>
<scope>provided</scope>
</dependency>
<!--jstl-->
<dependency>
<groupId>jstl</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>taglibs</groupId>
<artifactId>standard</artifactId>
<version>1.1.2</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<version>2.2</version>
</plugin>
</plugins>
</build>
</project>
2.1.2 创建包
创建不同的包结构,用来存储不同的类。包结构如下
2.1.3 创建表
-- 删除tb_brand表
drop table if exists tb_brand;
-- 创建tb_brand表
create table tb_brand
(
-- id 主键
id int primary key auto_increment,
-- 品牌名称
brand_name varchar(20),
-- 企业名称
company_name varchar(20),
-- 排序字段
ordered int,
-- 描述信息
description varchar(100),
-- 状态:0:禁用 1:启用
status int
);
-- 添加数据
insert into tb_brand (brand_name, company_name, ordered, description, status)
values ('三只松鼠', '三只松鼠股份有限公司', 5, '好吃不上火', 0),
('华为', '华为技术有限公司', 100, '华为致力于把数字世界带入每个人、每个家庭、每个组织,构建万物互联的智能世界', 1),
('小米', '小米科技有限公司', 50, 'are you ok', 1);
2.1.4 创建实体类
在 pojo
包下创建名为 Brand
的类。
public class Brand
// id 主键
private Integer id;
// 品牌名称
private String brandName;
// 企业名称
private String companyName;
// 排序字段
private Integer ordered;
// 描述信息
private String description;
// 状态:0:禁用 1:启用
private Integer status;
public Brand()
public Brand(Integer id, String brandName, String companyName, String description)
this.id = id;
this.brandName = brandName;
this.companyName = companyName;
this.description = description;
public Brand(Integer id, String brandName, String companyName, Integer ordered, String description, Integer status)
this.id = id;
this.brandName = brandName;
this.companyName = companyName;
this.ordered = ordered;
this.description = description;
this.status = status;
public Integer getId()
return id;
public void setId(Integer id)
this.id = id;
public String getBrandName()
return brandName;
public void setBrandName(String brandName)
this.brandName = brandName;
public String getCompanyName()
return companyName;
public void setCompanyName(String companyName)
this.companyName = companyName;
public Integer getOrdered()
return ordered;
public void setOrdered(Integer ordered)
this.ordered = ordered;
public String getDescription()
return description;
public void setDescription(String description)
this.description = description;
public Integer getStatus()
return status;
public void setStatus(Integer status)
this.status = status;
@Override
public String toString()
return "Brand" +
"id=" + id +
", brandName='" + brandName + '\\'' +
", companyName='" + companyName + '\\'' +
", ordered=" + ordered +
", description='" + description + '\\'' +
", status=" + status +
'';
2.1.5 准备mybatis环境
定义核心配置文件 Mybatis-config.xml
,并将该文件放置在 resources
下
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<!--起别名-->
<typeAliases>
<package name="com.itheima.pojo"/>
</typeAliases>
<environments default="development">
<environment id="development">
<transactionManager type="JDBC"/>
<dataSource type="POOLED">
<property name="driver" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql:///db1?useSSL=false&useServerPrepStmts=true"/>
<property name="username" value="root"/>
<property name="password" value="1234"/>
</dataSource>
</environment>
</environments>
<mappers>
<!--扫描mapper-->
<package name="com.itheima.mapper"/>
</mappers>
</configuration>
在 resources
下创建放置映射配置文件的目录结构 com/itheima/mapper
,并在该目录下创建映射配置文件 BrandMapper.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.itheima.mapper.BrandMapper">
</mapper>
2.2 查询所有
当我们点击 index.html
页面中的 查询所有
这个超链接时,就能查询到上图右半部分的数据。
对于上述的功能,点击 查询所有
超链接是需要先请后端的 servlet
,由 servlet
跳转到对应的页面进行数据的动态展示。而整个流程如下图:
2.2.1 编写BrandMapper
在 mapper
包下创建创建 BrandMapper
接口,在接口中定义 selectAll()
方法
/**
* 查询所有
* @return
*/
@Select("select * from tb_brand")
List<Brand> selectAll();
2.2.2 编写工具类
在 com.itheima
包下创建 utils
包,并在该包下创建名为 SqlSessionFactoryUtils
工具类
public class SqlSessionFactoryUtils
private static SqlSessionFactory sqlSessionFactory;
static
//静态代码块会随着类的加载而自动执行,且只执行一次
try
String resource = "mybatis-config.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
catch (IOException e)
e.printStackTrace();
public static SqlSessionFactory getSqlSessionFactory()
return sqlSessionFactory;
2.2.3 编写BrandService
在 service
包下创建 BrandService
类
public class BrandService
SqlSessionFactory factory = SqlSessionFactoryUtils.getSqlSessionFactory();
/**
* 查询所有
* @return
*/
public List<Brand> selectAll()
//调用BrandMapper.selectAll()
//2. 获取SqlSession
SqlSession sqlSession = factory.openSession();
//3. 获取BrandMapper
BrandMapper mapper = sqlSession.getMapper(BrandMapper.class);
//4. 调用方法
List<Brand> brands = mapper.selectAll();
sqlSession.close();
return brands;
2.2.4 编写Servlet
在 web
包下创建名为 SelectAllServlet
的 servlet
,该 servlet
的逻辑如下:
- 调用
BrandService
的 selectAll()
方法进行业务逻辑处理,并接收返回的结果 - 将上一步返回的结果存储到
request
域对象中 - 跳转到
brand.jsp
页面进行数据的展示
具体的代码如下:
@WebServlet("/selectAllServlet")
public class SelectAllServlet extends HttpServlet
private BrandService service = new BrandService();
@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
//1. 调用BrandService完成查询
List<Brand> brands = service.selectAll();
//2. 存入request域中
request.setAttribute("brands",brands);
//3. 转发到brand.jsp
request.getRequestDispatcher("/brand.jsp").forward(request,response);
以上是关于使用MVC三层架构实现对数据库表的增删改查操作(全部代码)的主要内容,如果未能解决你的问题,请参考以下文章
asp.net mvc oracle 做的增删改查功能,给我份源码。