SpringBoot2.x 整合Mybatis(多数据源),Redis,RabbitMQ,Thymeleaf等实现简单案例

g-HJY · Jan 4, 2022 · edaa7f5 · edaa7f5
1 parent eaf5479
commit edaa7f5
Show file tree

Hide file tree

Showing 21 changed files with 701 additions and 45 deletions.
diff --git a/HELP.md b/HELP.md
@@ -0,0 +1,9 @@
+# Getting Started
+
+### Reference Documentation
+For further reference, please consider the following sections:
+
+* [Official Apache Maven documentation](https://maven.apache.org/guides/index.html)
+* [Spring Boot Maven Plugin Reference Guide](https://docs.spring.io/spring-boot/docs/2.5.5/maven-plugin/reference/html/)
+* [Create an OCI image](https://docs.spring.io/spring-boot/docs/2.5.5/maven-plugin/reference/html/#build-image)
+
diff --git a/README.md b/README.md
@@ -1,5 +1,4 @@
 # SpringBootDemo
-SpringBoot2.x demo for study
 
 #### SpringBoot2.x 整合Mybatis,Redis,RabbitMQ,Thymeleaf等实现简单案例
 

diff --git a/src/main/java/com/example/demo/DemoApplication.java b/src/main/java/com/example/demo/DemoApplication.java
@@ -1,16 +1,16 @@
 package com.example.demo;
 
-import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
 import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.scheduling.annotation.EnableScheduling;
 //开启定时任务
 @EnableScheduling
 //★1、(@EnableCaching)开启Spring对缓存的支持
 @EnableCaching
-@SpringBootApplication
-@MapperScan("com.example.demo")
+@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})//多数据源配置
+//@MapperScan("com.example.demo")
 public class DemoApplication {
 
 	public static void main(String[] args) {

diff --git a/src/main/java/com/example/demo/InstallRequired.txt b/src/main/java/com/example/demo/InstallRequired.txt
@@ -5,5 +5,5 @@
 3.Mysql
 并修改相关配置成你自己的
 
-插件：
+IDEA插件：
 1.Lombok
diff --git a/src/main/java/com/example/demo/controller/SalariesController.java b/src/main/java/com/example/demo/controller/SalariesController.java
@@ -0,0 +1,84 @@
+package com.example.demo.controller;
+
+import com.example.demo.entity.test2.Salaries;
+import com.example.demo.service.SalariesService;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+
+/**
+ * (Salaries)表控制层
+ *
+ * @author makejava
+ * @since 2021-12-20 09:55:29
+ */
+@RestController
+@RequestMapping("/salaries")
+public class SalariesController {
+    /**
+     * 服务对象
+     */
+    @Resource
+    private SalariesService salariesService;
+
+    /**
+     * 分页查询
+     *
+     * @param salaries 筛选条件
+     * @param pageRequest      分页对象
+     * @return 查询结果
+     */
+    @GetMapping
+    public ResponseEntity<Page<Salaries>> queryByPage(Salaries salaries, PageRequest pageRequest) {
+        return ResponseEntity.ok(this.salariesService.queryByPage(salaries, pageRequest));
+    }
+
+    /**
+     * 通过主键查询单条数据
+     *
+     * @param id 主键
+     * @return 单条数据
+     */
+    @GetMapping("/queryById")
+    public ResponseEntity<Salaries> queryById(int id) {
+        return ResponseEntity.ok(this.salariesService.queryById(id));
+    }
+
+    /**
+     * 新增数据
+     *
+     * @param salaries 实体
+     * @return 新增结果
+     */
+    @PostMapping
+    public ResponseEntity<Salaries> add(Salaries salaries) {
+        return ResponseEntity.ok(this.salariesService.insert(salaries));
+    }
+
+    /**
+     * 编辑数据
+     *
+     * @param salaries 实体
+     * @return 编辑结果
+     */
+    @PutMapping
+    public ResponseEntity<Salaries> edit(Salaries salaries) {
+        return ResponseEntity.ok(this.salariesService.update(salaries));
+    }
+
+    /**
+     * 删除数据
+     *
+     * @param id 主键
+     * @return 删除是否成功
+     */
+    @DeleteMapping
+    public ResponseEntity<Boolean> deleteById(int id) {
+        return ResponseEntity.ok(this.salariesService.deleteById(id));
+    }
+
+}
+
diff --git a/src/main/java/com/example/demo/controller/TCustomerController.java b/src/main/java/com/example/demo/controller/TCustomerController.java
@@ -1,6 +1,6 @@
 package com.example.demo.controller;
 
-import com.example.demo.entity.TCustomer;
+import com.example.demo.entity.test.Customer;
 import com.example.demo.service.TCustomerService;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
@@ -32,7 +32,7 @@ public class TCustomerController {
      * @return 查询结果
      */
     @GetMapping
-    public ResponseEntity<Page<TCustomer>> queryByPage(TCustomer tCustomer, PageRequest pageRequest) {
+    public ResponseEntity<Page<Customer>> queryByPage(Customer tCustomer, PageRequest pageRequest) {
         return ResponseEntity.ok(this.tCustomerService.queryByPage(tCustomer, pageRequest));
     }
 
@@ -43,7 +43,7 @@ public ResponseEntity<Page<TCustomer>> queryByPage(TCustomer tCustomer, PageRequ
      * @return 单条数据
      */
     @GetMapping("/queryById")
-    public ResponseEntity<TCustomer> queryById(String id) {
+    public ResponseEntity<Customer> queryById(String id) {
         return ResponseEntity.ok(this.tCustomerService.queryById(id));
     }
 
@@ -54,7 +54,7 @@ public ResponseEntity<TCustomer> queryById(String id) {
      * @return 新增结果
      */
     @PostMapping
-    public ResponseEntity<TCustomer> add(TCustomer tCustomer) {
+    public ResponseEntity<Customer> add(Customer tCustomer) {
         return ResponseEntity.ok(this.tCustomerService.insert(tCustomer));
     }
 
@@ -65,7 +65,7 @@ public ResponseEntity<TCustomer> add(TCustomer tCustomer) {
      * @return 编辑结果
      */
     @PutMapping
-    public ResponseEntity<TCustomer> edit(TCustomer tCustomer) {
+    public ResponseEntity<Customer> edit(Customer tCustomer) {
         return ResponseEntity.ok(this.tCustomerService.update(tCustomer));
     }
 

diff --git a/...va/com/example/demo/dao/TCustomerDao.java → ...m/example/demo/dao/test/TCustomerDao.java b/...va/com/example/demo/dao/TCustomerDao.java → ...m/example/demo/dao/test/TCustomerDao.java
@@ -1,6 +1,6 @@
-package com.example.demo.dao;
+package com.example.demo.dao.test;
 
-import com.example.demo.entity.TCustomer;
+import com.example.demo.entity.test.Customer;
 import org.apache.ibatis.annotations.Param;
 import org.springframework.data.domain.Pageable;
 
@@ -20,7 +20,7 @@ public interface TCustomerDao {
      * @param fcustomerid 主键
      * @return 实例对象
      */
-    TCustomer queryById(String fcustomerid);
+    Customer queryById(String fcustomerid);
 
     /**
      * 查询指定行数据
@@ -29,31 +29,31 @@ public interface TCustomerDao {
      * @param pageable         分页对象
      * @return 对象列表
      */
-    List<TCustomer> queryAllByLimit(TCustomer tCustomer, @Param("pageable") Pageable pageable);
+    List<Customer> queryAllByLimit(Customer tCustomer, @Param("pageable") Pageable pageable);
 
     /**
      * 统计总行数
      *
      * @param tCustomer 查询条件
      * @return 总行数
      */
-    long count(TCustomer tCustomer);
+    long count(Customer tCustomer);
 
     /**
      * 新增数据
      *
      * @param tCustomer 实例对象
      * @return 影响行数
      */
-    int insert(TCustomer tCustomer);
+    int insert(Customer tCustomer);
 
     /**
      * 批量新增数据（MyBatis原生foreach方法）
      *
      * @param entities List<TCustomer> 实例对象列表
      * @return 影响行数
      */
-    int insertBatch(@Param("entities") List<TCustomer> entities);
+    int insertBatch(@Param("entities") List<Customer> entities);
 
     /**
      * 批量新增或按主键更新数据（MyBatis原生foreach方法）
@@ -62,15 +62,15 @@ public interface TCustomerDao {
      * @return 影响行数
      * @throws org.springframework.jdbc.BadSqlGrammarException 入参是空List的时候会抛SQL语句错误的异常，请自行校验入参
      */
-    int insertOrUpdateBatch(@Param("entities") List<TCustomer> entities);
+    int insertOrUpdateBatch(@Param("entities") List<Customer> entities);
 
     /**
      * 修改数据
      *
      * @param tCustomer 实例对象
      * @return 影响行数
      */
-    int update(TCustomer tCustomer);
+    int update(Customer tCustomer);
 
     /**
      * 通过主键删除数据

diff --git a/src/main/java/com/example/demo/dao/test2/SalariesDao.java b/src/main/java/com/example/demo/dao/test2/SalariesDao.java
@@ -0,0 +1,84 @@
+package com.example.demo.dao.test2;
+
+import com.example.demo.entity.test2.Salaries;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.data.domain.Pageable;
+
+import java.util.List;
+
+/**
+ * (Salaries)表数据库访问层
+ *
+ * @author makejava
+ * @since 2021-12-20 09:55:29
+ */
+public interface SalariesDao {
+
+    /**
+     * 通过ID查询单条数据
+     *
+     * @param  id 主键
+     * @return 实例对象
+     */
+    Salaries queryById(int id);
+
+    /**
+     * 查询指定行数据
+     *
+     * @param salaries 查询条件
+     * @param pageable         分页对象
+     * @return 对象列表
+     */
+    List<Salaries> queryAllByLimit(Salaries salaries, @Param("pageable") Pageable pageable);
+
+    /**
+     * 统计总行数
+     *
+     * @param salaries 查询条件
+     * @return 总行数
+     */
+    long count(Salaries salaries);
+
+    /**
+     * 新增数据
+     *
+     * @param salaries 实例对象
+     * @return 影响行数
+     */
+    int insert(Salaries salaries);
+
+    /**
+     * 批量新增数据（MyBatis原生foreach方法）
+     *
+     * @param entities List<Salaries> 实例对象列表
+     * @return 影响行数
+     */
+    int insertBatch(@Param("entities") List<Salaries> entities);
+
+    /**
+     * 批量新增或按主键更新数据（MyBatis原生foreach方法）
+     *
+     * @param entities List<Salaries> 实例对象列表
+     * @return 影响行数
+     * @throws org.springframework.jdbc.BadSqlGrammarException 入参是空List的时候会抛SQL语句错误的异常，请自行校验入参
+     */
+    int insertOrUpdateBatch(@Param("entities") List<Salaries> entities);
+
+    /**
+     * 修改数据
+     *
+     * @param salaries 实例对象
+     * @return 影响行数
+     */
+    int update(Salaries salaries);
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param  id 主键
+     * @return 影响行数
+     */
+    int deleteById(int id);
+
+}
+
diff --git a/...va/com/example/demo/entity/TCustomer.java → ...om/example/demo/entity/test/Customer.java b/...va/com/example/demo/entity/TCustomer.java → ...om/example/demo/entity/test/Customer.java
@@ -1,4 +1,4 @@
-package com.example.demo.entity;
+package com.example.demo.entity.test;
 
 import lombok.Getter;
 import lombok.Setter;
@@ -14,7 +14,7 @@
 
 @Getter
 @Setter
-public class TCustomer implements Serializable {
+public class Customer implements Serializable {
     private static final long serialVersionUID = -23726225018826148L;
     /**
      * 主键

diff --git a/src/main/java/com/example/demo/entity/test2/Salaries.java b/src/main/java/com/example/demo/entity/test2/Salaries.java
@@ -0,0 +1,31 @@
+package com.example.demo.entity.test2;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.util.Date;
+import java.io.Serializable;
+
+/**
+ * (Salaries)实体类
+ *
+ * @author makejava
+ * @since 2021-12-20 09:55:29
+ */
+@Getter
+@Setter
+public class Salaries implements Serializable {
+    private static final long serialVersionUID = -95213502783840294L;
+
+    private Integer id;
+
+    private Integer empNo;
+
+    private Integer salary;
+
+    private Date fromDate;
+
+    private Date toDate;
+
+}
+