80.【Spring5】（八）-阿里云开发者社区

(十五)、事务回顾

1.回顾事务

把一组业务当成一个业务来做；要么都成功，要么都失败
事务在项目开发中，十分的重要，涉及到数据的一致性问题，不能马虎
确保完整性和一致性

(1).ACID

原子性
一致性
隔离性:多个数据操作同一个资源
持久性: 事务一旦提交，结果都不会再影响

2.Spring的增删改业务实现

实体类

package Com.Jsxs.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@AllArgsConstructor
@NoArgsConstructor
@Data
public class User {
    private int id;
    private String name;
    private String pwd;
}

接口

package Com.Jsxs.Mapper;
import Com.Jsxs.pojo.User;
import java.util.List;
public interface UserMapper {
//    查询所有的用户
    List<User> selectUser();
//    添加一个用户
    int addUser(User user);
//    删除一个用户
    int deleteUser(int id);
}

接口实现类

package Com.Jsxs.Mapper;
import Com.Jsxs.pojo.User;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.support.SqlSessionDaoSupport;
import java.util.List;
public class UserMapperImpl extends SqlSessionDaoSupport implements UserMapper{
//    进行全部信息的查询
    @Override
    public List<User> selectUser() {
        UserMapper mapper = getSqlSession().getMapper(UserMapper.class);
        User user = new User(7,"说的","54545");
        mapper.addUser(user);
        mapper.deleteUser(7);
        return mapper.selectUser();
    }
//    进行数据的添加
    @Override
    public int addUser(User user) {
        return getSqlSession().getMapper(UserMapper.class).addUser(user);
    }
//   进行数据的删除
    @Override
    public int deleteUser(int id) {
        return getSqlSession().getMapper(UserMapper.class).deleteUser(id);
    }
}

接口配置文件

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "https://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="Com.Jsxs.Mapper.UserMapper">
<!--    进行数据的全部信息查询-->
    <select id="selectUser" resultType="Com.Jsxs.pojo.User">
        select *from mybatis.user
    </select>
<!-- 进行数据的添加-->
    <insert id="addUser" parameterType="Com.Jsxs.pojo.User">
        insert into user values(#{id},#{name},#{pwd})
    </insert>
<!--  进行数据的删除  -->
    <delete id="deleteUser" parameterType="int">
        delete from user where id=#{id}
    </delete>
</mapper>

mybatis核心文件

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "https://mybatis.org/dtd/mybatis-3-config.dtd">
<!--configuration核心配置文件-->
<configuration>
</configuration>

spring核心文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
">
<!--
DateSource: 使用Spring的数据源替换MyBatis的配置
我们这里使用Spring-Jdbc依赖提供的类 : org.springframework.jdbc.datasource.DriverManagerDataSource
-->
    <bean id="datasource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/mybatis?useSSL=false&amp;useUnicode=true&amp;charEncoding=UTF8"/>
        <property name="username" value="root"/>
        <property name="password" value="121788"/>
    </bean>
    <!--sqlSessionFactory-->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="datasource"/>
        <!--   绑定mybatis配置文件-->
        <property name="configLocation" value="classpath:mybatis-config.xml"/>
        <property name="mapperLocations" value="classpath:Com/Jsxs/Mapper/*.xml"/>
    </bean>
    <!--    SqlSessionTemplate: 就是我们需要用的sqlSession-->
<!--    <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">-->
<!--        &lt;!&ndash;       只能利用构造器注入 sqlSessionFactory，因为他没有set方法&ndash;&gt;-->
<!--        <constructor-arg index="0" ref="sqlSessionFactory"/>-->
<!--    </bean>-->
</beans>

汇总文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
">
    <import resource="spring-dao.xml"/>
    <!--创建bean1-->
    <bean id="user1" class="Com.Jsxs.Mapper.UserMapperImpl">
        <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>
</beans>

测试

import Com.Jsxs.Mapper.UserMapper;
import Com.Jsxs.pojo.User;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.util.List;
public class MyTest {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("application.xml");
        UserMapper user1 = context.getBean("user1", UserMapper.class);
        List<User> userList = user1.selectUser();
        for (User user : userList) {
            System.out.println(user);
        }
    }
}

