当前位置： 首页 > news >正文

SpringCloud 系列教程：微服务的未来（三）IService接口的业务实现

news 2025/8/4 2:42:12

本文将介绍 IService 接口的基本业务操作、复杂业务操作、Lambda 方法的使用以及批量增加操作，帮助开发者深入了解如何高效地利用 MyBatis-Plus 提供的功能进行数据库操作。无论是简单的单表查询，还是复杂的多表联动，甚至是大数据量的批量操作，IService 都能为你提供便利的解决方案。

文章目录

前言

Iservice接口基本业务

Iservice接口复杂业务

IService的Lambda方法

IService的批量新增

总结

前言

现代 Java 开发中，Spring 框架和 MyBatis-Plus 已成为开发高效、灵活的企业级应用程序的重要工具。MyBatis-Plus 作为 MyBatis 的增强工具，提供了丰富的功能来简化数据库操作，其中 IService 接口是其核心之一。IService 不仅为我们提供了常见的 CRUD 操作，还支持 Lambda 查询、批量操作等高级功能，极大地提高了开发效率。

本文将介绍 IService 接口的基本业务操作、复杂业务操作、Lambda 方法的使用以及批量增加操作，帮助开发者深入了解如何高效地利用 MyBatis-Plus 提供的功能进行数据库操作。无论是简单的单表查询，还是复杂的多表联动，甚至是大数据量的批量操作，IService 都能为你提供便利的解决方案。

Iservice接口基本业务

首先引入依赖swagger依赖和web依赖

        <dependency><groupId>com.github.xiaoymin</groupId><artifactId>knife4j-openapi2-spring-boot-starter</artifactId><version>4.1.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency>

然后配置swagger信息

knife4j:enable: trueopenapi:title: 用户管理接口文档description: "用户管理接口文档"email: zhanghuyi@itcast.cnconcat: 虎哥url: https://www.itcast.cnversion: v1.0.0group:default:group-name: defaultapi-rule: packageapi-rule-resources:- com.itheima.mp.controller

UserController类

新增用户

package com.itheima.mp.controller;import cn.hutool.core.bean.BeanUtil;
import com.itheima.mp.domain.dto.UserFormDTO;
import com.itheima.mp.domain.po.User;
import com.itheima.mp.service.IUserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@Api(tags="用户管理接口")
@RestController
@RequestMapping("/user")
public class UserController  {@Autowiredprivate IUserService userService;@ApiOperation("新增用户接口")@PostMapping//往往会传送json格式数据，所以加@RequestBodypublic void saveUseer(@RequestBody UserFormDTO userFormDTO) {//把DTO拷贝到poUser user = BeanUtil.toBean(userFormDTO, User.class);//新增userService.save(user);}
}

删除用户

    @ApiOperation("删除用户接口")@DeleteMapping("{id}")//往往会传送json格式数据，所以加@RequestBodypublic void deleteUserById(@ApiParam("用户id") @PathVariable("id") Long id) {userService.removeById(id);}

