使用SpringBoot注解方式处理事务回滚

深碍√TFBOYSˉ_ 2022-11-26 06:53 230阅读 0赞

我们在SpringBoot和MyBatis整合的时候，需要在SpringBoot中通过注解方式配置事务回滚  
1 Pojo类

package com.zxf.domain;
    
    import java.util.Date;
    
    public class User { 
        private Integer id;
        private String  name;
        private String pwd;
        private String head_img;
        private String  phone;
        private Date create_time;
    
        public Integer getId() { 
            return id;
        }
    
        public void setId(Integer id) { 
            this.id = id;
        }
    
        public String getName() { 
            return name;
        }
    
        public void setName(String name) { 
            this.name = name;
        }
    
        public String getPwd() { 
            return pwd;
        }
    
        public void setPwd(String pwd) { 
            this.pwd = pwd;
        }
    
        public String getHead_img() { 
            return head_img;
        }
    
        public void setHead_img(String head_img) { 
            this.head_img = head_img;
        }
    
        public String getPhone() { 
            return phone;
        }
    
        public void setPhone(String phone) { 
            this.phone = phone;
        }
    
        public Date getCreate_time() { 
            return create_time;
        }
    
        public void setCreate_time(Date create_time) { 
            this.create_time = create_time;
        }
    }

2 Mapper接口  
我们这里使用注解的方式编写SQL语句

package com.zxf.mapper;
    
    import com.zxf.domain.User;
    import org.apache.ibatis.annotations.Insert;
    import org.springframework.stereotype.Repository;
    
    @Repository
    public interface UserMapper { 
        @Insert("insert into user (name,pwd,head_img,phone,create_time) values(#{name},#{pwd},#{head_img},#{phone},#{create_time})")
            public int save(User user);
    }

3 Service接口和实现类

package com.zxf.service;
    
    import com.zxf.domain.User;
    
    
    public interface UserService { 
        public int save(User user);
    }

package com.zxf.service.impl;
    import com.zxf.domain.User;
    import com.zxf.mapper.UserMapper;
    import com.zxf.service.UserService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    
    @Service
    @Transactional  //实现事务的时候要在业务类中加入该注解
    public class UserServiceImpl implements UserService { 
        @Autowired
        private UserMapper userMapper;
    
        @Override
        public int save(User user) { 
            int f= userMapper.save(user);
          // int x=5/0;
            return f;
        }
    }

4 Controller层

package com.zxf.controller;
    
    import com.zxf.domain.User;
    import com.zxf.service.UserService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import java.util.Date;
    @RestController
    @RequestMapping("api/v1/user")
    public class UserController { 
        @Autowired
        private UserService userService;
         @RequestMapping("save")
        public Object save(){ 
            User user=new User();
               user.setName("zhang3");
               user.setPwd("abc123");
               user.setCreate_time(new Date());
               user.setPhone("1789238734");
               user.setHead_img("aabbddd.jpg");
            userService.save(user);
            return user;
        }
    }

5 application.properits 配置文件

spring.datasource.driver-class-name =com.mysql.jdbc.Driver
    spring.datasource.url=jdbc:mysql://localhost:3306/online
    spring.datasource.username=root
    spring.datasource.password=******
    mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

6 pom文件

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.3.2.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.zxf</groupId>
        <artifactId>xf_spring2</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>xf_spring2</name>
        <properties>
            <java.version>1.8</java.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.1.2</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.13</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

6 SpringBoot启动类

package com.zxf;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.transaction.annotation.EnableTransactionManagement;
    @SpringBootApplication
    @MapperScan("com.zxf.mapper")//扫描mapper接口
    @EnableTransactionManagement//事务处理的时候启动类必须要加的注解
    public class XfSpring2Application { 
        public static void main(String[] args) { 
            SpringApplication.run(XfSpring2Application.class, args);
        }
    }

7 也是最重要，也是很多人忽视的地方，就是MySQL要支持事务处理才可以  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nNjEzMjMyNg_size_16_color_FFFFFF_t_70]  
这里一定要记住；否则你的SpringBoot的事务没有任何效果  
大家在做这部分的内容，如果有问题可以在评论区讨论。如果喜欢我的文章可以关注我！！！

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nNjEzMjMyNg_size_16_color_FFFFFF_t_70]: /images/20221124/799328eb83e64d5f92544a430aaaf6c0.png