3.继承SqlSessionDaoSupport

在spring核心文件中可以不用写第三个factory的豆
自动帮我们进行提交事务，不用手动提交了

4.Spring声明事务

Spring中的事务管理

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

(1).基本要求

(1).接口

package Com.Jsxs.Mapper;
import Com.Jsxs.pojo.User;
import java.util.List;
public interface UserMapper {
//    查询所有的用户
    List<User> selectUser();
//    添加一个用户
    int addUser(User user);
//    删除一个用户
    int deleteUser(int id);
}

(2).mapper.xml文件

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "https://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="Com.Jsxs.Mapper.UserMapper">
<!--    进行数据的全部信息查询-->
    <select id="selectUser" resultType="Com.Jsxs.pojo.User">
        select *from mybatis.user
    </select>
<!-- 进行数据的添加-->
    <insert id="addUser" parameterType="Com.Jsxs.pojo.User">
        insert into user values(#{id},#{name},#{pwd})
    </insert>
<!--  进行数据的删除  -->
    <delete id="deleteUser" parameterType="int">
        deletes from user where id=#{id}
    </delete>
</mapper>

(3).接口实现类【new】

mapper.addUser(user);
mapper.deleteUser(7);.
在select方法中进行添加和删除；

package Com.Jsxs.Mapper;
import Com.Jsxs.pojo.User;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.support.SqlSessionDaoSupport;
import java.util.List;
public class UserMapperImpl extends SqlSessionDaoSupport implements UserMapper{
//    进行全部信息的查询
    @Override
    public List<User> selectUser() {
        UserMapper mapper = getSqlSession().getMapper(UserMapper.class);
        User user = new User(7,"说的","54545");
        mapper.addUser(user);
        mapper.deleteUser(7);
        return mapper.selectUser();
    }
//    进行数据的添加
    @Override
    public int addUser(User user) {
        return getSqlSession().getMapper(UserMapper.class).addUser(user);
    }
//   进行数据的删除
    @Override
    public int deleteUser(int id) {
        return getSqlSession().getMapper(UserMapper.class).deleteUser(id);
    }
}

(4).实体类

package Com.Jsxs.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@AllArgsConstructor
@NoArgsConstructor
@Data
public class User {
    private int id;
    private String name;
    private String pwd;
}

(5).mybatis核心文件

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "https://mybatis.org/dtd/mybatis-3-config.dtd">
<!--configuration核心配置文件-->
<configuration>
</configuration>

(6).Spring核心文件【new】

(1).命令开启事务
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <constructor-arg ref="datasource" />
</bean>
(2).结合Aop进行切面添加事务
(3).配置事务通知
<tx:advice id="txAdvice" transaction-manager="transactionManager">
(4).给哪些方法配置事务(需要添加约束) name: 需要添加事务接口的方法名 propagation 事务权限
 <tx:attributes>
            <tx:method name="addUser" propagation="REQUIRED"/>
            <tx:method name="deleteUser" propagation="REQUIRED"/>
            <tx:method name="selectUser" propagation="REQUIRED"/>
</tx:attributes>
(5).配置事务切入
<aop:config>
        <aop:pointcut id="pointcut" expression="execution(* Com.Jsxs.Mapper.*.*(..))"/>
        <aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut"/>
</aop:config>

<?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:tx="http://www.springframework.org/schema/tx"
       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/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
">
<!--
DateSource: 使用Spring的数据源替换MyBatis的配置
我们这里使用Spring-Jdbc依赖提供的类 : org.springframework.jdbc.datasource.DriverManagerDataSource
-->
    <bean id="datasource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/mybatis?useSSL=false&amp;useUnicode=true&amp;charEncoding=UTF8"/>
        <property name="username" value="root"/>
        <property name="password" value="121788"/>
    </bean>
    <!--sqlSessionFactory-->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="datasource"/>
        <!--   绑定mybatis配置文件-->
        <property name="configLocation" value="classpath:mybatis-config.xml"/>
        <property name="mapperLocations" value="classpath:Com/Jsxs/Mapper/*.xml"/>
    </bean>
    <!--    SqlSessionTemplate: 就是我们需要用的sqlSession-->
<!--    <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">-->
<!--        &lt;!&ndash;       只能利用构造器注入 sqlSessionFactory，因为他没有set方法&ndash;&gt;-->
<!--        <constructor-arg index="0" ref="sqlSessionFactory"/>-->
<!--    </bean>-->
<!--    配置声明式事务-->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <constructor-arg ref="datasource" />
    </bean>
<!--    结合AOP实现事物的植入-->
<!--配置事务通知:-->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
<!--
    给哪些方法进行配置事务
    配置事务的传播特性: propagation
    name: 指向配置事务的方法名
-->
        <tx:attributes>
            <tx:method name="addUser" propagation="REQUIRED"/>
            <tx:method name="deleteUser" propagation="REQUIRED"/>
<!--            <tx:method name="update" propagation="REQUIRED"/>-->
            <tx:method name="selectUser" propagation="REQUIRED"/>
        </tx:attributes>
    </tx:advice>
<!--    配置事务切入-->
    <aop:config>
        <aop:pointcut id="pointcut" expression="execution(* Com.Jsxs.Mapper.*.*(..))"/>
        <aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut"/>
    </aop:config>
</beans>

(7).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"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
">
    <import resource="spring-dao.xml"/>
    <!--创建bean1-->
    <bean id="user1" class="Com.Jsxs.Mapper.UserMapperImpl">
        <property name="sqlSessionFactory" ref="sqlSessionFactory"/>
    </bean>
</beans>

(8).测试

import Com.Jsxs.Mapper.UserMapper;
import Com.Jsxs.pojo.User;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.util.List;
public class MyTest {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("application.xml");
        UserMapper user1 = context.getBean("user1", UserMapper.class);
        List<User> userList = user1.selectUser();
        for (User user : userList) {
            System.out.println(user);
        }
    }
}

