spring boot学习系列之整合Mybatis持久层2

 2,886浏览     wenqyAdmin   

拯救 – 孙楠–:– / 05:32
(*+﹏+*)

MyBatis是一个基于Java的持久层框架，它支持定制化 SQL、存储过程以及高级映射。现将spring boot整合Mybatis。

添加依赖

添加mybatis的依赖

  1. <!– https://mvnrepository.com/artifact/org.mybatis.spring.boot/mybatis-spring-boot-starter –>
  2. <dependency>
  3.     <groupId>org.mybatis.spring.boot</groupId>
  4.     <artifactId>mybatis-spring-boot-starter</artifactId>
  5.         <version>1.3.0</version>
  6. </dependency>

项目会自动加载application.properties,在里面定义mybatis配置路径和数据源

  1. #加载mybatis配置文件
  2. mybatis.mapper-locations =classpath:mapper/*Mapper.xml
  3. mybatis.config-location =classpath:mapper/config/sqlConfig.xml
  4. #定义别名
  5. mybatis.type-aliases-package =com.wenqy.domain
  7. #数据源
  8. spring.datasource.url =jdbc:mysql://localhost:3306/wordpress
  9. spring.datasource.driver-class-name =com.mysql.jdbc.Driver
  10. spring.datasource.username =root
  11. spring.datasource.password =123456
  12. spring.datasource.max-active=10
  13. spring.datasource.max-idle=5
  14. spring.datasource.min-idle=0

添加mysql的jdbc依赖

  1. <!– https://mvnrepository.com/artifact/mysql/mysql-connector-java –>
  2. <dependency>
  3.     <groupId>mysql</groupId>
  4.     <artifactId>mysql-connector-java</artifactId>
  5.     <version>5.1.42</version>
  6. </dependency>

接下来就是mybatis的规范编程

定义domain bean

  1. public class User implements Serializable{
  2.     private int id;
  3.     private String name;
  5.     public int getId() {
  6.         return id;
  7.     }
  8.     public void setId(int id) {
  9.         this.id = id;
  10.     }
  11.     public String getName() {
  12.         return name;
  13.     }
  14.     public void setName(String name) {
  15.         this.name = name;
  16.     }
  18. }

定义mybatis Mapper 接口

  1. @Mapper
  2. public interface UserMapper {
  3.     /**
  4.      * 
  5.     * @Title: findAll 
  6.     * @Description:
  7.     * @param     
  8.     * @return List<User>     
  9.     * @throws
  10.      */
  11.     public List<User> findAll();
  13.     /**
  14.      * 
  15.     * @Title: getUserById 
  16.     * @Description:
  17.     * @param @param id
  18.     * @param 
  19.     * @return User
  20.     * @throws
  21.      */
  22.     public User getUserById(int id);
  23. }

使用Mapper注解进行注入

定义UserMapper.xml映射文件

  1. <!– namespace必须指向Dao接口 –>
  2. <mapper namespace=“com.wenqy.mapper.UserMapper”>
  4.     <!– 所有列 –>
  5.     <sql id=“Column_list”>
  6.         id,
  7.         name
  8.     </sql>
  10.     <resultMap id=“ListUser” type=“com.wenqy.domain.User” >
  11.         <id  column=“id” property=“id” />
  12.         <result column=“name” property=“name” />
  13.     </resultMap>
  15.     <!– 根据ID查询数据 –>
  16.     <select id=“getUserById” parameterType=“int” resultMap=“ListUser”>
  17.         SELECT
  18.         <include refid=“Column_list” />
  19.         FROM user
  20.         WHERE id = #{id}
  21.     </select>
  23.     <!– 查询所有用户 –>
  24.     <select id=“findAll” resultType=“com.wenqy.domain.User”>
  25.         SELECT * FROM user
  26.     </select>
  28. </mapper>

定义service接口

  1. public interface UserService {
  3.     /**
  4.      * 
  5.     * @Title: findAll 
  6.     * @Description:
  7.     * @param     
  8.     * @return List<User>     
  9.     * @throws
  10.      */
  11.     public List<User> findAll();
  14.     /**
  15.      * 
  16.     * @Title: getUserById 
  17.     * @Description:
  18.     * @param @param id
  19.     * @param 
  20.     * @return User
  21.     * @throws
  22.      */
  23.     public User getUserById(int id);
  24. }

定义service实现类

  1. @Service
  2. public class UserServiceImpl implements UserService {
  4.     @Autowired
  5.     private UserMapper userMapper;
  7.     public List<User> findAll() {
  8.         List<User> userList = userMapper.findAll();
  9.         return userList;
  10.     }
  13.     public User getUserById(int id) {
  14.         User userById = userMapper.getUserById(id);
  15.         return userById;
  16.     }
  17. }

定义表现层

  1. @RestController
  2. @RequestMapping(“/user”)
  3. public class UserController {
  5.     @Autowired
  6.     private UserService userService;
  8.     @RequestMapping(“/{id}”)
  9.     public User getUserById(@PathVariable(“id”) int id) {
  10.         User userById = userService.getUserById(id);
  11.         return userById;
  12.     }
  14.     @RequestMapping(“/findAll”)
  15.     public List<User> findAll() {
  16.         List<User> findAll = userService.findAll();
  17.         return findAll;
  18.     }
  20. //  public static void main(String[] args) {
  21. //      SpringApplication.run(UserController.class, args);
  22. //  }
  23. }

访问路由，效果图

springboot-mabatis-1

springboot-mabits-2

为mybatis添加分页插件

添加分页依赖

  1. <!–pagehelper–>
  2.     <dependency>
  3.     <groupId>com.github.pagehelper</groupId>
  4.     <artifactId>pagehelper-spring-boot-starter</artifactId>
  5.     <version>1.1.2</version>
  6. </dependency>

在application.properties 添加分页配置

  1. #pagehelper
  2. pagehelper.helperDialect=mysql
  3. pagehelper.reasonable=true
  4. pagehelper.supportMethodsArguments=true
  5. pagehelper.params=count=countSql

控制层,在控制层加入PageHelper分页工具类方法。

  1. /**
  2.      * 
  3.     * @Title: findByPage 
  4.     * @Description: 分页查询
  5.     * @param @param pageNo
  6.     * @param 页数 
  7.     * @return List<User>   页数据 
  8.     * @throws
  9.      */
  10.     @RequestMapping(“/find/{pageNo}”)
  11.     public List<User> findByPage(@PathVariable(“pageNo”) int pageNo) {
  12.         PageHelper.startPage(pageNo, 5);
  13.         List<User> findAll = userService.findAll();
  14.         System.out.println(“Total: “ + ((Page<User>) findAll).getTotal());
  15.         return findAll;
  16.     }

查询结果

springboot-mabits-3

Springboot快速开发，的确是如此的优雅，如此的简洁。我启动项目的时候却报错了，说无法连接数据库，发现是application.properties配置有前缀空格，而项目不是用utf8编码的，弄了我好久，这让我无比郁闷。。。

参考：

http://www.mybatis.org/spring-boot-starter/mybatis-spring-boot-autoconfigure/index.html

https://github.com/pagehelper/pagehelper-spring-boot

小二，再来一碟

赏

发表评论

电子邮件地址不会被公开。 必填项已用*标注

24 + 4 = ?