0
点赞
收藏
分享

微信扫一扫

【Spring】011-Spring声明式事务

天涯学馆 2023-02-23 阅读 151
springjavaxmlListMySQL数据库
加载失败


一、事务回顾

1、概述

①一组业务：要么都成功，要么都失败；

②事务在项目开发中，十分重要，涉及数据的一致性，不可马虎；

 

 

2、事务的ACID原则

A：原子性；

C：一致性；

I：隔离性：多个业务操作数据，相互隔离，不能相互影响；

D：持久性：事务一旦提交，无论系统发生什么问题，结果都不会被影响，都被被持久化地写到了存储器中；

 

3、环境搭建（类似Spring整合Mybatis案例）

第一步：创建新Moudle，并往pom.xml导入所依赖的Maven坐标

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>StudySpring</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>spring_011_transcation</artifactId>
    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.13</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.21</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.5.5</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>5.2.8.RELEASE</version>
        </dependency>
        <!--Spring操作数据库的话，好需要Spring JDBC-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.2.8.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.9.6</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>2.0.5</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.12</version>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
    </dependencies>

</project>

第二步：创建实体类Account

package com.zibo.pojo;

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

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Account {
    private int id;
    private String name;
    private double money;
}

第三步：创建AccountMapper接口

package com.zibo.mapper;

import com.zibo.pojo.Account;

import java.util.List;

public interface AccountMapper {
    List<Account> findAll();
}

第四步：编写AccountMapper.xml

<?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.zibo.mapper.AccountMapper">
    <!--    配置查询所有-->
    <select id="findAll" resultType="com.zibo.pojo.Account">
        select * from account;
    </select>
</mapper>

第五步：编写Spring整合Mybatis的配置文件applicationContext.xml

<?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:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd">
    <!--DataSource：使用Spring的数据源替换MyBatis的配置，c3p0 dbcp druid，
    我们这里使用Spring的JDBC:org.springframework.jdbc.datasource-->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/zibo?serverTimezone=UTC"/>
        <property name="username" value="root"/>
        <property name="password" value="zibo15239417242"/>
    </bean>
    <!--sqlSessionFactory-->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <!--绑定Mybatis配置文件-->
        <!--spring可以整合mybatis的配置，也可以将mybatis的配置文件引入-->
<!--        这个引入导致错误，暂时就不引入了，所有的配置也可由spring完成-->
<!--        <property name="configuration" value="classpath:mybatis-config.xml"/>-->
        <property name="mapperLocations" value="classpath:mapper/AccountMapper.xml"/>
<!--        设置别名-->
        <property name="typeAliasesPackage" value="com.zibo.pojo"/>
    </bean>
    <!--SqlSessionTemplate：就是我们使用的SqlSession-->
    <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
        <!--这里只能通过构造器注入，因为SqlSessionTemplate没有setter方法-->
        <constructor-arg name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>

    <!--注入AccountMapperImpl-->
    <bean id="accountMapper" class="com.zibo.mapper.AccountMapperImpl">
        <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>
</beans>

第六步：编写Log4j配置文件

# Set root category priority to INFO and its only appender to CONSOLE.
#log4j.rootCategory=INFO, CONSOLE            debug   info   warn error fatal
log4j.rootCategory=debug, CONSOLE, LOGFILE

# Set the enterprise logger category to FATAL and its only appender to CONSOLE.
log4j.logger.org.apache.axis.enterprise=FATAL, CONSOLE

# CONSOLE is set to be a ConsoleAppender using a PatternLayout.
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} %-6r [%15.15t] %-5p %30.30c %x - %m\n

# LOGFILE is set to be a File appender using a PatternLayout.
log4j.appender.LOGFILE=org.apache.log4j.FileAppender
log4j.appender.LOGFILE.File=d:\axis.log
log4j.appender.LOGFILE.Append=true
log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
log4j.appender.LOGFILE.layout.ConversionPattern=%d{ISO8601} %-6r [%15.15t] %-5p %30.30c %x - %m\n

