JAVA02_02学习总结(Spring开启事务,Spring通知和curd数据库)

今日内容

1. SpringAOP和数据库进行curd操作

SpringAOPSpring核心技术之一对数据库进行curd操作时,进行增强

思想增强数据库的curd业务,将SpringAOP技术整合进去,为后面的Spring方式控制事务做准备

需要准备的依赖包mybatismysql驱动spring-context依赖包druid连接池-德鲁伊log4j-日志包junit-单元测试包spring-jdbc存在lombokmybatis-spring整合包springAspect-AOP核心技术mybatis分页查询-pageHelperspring-test测试spring-tx事务管理

package com.szr.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

//用户实体类
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {//和数据库字段一一对应private Integer id ;private String name ;private Integer age ;private String gender ;
}

package com.szr.mapper;

import com.szr.pojo.User;
import org.springframework.stereotype.Repository;

import java.util.List;

//数据访问接口
//spring提供注解创建对象,数据访问层用@Repository
@Repository//后面没有内容,代表默认名称为当前类名
public interface UserMapper {/*** 获取所有用户信息* @return 返回用户信息集合*/List<User> getAllUserInfo();
}

package com.szr.service;

import com.github.pagehelper.PageInfo;
import com.szr.pojo.User;

import java.util.List;

//用户业务层
public interface UserService {/*** 获取所有用户信息* @return 返回所有用户信息的分页结果信息*/List<User> getAllUser();
}

package com.szr.service.impl;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.szr.mapper.UserMapper;
import com.szr.pojo.User;
import com.szr.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;
//用户业务实现类
//spring提供创建对象注解再service层@Service
@Service("userService")//后面不跟内容,代表默认名称为该类类名首字母小写
public class UserServiceImpl implements UserService {//调用mapper数据访问层,自动注入@Autowiredprivate UserMapper userMapper ;/*** 获取所有用户信息* @return 返回所有用户信息的分页结果信息*/@Overridepublic List<User> getAllUser() {//调用pagehelper分页查询//设置分页条件PageHelper.startPage(1,1);//完成调用方法List<User> userInfo = userMapper.getAllUserInfo();//创建pageinfo对象PageInfo<User> pageInfo = PageInfo.of(userInfo);System.out.println(pageInfo);return userInfo;}
}

package com.szr.myAspect;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;

//创建类对象的方式之一
@Component
//切面类
@Aspect//springAOP方法注解,标记这个类是一个切面类
public class MyAspect{
//创建切点-在什么方法进行时进行通知-切点表达式@Pointcut("execution(* *.*.service.impl.*.*(..))")public void pointCut(){}//配置环绕通知@Around("pointCut()")//标记这个方法时环绕通知方法-里面是引入切点public Object myAround(ProceedingJoinPoint joinPoint){Object obj = null ;try {//进行执行方法之前的通知System.out.println("已经校验过权限!");//进行反射获取方法obj = joinPoint.proceed();//完成执行方法后通知System.out.println("已经记录到日志!");return obj ;} catch (Throwable throwable) {throwable.printStackTrace();}return null ;}


}

