feat(整合Mybatis):在eureka-customer服务中整合Mybatis并添加简单的测试

Author: coderqianlq

eureka-customer/pom.xml

@@ -68,6 +68,20 @@
             <artifactId>spring-cloud-starter-config</artifactId>
         </dependency>
 
+        <!-- 引入Mybatis依赖 -->
+        <dependency>
+            <groupId>org.mybatis.spring.boot</groupId>
+            <artifactId>mybatis-spring-boot-starter</artifactId>
+            <version>1.3.2</version>
+        </dependency>
+
+        <!-- 引入Mybatis-Plus依赖 -->
+        <!--<dependency>-->
+            <!--<groupId>com.baomidou</groupId>-->
+            <!--<artifactId>mybatis-plus-boot-starter</artifactId>-->
+            <!--<version>3.0.4</version>-->
+        <!--</dependency>-->
+
         <!-- 引入MySQL连接依赖 -->
         <dependency>
             <groupId>mysql</groupId>
@@ -86,6 +100,14 @@
             <version>2.7.0</version>
         </dependency>
 
+        <!-- 引入lombok依赖 -->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.0</version>
+            <scope>provided</scope>
+        </dependency>
+
         <dependency>
             <groupId>io.springfox</groupId>
             <artifactId>springfox-swagger-ui</artifactId>

eureka-customer/src/main/java/com/coderqian/eurekacustomer/common/BaseResult.java

@@ -1,5 +1,7 @@
 package com.coderqian.eurekacustomer.common;
 
+import com.coderqian.eurekacustomer.common.constant.Code;
+
 /**
  * @author qianliqing
  * @date 2018-09-28 下午9:05
@@ -25,6 +27,17 @@ public BaseResult(String msg) {
         this.message = msg;
     }
 
+    public BaseResult(Code code) {
+        this.code = code.getCode();
+        this.message = code.getMsg();
+    }
+
+    public BaseResult(Code code, T data) {
+        this.code = code.getCode();
+        this.message = code.getMsg();
+        this.data = data;
+    }
+
     public BaseResult(int code, String message) {
         this.code = code;
         this.message = message;

eureka-customer/src/main/java/com/coderqian/eurekacustomer/common/BaseResultFactory.java

@@ -0,0 +1,32 @@
+package com.coderqian.eurekacustomer.common;
+
+import com.coderqian.eurekacustomer.common.constant.Code;
+
+/**
+ * @author qianliqing
+ * @date 2018-10-02 下午2:52
+ * mail: [email protected]
+ */
+
+@SuppressWarnings("unchecked")
+public class BaseResultFactory {
+
+    /**
+     * 构建成功并返回的数据
+     *
+     * @param data 返回数据
+     * @return
+     */
+    public static BaseResult createSuccessResult(Object data) {
+        return new BaseResult(Code.SUCCESS, data);
+    }
+
+    /**
+     * 成功但不返回的数据
+     *
+     * @return
+     */
+    public static BaseResult createEmptyResult() {
+        return new BaseResult(Code.SUCCESS);
+    }
+}

eureka-customer/src/main/java/com/coderqian/eurekacustomer/common/exception/BaseException.java

