SpringBoot整合Mybatis，並實現事務控制

SpringBoot整合Mybatis，並實現事務控制

1、 在pom文件里添加相關maven文件

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.3.RELEASE</version>
        <relativePath/> 
    </parent>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.21</version>
        </dependency>

        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.2</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!-- Junit依賴 -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

2、 在application.properties配置文件中引入數據源,創建數據庫表，並插入兩條原始數據：andy 余額200元，lucy 余額300元

spring.datasource.url=jdbc:mysql://localhost:3306/springboot_demo
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

DROP TABLE IF EXISTS tbl_account;
CREATE TABLE tbl_account (
  id int(11) NOT NULL AUTO_INCREMENT,
  name varchar(20) NOT NULL,
  balance float,
  PRIMARY KEY (id)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;


insert into tbl_account(id,name,balance) values(1, 'andy','200');
insert into tbl_account(id,name,balance) values(2, 'lucy','300');

數據庫初始值如下：

3、 開發實體類,dao,service,controller,mapper等
實體類 ：

public class Account {

    private int id; 
    private String name;
    private float balance;

    public Account() {

    }
    // 省略setter / getter
}

dao ：

public interface AccountDao {

    public void moveIn(@Param("id") int id, @Param("money") float money); // 轉入

    public void moveOut(@Param("id") int id, @Param("money") float money); // 轉出
}

service ：

public interface AccountService {    
    //轉賬
    public void transfer(int outter,int inner,Integer money);

}

service 實現類：

@Service
public class AccountServiceImpl implements AccountService{

    @Autowired
    private AccountDao accountDao;

    public void transfer(int outter, int inner, Integer money) {

        accountDao.moveOut(outter, money); //轉出
        accountDao.moveIn(inner, money); //轉入

    }
}

controller：

@RestController
@RequestMapping(value = "/account")
public class AccountController {

    @Autowired
    private AccountService accountService;


    @RequestMapping("/transfer")
    public String test(){
        try {
            // andy 給lucy轉賬50元
            accountService.transfer(1, 2, 50);
            return "轉賬成功";
        } catch (Exception e) {
            e.printStackTrace();
            return "轉賬失敗";
        }
    }
}

mapper:

<?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="cn.yideng.tx.dao.AccountDao">

    <!-- 轉入 -->
    <update id="moveIn" >
        update tbl_account 
        set balance = balance + #{money }
        where id= #{id,jdbcType=INTEGER}
    </update>

    <!-- 轉出 -->
    <update id="moveOut" >
        update tbl_account 
        set balance = balance - #{money }
        where id= #{id,jdbcType=INTEGER}
    </update>

</mapper>

4、 在application.properties配置文件中添加對mapper文件的掃描

mybatis.typeAliasesPackage: cn.yideng.*.entity
mybatis.mapperLocations: classpath:mapper/*.xml

5、 在啟動類中添加對mapper包掃描@MapperScan

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
@EnableAutoConfiguration
@MapperScan("cn.yideng.*.dao")
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    } 
}

6、 瀏覽器測試 http://localhost:8080/account/transfer , 測試顯示 轉賬成功，看看數據庫的數據，andy余額是150， lucy余額350，都是對的，如下圖所示。

7，接着我們修改service,在實現類里，轉出之后拋個異常，代碼如下

@Service
public class AccountServiceImpl implements AccountService{

    @Autowired
    private AccountDao accountDao;

    public void transfer(int outter, int inner, Integer money) {

        accountDao.moveOut(outter, money); //轉出
        int i = 1/0;  // 拋出異常
        accountDao.moveIn(inner, money); //轉入

    }
}

 

8，把數據庫的數據恢復成最初的 andy-200, lucy-300, 然后啟動類測試，瀏覽器輸入 http://localhost:8080/account/transfer , 測試顯示 轉賬失敗，看看數據庫的數據，andy余額是150， lucy余額300，如下圖所示。

相當於轉出成功，轉入沒有成功，這是不對的，應該都成功，或者都不成功。

9， 我們接着在service實現類上添加@Transactional 注解，聲明一個事務，如下

@Service
public class AccountServiceImpl implements AccountService{

    @Autowired
    private AccountDao accountDao;

    @Transactional
    public void transfer(int outter, int inner, Integer money) {

        accountDao.moveOut(outter, money); //轉出
        int i = 1/0;  // 拋出異常
        accountDao.moveIn(inner, money); //轉入

    }
}

10，再把數據庫的數據恢復成最初的 andy-200, lucy-300, 然后啟動類測試，瀏覽器輸入 http://localhost:8080/account/transfer , 測試顯示 轉賬失敗，看看數據庫的數據，andy余額是200， lucy余額300，如下圖所示。

說明轉出和轉入都沒有成功，這才是合乎邏輯的。

springboot 開啟事物很簡單，只需要加注解@Transactional 和 @EnableAutoConfiguration，聲明事務就可以了，