十次方微服务项目实战03--基础微服务模块搭建及基本CRUD复杂查询

本文主要是介绍十次方微服务项目实战03--基础微服务模块搭建及基本CRUD复杂查询,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一、基础微服务工程

1.1 创建基础微服务模块tensquare_base

创建过程参考tensquare_common,此处不再赘述。

1.2 pom.xml引入依赖

tensquare_base中引入jpamysql以及tensquare_common等依赖。
全文如下:

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>tensquare_parent</artifactId><groupId>com.tensquare</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>tensquare_base</artifactId><dependencies><!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-jpa --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><dependency><groupId>com.tensquare</groupId><artifactId>tensquare_common</artifactId><version>1.0-SNAPSHOT</version></dependency></dependencies>
</project>

1.3 创建启动类

tensquare_base中,新建包com.tensquare.base,建立BaseApplication.java启动类。
如下:

package com.tensquare.base;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import util.IdWorker;/*** Created by me on 2019/6/25.*/
@SpringBootApplication
public class BaseApplication {public static void main(String[] args) {SpringApplication.run(BaseApplication.class);}@Beanpublic IdWorker idWorker() {return new IdWorker(1, 1);}}

此处通过@Bean注解,注入IdWorker对象,其中第一个参数为工作机器ID,第二个参数为业务编码。

1.4 创建配置文件

resource目录下,新建application.yml配置文件,进行基础配置。
如下:

server:port: 9001
spring:application:name: tensquare-basedatasource:driver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://localhost:3306/tensquare_base?characterEncoding=utf-8username: rootpassword: rootjpa:database: MYSQLshow-sql: true
#    generate-ddl: true

至此,tensquare_base工程搭建完毕,可以运行BaseApplication.java,查看效果。

二、标签管理-基本CRUD

2.1 表结构分析

字段名称字段含义字段类型备注
idID文本
name标签名称文本
state状态文本0:无效 1:有效
count使用数量整型
fans关注数整型
recommend是否推荐文本0:不推荐 1:推荐

2.2 基本CRUD实现

2.2.1 创建实体类

创建com.tensquare.base包,在包下创建pojo包,并创建实体类Label
代码如下:

package com.tensquare.base.pojo;import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;/*** Created by me on 2019/6/25.*/
@Entity
@Table(name = "tb_label")
public class Label {@Idprivate String id;private String labelname;private String state;private Long count;private Long fans;private String recommend;// 省略get set方法
}
2.2.2 创建数据访问接口

com.tensquare.base下创建dao包,并创建LabelDao接口。
代码如下:

package com.tensquare.base.dao;import com.tensquare.base.pojo.Label;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;/*** Created by me on 2019/6/25.*/
public interface LabelDao extends JpaRepository<Label, String>, JpaSpecificationExecutor<Label> {
}

其中:
JpaRepository:提供了基本的增删改查
JpaSpeccificationExecutor:用于做复杂的条件查询

2.2.3 创建业务逻辑类

com.tensquare.base包下创建service包,并创建LabelService类。在该类中,实现基本的增删改查功能。
代码如下:

package com.tensquare.base.service;import com.tensquare.base.dao.LabelDao;
import com.tensquare.base.pojo.Label;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import util.IdWorker;import java.util.List;/*** Created by me on 2019/6/25.*/
@Service
@Transactional
public class LabelService {@Autowiredprivate LabelDao labelDao;@Autowiredprivate IdWorker idWorker;/*** 查询所有标签* @return*/public List<Label> findAll() {return labelDao.findAll();}/*** 根据标签ID查找标签* @param id* @return*/public Label findById(String id) {return labelDao.findById(id).get();}/*** 添加标签* @param label*/public void add(Label label) {label.setId(idWorker.nextId() + "");labelDao.save(label);}/*** 更新标签* @param label*/public void update(Label label) {labelDao.save(label);}/*** 根据id删除标签* @param id*/public void deleteById(String id) {labelDao.deleteById(id);}}
2.2.3 创建业务逻辑类

com.tensquare.base包下创建controller包,并创建UserController类。
代码如下:

