Spring学习笔记(spring教程 csdn)_3

  本篇文章为你整理了Spring学习笔记(spring教程 csdn)的详细内容,包含有spring入门教程 spring教程 csdn spring详细教程 spring 教程 Spring学习笔记,希望能帮助你了解 Spring学习笔记。

  import org.aspectj.lang.annotation.Pointcut;

  import org.springframework.stereotype.Component;

  @Component

  @Aspect

  public class MyAdvice {

   @Pointcut("execution(void priv.dandelion.dao.BookDao.*te())")

   private void pt() {

   @Around("pt()")

   public void around(ProceedingJoinPoint pjp) throws Throwable {

   //记录程序当前执行执行(开始时间)

   Long startTime = System.currentTimeMillis();

   //业务执行万次

   for (int i = 0;i 10000;i++) {

   // 表示对原始操作的调用

   pjp.proceed();

   //记录程序当前执行时间(结束时间)

   Long endTime = System.currentTimeMillis();

   //计算时间差

   Long totalTime = endTime-startTime;

   //输出信息

   System.out.println("执行万次消耗时间:" + totalTime + "ms");

  

 

 

  
public static void main(String[] args) {

   ApplicationContext ctx = new AnnotationConfigApplicationContext(SpringConfig.class);

   BookDao bookDao = ctx.getBean(BookDao.class);

   bookDao.save();

   // bookDao.update();

   // bookDao.delete();

   // bookDao.select();

  

 

 

  
连接点:在 AOP 中,将所以原始方法称为连接点(如右侧的 save,update,delete和select 方法)。

  切入点:在上述四个方法中,除 save 方法之外,仅 update 和 delete 方法执行了万次,即追加了功能。这些追加了同一种功能的方法(可以是一个也可以是多个,此处为两个)称为一个切入点,反之,如 save, select 方法就不是切入点。

  通知:共性功能,即左边的方法。

  通知类:通知是一个方法,必须写在一个类中。

  切面:通知与切入点的关系,一个通知对应一个切入点,称为一个切面。

  
连接点(JoinPoint):程序执行过程中的任意位置,粒度为执行方法、抛出异常、设置变量等

  在SpringAOP中,理解为方法的执行

  
一个具体的方法:如priv.dandelion.dao包下的BookDao接口中的无形参无返回值的save方法

  匹配多个方法:所有的save方法,所有的get开头的方法,所有以Dao结尾的接口中的任意方法,所有带有一个参数的方法

  
连接点范围要比切入点范围大,是切入点的方法也一定是连接点,但是是连接点的方法就不一定要被增强,所以可能不是切入点。

  
打印save方法的时候,因为方法中有打印系统时间,所以运行的时候是可以看到系统时间

  对于update方法来说,就没有该功能

  
System.out.println(System.currentTimeMillis());

   System.out.println("book dao save ...");

   public void update(){

   System.out.println("book dao update ...");

  

 

 

  
public static void main(String[] args) {

   ApplicationContext ctx = new AnnotationConfigApplicationContext(SpringConfig.class);

   BookDao bookDao = ctx.getBean(BookDao.class);

   bookDao.save();

  

 

 

  
Spring 有自己的 AOP 实现,但是相比于 AspectJ 来说比较麻烦,所以我们直接采用Spring 整合 ApsectJ 的方式进行 AOP 开发

  


 !-- 因为spring-context依赖aop,aop的包已经导入 -- 

 

   !-- 此处我们额外导入aspectjweaver包 --

   dependency

   groupId org.aspectj /groupId

   artifactId aspectjweaver /artifactId

   version 1.9.4 /version

   /dependency

  

 

  
切入点定义依托一个不具有实际意义的方法进行,即无参数、无返回值、方法体无实际逻辑

  execution及后面编写的内容,将在后续的章节中详细介绍

  
// 定义切入点,注解中execution后面的内容即为对切入点的描述(即当执行到这个方法的时候)

   @Pointcut("execution(void priv.dandelion.dao.BookDao.update())")

   private void pt(){}

   public void method(){

   System.out.println(System.currentTimeMillis());

  

 

 

  
// 定义执行时间(在运行到哪一个切入点的什么时间执行,如此处使用Before就是在运行pt()切入点前执行)

   @Before("pt()")

   public void method(){

   System.out.println(System.currentTimeMillis());

  

 

 

  
AOP 是基于 Spring 容器管理的 bean 做的增强,所以整个工作过程需要从 Spring 加载 bean 说起

  
读取所有切面配置中的切入点(仅包含已经被使用到了的切入点,具体案例如下)

  

@Component

 

  @Aspect

  public class MyAdvice {

   // ptx()未被使用到,不会被读取

   @Pointcut("execution(void priv.dandelion.dao.BookDao.save())")

   private void ptx(){}

   // pt()被使用到,会被读取

   @Pointcut("execution(void priv.dandelion.dao.BookDao.update())")

   private void pt(){}

   // 仅使用了pt()

   @Before("pt()")

   public void method(){

   System.out.println(System.currentTimeMillis());

  

 

  
获取 bean 调用方法并执行,完成操作

  获取的 bean 是代理对象时,根据代理对象的运行模式运行原始方法与增强内容,完成操作

  
不能直接打印对象,直接打印对象走的是对象的toString方法,不管是不是代理对象打印的结果都是一样的,原因是内部对toString方法进行了重写

  此处使用getClass()方法

  
public static void main(String[] args) {

   ApplicationContext ctx = new AnnotationConfigApplicationContext(SpringConfig.class);

   BookDao bookDao = ctx.getBean(BookDao.class);

   System.out.println(bookDao.getClass());

  

 

 

  
// Dao中无该方法,bean中的方法匹配不到当前切入点

   @Pointcut("execution(void priv.dandelion.dao.BookDao.update1())")

   private void pt(){}

   @Before("pt()")

   public void method(){

   System.out.println(System.currentTimeMillis());

   * 控制台输出为原始对象:

   * class priv.dandelion.dao.impl.BookDaoImpl

  

 

 

  
目标对象(Target):原始功能去掉共性功能对应的类产生的对象,这种对象是无法直接完成最终工作的

  简单来说,目标对象就是要增强的类 [如:BookServiceImpl 类] 对应的对象,也叫原始对象,不能说它不能运行,只能说它在运行的过程中对于要增强的内容是缺失的。

  
代理(Proxy):目标对象无法直接完成工作,需要对其进行功能回填,通过原始对象的代理对象实现

  SpringAOP是在不改变原有设计 (代码) 的前提下对其进行增强的,它的底层采用的是代理模式实现的,所以要对原始对象进行增强,就需要对原始对象创建代理对象,在代理对象中的方法把通知 [如:MyAdvice 中的 method 方法] 内容加进去,就实现了增强,这就是我们所说的代理 (Proxy)

  
切入点表达式在上面的章节出现过,即@Pointcut中的内容

  

@Pointcut("execution(void priv.dandelion.dao.BookDao.update())")

 

  private void pt(){}

  

 

  
对于AOP中的切入点表达式,本文将详细说明三个内容,分别是语法格式、通配符和书写技巧

  
因为调用接口方法的时候最终运行的还是其实现类的方法,所以下面两种描述方式都是可以的。

  
执行接口中的方法(按接口描述)

  

execution(void priv.dandelion.dao.BookDao.update())

 

  

 

  
执行实现类中的方法(按实现类描述)

  

execution(void priv.dandelion.dao.impl.BookDaoImpl.update())

 

  

 

  
execution:动作关键字,描述切入点的行为动作,例如 execution 表示执行到指定切入点

  public:访问修饰符,还可以是 public,private 等(可以省略,默认 public)

  User:返回值,写返回值类型

  priv.dandelion.service:包名,多级包使用点连接

  UserService:类/接口名称

  findById:方法名

  int:参数,直接写参数的类型,多个类型用逗号隔开

  异常名:方法定义中抛出指定异常(可以省略)

  
匹配 priv.dandelion 包下的任意包中的 UserService 类或接口中所有 find 开头的带有一个参数的方法

  

execution(public * priv.dandelion.*.UserService.find*(*))

 

  

 

  
这个使用率较低,描述子类的,做JavaEE开发,继承机会就一次,使用都很慎重,所以很少用它。*Service+,表示所有以Service结尾的接口的子类。

  

execution(* *..*Service+.*(..))

 

  

 

  
System.out.println(System.currentTimeMillis());

   System.out.println("book dao save ...");

   public void update(){

   System.out.println("book dao update ...");

  

 

 

  

// 匹配接口,能匹配到

 

  execution(void priv.dandelion.dao.BookDao.update())

  // 匹配实现类,能匹配到

  execution(void priv.dandelion.dao.impl.BookDaoImpl.update())

  // 返回值任意,能匹配到

  execution(* priv.dandelion.dao.impl.BookDaoImpl.update())

  // 返回值任意,但是update方法必须要有一个参数,无法匹配,要想匹配需要在update接口和实现类添加参数

  execution(* priv.dandelion.dao.impl.BookDaoImpl.update(*))

  // 返回值为void,priv包下的任意包三层包下的任意类的update方法,匹配到的是实现类,能匹配

  execution(void priv.*.*.*.*.update())

  // 返回值为void,priv包下的任意两层包下的任意类的update方法,匹配到的是接口,能匹配

  execution(void priv.*.*.*.update())

  // 返回值为void,方法名是update的任意包下的任意类,能匹配

  execution(void *..update())

  // 匹配项目中任意类的任意方法,能匹配,但是不建议使用这种方式,影响范围广

  execution(* *..*(..))

  // 匹配项目中任意包任意类下只要以u开头的方法,update方法能满足,能匹配

  execution(* *..u*(..))

  // 匹配项目中任意包任意类下只要以e结尾的方法,update和save方法能满足,能匹配

  execution(* *..*e(..))

  // 返回值为void,priv包下的任意包任意类任意方法,能匹配,*代表的是方法

  execution(void priv..*())

  // 将项目中所有业务层方法的以find开头的方法匹配

  execution(* priv.dandelion.*.*Service.find*(..))

  // 将项目中所有业务层方法的以save开头的方法匹配

  execution(* priv.dandelion.*.*Service.save*(..))

  

 

  
所有代码按照标准规范开发,否则以下技巧全部失效

  描述切入点通常描述接口,而不描述实现类,如果描述到实现类,就出现紧耦合了

  访问控制修饰符针对接口开发均采用 public 描述(可省略访问控制修饰符描述)

  返回值类型对于增删改类使用精准类型加速匹配,对于查询类使用*通配快速描述

  包名书写尽量不使用..匹配,效率过低,常用*做单个包描述匹配,或精准匹配

  接口名/类名书写名称与模块相关的采用*匹配,例如 UserService 书写成 *Service ,绑定业务层接口名

  方法名书写以动词进行精准匹配,名词采用*匹配,例如 getById 书写成 getBy*,selectAll 就书写成 selectAll 即可

  参数规则较为复杂,根据业务方法灵活调整

  通常不使用异常作为匹配规则

  4.2 AOP 通知类型

  前面的案例中,涉及到如下内容:

  

@Before("pt()")

 

  

 

  其代表的含义是将通知添加到切入点方法执行的前面

  4.2.1 类型介绍

  
AOP 通知描述了抽取的共性功能,根据共性功能抽取的位置不同,最终运行代码时要将其加入到合理的位置

  
AOP 代码加入位置演示

  

// 环绕通知功能比较强大,它可以追加功能到方法执行的前后,是比较常用的方式,它可以实现其他四种通知类型的功能,具体的实现方式将在下面进行说明

 

  public int methodName() {

   // 前置通知追加位置1,即方法执行前

   try {

   // 前置通知追加位置2,即方法执行前

   // code,原始的业务操作,即要被增强的方法本体

   return;

   // 返回后通知追加位置,即方法执行后(只有方法正常执行结束后才进行,如果方法执行抛出异常,返回后通知将不会被添加)

   } catch (Exception e) {

   // 抛出异常后通知追加位置,即抛出异常后(只有方法抛出异常后才会被添加)

   // 后置通知追加位置,在方法执行后(不管方法执行的过程中有没有抛出异常都会执行)

  

 

  
public class MyAdvice {

   @Pointcut("execution(void priv.dandelion.dao.BookDao.update())")

   private void pt(){}

   public void before() {

   System.out.println("before advice ...");

   public void after() {

   System.out.println("after advice ...");

   public void around(){

   System.out.println("around before advice ...");

   System.out.println("around after advice ...");

   public void afterReturning() {

   System.out.println("afterReturning advice ...");

   public void afterThrowing() {

   System.out.println("afterThrowing advice ...");

  

 

 

  
public static void main(String[] args) {

   ApplicationContext ctx = new AnnotationConfigApplicationContext(SpringConfig.class);

   BookDao bookDao = ctx.getBean(BookDao.class);

   bookDao.update();

  

 

 

  


@Pointcut("execution(void priv.dandelion.dao.BookDao.update())")

 

  private void pt() {

  @Pointcut("execution(int priv.dandelion.dao.BookDao.select())")

  private void pt2() {

  // 环绕通知方法需要有一个ProceedingJoinPoint类型的参数,用于调用原始对象

  @Around("pt()")

  public void around(ProceedingJoinPoint pjp) throws Throwable {

   System.out.println("around before advice ...");

   // 表示对原始操作的调用,环绕通知必须手动调用原始方法

   pjp.proceed();

   System.out.println("around after advice ...");

  // 有返回值的方法在增强时,环绕通知方法必须要有Object的返回值

  @Around("pt2()")

  public Object around2(ProceedingJoinPoint pjp) throws Throwable {

   System.out.println("around before advice ...");

   // 表示对原始操作的调用,并接收返回值

   Object proceed = pjp.proceed();

   System.out.println("around after advice ...");

   return proceed;

  

 

  
环绕通知方法需要有一个 ProceedingJoinPoint 类型的参数,用于调用原始对象,其中,可以使用pjp.proceed()来调用原始方法。

  环绕通知不手动调用原始方法时,会自动跳过原始方法(利用这一特性可完成权限校验与内容分配等功能)

  由于无法预知原始方法运行后是否会抛出异常,因此环绕通知方法必须要处理 Throwable 异常

  有返回值的方法在增强时,环绕通知方法必须要有 Object 的返回值

  无返回值的原始方法对应的通知类一般返回 void,但也可以写返回值,正常获取并返回后得到的结果为null,通常会返回 Object

  
设置当前通知方法与切入点之间绑定关系,当前通知方法在原始切入点方法正常执行完毕后执行

  
设置当前通知方法与切入点之间绑定关系,当前通知方法在原始切入点方法运行抛出异常后执行名称

  
环绕通知方法需要有一个 ProceedingJoinPoint 类型的参数,用于调用原始对象,其中,可以使用pjp.proceed()来调用原始方法。

  环绕通知不手动调用原始方法时,会自动跳过原始方法(利用这一特性可完成权限校验与内容分配等功能)

  由于无法预知原始方法运行后是否会抛出异常,因此环绕通知方法必须要处理 Throwable 异常

  有返回值的方法在增强时,环绕通知方法必须要有 Object 的返回值

  无返回值的原始方法对应的通知类可以返回 void,但也可以写返回值,正常获取并返回后得到的结果为null,通常会返回 Object

  
@Insert("insert into tbl_account(name,money)values(#{name},#{money})")

   void save(Account account);

   @Delete("delete from tbl_account where id = #{id} ")

   void delete(Integer id);

   @Update("update tbl_account set name = #{name} , money = #{money} where id = #{id} ")

   void update(Account account);

   @Select("select * from tbl_account")

   List Account findAll();

   @Select("select * from tbl_account where id = #{id} ")

   Account findById(Integer id);

  

 

 

  


jdbc.driver=com.mysql.jdbc.Driver

 

  jdbc.url=jdbc:mysql://localhost:3306/spring_db?useSSL=false

  jdbc.username=root

  jdbc.password=123456

  

 

  
@PropertySource("classpath:jdbc.properties")

  @Import({JdbcConfig.class,MybatisConfig.class})

  public class SpringConfig {

  

 

 

  
public SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource){

   SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean();

   ssfb.setTypeAliasesPackage("priv.dandelion.entity");

   ssfb.setDataSource(dataSource);

   return ssfb;

   @Bean

   public MapperScannerConfigurer mapperScannerConfigurer(){

   MapperScannerConfigurer msc = new MapperScannerConfigurer();

   msc.setBasePackage("priv.dandelion.dao");

   return msc;

  

 

 

  
@Pointcut("execution(* priv.dandelion.service.*Service.*(..))")

   private void servicePt(){}

   @Around("servicePt()")

   public Object runSpeed(ProceedingJoinPoint pjp) throws Throwable {

   Signature signature = pjp.getSignature();

   String className = signature.getDeclaringTypeName();

   String methodName = signature.getName();

   long start = System.currentTimeMillis();

   Object proceed = null;

   for (int i = 0; i 10000; i++) {

   proceed = pjp.proceed();

   long end = System.currentTimeMillis();

   System.out.println("万次执行:" + className + "." + methodName + "----- " + (end - start) + "ms");

   return proceed;

  

 

 

  


@RunWith(SpringJUnit4ClassRunner.class)

 

  @ContextConfiguration(classes = SpringConfig.class)

  public class AccountServiceTestCase {

   @Autowired

   private AccountService accountService;

   @Test

   public void testFindById(){

   Account ac = accountService.findById(2);

   System.out.println(ac);

   @Test

   public void testFindAll(){

   List Account all = accountService.findAll();

   System.out.println(all);

  

 

  
获取异常信息(获取切入点方法运行异常信息,前置和返回后通知不会有,后置通知可有可无,所以不做研究)

  抛出异常后通知

  
public class MyAdvice {

   @Pointcut("execution(* priv.dandelion.dao.BookDao.findName(..))")

   private void pt(){}

   @Before("pt()")

   public void before() {

   System.out.println("before advice ..." );

   @After("pt()")

   public void after() {

   System.out.println("after advice ...");

   @Around("pt()")

   public Object around(ProceedingJoinPoint pjp) throws Throwable{

   Object ret = pjp.proceed();

   return ret;

   @AfterReturning("pt()")

   public void afterReturning() {

   System.out.println("afterReturning advice ...");

  
public static void main(String[] args) {

   ApplicationContext ctx = new AnnotationConfigApplicationContext(SpringConfig.class);

   BookDao bookDao = ctx.getBean(BookDao.class);

   String name = bookDao.findName(100);

   System.out.println(name);

  

 

 

  
public Object around(ProceedingJoinPoint pjp) throws Throwable{

   Object[] args = pjp.getArgs();

   System.out.println(Arrays.toString(args));

   Object ret = pjp.proceed();

   return ret;

  

 

 

  
ProceedingJoinPoint 的 proceed() 方法用于调用原始方法,但是该方法除了空参的形式还包括有参形式 proceed(Object[] args),二者本质区别不大,后者用于手动传入参数

  

@Around("pt()")

 

  public Object around(ProceedingJoinPoint pjp) throws Throwable{

   Object[] args = pjp.getArgs();

   System.out.println(Arrays.toString(args));

   // 假设原始方法被调用时传入的参数有问题,此处进行处理

   args[0] = 666;

   // 手动传入参数,执行原始方法时将使用被手动传入的参数

   Object ret = pjp.proceed(args);

   return ret;

  

 

  
环绕通知获取返回值时,在调用原始方法时接收返回值,并且为通知方法定义返回值类型 Object,如果有需要可以进行修改

  

@Around("pt()")

 

  public Object around(ProceedingJoinPoint pjp) throws Throwable{

   Object[] args = pjp.getArgs();

   System.out.println(Arrays.toString(args));

   // 假设原始方法被调用时传入的参数有问题,此处进行处理

   args[0] = 666;

   // 手动传入参数,执行原始方法时将使用被手动传入的参数

   Object ret = pjp.proceed(args);

   return ret;

  

 

  4.4.3.2 非环绕通知获取返回值

  


@AfterReturning(value = "pt()", returning = "ret")

 

  public void afterReturning(Object ret) {

   System.out.println("afterReturning advice ..." + ret);

  

 

  


@AfterReturning(value = "pt()", returning = "ret")

 

  public void afterReturning(JoinPoint jp, Object ret) {

   Object[] args = jp.getArgs();

   System.out.println(Arrays.toString(args));

   System.out.println("afterReturning advice ..." + ret);

  

 

  
对于获取抛出的异常,只有抛出异常后AfterThrowing和环绕Around这两个通知类型可以获取

  
public Object around(ProceedingJoinPoint pjp) throws Throwable{

   Object[] args = pjp.getArgs();

   System.out.println(Arrays.toString(args));

   // 假设原始方法被调用时传入的参数有问题,此处进行处理

   args[0] = 666;

   Object ret = null;

   try {

   // 手动传入参数,执行原始方法时将使用被手动传入的参数

   ret = pjp.proceed(args);

   } catch (Throwable t) {

   // 捕获异常

   t.printStackTrace();

   return ret;

  

 

 

  4.4.4.2 抛出异常后通知获取异常

  

@AfterThrowing(value = "pt()", throwing = "t")

 

  public void afterThrowing(Throwable t) {

   System.out.println("afterThrowing advice ..." + t);

  

 

  4.5 百度网盘密码数据兼容处理

  4.5.1 需求分析

  百度网盘选取分享密码时会多带一个空格,影响正常使用

  
在业务方法执行之前对所有的输入参数使用trim()进行格式处理

  后续类似的操作可能很多,故此处采用 AOP 进行统一处理

  需要先处理参数再调用原始方法,故此处采用环绕通知

  4.5.2 环境准备

  
public boolean openURL(String url, String password) {

   return resourcesDao.readResources(url,password);

  

 

 

  
public static void main(String[] args) {

   ApplicationContext ctx = new AnnotationConfigApplicationContext(SpringConfig.class);

   ResourcesService resourcesService = ctx.getBean(ResourcesService.class);

   boolean flag = resourcesService.openURL("http://pan.baidu.com/haha", "root");

   System.out.println(flag);

  

 

 

  


// 定义切入点,假设对业务层任意包含字符串的参数都进行处理

 

  @Pointcut("execution(boolean priv.dandelion.service.*Service.*(..))")

  private void servicePt(){}

  

 

  


@Around("servicePt()")

 

  public Object trimStr(ProceedingJoinPoint pjp) throws Throwable {

   // 获取参数,若参数为字符串类型,则去除空格

   Object[] args = pjp.getArgs();

   for (int i = 0; i args.length; i++) {

   if (args[i].getClass().equals(String.class))

   args[i] = args[i].toString().trim();

   // 调用原始方法,手动传入修改后的参数

   Object proceed = pjp.proceed(args);

   return proceed;

  

 

  
代理(Proxy):SpringAOP 的核心本质是采用代理模式实现的

  连接点(JoinPoint):在 SpringAOP 中,理解为任意方法的执行

  切入点(Pointcut):匹配连接点的式子,也是具有共性功能的方法描述

  通知(Advice):若干个方法的共性功能,在切入点处执行,最终体现为一个方法

  切面(Aspect):描述通知与切入点的对应绑定关系

  目标对象(Target):被代理的原始对象成为目标对象

  
减少使用..的形式描述包

  对接口进行描述,使用*表示模块名,例如UserService的匹配描述为*Service

  方法名书写保留动词,例如get,使用*表示名词,例如getById匹配描述为getBy*

  参数根据实际情况灵活调整

  
环绕通知依赖形参ProceedingJoinPoint才能实现对原始方法的调用

  环绕通知可以隔离原始方法的调用执行

  环绕通知返回值设置为Object类型

  环绕通知中可以对原始方法调用过程中出现的异常进行处理

  
获取切入点方法返回值,前置和抛出异常后通知是没有返回值,后置通知可有可无,所以不做研究

  返回后通知

  
获取切入点方法运行异常信息,前置和返回后通知是不会有,后置通知可有可无,所以不做研究

  抛出异常后通知

  
Spring 提供了接口 PlatformTransactionManager 以及其简单实现类 DataSourceTransactionManager(内部使用 JDBC 事务)

  

public interface PlatformTransactionManager {

 

   void commit(TransactionStatus status) throws TransactionException;

   void rollback(TransactionStatus status) throws TransactionException;

  

 

  
insert into tbl_account values(1,Tom,1000);

  insert into tbl_account values(2,Jerry,1000);

  

 

 

  
@Update("update tbl_account set money = money + #{money} where name = #{name}")

   void inMoney(@Param("name") String name, @Param("money") Double money);

   @Update("update tbl_account set money = money - #{money} where name = #{name}")

   void outMoney(@Param("name") String name, @Param("money") Double money);

  

 

 

  
public void transfer(String out,String in ,Double money) {

   accountDao.outMoney(out,money);

   accountDao.inMoney(in,money);

  

 

 

  


jdbc.driver=com.mysql.jdbc.Driver

 

  jdbc.url=jdbc:mysql://localhost:3306/spring_db?useSSL=false

  jdbc.username=root

  jdbc.password=123456

  

 

  
public SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource){

   SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean();

   ssfb.setTypeAliasesPackage("priv.dandelion.entity");

   ssfb.setDataSource(dataSource);

   return ssfb;

   @Bean

   public MapperScannerConfigurer mapperScannerConfigurer(){

   MapperScannerConfigurer msc = new MapperScannerConfigurer();

   msc.setBasePackage("priv.dandelion.dao");

   return msc;

  

 

 

  
@PropertySource("classpath:jdbc.properties")

  @Import({JdbcConfig.class,MybatisConfig.class})

  public class SpringConfig {

  

 

 

  


@RunWith(SpringJUnit4ClassRunner.class)

 

  @ContextConfiguration(classes = SpringConfig.class)

  public class AccountServiceTest {

   @Autowired

   private AccountService accountService;

   @Test

   public void testTransfer() throws IOException {

   accountService.transfer("Tom","Jerry",100D);

  

 

  
再需要被事务管理的方法上添加@Transactional注解(一般加在接口而非实现类中)

  

public interface AccountService {

 

   * 转账操作

   * @param out 传出方

   * @param in 转入方

   * @param money 金额

   @Transactional

   public void transfer(String out,String in ,Double money);

  

 

  


@Bean

 

  public PlatformTransactionManager transactionManager(DataSource dataSource) {

   DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();

   // 需要其他的Bean,直接写参数,详见Bean的注入

   transactionManager.setDataSource(dataSource);

   return transactionManager;

  

 

  
@PropertySource("classpath:jdbc.properties")

  @Import({JdbcConfig.class,MybatisConfig.class})

  @EnableTransactionManagement

  public class SpringConfig {

  

 

 

  
为当前业务层方法添加事务(如果设置在类或接口上方则类或接口中所有方法均添加事务)名称

  
事务管理员:发起事务方,在Spring中通常指代业务层开启事务的方法

  事务协调员:加入事务方,在Spring中通常指代数据层方法,也可以是业务层方法

  
public void transfer(String out,String in ,Double money) {

   accountDao.outMoney(out,money);

   accountDao.inMoney(in,money);

  

 

 

  
Dao 接口中的方法 (事务协调员)

  

@Update("update tbl_account set money = money + #{money} where name = #{name}")

 

  void inMoney(@Param("name") String name, @Param("money") Double money);

  @Update("update tbl_account set money = money - #{money} where name = #{name}")

  void outMoney(@Param("name") String name, @Param("money") Double money);

  

 

  
Service 中运行到 outMoney() 时,调用Dao,操作数据库,该步骤是一个完整的事务

  Service 中运行到 inMoney() 时,调用Dao,操作数据库,该步骤是一个完整的事务

  outMoney() 和 inMoney() 之间没有事务关系

  
Service 中运行到 outMoney() 时,调用Dao,操作数据库,该步骤是一个完整的事务

  Service 中运行到 inMoney() 时,调用Dao,操作数据库,该步骤是一个完整的事务

  开启 Spring 的事务管理后,Service 的 transfer() 方法成为一个独立事务,此时其下事务将进行事务合并,outMoney() 和 inMoney() 都加入到了transfer()事务中,合并成了完整的事务

  
事务仅在发生 Error 和 运行时异常 时才能正常回滚

  此外的异常若想正常回滚需要设置 rollbackFor 属性

  


public interface LogDao {

 

   @Insert("insert into tbl_log (info,createDate) values(#{info},now())")

   void log(String info);

  

 

  
public void log(String out,String in,Double money ) {

   logDao.log("转账操作由"+out+"到"+in+",金额:"+money);

  

 

 

  
代码中,outMoney()、inMoney()、三个为独立事务,但是都加入了事务管理者transfer()开启的事务中,合并为一个整体,出现异常时全部回滚,无法记录日志

  

@Transactional

 

  public void transfer(String out,String in ,Double money) {

   try{

   accountDao.outMoney(out,money);

   accountDao.inMoney(in,money);

   }finally {

   logService.log(out,in,money);

  

 

  
可以将log()对应的事务独立出来,不参与与事务管理者transfer()开启的的事务合并,自然可以不随之而回滚,可在任何时候完成事务

  
@Transactional(propagation = Propagation.REQUIRES_NEW)

   public void log(String out,String in,Double money ) {

   logDao.log("转账操作由"+out+"到"+in+",金额:"+money);

  

 

 

  6.3.3.2 事务传播行为的可选值

  以上就是Spring学习笔记(spring教程 csdn)的详细内容,想要了解更多 Spring学习笔记的内容,请持续关注盛行IT软件开发工作室。

郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。

留言与评论(共有 条评论)
   
验证码: