spring boot 整合 mybatis 以及原理

同上一篇文章一样,spring boot 整合 mybatis过程中没有看见SqlSessionFactory,sqlsession(sqlsessionTemplate),就连在spring框架整合 mybatis时的SqlSessionFactoryBean都没看到,那spring boot 把这些参数都放在了 mybatis-spring boot autoconfigure.jar 包中的MybatisAutoConfiguration 这个类中,使用 @ConditionalOnMissingBean这个注解,当环境中缺少 sqlsessionFactory sqlsessionTemplate时会自动注入

Example

使用spring boot 的starter pom

需要导入 mybatis-spring-boot-starter 和 数据库连接相关的配置

pom.xml

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  2. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  3. <modelVersion>4.0.0</modelVersion>
  4. <groupId>com.ibigsea</groupId>
  5. <artifactId>bootdao</artifactId>
  6. <version>0.0.1-SNAPSHOT</version>
  7. <packaging>jar</packaging>
  8. <name>bootdao</name>
  9. <url>http://maven.apache.org</url>
  10. <properties>
  11. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  12. <boot.version>1.3.1.RELEASE</boot.version>
  13. </properties>
  14. <dependencies>
  15. <dependency>
  16. <groupId>org.springframework.boot</groupId>
  17. <artifactId>spring-boot-starter-web</artifactId>
  18. <version>${boot.version}</version>
  19. </dependency>
  20. <dependency>
  21. <groupId>org.mybatis.spring.boot</groupId>
  22. <artifactId>mybatis-spring-boot-starter</artifactId>
  23. <version>1.1.1</version>
  24. </dependency>
  25. <!-- mysql 驱动 -->
  26. <dependency>
  27. <groupId>mysql</groupId>
  28. <artifactId>mysql-connector-java</artifactId>
  29. <version>5.1.38</version>
  30. </dependency>
  31. <!-- 数据库连接池 -->
  32. <dependency>
  33. <groupId>com.alibaba</groupId>
  34. <artifactId>druid</artifactId>
  35. <version>1.0.5</version>
  36. </dependency>
  37. <dependency>
  38. <groupId>org.springframework.boot</groupId>
  39. <artifactId>spring-boot-starter-test</artifactId>
  40. <version>${boot.version}</version>
  41. <scope>test</scope>
  42. </dependency>
  43. </dependencies>
  44. <build>
  45. <plugins>
  46. <plugin>
  47. <groupId>org.springframework.boot</groupId>
  48. <artifactId>spring-boot-maven-plugin</artifactId>
  49. </plugin>
  50. </plugins>
  51. </build>
  52. </project>

是不是很方便,mybatis的starter pom里面依赖了mybatis和spring相关的jar

只需导入一个就OK了

spring boot 整合 mybatis 以及原理

这里采用的是阿里巴巴的druid数据连接池

为了方便使用 yml配置文件

application.yml

  1. ---
  2. spring:
  3. profiles : dev
  4. datasource:
  5. name: mydb
  6. type: com.alibaba.druid.pool.DruidDataSource
  7. url: jdbc:mysql://127.0.0.1:3306/mytestdb
  8. username: root
  9. password: 123456
  10. driver-class-name: com.mysql.jdbc.Driver
  11. minIdle: 1
  12. maxActive: 2
  13. initialSize: 1
  14. timeBetweenEvictionRunsMillis: 3000
  15. minEvictableIdleTimeMillis: 300000
  16. validationQuery: SELECT 'ZTM' FROM DUAL
  17. testWhileIdle: true
  18. testOnBorrow: false
  19. testOnReturn: false
  20. mybatis:
  21. mapperLocations: classpath*:com/ibigsea/bootdao/mapper/*.xml
  22. typeAliasesPackage: com.ibigsea.bootdao.entity

User.java

  1. package com.ibigsea.bootdao.entity;
  2. import java.io.Serializable;
  3. public class User implements Serializable {
  4. private static final long serialVersionUID = 8809101560720973267L;
  5. private Integer id;
  6. private String userName;
  7. private Integer age;
  8. public Integer getId() {
  9. return id;
  10. }
  11. public void setId(Integer id) {
  12. this.id = id;
  13. }
  14. public String getUserName() {
  15. return userName;
  16. }
  17. public void setUserName(String userName) {
  18. this.userName = userName;
  19. }
  20. public Integer getAge() {
  21. return age;
  22. }
  23. public void setAge(Integer age) {
  24. this.age = age;
  25. }
  26. @Override
  27. public String toString() {
  28. return "User [id=" + id + ", userName=" + userName + ", age=" + age + "]";
  29. }
  30. }

UserMapper.java

  1. package com.ibigsea.bootdao.mapper;
  2. import java.util.List;
  3. import org.apache.ibatis.annotations.Mapper;
  4. import com.ibigsea.bootdao.entity.User;
  5. @Mapper
  6. public interface UserMapper {
  7. int save(User user);
  8. User selectById(Integer id);
  9. int updateById(User user);
  10. int deleteById(Integer id);
  11. List<User> queryAll();
  12. }
  1. <p>UserMapper.xml</p>
  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
  3. <mapper namespace="com.ibigsea.bootdao.mapper.UserMapper" >
  4. <insert id="save" parameterType="com.ibigsea.bootdao.entity.User">
  5. insert into t_user(username,age) values(#{userName,jdbcType=VARCHAR},#{age,jdbcType=NUMERIC})
  6. </insert>
  7. <select id="selectById" resultType="com.ibigsea.bootdao.entity.User">
  8. select * from t_user where id = #{id,jdbcType=NUMERIC}
  9. </select>
  10. <update id="updateById" parameterType="com.ibigsea.bootdao.entity.User">
  11. update t_user set
  12. username = #{userName,jdbcType=VARCHAR} ,
  13. age = #{age,jdbcType=NUMERIC}
  14. where id = #{id,jdbcType=NUMERIC}
  15. </update>
  16. <delete id="deleteById">
  17. delete from t_user where id = #{id,jdbcType=NUMERIC}
  18. </delete>
  19. <select id="queryAll" resultType="com.ibigsea.bootdao.entity.User">
  20. select * from t_user
  21. </select>
  22. </mapper>

启动类 App.class

  1. package com.ibigsea.bootdao;
  2. import org.springframework.boot.autoconfigure.SpringBootApplication;
  3. /**
  4. * Hello world!
  5. *
  6. */
  7. @SpringBootApplication
  8. //启注解事务管理
  9. @EnableTransactionManagement
  10. public class App {
  11. public static void main(String[] args) {
  12. System.out.println("Hello World!");
  13. }
  14. }