(9).效果展示

我们因为对查询的方法进行了切面(AOP)的操作,并且我们给事务增加，删除和查询都进行事务的管理，添加了事务。所以我们在进行设置查询的时候；查询的方法内涵着(添加和删除)，我们故意在删除的时候埋下埋伏，验证成功事务设置成功；不会添加信息7

5.为什么要使用事务

如果不配置事务，可能存在数据提交不一致的情况
如果我们不在Spring中去配置声明式事务，我们就需要在代码中进行手动
事务在项目中十分重要，涉及到数据的一致性和完整性问题，不能马虎。

80.【Spring5】（八）

(十五)、事务回顾

1.回顾事务

(1).ACID

2.Spring的增删改业务实现

3.继承SqlSessionDaoSupport

4.Spring声明事务

(1).基本要求

(1).接口

(2).mapper.xml文件

(3).接口实现类【new】

(4).实体类

(5).mybatis核心文件

(6).Spring核心文件【new】

(7).applicationContext.xml

(8).测试

(9).效果展示

5.为什么要使用事务

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

80.【Spring5】（八）

(十五)、事务回顾

1.回顾事务

(1).ACID

2.Spring的增删改业务实现

3.继承SqlSessionDaoSupport

4.Spring声明事务

(1).基本要求

(1).接口

(2).mapper.xml文件

(3).接口实现类【new】

(4).实体类

(5).mybatis核心文件

(6).Spring核心文件【new】

(7).applicationContext.xml

(8).测试

(9).效果展示

5.为什么要使用事务

热门文章

最新文章

相关课程

相关电子书

相关实验场景