什么是事务

一组操作，要么都成功，要么都失败。

  • 声明式事务：AOP
  • 编程式事务：需要在代码中进行事务管理

使用Spring声明式事务

Mapper接口实现类

  2. public interface IEmpMapper {
  3.     List<Emp> select();
  4.     int insert(Emp emp);
  5.     int delete(@Param("id")int id);
  6. }
  8. //继承SqlSessionDaoSupport
  9. public class EmpMapper2 extends SqlSessionDaoSupport implements IEmpMapper{
  11.     //在调用select时，会先添加，在删除，最后查询
  12.     @Override
  13.     public List<Emp> select() {
  14.         insert(new Emp(1,"问问",56,"男","999@qq.com",new Dept(2)));
  15.         delete(2);
  16.         return getSqlSession().getMapper(IEmpMapper.class).select();
  17.     }
  19.     @Override
  20.     public int insert(Emp emp) {
  21.         return getSqlSession().getMapper(IEmpMapper.class).insert(emp);
  22.     }
  24.     @Override
  25.     public int delete(int id) {
  26.         return getSqlSession().getMapper(IEmpMapper.class).delete(id);
  27.     }
  28. }

Mapper.xml映射文件
可以看到我故意写错了delete语句。如果执行上面的select()方法，添加成功过后，删除会失败。
这时候，数据库有被添加的数据，但是要删除的数据却还在。
应该用事务把select()方法看作是一个整体，全部成功就成功，一个失败了，全部回滚都失败。

  1. <mapper namespace="com.lyd.mapper.IEmpMapper">
  3.     <select id="select" resultType="Emp">
  4.         select*from t_emp
  5.     </select>
  6.     <insert id="insert">
  7.         insert into t_emp values(null,#{empName},#{age},#{sex},#{email},#{dept.did})
  8.     </insert>
  9.     <delete id="delete">
  10.         deletes from t_emp where eid = #{id}
  11.     </delete>
  12. </mapper>

在Spring配置文件里面配置事务

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.        xmlns:aop="http://www.springframework.org/schema/aop"
  5.        xmlns:tx="http://www.springframework.org/schema/tx"
  6.        xsi:schemaLocation="http://www.springframework.org/schema/beans
  7.         https://www.springframework.org/schema/beans/spring-beans.xsd
  8.         http://www.springframework.org/schema/aop
  9.         https://www.springframework.org/schema/aop/spring-aop.xsd
  10.         http://www.springframework.org/schema/tx
  11.         https://www.springframework.org/schema/tx/spring-tx.xsd">
  14.     <!--
  15.     DataSource：
  16.     使用Spring的数据源替换Mybatis的配置，c3p0 dbcp druid
  17.     这里使用Spring提供的JDBC
  18.     -->
  19.     <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
  20.         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  21.         <property name="url" value="jdbc:mysql://localhost:3306/mybatisdb?useUnicode=true&amp;characterEncoding=utf8"/>
  22.         <property name="username" value="root"/>
  23.         <property name="password" value="123456"/>
  24.     </bean>
  25.     <!--
  26.     sqlSessionFactory:
  27.     -->
  28.     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
  29.         <property name="dataSource" ref="dataSource" />
  30.         <!--绑定Mybatis配置文件-->
  31.         <property name="configLocation" value="classpath:mybatis-config.xml"/>
  32.         <property name="mapperLocations" value="classpath:com/lyd/mapper/*.xml"/>
  33.     </bean>
  35.     <!--配置声明式事务-->
  36.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  37.         <property name="dataSource" ref="dataSource"/>
  38.     </bean>
  39.     <!--结合AOP实现事务的织入-->
  40.     <!--配置事务通知-->
  41.     <tx:advice id="txAdvice" transaction-manager="transactionManager">
  42.         <!--给哪些方法配置事务-->
  43.         <!---->
  44.         <tx:attributes>
  45.             <tx:method name="query" propagation="REQUIRED"/>
  46.         </tx:attributes>
  47.     </tx:advice>
  48.     <!--配置事务的切入-->
  49.     <aop:config>
  50.         <aop:pointcut id="txPointCut" expression="execution(* com.lyd.mapper.*.*(..))"/>
  51.         <aop:advisor advice-ref="txAdvice" pointcut-ref="txPointCut"/>
  52.     </aop:config>
  54.     <!--
  55.     上面都是固定的写法：
  56.     下面都是才是自己编写的实现类，有多少实现类就编写多少bean
  57.     注入sqlSession对象
  58.     -->
  59.     <bean id="empMapper2" class="com.lyd.mapper.EmpMapper2">
  60.         <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
  61.     </bean>
  62. </beans>

现在测试，哪怕insert()方法没问题，delete()方法失败了，最终insert()也没有真正的加入数据到数据库

  1.     @Test
  2.     public void test1() throws IOException {
  4.         ApplicationContext context = new ClassPathXmlApplicationContext("ApplicationContext.xml");
  5.         IEmpMapper iempMapper =context.getBean("empMapper2",IEmpMapper.class);
  6.         List<Emp> emps = iempMapper.select();
  7.         for (Emp emp: emps) {
  8.             System.out.println(emp.toString());
  9.         }
  10.     }