<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--配置映射文件,完成对数据库的curd-->
<mapper namespace="com.szr.mapper.UserMapper"><!--配置基本集合存放数据--><resultMap id="baseMap" type="user"><id property="id" column="id"></id><result property="name" column="name"></result><result property="age" column="age"></result><result property="gender" column="gender"></result></resultMap><!--书写操作语句--><select id="getAllUserInfo" resultMap="baseMap">select * from user</select>
</mapper>

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:context="http://www.springframework.org/schema/context"xmlns:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttps://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/aophttps://www.springframework.org/schema/aop/spring-aop.xsdhttp://www.springframework.org/schema/txhttps://www.springframework.org/schema/tx/spring-tx.xsd">
<!--读取全局注解文件--><context:component-scan base-package="com.szr"/>
<!--配置spring-config配置文件,三大部分--><!--第一部分--><!--读取外部配置文件--><context:property-placeholder location="classpath:jdbc.properties"/><!--配置数据库数据源--><bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"><!--el表达式,使用${}将数据加载变成动态获取--><property name="driverClassName" value="${jdbc.driverClassName}"></property><property name="url" value="${jdbc.url}"></property><property name="username" value="${jdbc.username}"></property><property name="password" value="${jdbc.password}"></property><!--其他参数--><property name="maxActive" value="${jdbc.maxActive}"></property></bean>
<!--第二部分--><!--配置SqlSessionFactoryBean,就是mybatis和spring整合包内容--><bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"><!--关联数据库数据源,上面已经配置过,直接关联名称即可--><property name="dataSource" ref="dataSource"></property><!--给实体类起别名--><property name="typeAliasesPackage" value="com.szr.pojo"></property><!--配置数据访问层相对应的映射文件--><property name="mapperLocations" value="com/szr/mapper/*Mapper.xml"></property><!--配置分页查询插件--><property name="plugins"><array><!--配置了拦截器,如果配置了但是没有使用,会报错!--><bean class="com.github.pagehelper.PageInterceptor"></bean></array></property></bean><!--第三部分--><!--配置MapperScannerConfigurer,mybatis和spring整合包--><bean id="mapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer"><!--关联SqlSessionFactoryBean--><property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property><!--对数据访问接口进行包扫描--><property name="basePackage" value="com.szr.mapper"></property></bean>
<!--开启AOP注解--><aop:aspectj-autoproxy/>
</beans>

package com.szr.test;

import com.github.pagehelper.PageInfo;
import com.szr.pojo.User;
import com.szr.service.UserService;
import com.szr.service.impl.UserServiceImpl;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.List;

//测试类
public class SpringTest {
@Testpublic void SpringTestCurd(){ClassPathXmlApplicationContext context =new ClassPathXmlApplicationContext("spring-config.xml");UserService userService = (UserService) context.getBean("userService");//调用方法List<User> allUser = userService.getAllUser();System.out.println(allUser);/*已经校验过权限!2023-02-03 20:38:19,744 0      [           main] INFO  aba.druid.pool.DruidDataSource  - {dataSource-1} initedPageInfo{pageNum=1, pageSize=1, size=1, startRow=1, endRow=1, total=2, pages=2, list=Page{count=true, pageNum=1, pageSize=1, startRow=0, endRow=1, total=2, pages=2, reasonable=false, pageSizeZero=false}[User(id=1, name=钟离, age=500, gender=男)], prePage=0, nextPage=2, isFirstPage=true, isLastPage=false, hasPreviousPage=false, hasNextPage=true, navigatePages=8, navigateFirstPage=1, navigateLastPage=2, navigatepageNums=[1, 2]}已经记录到日志!Page{count=true, pageNum=1, pageSize=1, startRow=0, endRow=1, total=2, pages=2, reasonable=false, pageSizeZero=false}[User(id=1, name=钟离, age=500, gender=男)]*/}
}

2. Spring开启事务管理

事务理解同进退,共生死--要么一起成功,要么都别成功,回到最开始的样子特点原子性一致性隔离性持久性事务的隔离级别读未提交read uncommitted读已提交 read committed可重复读repeatable read   mysql的默认隔离级别串行话 serializable

Spring事务两种方式开启事务xml文件配置方式1)加入Spring事务的约束文件2)配置Spring-jdbc事务管理器DataSourceTransactionManager注入数据库数据源3)管理事务管理器id属性:唯一通知的标识transaction-manager:管理事务管理器DataSourceTrancationManager4)配置事务的属性tx:method name ="要开启事务的方法名"isolation="事务的隔离级别 可以不写默认 mysql的隔离级别"propagation:事务的 传播行为REQUIRED 需要在update/add/delete修改添加删除的都需要控制事务SUPPORTS:支持事务 findxxx/selectXXX/searchXXX 查询操作 设置SUPPORTSrollback-for="Exception" 当前业务出现了什么异常,进行回滚,exception最大异常类