第七步：创建AccountMapper接口的实现类

package com.zibo.mapper;

import com.zibo.pojo.Account;
import org.mybatis.spring.support.SqlSessionDaoSupport;

import java.util.List;

public class AccountMapperImpl extends SqlSessionDaoSupport implements AccountMapper {
    @Override
    public List<Account> findAll() {
        return getSqlSession().getMapper(AccountMapper.class).findAll();
    }
}

第八步：创建测试类

package zibo;

import com.zibo.mapper.AccountMapper;
import com.zibo.pojo.Account;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.List;

public class MyTest {
    @Test
    public void testFindAll(){
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
        AccountMapper mapper = context.getBean("accountMapper", AccountMapper.class);
        List<Account> all = mapper.findAll();
        for (Account account : all) {
            System.out.println(account);
        }
    }
}

测试结果：

Account(id=1, name=大哥, money=100.0)
Account(id=2, name=二哥, money=200.0)
Account(id=6, name=訾博, money=88.0)

 

4、开始模拟事务

第一步：修改AccountMapper接口

package com.zibo.mapper;

import com.zibo.pojo.Account;

import java.util.List;

public interface AccountMapper {
    List<Account> findAll();
    
    //添加账户
    int saveAccount(Account account);

    //删除账户
    int deleteAccount(int id);
}

第二步：修改AccountMapper.xml

