SpringCloud(第 043 篇)链接Mysql数据库简单的集成Mybatis框架访问数据库
一、大致介绍
1、访问数据库,自然少不了一些持久化框架,而我本身也是Mybatis框架的支持者;2、Mybatis是那种专注于sql的框架,对象映射以及输入输出都是由框架自动完成;3、因此本章节就简单小试牛刀尝试下如何使用Mybatis持久化框架进行对数据的操作;
二、实现步骤
2.1 添加 maven 引用包
4.0.0 springms-provider-user-mysql-mybatis 1.0-SNAPSHOT jar com.springms.cloud springms-spring-cloud 1.0-SNAPSHOT org.springframework.boot spring-boot-starter-data-jpa org.springframework.boot spring-boot-starter-web mysql mysql-connector-java org.mybatis.spring.boot mybatis-spring-boot-starter 1.3.1
2.2 添加应用配置文件(springms-provider-user-mysql-mybatis\src\main\resources\application.yml)
server: port: 8325spring: application: name: springms-provider-user-mysql-mybatis #全部小写###################################################################################################### mysql 属性配置 datasource: driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql://ip:3306/hmilyylimh username: username password: password# jpa:# hibernate:# #ddl-auto: create #ddl-auto:设为create表示每次都重新建表# ddl-auto: update #ddl-auto:设为update表示每次都不会重新建表# show-sql: true########################################################################################################################################################################################################### 打印日志logging: level: root: INFO org.hibernate: INFO org.hibernate.type.descriptor.sql.BasicBinder: TRACE org.hibernate.type.descriptor.sql.BasicExtractor: TRACE com.springms: DEBUG#####################################################################################################
2.3 添加实体用户类User(springms-provider-user-mysql-mybatis/src/main/java/com/springms/cloud/entity/User.java)
package com.springms.cloud.entity;import javax.persistence.*;/** * * Mybatis 需要加上这些注解才可以使用,不然启动都会报错; * */@Entitypublic class User { @Id @GeneratedValue(strategy = GenerationType.AUTO) private Long id; @Column private String username; @Column private String name; @Column private Integer age; @Column private String balance; public Long getId() { return this.id; } public void setId(Long id) { this.id = id; } public String getUsername() { return this.username; } public void setUsername(String username) { this.username = username; } public String getName() { return this.name; } public void setName(String name) { this.name = name; } public Integer getAge() { return this.age; } public void setAge(Integer age) { this.age = age; } public String getBalance() { return this.balance; } public void setBalance(String balance) { this.balance = balance; }}
2.4 添加用户mapper接口(springms-provider-user-mysql-mybatis/src/main/java/com/springms/cloud/mapper/IUserMapper.java)
package com.springms.cloud.mapper;import com.springms.cloud.entity.User;import org.apache.ibatis.annotations.Insert;import org.apache.ibatis.annotations.Select;import java.util.List;/** * 用户 mybatis 映射文件。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017-10-19 * */public interface IUserMapper { @Select("select * from user where id = #{id}") User findUserById(Long id); @Select("select * from user") ListfindAllUsers(); @Insert("INSERT INTO user(username, name, age, balance) VALUES(#{username}, #{name}, #{age}, #{balance})") int insertUser(User user);}
2.5 添加用户mapper接口实现类(springms-provider-user-mysql-mybatis/src/main/java/com/springms/cloud/mapper/user/UserMapper.java)
package com.springms.cloud.mapper.user;/** * * * @author hmilyylimh * * @version 0.0.1 * * @date 2017-10-19 * */public class UserMapper {}
2.6 添加用户Service接口类(springms-provider-user-mysql-mybatis/src/main/java/com/springms/cloud/service/IUserService.java)
package com.springms.cloud.service;import com.springms.cloud.entity.User;import java.util.List;/** * 简单用户链接Mysql数据库微服务(通过@Service注解标注该类为持久化操作对象)。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017-10-19 * */public interface IUserService { User findUserById(Long id); ListfindAllUsers(); int insertUser(User user);}
2.7 添加用户Service接口实现类(springms-provider-user-mysql-mybatis/src/main/java/com/springms/cloud/service/impl/UserServiceImpl.java)
package com.springms.cloud.service.impl;import com.springms.cloud.entity.User;import com.springms.cloud.mapper.IUserMapper;import com.springms.cloud.service.IUserService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import java.util.List;/** * 简单用户链接Mysql数据库微服务(通过@Service注解标注该类为持久化操作对象)。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017-10-19 * */@Servicepublic class UserServiceImpl implements IUserService { @Autowired IUserMapper iUserMapper; @Override public User findUserById(Long id) { return iUserMapper.findUserById(id); } @Override public ListfindAllUsers() { return iUserMapper.findAllUsers(); } @Override public int insertUser(User user) { return iUserMapper.insertUser(user); }}
2.8 添加用户Web访问层Controller(springms-provider-user-mysql-mybatis/src/main/java/com/springms/cloud/controller/ProviderUserMysqlMybatisController.java)
package com.springms.cloud.controller;import com.springms.cloud.entity.User;import com.springms.cloud.service.IUserService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.*;import java.util.List;/** * 用户微服务Controller。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017-10-19 * */@RestControllerpublic class ProviderUserMysqlMybatisController { @Autowired private IUserService iUserService; @GetMapping("/simple/{id}") public User findUserById(@PathVariable Long id) { return this.iUserService.findUserById(id); } @GetMapping("/simple/list") public ListfindUserList() { return this.iUserService.findAllUsers(); } /** * 添加一个student,使用postMapping接收post请求 * * http://localhost:8310/simple/addUser?username=user11&age=11&balance=11 * * @return */ @PostMapping("/simple/addUser") public User addUser(@RequestParam(value = "username", required=false) String username, @RequestParam(value = "age", required=false) Integer age, @RequestParam(value = "balance", required=false) String balance){ User user=new User(); user.setUsername(username); user.setName(username); user.setAge(age); user.setBalance(balance); int result = iUserService.insertUser(user); if(result > 0){ return user; } user.setId(0L); user.setName(null); user.setUsername(null); user.setBalance(null); return user; }}
2.9 添加微服务启动类(springms-provider-user-mysql-mybatis/src/main/java/com/springms/cloud/MsProviderUserMysqlMybatisApplication.java)
package com.springms.cloud;import org.mybatis.spring.annotation.MapperScan;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;/** * 链接Mysql数据库简单的集成Mybatis框架访问数据库。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017-10-19 * */@SpringBootApplication@MapperScan("com.springms.cloud.mapper.**")public class MsProviderUserMysqlMybatisApplication { public static void main(String[] args) { SpringApplication.run(MsProviderUserMysqlMybatisApplication.class, args); System.out.println("【【【【【【 链接MysqlMybatis数据库微服务 】】】】】】已启动."); }}
三、测试
/**************************************************************************************** 注意:Mybatis 需要加上 entity 等注解才可以使用,不然启动都会报错; @MapperScan("com.springms.cloud.mapper.**") 或者在每个 Mapper 接口文件上添加 @Mapper 也可以; 一、简单用户链接Mysql数据库微服务(通过 mybatis 链接 mysql 编写数据访问): 1、启动 springms-provider-user-mysql-mybatis 模块服务,启动1个端口; 2、在浏览器输入地址 http://localhost:8325/simple/10 可以看到用户ID=10的信息成功的被打印出来; 3、使用 IDEA 自带工具 Test Restful WebService 发送 HTTP POST 请求,并添加 username、age、balance三个参数,然后执行请求,并去 mysql 数据库查看数据是否存在,正常情况下 mysql 数据库刚刚插入的数据成功了: 4、使用 REST Client 执行 "/simple/list" 接口,也正常将 mysql 数据库中所有的用户信息打印出来了; ****************************************************************************************/
四、下载地址
SpringCloudTutorial交流QQ群: 235322432
SpringCloudTutorial交流微信群:
欢迎关注,您的肯定是对我最大的支持!!!