package com.szr.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

//账户实体类
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Account {//账户IDprivate Integer id ;//账户金额private Integer money ;//账户拥有者private String name ;
}

package com.szr.mapper;

import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;

//数据库访问层
@Repository//数据访问层的创建实例注解
public interface AccountMapper {/*** 转账* @param lostmoney 转账人* @param changemoney 转账金额*/void updateLost(@Param("lostmoney") String lostmoney,@Param("changemoney") Integer changemoney);
/*** 收账* @param getmoney 收账人* @param changemoney 转账金额*/void updateAdd(@Param("getmoney") String getmoney,@Param("changemoney") Integer changemoney);
}

package com.szr.service;
/*
账户操作业务层*/
public interface AccountService {/*** 转账操作* @param lostmoney 转账人* @param getmoney 接收人* @param changemoney 转账金额*/void ChangeMoney(String lostmoney , String getmoney , Integer changemoney);
}

package com.szr.service.impl;

import com.szr.mapper.AccountMapper;
import com.szr.service.AccountService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

//业务层实现类
@Service("accountService")//业务层创建实例注解
public class AccountServiceImpl implements AccountService {
//自动注入@Autowiredprivate AccountMapper accountMapper ;/*** 转账操作* @param lostmoney 转账人* @param getmoney 接收人* @param changemoney 转账金额*/@Overridepublic void ChangeMoney(String lostmoney, String getmoney, Integer changemoney) {//完成转账操作//转账accountMapper.updateLost(lostmoney,changemoney);//错误异常//int i = 10 / 0 ;//收账accountMapper.updateAdd(getmoney,changemoney);//提示System.out.println("转账成功!");}
}

