1.0 概述
1.1 持久层:
DAO层(mapper)
-
DAO层:DAO层主要是做数据持久层的工作,负责与数据库进行联络的一些任务都封装在此
-
DAO层的设计首先是设计DAO的接口,
-
然后在spring-mapper.xml的配置文件中定义此接口的实现类,
-
然后就可在模块中调用此接口来进行数据业务的处理,而不用关心此接口的具体实现类是哪个类,显得结构非常清晰,
-
DAO层的数据源配置,以及有关数据库连接的参数都在spring-mapper的配置文件中进行配置。
-
1.2 业务层:
Service层
-
Service层:Service层主要负责业务模块的逻辑应用设计。
-
首先设计接口,再设计其实现的类
-
接着再在Spring的配置文件中配置其实现的关联。这样我们就可以在应用中调用Service接口来进行业务处理
-
Service层的业务实现,具体要调用到已定义的DAO层的接口
-
数据库的事务配置在service.xml中配置
-
封装Service层的业务逻辑有利于通用的业务逻辑的独立性和重复利用性,程序显得非常简洁。
-
1.3 表现层:
Controller层(Handler层)
-
Controller层:Controller层负责具体的业务模块流程的控制,
-
在此层里面要调用Service层的接口来控制业务流程,
-
控制的配置也同样是在springmvc.xml的配置文件里面进行,针对具体的业务流程,会有不同的控制器,
-
我们具体的设计过程中可以将流程进行抽象归纳,设计出可以重复利用的子单元流程模块,
这样不仅使程序结构变得清晰,也大大减少了代码量
-
1.4 View层
-
View层 此层与控制层结合比较紧密,需要二者结合起来协同工发。View层主要负责前台jsp页面的表示.
1.5 各层联系
-
DAO层,Service层这两个层次都可以单独开发,互相的耦合度很低,完全可以独立进行,这样的一种模式在开发大项目的过程中尤其有优势
-
Controller,View层因为耦合度比较高,因而要结合在一起开发,但是也可以看作一个整体独立于前两个层进行开发。这样,在层与层之前我们只需要知道接口的定义,调用接口即可完成所需要的逻辑单元应用,一切显得非常清晰简单。
-
Service逻辑层设计
-
Service层是建立在DAO层之上的,建立了DAO层后才可以建立Service层,而Service层又是在Controller层之下的,因而Service层应该既调用DAO层的接口,又要提供接口给Controller层的类来进行调用,它刚好处于一个中间层的位置。每个模型都有一个Service接口,每个接口分别封装各自的业务处理方法。
-
2.0 SSM整合
2.1 创建SpringBoot项目
2.2 引入依赖
<properties>
<java.version>11</java.version>
<mybatis.version>2.2.2</mybatis.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>${mybatis.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
<optional>true</optional>
</dependency>
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
注意:引入 spring-boot-devtools 依赖后,每次我们只需要重新编译源代码即可,不要需要重启springboot项目
2.3 工程搭建
#启动端口
server.port=8088
#数据源
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql:///220706a
spring.datasource.username=root
spring.datasource.password=123456
# 日志登记
logging.level.com.whitecamellia.mybatis_demo = debug
#xml配置
mybatis.mapper-locations=classpath:mapper/*Mapper.xml
#驼峰映射
mybatis.configuration.map-underscore-to-camel-case=true
#配置别名
mybatis.type-aliases-package = com.whitecamellia.mybatis_demo.entity
#主键返回
mybatis.configuration.use-generated-keys=true
# 延迟加载
mybatis.configuration.lazy-loading-enabled=true
#二级缓存
mybatis.configuration.cache-enabled=true
2.4 封装Result工具类
package com.whitecamellia.ssm_test.util;
import lombok.Getter;
@Getter
public class Result {
private int code;
private String message;
private Object data;
private Result() {
}
public static Result ok () {
Result result = new Result();
result.code = 200;
result.message = "success";
return result;
}
public static Result ok (Object data) {
Result result = new Result();
result.code = 200;
result.message = "success";
result.data = data;
return result;
}
public static Result error (int code,String message) {
Result result = new Result();
result.code = code;
result.message = message;
return result;
}
}
// 测试
@RestController
public class PersonController {
@Autowired
private PersonService personService;
@GetMapping("/findList")
public Result findList () {
List<Person> list = personService.findList();
return list.size()!= 0 ?
Result.ok(list) :
Result.error(201,"无数据");
}
}
2.5 优化工具类
@Getter
public class Result<T> {
private int code;
private String message;
private T data;
private static final int DEFAULT_SUCCESS_CODE = 200;
private static final String DEFAULT_SUCCESS_MESSAGE = "SUCCESS";
private Result() {
}
public static Result<Void> ok () {
Result<Void> result = new Result<>();
result.code = DEFAULT_SUCCESS_CODE;
result.message = DEFAULT_SUCCESS_MESSAGE;
return result;
}
public static T> Result<T> ok (T data) {
Result<T> result = new Result<>();
result.code = DEFAULT_SUCCESS_CODE;
result.message = DEFAULT_SUCCESS_MESSAGE;
result.data = data;
return result;
}
public static Result<Void> error (int code,String message) {
Result<Void> result = new Result<>();
result.code = code;
result.message = message;
return result;
}
}
2.6 测试
@GetMapping("/findList")
public Result<List<Person>> findList () {
return Result.ok(personService.findList());
}
3.0 分页
3.1 基本使用
@RestController
public class SpAttributeController {
@Autowired
private SpAttributeService spAttributeService;
@GetMapping("/find")
public Result<List<SpAttribute>> findByPage() {
return Result.ok(spAttributeService.findByPage());
}
}
public interface SpAttributeService {
List<SpAttribute> findByPage();
}
@Service
public class SpAttributeServiceImpl implements SpAttributeService {
@Autowired
private SpAttributeMapper spAttributeMapper;
@Override
public List<SpAttribute> findByPage() {
return spAttributeMapper.findByPage();
}
}
@Mapper
public interface SpAttributeMapper {
@Select(" select * from sp_attribute")
List<SpAttribute> findByPage();
}
@Data
public class SpAttribute {
private Integer attrId;
private String attrName;
private Integer catId;
private String attrSel;
private String attrWrite;
private String attrVals;
// getter&&setter
}
3.2 导入依赖
<pagehelper-version>1.4.1</pagehelper-version>
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
<version>${pagehelper-version}</version>
</dependency>
3.3 分页助手
Page<SpAttribute> page1 = PageHelper.offsetPage(pageNum, pageSize);
Page<SpAttribute> page2 = PageHelper.startPage(pageNum, pageSize);
3.4 测试:
// http://localhost:8088/findByPage1?pageNum=1&pageSize=10
@GetMapping("/findByPage1")
public Result<List<SpAttribute>> findByPage1(Integer pageNum, Integer pageSize) {
// PageHelper.offsetPage(pageNum, pageSize);
PageHelper.startPage(pageNum, pageSize);
return Result.ok(spAttributeService.findByPage());
}
3.5 封装PageData
@Data
@AllArgsConstructor
@NoArgsConstructor
public class PageData<T> {
private List<T> data;
private long total;
}
3.6 测试
@GetMapping("/findByPage2")
public Result<PageData<SpAttribute>> findByPage2(Integer pageNum, Integer pageSize) {
Page<SpAttribute> result = PageHelper.startPage(pageNum, pageSize);
spAttributeService.findByPage();
PageData<SpAttribute> pageData = new PageData<>(result.getResult(), result.getTotal());
return Result.ok(pageData);
}
3.7 分页演示
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>table 模块快速使用</title>
<!-- 引入 layui.css -->
<link rel="stylesheet" href="//unpkg.com/layui@2.6.8/dist/css/layui.css">
<!-- 引入 layui.js -->
<script src="//unpkg.com/layui@2.6.8/dist/layui.js"></script>
</head>
<body>
<table id="demo" lay-filter="test"></table>
<script>
layui.use('table', function () {
var table = layui.table;
//第一个实例
table.render({
elem: '#demo'
, height: 312
, url: '/findByPage3' //数据接口
, page: true //开启分页
, cols: [[ //表头
{field: 'attrId', title: '主键id', width: 180, sort: true, fixed: 'left'}
, {field: 'attrName', title: '属性名称', width: 180}
, {field: 'catId', title: '类型id', width: 180, sort: true}
, {field: 'attrSel', title: '动态参数', width: 180}
, {field: 'attrWrite', title: '静态属性', width: 180}
]],
parseData: function(d){
return {
code: d.code,
msg: d.message,
count: d.data.total,
data: d.data.data,
};
}
});
});
</script>
</body>
</html>
@GetMapping("/findByPage3")
public Result<PageData<SpAttribute>> findByPage3(@RequestParam(name = "page")
Integer pageNum,
@RequestParam(name = "limit")
Integer pageSize) {
Page<SpAttribute> result = PageHelper.startPage(pageNum, pageSize);
spAttributeService.findByPage();
PageData<SpAttribute> pageData = new PageData<>(result.getResult(), result.getTotal());
return Result.ok(pageData);
}
3.8 增加排序功能
Page<SpAttribute> result = PageHelper.startPage(pageNum, pageSize, "attr_id DESC");
3.9 注意事项:
-
在使用排序时,我们发现pagehelper采用的是字符串拼接的形式,这样会有潜在的sql注入问题,这就要求我们在排序时必须严格校验排序的参数。必须与表或者实体类字段做好对应。
前端传参
@GetMapping("/findByPage")
public Result<PageData<SpAttribute>> findByPage(@RequestParam(defaultValue = "1") Integer pageNum,
@RequestParam(defaultValue = "10") Integer pageSize) {
pageSize = pageSize >= 50 ? 50 : pageSize;
return ...
}
注意事项:
-
pageNum,pageSize指定默认值
-
pageNum 可以不做限制但是pageSize必做,防止前端恶意传参
pageHelper注意事项
-
分页插件是当调用startPage或者offsetPage之后开始拦截select语句,拦截之后,在select语句后拼接limit参数,拦截以后,分页功能关闭,再准备拦截下一次select语句。也就是说如果我们连续发了2个select语句请求只会拦截第一次操作。
-
不要在拦截select语句与请求的select语句之间使用page的任意方法,只有select语句请求以后,page里面才有数据。
4.0 事务
事务:transaction
4.1 基本使用
public class Account {
private Integer id;
private String name;
private double balance;
//getter&&setter
}
@RestController
public class AccountController {
@Autowired
private AccountService accountService;
@PostMapping("/balance")
public void update() {
boolean update = accountService.update();
System.out.println(update);
}
}
public interface AccountService {
boolean update();
}
在你认为可能出现问题的方法上加上注解@Transactional
@Service
public class AccountServiceImpl implements AccountService {
@Autowired
private AccountMapper accountMapper;
@Transactional
@Override
public boolean update() {
int sub = accountMapper.sub();
int i = 1 / 0;
int add = accountMapper.add();
return sub == add ? true : false;
}
}
@Mapper
public interface AccountMapper {
int sub();
int add();
}
<?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.whitecamellia.mapper.AccountMapper">
<update id="add">
UPDATE account
set balance = balance + 500
WHERE id = 2
</update>
<update id="sub">
UPDATE account
set balance = balance - 500
WHERE id = 1
</update>
</mapper>
4.2 rollbackFor
@Service
public class AccountServiceImpl implements AccountService {
@Autowired
private AccountMapper accountMapper;
@Transactional // 默认 只有运行时异常 会自动回滚
@Override
public boolean update() throws FileNotFoundException {
int sub = accountMapper.sub();
// IOException 非运行时异常
FileInputStream fileInputStream = new FileInputStream("C:\\WINDOWS\\1.txt");
int add = accountMapper.add();
return sub == add ? true : false;
}
}
-
程序报错!尽管我们添加了事务注解,但是我们发现数据还是可以在数据库中进行修改
-
实际上spring框架在封装 @Transactional注解默认只会处理runtimeException,对于编译异常,默认交给用户处理。
-
我们希望编译异常也交给spring框架来管理,具体配置如下
@Transactional(rollbackFor = RuntimeException.class)//默认
@Transactional(rollbackFor = Exception.class) // 所有 遇见运行时异常 或者 非运行时异常。都会回滚,前提是该方法内的异常抛出而非捕获
@Service
public class AccountServiceImpl implements AccountService {
@Autowired
private AccountMapper accountMapper;
@Transactional(rollbackFor = Exception.class)
@Override
public boolean update() throws FileNotFoundException {
int sub = accountMapper.sub();
// int i = 1 / 0;
FileInputStream fileInputStream = new FileInputStream("C:\\WINDOWS\\1.txt");
int add = accountMapper.add();
return sub == add ? true : false;
}
}
4.3 事务的传播机制
-
REQUIRED (默认)
-
支持当前事务,如果当前没有事务,则新建事务
-
如果当前存在事务,则加入当前事务,合并成一个事务
-
-
REQUIRES_NEW
-
新建事务,如果当前存在事务,则把当前事务挂起(无论当前环境是否有事物)
-
这个方法会独立提交事务,不受调用者的事务影响,父级异常,它也是正常提交
-
-
NESTED
-
如果当前存在事务,它将会成为父级事务的一个子事务,方法结束后并没有提交,只有等父事务结束才提交
-
如果当前没有事务,则新建事务
-
如果它异常,父级可以捕获它的异常而不进行回滚,正常提交
-
但如果父级异常,它必然回滚,这就是和
REQUIRES_NEW
的区别
-
-
SUPPORTS
-
如果当前存在事务,则加入事务
-
如果当前不存在事务,则以非事务方式运行,这个和不写没区别
-
-
NOT_SUPPORTED
-
以非事务方式运行
-
如果当前存在事务,则把当前事务挂起
-
-
MANDATORY
-
如果当前存在事务,则运行在当前事务中
-
如果当前无事务,则抛出异常,也即父级方法必须有事务
-
-
NEVER
-
以非事务方式运行,如果当前存在事务,则抛出异常,即父级方法必须无事务
-
一般用得比较多的是
REQUIRED
,REQUIRES_NEW
;
REQUIRES_NEW
一般用在子方法需要单独事务。
@Transactional(propagation = Propagation.REQUIRED)
代码演示:
testService
public interface TestService {
void TestInsert ();
}
testServiceImpl
@Service
public class TestServiceImpl implements TestService {
@Autowired
private PersonMapper personMapper;
@Transactional
@Override
public void TestInsert() {
Person person = new Person();
person.setName("测试");
person.setAge(20);
// int i = 1 / 0;
personMapper.insert(person);
}
}
PersonServiceImpl
@Service
public class PersonServiceImpl implements PersonService {
@Autowired
private PersonMapper personMapper;
@Autowired
private TestService testService;
@Override
@Transactional(rollbackFor = Exception.class)
public int insert(Person person) throws FileNotFoundException {
int insert = personMapper.insert(person);
testService.TestInsert();
// int i = 1 / 0;
// new FileInputStream("c:/1.txt");
return insert;
}
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
@Service
public class TestServiceImpl implements TestService {
@Autowired
private PersonMapper personMapper;
// 默认
// @Transactional(propagation = Propagation.REQUIRED)
@Transactional(propagation = Propagation.REQUIRES_NEW)
@Override
public void TestInsert() {
Person person = new Person();
person.setName("测试");
person.setAge(20);
personMapper.insert(person);
}
}
4.4 事务的失效场景
5.0 Lombok
5.1 常用注解
@Getter
@Setter
@ToString
@EqualsAndHashCode
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Student {
// @Getter
private Integer id;
// @Setter
private String name;
private Integer age;
}
5.2 @Slf4j (日志框架)
编译前
@Slf4j
class Demo {
public static void main(String[] args) {
}
}
编译后
class Demo {
private static final Logger log = LoggerFactory.getLogger(Demo.class);
Demo() {
}
public static void main(String[] args) {
// 日志输出级别:debug、info、warn、error
log.debug();
}
}
5.3 级别演示
@Slf4j
@Service
public class PersonServiceImpl implements PersonService {
@Autowired
private PersonMapper personMapper;
@Override
public List<Person> findList() {
log.debug("开始打印数据");
return personMapper.findList();
}
}
注意:我们项目配置文件中配置日志的打印级别是debug,故会将所有的日志全部打印
#开发环境日志级别
logging.level.com.whitecamellia.ssm_test=debug
#生产环境日志级别
#logging.level.com.whitecamellia.ssm_test=info
#再次精简打印信息
logging.level.root=warn
5.4 调试打印
@Slf4j
@Service
public class PersonServiceImpl implements PersonService {
@Autowired
private PersonMapper personMapper;
@Override
public List<Person> findList() {
List<Person> list = personMapper.findList();
log.debug("开始打印{}集合数据",list);
return list;
}
}
5.5 写入日志
#生产环境,将打印信息写到文件中
logging.file.name = logger.log