十次方微服务项目实战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

相关文章

MyBatis分页查询实战案例完整流程

《MyBatis分页查询实战案例完整流程》MyBatis是一个强大的Java持久层框架,支持自定义SQL和高级映射,本案例以员工工资信息管理为例,详细讲解如何在IDEA中使用MyBatis结合Page... 目录1. MyBATis框架简介2. 分页查询原理与应用场景2.1 分页查询的基本原理2.1.1 分

使用Python批量将.ncm格式的音频文件转换为.mp3格式的实战详解

《使用Python批量将.ncm格式的音频文件转换为.mp3格式的实战详解》本文详细介绍了如何使用Python通过ncmdump工具批量将.ncm音频转换为.mp3的步骤,包括安装、配置ffmpeg环... 目录1. 前言2. 安装 ncmdump3. 实现 .ncm 转 .mp34. 执行过程5. 执行结

Python中logging模块用法示例总结

《Python中logging模块用法示例总结》在Python中logging模块是一个强大的日志记录工具,它允许用户将程序运行期间产生的日志信息输出到控制台或者写入到文件中,:本文主要介绍Pyt... 目录前言一. 基本使用1. 五种日志等级2.  设置报告等级3. 自定义格式4. C语言风格的格式化方法

SpringBoot 多环境开发实战(从配置、管理与控制)

《SpringBoot多环境开发实战(从配置、管理与控制)》本文详解SpringBoot多环境配置,涵盖单文件YAML、多文件模式、MavenProfile分组及激活策略,通过优先级控制灵活切换环境... 目录一、多环境开发基础(单文件 YAML 版)(一)配置原理与优势(二)实操示例二、多环境开发多文件版

使用docker搭建嵌入式Linux开发环境

《使用docker搭建嵌入式Linux开发环境》本文主要介绍了使用docker搭建嵌入式Linux开发环境,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录1、前言2、安装docker3、编写容器管理脚本4、创建容器1、前言在日常开发全志、rk等不同

Three.js构建一个 3D 商品展示空间完整实战项目

《Three.js构建一个3D商品展示空间完整实战项目》Three.js是一个强大的JavaScript库,专用于在Web浏览器中创建3D图形,:本文主要介绍Three.js构建一个3D商品展... 目录引言项目核心技术1. 项目架构与资源组织2. 多模型切换、交互热点绑定3. 移动端适配与帧率优化4. 可

从基础到高级详解Python数值格式化输出的完全指南

《从基础到高级详解Python数值格式化输出的完全指南》在数据分析、金融计算和科学报告领域,数值格式化是提升可读性和专业性的关键技术,本文将深入解析Python中数值格式化输出的相关方法,感兴趣的小伙... 目录引言:数值格式化的核心价值一、基础格式化方法1.1 三种核心格式化方式对比1.2 基础格式化示例

sysmain服务可以禁用吗? 电脑sysmain服务关闭后的影响与操作指南

《sysmain服务可以禁用吗?电脑sysmain服务关闭后的影响与操作指南》在Windows系统中,SysMain服务(原名Superfetch)作为一个旨在提升系统性能的关键组件,一直备受用户关... 在使用 Windows 系统时,有时候真有点像在「开盲盒」。全新安装系统后的「默认设置」,往往并不尽编

redis-sentinel基础概念及部署流程

《redis-sentinel基础概念及部署流程》RedisSentinel是Redis的高可用解决方案,通过监控主从节点、自动故障转移、通知机制及配置提供,实现集群故障恢复与服务持续可用,核心组件包... 目录一. 引言二. 核心功能三. 核心组件四. 故障转移流程五. 服务部署六. sentinel部署

Python ORM神器之SQLAlchemy基本使用完全指南

《PythonORM神器之SQLAlchemy基本使用完全指南》SQLAlchemy是Python主流ORM框架,通过对象化方式简化数据库操作,支持多数据库,提供引擎、会话、模型等核心组件,实现事务... 目录一、什么是SQLAlchemy?二、安装SQLAlchemy三、核心概念1. Engine(引擎)