这里使用test来测试

  1. package com.ibigsea.bootdao;
  2. import org.junit.Test;
  3. import org.junit.runner.RunWith;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.boot.test.SpringApplicationConfiguration;
  6. import org.springframework.test.context.ActiveProfiles;
  7. import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
  8. import com.ibigsea.bootdao.entity.User;
  9. import com.ibigsea.bootdao.mapper.UserMapper;
  10. @RunWith(SpringJUnit4ClassRunner.class)
  11. @SpringApplicationConfiguration(classes = {App.class})
  12. //相当于  --spring.profiles.active=dev
  13. @ActiveProfiles(value="dev")
  14. public class AppTest {
  15. @Autowired
  16. private UserMapper mapper;
  17. @Test
  18. public void testInsert(){
  19. User user = new User();
  20. user.setUserName("张三");
  21. user.setAge(23);
  22. mapper.save(user);
  23. System.out.println("插入用户信息"+user.getUserName());
  24. }
  25. }

运行结果:

spring boot 整合 mybatis 以及原理

Ok 数据库这边也有数据了

spring boot 整合 mybatis 以及原理

表结构这边就不提供了 , 就一个很简单的表 自己创建一个就可以了

查询:

  1. @Test
  2. public void testSelect(){
  3. User user = mapper.selectById(1);
  4. System.out.println(user);
  5. }

spring boot 整合 mybatis 以及原理
update

  1. @Test
  2. public void testUpdate(){
  3. User user = mapper.selectById(1);
  4. System.out.println(user);
  5. user.setAge(24);
  6. mapper.updateById(user);
  7. user = mapper.selectById(1);
  8. System.out.println(user);
  9. }

spring boot 整合 mybatis 以及原理

Mybatis相关的配置

spring boot 整合 mybatis 以及原理

MybatisAutoConfiguration

Spring boot 在运行的时候会进行自动配置

读取到 mybatis-spring-boot-autoconfigure 里面的spring.factories,然后自动配置

就是下面这个类

spring boot 整合 mybatis 以及原理

spring boot 整合 mybatis 以及原理

这个方法使用了PostConstruct注解,在初始化的时候去加载mybatis的配置文件,然后创建SqlSessionFactory

spring boot 整合 mybatis 以及原理

spring boot 整合 mybatis 以及原理

Mybatis自动配置会自动创建 sqlSessionFactorySqlSessionTemplate

spring boot 整合 mybatis 以及原理

这个东西 就是 加载在注解了@Mapper的类

如果不喜欢在mapper上面加注解的话,也可以通过@MapperScan

spring boot 整合 mybatis 以及原理

这样子:

spring boot 整合 mybatis 以及原理

这样就OK啦

关于事务方面

在启动类上面添加

@EnableTransactionManagement注解

然后在类上面或者方法上面添加@Transactional注解

  1. package com.ibigsea.bootdao.service;
  2. import org.springframework.beans.factory.annotation.Autowired;
  3. import org.springframework.stereotype.Service;
  4. import org.springframework.transaction.annotation.Transactional;
  5. import com.ibigsea.bootdao.entity.User;
  6. import com.ibigsea.bootdao.mapper.UserMapper;
  7. @Service("userService")
  1. //在方法和类上面都可以
  2. @Transactional
  3. public class UserService {
  4. @Autowired
  5. private UserMapper mapper;
  6. public void insetUser() throws Exception {
  7. User user = new User();
  8. user.setUserName("李四");
  9. user.setAge(23);
  10. mapper.save(user);
  11. System.out.println("插入用户信息"+user.getUserName());
  12. if (user.getUserName().equals("李四")) {
  13. throw new IllegalArgumentException("出现异常QAQ");
  14. }
  15. user = new User();
  16. user.setUserName("李四11111");
  17. user.setAge(23);
  18. mapper.save(user);
  19. }
  20. }

测试类

  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @SpringApplicationConfiguration(classes = {App.class})
  3. //相当于  --spring.profiles.active=dev
  4. @ActiveProfiles(value="dev")
  5. @EnableTransactionManagement
  6. public class AppTest {
  7. @Autowired
  8. private UserService userService;
  9. @Test
  10. public void testTransactional() throws Exception {
  11. userService.insetUser();
  12. }
  13. }

spring boot 整合 mybatis 以及原理

数据库结果

spring boot 整合 mybatis 以及原理

我们吧@Transactional注解去掉 或者去掉 @EnableTransactionManagement注解

测试下看看

spring boot 整合 mybatis 以及原理

数据被插入~~~~~

上一篇:nginx的root alias 指令


下一篇:Cocos2d 中的Sprite大小调整问题