根据id查询用户接口

    @ApiOperation("根据id查询用户")@GetMapping("{id}")public UserVO getUserById(@ApiParam("用户id") @PathVariable("id") Long id) {//查询用户User user = userService.getById(id);//把po拷贝到voUserVO userVO = BeanUtil.copyProperties(user, UserVO.class);return userVO;}

 根据id批量查询用户

    @ApiOperation("根据id批量查询用户")@GetMappingpublic List<UserVO> queryUserByIds(@ApiParam("用户id集合 ") @RequestParam("ids") List<Long> ids) {//查询用户List<User> users = userService.listByIds(ids);//把PO拷贝到VOList<UserVO> userVOS = BeanUtil.copyToList(users, UserVO.class);return userVOS;}

Iservice接口复杂业务

根据id扣减用户余额

    @ApiOperation("根据id扣除余额")@PutMapping("/{id}/deduction/{money}")public void deductMoneyById(@ApiParam("用户id") @PathVariable("id") Long id,@ApiParam("扣减的金额") @PathVariable("money") Integer money){userService.deductBalance(id,money);}

IUserService接口

public interface IUserService extends IService<User> {void deductBalance(Long id,Integer money);
}

UserServiceImpl类

package com.itheima.mp.service.impl;import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.itheima.mp.domain.po.User;
import com.itheima.mp.mapper.UserMapper;
import com.itheima.mp.service.IUserService;
import org.springframework.stereotype.Service;@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {@Overridepublic void deductBalance(Long id, Integer money) {//查询用户User user = this.getById(id);//校验用户状态if(user==null || user.getStatus() == 2){throw new RuntimeException("用户状态异常");}//校验余额是否充足if(user.getBalance() < money){throw new RuntimeException("用户余额不足！");}//扣减余额baseMapper.deductBalance(id,money);}
}

userMapperr类 

 @Update("update user set balance = balance - #{money} where id = id")void deductBalance(@Param("id")Long id,@Param("money")Integer money);

 通过localhost:8080/doc.html就可以访问接口文档

IService的Lambda方法

<select id="queryUsers" resultType="com.itheima.mp.domain.po.UserSELECT *FROM tb_user<where><if test="name != null">AND username LIKE #{name]</if><if test="status != null">ANDstatus`=#{status}</if><if test="minBalance != null and maxBalance != null">AND balance BETWEEN #{minBalance}AND #{maxBalance}</if></where>
</select>

 UserController类

    @ApiOperation("根据复杂条件查询用户接口")@GetMapping("/list")public List<UserVO> queryUsers(UserQuery userQuery) {//查询用户poList<User> users = userService.queryUsers(userQuery.getName(),userQuery.getStatus(),userQuery.getMinBalance(),userQuery.getMaxBalance());List<UserVO> userVOS = BeanUtil.copyToList(users, UserVO.class);return userVOS;}

IService接口 

List<User> queryUsers(String name, Integer status, Integer minBalance, Integer maxBalance);

UserServiceImpl实现类 

    @Overridepublic List<User> queryUsers(String name, Integer status, Integer minBalance, Integer maxBalance) {List<User> users = lambdaQuery().like(name != null, User::getUsername, name).eq(status != null, User::getStatus, status).ge(minBalance != null, User::getBalance, minBalance).le(maxBalance != null, User::getBalance, maxBalance).list();return users;}

    @Overridepublic void deductBalance(Long id, Integer money) {//查询用户User user = this.getById(id);//校验用户状态if(user==null || user.getStatus() == 2){throw new RuntimeException("用户状态异常");}//校验余额是否充足if(user.getBalance() < money){throw new RuntimeException("用户余额不足！");}//余额int remain = user.getBalance() - money;lambdaUpdate().set(User::getBalance, remain).set(remain == 0, User::getStatus, 2).eq(User::getId, id)//防止多线程引发.eq(User::getBalance, user.getBalance()).update();}

IService的批量新增

    @Testvoid testSaveBatch(){long b = System.currentTimeMillis();//每次批量处理1000条List<User> list = new ArrayList<>(1000);for(int i = 1;i <= 100000;i++){list.add(buildUser(i));if(i % 10000 == 0){//每1000条批量处理一次userService.saveBatch(list);list.clear();}}long e = System.currentTimeMillis();System.out.println("耗时："+(e - b));}

 在application.yml文件中加入rewriteBatchedStatements=true

spring:datasource:url: jdbc:mysql://127.0.0.1:3306/mp?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true

总结

通过本文的讲解，我们深入探讨了 MyBatis-Plus 中 IService 接口的多种常见用法。首先，IService 的基本业务方法简化了常见的 CRUD 操作，开发者无需编写冗长的 SQL 语句，便能实现数据库的增、删、改、查等操作。其次，借助 MyBatis-Plus 强大的 Lambda 功能，开发者可以更加灵活和简洁地构建查询条件，避免了传统 SQL 中条件拼接的复杂性。接着，我们介绍了如何通过 IService 实现复杂业务逻辑，尤其是多表操作的处理，进一步增强了应用的可扩展性和灵活性。最后，批量操作作为大数据量处理中的一项重要优化方法，saveBatch 使得批量插入变得更加简单高效，减少了数据库访问的次数。

通过充分掌握 IService 接口的使用，你可以大幅提升开发效率，减少代码重复度，并且能够灵活应对各种复杂的业务场景。希望本文所介绍的内容能够帮助你更好地理解并应用 MyBatis-Plus 的强大功能，提升你的开发水平与应用性能。

http://www.lryc.cn/news/513211.html

相关文章：

  • 测试带宽上行方法
  • 天天跳绳（？？？）
  • module ‘django.db.models‘ has no attribute ‘FieldDoesNotExist‘
  • 智能工厂的设计软件 应用场景的一个例子：为AI聊天工具添加一个知识系统 之10 方案再探之1：特定于领域的模板 之1 随想交流
  • Excel将混乱的多行做成1列
  • Django项目部署到服务器
  • SpringBoot集成Flowable
  • 大模型从零开始——预训练之分词 Tokenization
  • Python下载包缓慢时怎么修改镜像源
  • 每日一练 | 时延和抖动
  • 嵌入式开发之使用 FileZilla 在 Windows 和 Ubuntu 之间传文件
  • 腾势D9风光不再？中期改款能否及时“救火”
  • OpenCV-Python实战（11）——边缘检测
  • 【智行安全】基于Synaptics SL1680的AI疲劳驾驶检测方案
  • 机器学习随机森林回归时间序列预模型中时间滑动窗口作用以及参数设置
  • 【Rust自学】7.5. use关键字 Pt.2 ：重导入与换国内镜像源教程
  • 自定义luacheck校验规则
  • python钉钉机器人
  • 汇编学习笔记
  • 混合并行训练框架性能对比
  • 基于Docker+模拟器的Appium自动化测试（二）
  • 数据结构之线性表之链表(附加一个考研题)
  • etmem
  • LangChain4j与Elasticsearch：构建高效的语义嵌入存储
  • 黄河小浪底水利枢纽泄洪预警广播系统正式上线
  • 理解生成协同促进？华为诺亚提出ILLUME，15M数据实现多模态理解生成一体化
  • [文献阅读]ReAct: Synergizing Reasoning and Acting in Language Models
  • 摄像头监视脚本
  • FreeRTOS的内存管理（选择heap4.c文件的理由）
  • SQL-leetcode-183. 从不订购的客户