package com.tensquare.base.controller;import com.tensquare.base.pojo.Label;
import com.tensquare.base.service.LabelService;
import entity.Result;
import entity.StatusCode;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;import java.util.List;/*** 标签控制层* Created by me on 2019/6/25.*/
@CrossOrigin
@RestController
@RequestMapping("/label")
public class LabelController {@Autowiredprivate LabelService labelService;@GetMapping("list")public Result<List> findAll() {return new Result<>(true, StatusCode.OK, "success", labelService.findAll());}@RequestMapping(value = "/{id}", method = RequestMethod.GET)public Result<Label> findById(@PathVariable String id) {return new Result<>(true, StatusCode.OK, "success", labelService.findById(id));}@RequestMapping(method = RequestMethod.POST)public Result add(@RequestBody Label label) {labelService.add(label);return new Result(true, StatusCode.OK, "添加成功");}@RequestMapping(value = "/{id}", method = RequestMethod.PUT)public Result update(@RequestBody Label label, @PathVariable String id) {label.setId(id);labelService.update(label);return new Result(true, StatusCode.OK, "修改成功");}@RequestMapping(value = "/{id}", method = RequestMethod.DELETE)public Result deleteById(@PathVariable String id) {labelService.deleteById(id);return new Result(true, StatusCode.OK, "删除成功");}}

至此,标签的CRUD功能基本完成,接下来可以使用PostMan工具进行测试,此处就不再赘述了。

三、标签管理-复杂查询

在讲了基本CRUD后,来处理一下实际使用中常见的复杂查询。

3.1 根据条件查询标签列表

3.1.1 修改LabelService,增加方法

代码如下:

