Spring中的声明式事务管理

方式一：基于xml配置文件方式

1.创建一个测试类

package com.dzj.service;

import com.dzj.dao.UserDaoImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.interceptor.TransactionAspectSupport;

@Service
public class UserService {

    @Autowired
    UserDaoImpl userDao;

    public String addAndReduce(int account){
        try {
            userDao.add(account);
            int i = 10/0;  //模拟异常
            userDao.reduce(account);
            return "成功了";
        }catch (Exception e){
            System.out.println("操作失败："+e);
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();  //手动回滚
//            throw new RuntimeException("heihei");
            return "操作失败，有异常！";
        }

    }
}

2.编写xml配置文件 applicationbean.xml

3.测试方法

@Test
public void userTest1(){

    ClassPathXmlApplicationContext context =
            new ClassPathXmlApplicationContext("applicationbean.xml");
    UserService userService = context.getBean("userService", UserService.class);
    System.out.println(userService.addAndReduce(100));
}

方式二：基于xml配置文件的注解方式

1.创建一个测试类

package com.dzj.service;

import com.dzj.dao.UserDaoImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;

@Service
@Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.REPEATABLE_READ)  //事务注解，可以加在类上面，也可以加在方法上
public class UserService {

    @Autowired
    UserDaoImpl userDao;

    public String addAndReduce(int account){
        try {
            userDao.add(account);
            int i = 10/0;  //模拟异常
            userDao.reduce(account);
            return "成功了";
        }catch (Exception e){
            System.out.println("操作失败："+e);
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();  //手动回滚
//            throw new RuntimeException("heihei");
            return "操作失败，有异常！";
        }

    }
}

2.编写xml配置文件 applicationbean2.xml**

3.测试方法

@Test
public void userTest(){

    ClassPathXmlApplicationContext context =
            new ClassPathXmlApplicationContext("applicationbean2.xml");
    UserService userService = context.getBean("userService", UserService.class);
    System.out.println(userService.addAndReduce(100));
}

方式三：完全注解方式

1.创建一个配置类，替代xml配置文件

package com.dzj.config;

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;

@Configuration  //配置类
@ComponentScan(basePackages = "com.dzj")  //注解扫描
@EnableTransactionManagement //开启事务
public class TxConfig {

    //1.创建数据库连接池
    @Bean
    public DruidDataSource getDruidDataSource(){
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql:///user_db");
        dataSource.setUsername("root");
        dataSource.setPassword("aadzj");
        return dataSource;
    }

    //2.配置JdbcTemplate对象，注入dataSource
    @Bean
    public JdbcTemplate getJdbcTemplate(DataSource dataSource){  //根据类型到ioc中找到DataSource
        JdbcTemplate jdbcTemplate = new JdbcTemplate();
        //注入DataSource
        jdbcTemplate.setDataSource(dataSource);
        return jdbcTemplate;
    }

    //3.创建事务管理器
    @Bean
    public DataSourceTransactionManager getDataSourceTransactionManager(DataSource dataSource){
        DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
        transactionManager.setDataSource(dataSource);
        return transactionManager;
    }
}

2.创建一个测试类

package com.dzj.service;

import com.dzj.dao.UserDaoImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;

@Service
@Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.REPEATABLE_READ)  //事务注解，可以加在类上面，也可以加在方法上
public class UserService {

    @Autowired
    UserDaoImpl userDao;

    public String addAndReduce(int account){
        try {
            userDao.add(account);
            int i = 10/0;  //模拟异常
            userDao.reduce(account);
            return "成功了";
        }catch (Exception e){
            System.out.println("操作失败："+e);
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();  //手动回滚
//            throw new RuntimeException("heihei");
            return "操作失败，有异常！";
        }

    }
}

3.测试方法

@Test
public void userTest3(){

    AnnotationConfigApplicationContext context =
            new AnnotationConfigApplicationContext(TxConfig.class);
    UserService userService = context.getBean("userService", UserService.class);
    System.out.println(userService.addAndReduce(100));
}

Original: https://www.cnblogs.com/aadzj/p/15719776.html
Author: 小公羊
Title: Spring中的声明式事务管理