Spring Boot @Transactional注解使用

深藏阁楼爱情的钟 2023-06-27 14:00 16阅读 0赞

# 一、使用spring 事务注解@Transactional #

## 1.数据库表 ##

users.sql

DROP TABLE IF EXISTS `users`;
    CREATE TABLE `users`  (
      `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键id',
      `userName` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '用户名',
      `passWord` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '密码',
      `user_sex` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `nick_name` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      PRIMARY KEY (`id`) USING BTREE
    ) ENGINE = InnoDB AUTO_INCREMENT = 28 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

## 2.pom依赖 ##

pom.xml

<dependencies>
    		
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.1.1</version>
            </dependency>
    
            
    		
    
            
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.1.10</version>
            </dependency>
            
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>1.2.17</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>

# 3.spring boot配置文件 #

application.properties

mybatis.type-aliases-package=com.ljj.entity
    mybatis.mapper-locations=classpath:mapping/*.xml
    
    #################### spring boot druid配置 ################################
    
    spring.datasource.druid.url=jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8&useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=GMT%2B8
    spring.datasource.druid.username=root
    spring.datasource.druid.password=root
    spring.datasource.druid.driver-class-name=com.mysql.cj.jdbc.Driver
    # 初始化大小，最小，最大
    spring.datasource.druid.initial-size=5
    spring.datasource.druid.min-idle=5
    spring.redis.jedis.pool.max-idle=100
    spring.datasource.druid.max-active=200
    
    
    # 配置获取连接等待超时的时间
    spring.datasource.druid.max-wait=5000
    
    # 每次使用连接时进行校验，会影响系统性能。默认为false
    spring.datasource.druid.test-on-borrow=false
    spring.datasource.druid.test-on-return=false
    
    # 验证使用的SQL语句
    spring.datasource.druid.validation-query=SELECT 1
    
    # 指明连接是否被空闲连接回收器(如果有)进行检验.如果检测失败,则连接将被从池中去除
    spring.datasource.druid.test-while-idle=true
    
    # 每30秒运行一次空闲连接回收器（默认-1）
    spring.datasource.druid.time-between-eviction-runs-millis=30000
    
    # 池中的连接空闲30分钟后被回收（默认30分钟）
    spring.datasource.druid.min-evictable-idle-time-millis=1800000
    
    # 在每次空闲连接回收器线程(如果有)运行时检查的连接数量（设置为和maxIdle一样）
    # 不再使用，一个DruidDataSource只支持一个EvictionRun
    # spring.datasource.druid.num-tests-per-eviction-run=100
    
    # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
    spring.datasource.druid.filters=stat,wall,log4j
    spring.datasource.druid.filter.stat.log-slow-sql=true
    
    ################################################################################

## 4.实体类 ##

User.java

@Data
    @AllArgsConstructor
    @NoArgsConstructor
    @ToString
    @EqualsAndHashCode
    public class User {
        private long id;
        private String userName;
        private String passWord;
        private String userSex;
        private String nickName;
    
        public User(String userName, String passWord, String userSex, String nickName) {
            this.userName = userName;
            this.passWord = passWord;
            this.userSex = userSex;
            this.nickName = nickName;
        }
    }

## 5.dao层 ##

UserDao.java

@Repository
    @MapperScan(basePackages = "com.ljj.dao")
    public interface UserDao {
        List<User> getAll();
    
        User getOne(Long id);
    
        void insert(User user);
    
        void update(User user);
    
        void delete(Long id);
    }

## 6.mapping映射 ##

resources/mapping/UserMapper.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.ljj.dao.UserDao" >
        <resultMap id="BaseResultMap" type="com.ljj.entity.User" >
            <id column="id" property="id" jdbcType="BIGINT" />
            <result column="userName" property="userName" jdbcType="VARCHAR" />
            <result column="passWord" property="passWord" jdbcType="VARCHAR" />
            <result column="user_sex" property="userSex" jdbcType="VARCHAR"/>
            <result column="nick_name" property="nickName" jdbcType="VARCHAR" />
        </resultMap>
    
        <sql id="Base_Column_List" >
            id, userName, passWord, user_sex, nick_name
        </sql>
    
        <select id="getAll" resultMap="BaseResultMap"  >
            SELECT
            <include refid="Base_Column_List" />
            FROM users
        </select>
    
        <select id="getOne" parameterType="java.lang.Long" resultMap="BaseResultMap" >
            SELECT
            <include refid="Base_Column_List" />
            FROM users
            WHERE id = #{id}
        </select>
    
        <insert id="insert" parameterType="com.ljj.entity.User" >
            INSERT INTO
                users
                (userName,passWord,user_sex)
            VALUES
                (#{userName}, #{passWord}, #{userSex})
        </insert>
    
        <update id="update" parameterType="com.ljj.entity.User" >
            UPDATE
            users
            SET
            <if test="userName != null">userName = #{userName},</if>
            <if test="passWord != null">passWord = #{passWord},</if>
            nick_name = #{nickName}
            WHERE
            id = #{id}
        </update>
    
        <delete id="delete" parameterType="java.lang.Long" >
            DELETE FROM
                users
            WHERE
                id =#{id}
        </delete>
    
    </mapper>

## 7.service层 ##

UserService.java

@Service
    @Transactional
    //@Transactional(rollbackFor = Exception.class)
    @Slf4j
    public class UserService {
    
        @Autowired
        private UserDao userDao;
    
        public void test() throws Exception {
            List<User> user = userDao.getAll();
            log.info("----------------> user: {}", user);
            User user1 = new User("eee", "eee", "eee", "angular");
            userDao.insert(user1);
            List<User> user2 = userDao.getAll();
            log.info("----------------> user: {}", user2);
            throw new RuntimeException("抛出一个运行期异常");
        }
    }

@Transactional默认只是拦截RuntimeException，如果需要拦截Exception，则要加上rollbackFor参数

## 8.测试 ##

@RunWith(SpringRunner.class)
    @SpringBootTest
    public class TransactionApplicationTests {
    
        @Autowired
        private UserService userService;
    
        @Test
        public void test() {
            try {
                userService.test();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

## 9.github ##

[GitHub][]

[GitHub]: https://github.com/kanateSong/spring-boot-transaction