/*** 根据条件查询标签** @param searchMap* @return*/public List<Label> searchLabel(Map searchMap) {Specification<Label> specification = createSpecification(searchMap);return labelDao.findAll(specification);}/*** 根据参数构造查询条件** @param serachMap* @return*/private Specification<Label> createSpecification(Map serachMap) {return new Specification<Label>() {@Overridepublic Predicate toPredicate(Root<Label> root, CriteriaQuery<?> criteriaQuery, CriteriaBuilder criteriaBuilder) {List<Predicate> predicateList = new ArrayList<>();// labelname校验String labelname = (String) serachMap.get("labelname");if (labelname != null && !"".equals(labelname)) {predicateList.add(criteriaBuilder.like(root.get("labelname").as(String.class), "%" + labelname + "%"));}// state校验String state = (String) serachMap.get("state");if (state != null && !"".equals(state)) {predicateList.add(criteriaBuilder.equal(root.get("state").as(String.class), state));}// recommend校验String recommend = (String) serachMap.get("recommend");if (recommend != null && !"".equals(recommend)) {predicateList.add(criteriaBuilder.equal(root.get("recommend").as(String.class), recommend));}return criteriaBuilder.and(predicateList.toArray(new Predicate[predicateList.size()]));}};}
3.1.2 修改LabelController,增加方法
@RequestMapping(value = "/search", method = RequestMethod.POST)public Result searchLabel(@RequestBody Map searchMap) {List<Label> labelList = labelService.searchLabel(searchMap);return Result.ok(labelList);}

3.2 带分页的条件查询

3.2.1 修改LabelService

LabelService类中增加方法,进行分页操作,需要使用到类PageRequest
代码如下:

/*** 带分页的条件查询** @param searchMap 查询条件* @param page      当前页码* @param size      每页展示数量* @return*/public Page<Label> findSearch(Map searchMap, int page, int size) {Specification<Label> specification = createSpecification(searchMap);// 页码数-1处理PageRequest pageRequest = PageRequest.of(page - 1, size);return labelDao.findAll(specification, pageRequest);}
3.2.2 修改LabelController

增加findSearch方法,此处就使用到之前在tensquare_common中定义的PageResult类了。
代码如下:

@RequestMapping(value = "/search/{page}/{size}", method = RequestMethod.POST)public Result findSearch(@RequestBody Map searchMap, @PathVariable int page, @PathVariable int size) {Page<Label> labelPage = labelService.findSearch(searchMap, page, size);return new Result(true, StatusCode.OK, "查询成功", new PageResult<>(labelPage.getTotalElements(), labelPage.getContent());}

好了,复杂查询就简单介绍到这了。

四、小结

本篇主要介绍了:

  • 创建基础微服务子工程及其配置
  • 基本查询
  • 复杂查询

这篇关于十次方微服务项目实战03--基础微服务模块搭建及基本CRUD复杂查询的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/982415

相关文章

关于DNS域名解析服务

《关于DNS域名解析服务》:本文主要介绍关于DNS域名解析服务,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录DNS系统的作用及类型DNS使用的协议及端口号DNS系统的分布式数据结构DNS的分布式互联网解析库域名体系结构两种查询方式DNS服务器类型统计构建DNS域

从入门到精通MySQL联合查询

《从入门到精通MySQL联合查询》:本文主要介绍从入门到精通MySQL联合查询,本文通过实例代码给大家介绍的非常详细,需要的朋友可以参考下... 目录摘要1. 多表联合查询时mysql内部原理2. 内连接3. 外连接4. 自连接5. 子查询6. 合并查询7. 插入查询结果摘要前面我们学习了数据库设计时要满

MySQL查询JSON数组字段包含特定字符串的方法

《MySQL查询JSON数组字段包含特定字符串的方法》在MySQL数据库中,当某个字段存储的是JSON数组,需要查询数组中包含特定字符串的记录时传统的LIKE语句无法直接使用,下面小编就为大家介绍两种... 目录问题背景解决方案对比1. 精确匹配方案(推荐)2. 模糊匹配方案参数化查询示例使用场景建议性能优

从原理到实战深入理解Java 断言assert

《从原理到实战深入理解Java断言assert》本文深入解析Java断言机制,涵盖语法、工作原理、启用方式及与异常的区别,推荐用于开发阶段的条件检查与状态验证,并强调生产环境应使用参数验证工具类替代... 目录深入理解 Java 断言(assert):从原理到实战引言:为什么需要断言?一、断言基础1.1 语

mysql表操作与查询功能详解

《mysql表操作与查询功能详解》本文系统讲解MySQL表操作与查询,涵盖创建、修改、复制表语法,基本查询结构及WHERE、GROUPBY等子句,本文结合实例代码给大家介绍的非常详细,感兴趣的朋友跟随... 目录01.表的操作1.1表操作概览1.2创建表1.3修改表1.4复制表02.基本查询操作2.1 SE

Python中re模块结合正则表达式的实际应用案例

《Python中re模块结合正则表达式的实际应用案例》Python中的re模块是用于处理正则表达式的强大工具,正则表达式是一种用来匹配字符串的模式,它可以在文本中搜索和匹配特定的字符串模式,这篇文章主... 目录前言re模块常用函数一、查看文本中是否包含 A 或 B 字符串二、替换多个关键词为统一格式三、提

Java MQTT实战应用

《JavaMQTT实战应用》本文详解MQTT协议,涵盖其发布/订阅机制、低功耗高效特性、三种服务质量等级(QoS0/1/2),以及客户端、代理、主题的核心概念,最后提供Linux部署教程、Sprin... 目录一、MQTT协议二、MQTT优点三、三种服务质量等级四、客户端、代理、主题1. 客户端(Clien

Linux中SSH服务配置的全面指南

《Linux中SSH服务配置的全面指南》作为网络安全工程师,SSH(SecureShell)服务的安全配置是我们日常工作中不可忽视的重要环节,本文将从基础配置到高级安全加固,全面解析SSH服务的各项参... 目录概述基础配置详解端口与监听设置主机密钥配置认证机制强化禁用密码认证禁止root直接登录实现双因素

Go语言数据库编程GORM 的基本使用详解

《Go语言数据库编程GORM的基本使用详解》GORM是Go语言流行的ORM框架,封装database/sql,支持自动迁移、关联、事务等,提供CRUD、条件查询、钩子函数、日志等功能,简化数据库操作... 目录一、安装与初始化1. 安装 GORM 及数据库驱动2. 建立数据库连接二、定义模型结构体三、自动迁

MyBatisPlus如何优化千万级数据的CRUD

《MyBatisPlus如何优化千万级数据的CRUD》最近负责的一个项目,数据库表量级破千万,每次执行CRUD都像走钢丝,稍有不慎就引起数据库报警,本文就结合这个项目的实战经验,聊聊MyBatisPl... 目录背景一、MyBATis Plus 简介二、千万级数据的挑战三、优化 CRUD 的关键策略1. 查