<?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.zibo.mapper.AccountMapper">
    <!--配置查询所有-->
    <select id="findAll" resultType="com.zibo.pojo.Account">
        select * from account;
    </select>
    <!--配置添加用户-->
    <insert id="saveAccount" parameterType="account">
        insert into account (id,name,money) values (#{id},#{name},#{money});
    </insert>
    <!--配置删除用户，为了程序出错，故意将delete多写个s-->
    <delete id="deleteAccount" parameterType="int">
        deletes from account where id = #{id};
    </delete>
</mapper>

第三步：在接口实现类中补全新增的方法

package com.zibo.mapper;

import com.zibo.pojo.Account;
import org.mybatis.spring.support.SqlSessionDaoSupport;

import java.util.List;

public class AccountMapperImpl extends SqlSessionDaoSupport implements AccountMapper {
    @Override
    public List<Account> findAll() {
        //在这里多做一些事情，制造一些错误
        Account account = new Account(10, "三哥", 100);
        saveAccount(account);
        deleteAccount(10);
        return getSqlSession().getMapper(AccountMapper.class).findAll();
    }

    @Override
    public int saveAccount(Account account) {
        return getSqlSession().getMapper(AccountMapper.class).saveAccount(account);
    }

    @Override
    public int deleteAccount(int id) {
        return getSqlSession().getMapper(AccountMapper.class).deleteAccount(id);
    }
}

测试结果（报错）：

【Spring】011-Spring声明式事务_spring

看看数据库：

【Spring】011-Spring声明式事务_List_02

这就很尴尬了吧，我就想犯贱插入再删除，结果插入了没删除成功！

那咋办，这个时候我们就需要用到事务了，使其要成功都成功，要失败都失败！

 

5、mybatis-spring的事务管理概述

一个使用 MyBatis-Spring 的其中一个主要原因是它允许 MyBatis 参与到 Spring 的事务管理中。而不是给 MyBatis 创建一个新的专用事务管理器，MyBatis-Spring 借助了 Spring 中的 DataSourceTransactionManager 来实现事务管理；

一旦配置好了 Spring 的事务管理器，你就可以在 Spring 中按你平时的方式来配置事务。并且支持 @Transactional 注解和 AOP 风格的配置。在事务处理期间，一个单独的 SqlSession 对象将会被创建和使用。当事务完成时，这个 session 会以合适的方式提交或回滚；

事务配置好了以后，MyBatis-Spring 将会透明地管理事务。这样在你的 DAO 类中就不需要额外的代码了；

 

二、Spring声明式事务

1、Spring中的事务管理分为两种

声明式事务（常用）：AOP；

编程式事务：需要在代码中进行事务管理；

 

2、代码演示

第一步：在applicationContext.xml中配置声明式事务

<?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:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd">
    <!--DataSource：使用Spring的数据源替换MyBatis的配置，c3p0 dbcp druid，
    我们这里使用Spring的JDBC:org.springframework.jdbc.datasource-->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/zibo?serverTimezone=UTC"/>
        <property name="username" value="root"/>
        <property name="password" value="zibo15239417242"/>
    </bean>
    <!--sqlSessionFactory-->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <!--绑定Mybatis配置文件-->
        <!--spring可以整合mybatis的配置，也可以将mybatis的配置文件引入-->
<!--        这个引入导致错误，暂时就不引入了，所有的配置也可由spring完成-->
<!--        <property name="configuration" value="classpath:mybatis-config.xml"/>-->
        <property name="mapperLocations" value="classpath:mapper/AccountMapper.xml"/>
<!--        设置别名-->
        <property name="typeAliasesPackage" value="com.zibo.pojo"/>
    </bean>
    <!--SqlSessionTemplate：就是我们使用的SqlSession-->
    <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
        <!--这里只能通过构造器注入，因为SqlSessionTemplate没有setter方法-->
        <constructor-arg name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>

    <!--注入AccountMapperImpl-->
    <bean id="accountMapper" class="com.zibo.mapper.AccountMapperImpl">
        <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>
    <!--开启 Spring 的事务处理功能-->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <constructor-arg ref="dataSource" />
    </bean>
    <!--结合AOP，实现事务的织入-->
    <!--配置事务通知-->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <!--给那些方法配置事务-->
        <!--配置事务的传播特性（新）,propagation默认就是REQUIRED-->
        <tx:attributes>
            <tx:method name="save" propagation="REQUIRED"/>
            <tx:method name="delete" propagation="REQUIRED"/>
            <tx:method name="update" propagation="REQUIRED"/>
            <tx:method name="query" read-only="true"/>
            <tx:method name="*" propagation="REQUIRED"/>
        </tx:attributes>
    </tx:advice>
    <!--配置事务切入-->
    <aop:config>
        <aop:pointcut id="txPointCut" expression="execution(* com.zibo.mapper.*.*(..))"/>
        <aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut"/>
    </aop:config>
</beans>

测试结果：

【Spring】011-Spring声明式事务_List_03

依旧报错，但没有插入成功；

【Spring】011-Spring声明式事务_spring_04

我们没有修改原来的代码，只是通过AOP配置了事务管理，就成功达到了事务管理的目的，这就是Spring AOP的伟大！

 

3、注意

为什么需要事务：

如果不配置事务，可能无法保证数据提交的一致性；

如果我们不配置Spring声明式事务，我们需要在代码中手动配置事务；

事务在项目开发中，十分重要，涉及数据的一致性，不可马虎！

 

三、Spring学习整个项目的源码

链接：https://pan.baidu.com/s/1Jy3Q4MPtBxrlor7jybHl3g 
提取码：zibo

 

 

 

 

 

 

 

举报

相关推荐

Spring 声明式事务

springjavahibernate

Spring声明式事务

springjava数据库

（十二）Spring 事务 - 声明式事务

springjava后端

Spring声明式事务控制

分布式数据库中间件

Spring Boot 声明式事务

spring boot后端java

Spring声明式事务详解

事务管理分布式事务java

spring-声明式事务

springjava后端

Spring声明式事务介绍

java数据库spring后端spring boot

spring的声明式事务

spring配置文件事务hibernate事务管理OpenStack云计算

Spring的声明式事务

事务管理回滚隔离级别Java后端开发指尖人生
0 条评论
加载失败