快捷導(dǎo)航

spring 注解如何開(kāi)啟聲明式事務(wù)

更新時(shí)間：2022年12月28日 10:49:29 作者：很懶的十六

這篇文章主要介紹了spring 注解開(kāi)啟聲明式事務(wù)問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

spring開(kāi)啟聲明式事務(wù)

導(dǎo)入依賴(lài)

pom.xml

<dependencies>
? ? ? ? <!-- https://mvnrepository.com/artifact/org.springframework/spring-context -->
? ? ? ? <!--spring依賴(lài)-->
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>org.springframework</groupId>
? ? ? ? ? ? <artifactId>spring-context</artifactId>
? ? ? ? ? ? <version>4.3.12.RELEASE</version>
? ? ? ? </dependency>
? ? ? ? <!--單元測(cè)試依賴(lài)-->
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>junit</groupId>
? ? ? ? ? ? <artifactId>junit</artifactId>
? ? ? ? ? ? <version>4.13</version>
? ? ? ? ? ? <scope>test</scope>
? ? ? ? </dependency>

? ? ? ? <!--mysql驅(qū)動(dòng)-->
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>mysql</groupId>
? ? ? ? ? ? <artifactId>mysql-connector-java</artifactId>
? ? ? ? ? ? <version>8.0.21</version>
? ? ? ? </dependency>
? ? ? ? <!-- https://mvnrepository.com/artifact/c3p0/c3p0 -->
? ? ? ? <!--c3p0數(shù)據(jù)源-->
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>c3p0</groupId>
? ? ? ? ? ? <artifactId>c3p0</artifactId>
? ? ? ? ? ? <version>0.9.1.2</version>
? ? ? ? </dependency>
? ? ? ? <!--spring jdbc spring操作數(shù)據(jù)庫(kù)-->
? ? ? ? <dependency>
? ? ? ? ? ? <groupId>org.springframework</groupId>
? ? ? ? ? ? <artifactId>spring-jdbc</artifactId>
? ? ? ? ? ? <version>4.3.12.RELEASE</version>
? ? ? ? </dependency>
? ? </dependencies>

操作數(shù)據(jù)庫(kù)需要配置數(shù)據(jù)源，spring提供的操作數(shù)據(jù)庫(kù)的JdbcTemplate創(chuàng)建時(shí)需要傳入數(shù)據(jù)源，事務(wù)管理器創(chuàng)建時(shí)也需要傳入數(shù)據(jù)源，然后將數(shù)據(jù)源，JdbcTemplate，事務(wù)管理器注冊(cè)到容器中

具體代碼如下：

配置類(lèi)文件

SpringTxConfig.java

package com.sixteen.tx;

import com.mchange.v2.c3p0.ComboPooledDataSource;
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.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;
import java.beans.PropertyVetoException;

@ComponentScan(basePackages = {"com.sixteen.tx"})//包掃描
@Configuration
@EnableTransactionManagement//開(kāi)啟基于注解的聲明式事務(wù)
public class SpringTxConfig {

?? ?//注冊(cè)數(shù)據(jù)源
? ? @Bean
? ? public DataSource dataSource() throws PropertyVetoException {
? ? ? ? ComboPooledDataSource dataSource = new ComboPooledDataSource();
? ? ? ? dataSource.setDriverClass("com.mysql.cj.jdbc.Driver");
? ? ? ? dataSource.setPassword("123456");
? ? ? ? dataSource.setUser("root");
? ? ? ? dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/jdbc?serverTimezone=Asia/Shanghai&useSSL=true&useUnicode=true&characterEncoding=UTF-8");
? ? ? ? return dataSource;
? ? }

?? ?//注冊(cè)JdbcTemplate
? ? @Bean
? ? public JdbcTemplate jdbcTemplate() throws PropertyVetoException {
? ? ? ? //兩種方法獲取DataSource
? ? ? ? //1. 直接在方法放置參數(shù) public JdbcTemplate jdbcTemplate(DataSource dataSource)
? ? ? ? // ? ? ?默認(rèn)會(huì)去容器中獲取
? ? ? ? //2. 如下： 調(diào)用上面的方法


? ? ? ? //spring對(duì)@Configuration類(lèi)有特殊處理，注冊(cè)組件的方法多次調(diào)用只是在IOC容器中找組件
? ? ? ? return new JdbcTemplate(dataSource());
? ? }

? ? //注冊(cè)事務(wù)管理器
? ? @Bean
? ? public PlatformTransactionManager transactionManager() throws PropertyVetoException {
? ? ? ? return new DataSourceTransactionManager(dataSource());//需要傳入dataSource
? ? }
}

ps: 我用的mysql是8.0+版本，編寫(xiě)jdbcUrl時(shí)至少需要附帶時(shí)區(qū)參數(shù):serverTimezone=Asia/Shanghai

在此之前需要在mysql數(shù)據(jù)庫(kù)中建一張普通的User表,如下所示：(id自增)

id	name
1	zhangsan

業(yè)務(wù)邏輯編寫(xiě)

UserDao.java

package com.sixteen.tx;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import java.util.UUID;

@Repository
public class UserDao {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    public void insert(){
        String sql = "INSERT INTO `user`(name) VALUES(?)";
        String name = UUID.randomUUID().toString().substring(0, 5);
        jdbcTemplate.update(sql,name);
    }
}

UserService.java

package com.sixteen.tx;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {

? ? @Autowired
? ? private UserDao userDao;

? ? @Transactional
? ? public void insertUser(){
? ? ? ? userDao.insert();
? ? ? ? System.out.println("插入完成");
? ? ? ? //故意制造錯(cuò)誤，使事務(wù)生效，進(jìn)行回滾
? ? ? ? int i = 10/0;
? ? }
}

測(cè)試代碼

SpringTxTest.java

package com.sixteen.test;

import com.sixteen.tx.SpringTxConfig;
import com.sixteen.tx.UserService;
import org.junit.Test;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class SpringTxTest {
? ? @Test
? ? public void testInsert(){
? ? ? ? AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(SpringTxConfig.class);
? ? ? ? UserService service = context.getBean(UserService.class);
? ? ? ? service.insertUser();
? ? }
}