<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.szr.mapper.AccountMapper"><!--转账操作--><update id="updateLost">update acount set money = money - #{changemoney} where name = #{lostmoney}</update><!--收账操作--><update id="updateAdd">update acount set money = money + #{changemoney} where name = #{getmoney}</update>
</mapper>

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:context="http://www.springframework.org/schema/context"xmlns:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttps://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/aophttps://www.springframework.org/schema/aop/spring-aop.xsdhttp://www.springframework.org/schema/txhttps://www.springframework.org/schema/tx/spring-tx.xsd">
<!--读取全局注解文件--><context:component-scan base-package="com.szr"/>
<!--配置spring-config配置文件,三大部分--><!--第一部分--><!--读取外部配置文件--><context:property-placeholder location="classpath:jdbc.properties"/><!--配置数据库数据源--><bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"><!--el表达式,使用${}将数据加载变成动态获取--><property name="driverClassName" value="${jdbc.driverClassName}"></property><property name="url" value="${jdbc.url}"></property><property name="username" value="${jdbc.username}"></property><property name="password" value="${jdbc.password}"></property><!--其他参数--><property name="maxActive" value="${jdbc.maxActive}"></property></bean>
<!--第二部分--><!--配置SqlSessionFactoryBean,就是mybatis和spring整合包内容--><bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"><!--关联数据库数据源,上面已经配置过,直接关联名称即可--><property name="dataSource" ref="dataSource"></property><!--给实体类起别名--><property name="typeAliasesPackage" value="com.szr.pojo"></property><!--配置数据访问层相对应的映射文件--><property name="mapperLocations" value="com/szr/mapper/*Mapper.xml"></property></bean><!--第三部分--><!--配置MapperScannerConfigurer,mybatis和spring整合包--><bean id="mapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer"><!--关联SqlSessionFactoryBean--><property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property><!--对数据访问接口进行包扫描--><property name="basePackage" value="com.szr.mapper"></property></bean>

<!--配置Spring事务约束--><!--配置spring-jdbc事务管理器--><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><!--注入数据源--><property name="dataSource" ref="dataSource"></property></bean><!--配置事务通知--><tx:advice id="tx" transaction-manager="transactionManager"><!--配置事务属性--><tx:attributes><!--开启事务的方法名  在修改,删除,添加开启的事务    遇见异常回滚   --><tx:method name="ChangeMoney" propagation="REQUIRED" rollback-for="Exception"/></tx:attributes></tx:advice><!--配置aop的通知类型--><aop:config><aop:advisor advice-ref="tx" pointcut="execution(* *.*.service.impl.*.*(..))"></aop:advisor></aop:config>
</beans>

package com.szr.test;

import com.szr.service.AccountService;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;

//测试类
public class SpringTransactionTest {
@Testpublic void transactionTest(){//完成转账操作ClassPathXmlApplicationContext context =new ClassPathXmlApplicationContext("spring-config.xml");AccountService account = (AccountService) context.getBean("accountService");account.ChangeMoney("胡桃","钟离",500);}
}

注解配置方式1)加入Spirng事务约束文件2)配置Spring-jdbc事务管理器注入数据库数据源3)开启事务注解<tx:annotation-driven transaction-manager="transactionManager"/>注意事务和切面中的异常报错不能同时配置事务需要通过异常来回滚,切面中的异常报错也需要异常来输出信息这会导致切面中提前捕获异常输出信息,后面的程序不执行,所以事务无法回滚!

package com.szr.service.impl;

import com.szr.mapper.AccountMapper;
import com.szr.service.AccountService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

//业务层实现类
@Service("accountService")//业务层创建实例注解
public class AccountServiceImpl implements AccountService {
//自动注入@Autowiredprivate AccountMapper accountMapper ;/*** 转账操作* @param lostmoney 转账人* @param getmoney 接收人* @param changemoney 转账金额*///这里使用注解方式,一句话解决@Transactional(propagation = Propagation.REQUIRED)@Overridepublic void ChangeMoney(String lostmoney, String getmoney, Integer changemoney) {//完成转账操作//转账accountMapper.updateLost(lostmoney,changemoney);//错误异常//int i = 10 / 0 ;//收账accountMapper.updateAdd(getmoney,changemoney);//提示System.out.println("转账成功!");}
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:context="http://www.springframework.org/schema/context"xmlns:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttps://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/aophttps://www.springframework.org/schema/aop/spring-aop.xsdhttp://www.springframework.org/schema/txhttps://www.springframework.org/schema/tx/spring-tx.xsd">
<!--读取全局注解文件--><context:component-scan base-package="com.szr"/>
<!--配置spring-config配置文件,三大部分--><!--第一部分--><!--读取外部配置文件--><context:property-placeholder location="classpath:jdbc.properties"/><!--配置数据库数据源--><bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"><!--el表达式,使用${}将数据加载变成动态获取--><property name="driverClassName" value="${jdbc.driverClassName}"></property><property name="url" value="${jdbc.url}"></property><property name="username" value="${jdbc.username}"></property><property name="password" value="${jdbc.password}"></property><!--其他参数--><property name="maxActive" value="${jdbc.maxActive}"></property></bean>
<!--第二部分--><!--配置SqlSessionFactoryBean,就是mybatis和spring整合包内容--><bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"><!--关联数据库数据源,上面已经配置过,直接关联名称即可--><property name="dataSource" ref="dataSource"></property><!--给实体类起别名--><property name="typeAliasesPackage" value="com.szr.pojo"></property><!--配置数据访问层相对应的映射文件--><property name="mapperLocations" value="com/szr/mapper/*Mapper.xml"></property></bean><!--第三部分--><!--配置MapperScannerConfigurer,mybatis和spring整合包--><bean id="mapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer"><!--关联SqlSessionFactoryBean--><property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property><!--对数据访问接口进行包扫描--><property name="basePackage" value="com.szr.mapper"></property></bean>

<!--配置Spring事务约束--><!--配置spring-jdbc事务管理器--><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><!--注入数据源--><property name="dataSource" ref="dataSource"></property></bean><!--开启事务注解--><tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>
</beans>

本文链接:https://www.ngui.cc/article/show-861345.html

JAVA02_02学习总结(Spring开启事务,Spring通知和curd数据库)

今日内容

1. SpringAOP和数据库进行curd操作

2. Spring开启事务管理

Mysql快速上手一（基础知识、数据模型、数据类型、SQL语句）

2023/3/26 3:53:54

Dubbo--笔记1

2023/3/26 3:50:03

简单linux 下 x64任意地址的inlinehook

2023/3/26 3:49:42

谈谈计算机的本质

2023/3/26 3:49:27

@Transactional和synchronized同时使用时的一些问题以及解决

2023/3/26 3:48:58

记一次前端cookie冲突，导致同一个浏览器其他系统被踢下线问题分享

2023/3/26 3:48:19

三、Trino406系列 之 客户端

2023/3/26 3:44:15

华为OD机试题【字符匹配】用 Java 解 | 含解题说明

2023/3/26 3:44:04

Golang流媒体实战之一：体验开源项目lal

2023/3/26 3:43:48

OpenWrt开启IPV6设置教程

2023/3/26 3:39:04

Mysql快速上手一（基础知识、数据模型、数据类型、SQL语句）

2023/3/26 3:53:54

Dubbo--笔记1

2023/3/26 3:50:03

简单linux 下 x64任意地址的inlinehook

2023/3/26 3:49:42

谈谈计算机的本质

2023/3/26 3:49:27

@Transactional和synchronized同时使用时的一些问题以及解决

2023/3/26 3:48:58

记一次前端cookie冲突，导致同一个浏览器其他系统被踢下线问题分享

2023/3/26 3:48:19

三、Trino406系列 之 客户端

2023/3/26 3:44:15

华为OD机试题【字符匹配】用 Java 解 | 含解题说明

2023/3/26 3:44:04

Golang流媒体实战之一：体验开源项目lal

2023/3/26 3:43:48

OpenWrt开启IPV6设置教程

2023/3/26 3:39:04

TENER: Adapting Transformer Encoder for Named Entity Recognition 笔记

2023/3/26 3:38:50

【实战】16.Vue Router 入门

2023/3/26 3:38:36

实验十 图着色问题

2023/3/26 3:38:20

蓝桥杯刷题冲刺 | 倒计时14天

2023/3/26 3:33:59

pip安装及国内源更换

2023/3/26 3:33:48

vue2 和vue3动态绑定src

2023/3/26 3:33:36

java并发-通信工具类

2023/3/26 3:32:45

浅谈Dubbo的异步调用

2023/3/26 3:32:32

1650_MIT 6.828 open函数的简单梳理

2023/3/26 3:29:22

C++ 15 string容器

2023/3/26 3:29:03

技术实战：农产品质量溯源区块链方案

2023/3/26 3:53:54

农产品质量溯源区块链方案

2023/3/26 3:53:39

数据库系统--关系代数中笛卡尔积，选择，投影，自然连接，除运算

2023/3/26 3:52:54

计算机二级投影运算怎么看,二级计算机中交、并、除、自然连接、投影、选择和笛卡尔积是怎么计算的？...

2023/3/26 3:52:01

SQL数据库笛卡尔积、投影、选择、连接运算

2023/3/26 3:51:52

关系代数之专门的关系运算（选择、投影）

2023/3/26 3:51:28

【数据库系统】关系代数之基本运算、附加运算、扩展操作

2023/3/26 3:51:19

mysql 投影,MySQL —— select

2023/3/26 3:51:09

三、Trino406系列之客户端

三、Trino406系列之客户端

实验十图着色问题

数据库系统概论--读书笔记--8 关系运算：选择投影连接除运算

mysql关系运算选择投影连接_数据库关系代数操作并差积选择投影连接等操作...