@@ -12,27 +12,27 @@
 
 public abstract class BaseException extends RuntimeException {
 
-    private int codeInt;
+    private int code;
     private String msg;
     private BaseResult baseResult;
 
     BaseException() {
         super();
     }
 
-    BaseException(int codeInt, String msg) {
+    BaseException(int code, String msg) {
         super(msg);
-        this.codeInt = codeInt;
+        this.code = code;
         this.msg = msg;
-        this.baseResult = new BaseResult(codeInt, msg);
+        this.baseResult = new BaseResult(code, msg);
     }
 
-    public int getCodeInt() {
-        return codeInt;
+    public int getCode() {
+        return code;
     }
 
-    public void setCodeInt(int codeInt) {
-        this.codeInt = codeInt;
+    public void setCode(int code) {
+        this.code = code;
     }
 
     public String getMsg() {

eureka-customer/src/main/java/com/coderqian/eurekacustomer/controller/TestController.java

@@ -27,9 +27,6 @@ public class TestController {
     @Autowired
     private TestService testService;
 
-    @Value("${profile}")
-    private String profile;
-
     @ApiOperation(value = "返回用户输入的结果", notes = "返回用户输入的结果")
     @RequestMapping(value = "/result", method = RequestMethod.GET)
     public String test(@RequestParam(value = "text") String text) {
@@ -48,9 +45,9 @@ public BaseResult testBaseResult(@RequestParam(value = "text") String text) {
         return testService.testBaseResult(text);
     }
 
-    @ApiOperation(value = "测试读取配置文件中的值", notes = "测试读取配置文件中的值")
-    @RequestMapping(value = "/config", method = RequestMethod.GET)
-    public String testConfig() {
-        return profile;
+    @ApiOperation(value = "根据用户id获取用户信息", notes = "根据用户id获取用户信息")
+    @RequestMapping(value = "/find", method = RequestMethod.GET)
+    public BaseResult testMybatis(@RequestParam("id") String id) {
+        return testService.testMybatis(id);
     }
 }

eureka-customer/src/main/java/com/coderqian/eurekacustomer/entity/User.java

@@ -0,0 +1,26 @@
+package com.coderqian.eurekacustomer.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.apache.ibatis.type.Alias;
+
+import java.io.Serializable;
+
+/**
+ * @author qianliqing
+ * @date 2018-10-02 下午2:33
+ * mail: [email protected]
+ */
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class User implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private String id;
+
+    private String name;
+}

eureka-customer/src/main/java/com/coderqian/eurekacustomer/mapper/UserMapper.java

@@ -0,0 +1,22 @@
+package com.coderqian.eurekacustomer.mapper;
+
+import com.coderqian.eurekacustomer.entity.User;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author qianliqing
+ * @date 2018-10-02 下午2:31
+ * mail: [email protected]
+ */
+
+@Mapper
+public interface UserMapper {
+
+    /**
+     * 根据用户id查询
+     *
+     * @param id 用户id
+     * @return
+     */
+    User findUserById(String id);
+}

eureka-customer/src/main/java/com/coderqian/eurekacustomer/service/TestService.java

@@ -33,4 +33,12 @@ public interface TestService {
      * @return
      */
     BaseResult testBaseResult(String text);
+
+    /**
+     * 测试mybatis接口
+     *
+     * @param id 用户id
+     * @return
+     */
+    BaseResult testMybatis(String id);
 }

eureka-customer/src/main/java/com/coderqian/eurekacustomer/service/impl/TestServiceImpl.java

@@ -1,9 +1,12 @@
 package com.coderqian.eurekacustomer.service.impl;
 
 import com.coderqian.eurekacustomer.common.BaseResult;
+import com.coderqian.eurekacustomer.common.BaseResultFactory;
 import com.coderqian.eurekacustomer.common.constant.Code;
 import com.coderqian.eurekacustomer.common.exception.BusinessException;
+import com.coderqian.eurekacustomer.mapper.UserMapper;
 import com.coderqian.eurekacustomer.service.TestService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 /**
@@ -15,6 +18,9 @@
 @Service
 public class TestServiceImpl implements TestService {
 
+    @Autowired
+    private UserMapper userMapper;
+
     @Override
     public String test(String text) {
         return text;
@@ -29,4 +35,9 @@ public void testException(String text) throws BusinessException {
     public BaseResult testBaseResult(String text) {
         return new BaseResult(text);
     }
+
+    @Override
+    public BaseResult testMybatis(String id) {
+        return BaseResultFactory.createSuccessResult(userMapper.findUserById(id));
+    }
 }

eureka-customer/src/main/resources/application.properties

@@ -21,4 +21,7 @@ spring.datasource.maxWait=60000
 # 配置监控统计拦截的filters，用于监控SQL，wall用于防火墙
 spring.datasource.filters=stat,wall
 
-logging.config=classpath:log4j2.xml
+logging.config=classpath:log4j2.xml
+
+mybatis.mapper-locations=classpath:mapper/*.xml
+mybatis.config-location=classpath:config/mybatis-config.xml