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

springboot 集成 MongoDB 基础篇

demo架构:
在这里插入图片描述

Book Controller:

package com.zy.controller;import com.zy.entity.Book;
import com.zy.service.MongoDbService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
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.RequestParam;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** @Author: zy* @Date: 2025-03-05-19:44* @Description:*/
@RestController
@RequestMapping("/book")
public class BookController {@Autowiredprivate MongoDbService mongoDbService;@PostMapping("/mongo/save")public String saveObj(@RequestBody Book book) {return mongoDbService.saveObj(book);}@GetMapping("/mongo/findAll")public List<Book> findAll() {return mongoDbService.findAll();}@GetMapping("/mongo/findOne")public Book findOne(@RequestParam String id) {return mongoDbService.getBookById(id);}@GetMapping("/mongo/findOneByName")public Book findOneByName(@RequestParam String name) {return mongoDbService.getBookByName(name);}@PostMapping("/mongo/update")public String update(@RequestBody Book book) {return mongoDbService.updateBook(book);}@PostMapping("/mongo/delOne")public String delOne(@RequestBody Book book) {return mongoDbService.deleteBook(book);}@GetMapping("/mongo/delById")public String delById(@RequestParam String id) {return mongoDbService.deleteBookById(id);}
}
package com.zy.dao;import com.zy.entity.Book;
import org.springframework.stereotype.Repository;/*** @Author: zy* @Date: 2025-03-05-20:31* @Description:*/
@Repository
public class BookMongoDbDao extends MongoDbDao<Book> {@Overrideprotected Class<Book> getEntityClass() {return Book.class;}
}
package com.zy.dao;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.List;/*** 描述:* mongoDB基础方法封装* /**** @Author: zy* @Date: 2025-03-05-20:29* @Description:*/
public abstract class MongoDbDao<T> {protected Logger logger = LoggerFactory.getLogger(MongoDbDao.class);/*** 反射获取泛型类型** @return*/protected abstract Class<T> getEntityClass();@Autowiredprivate MongoTemplate mongoTemplate;/**** 保存一个对象* @param t*/public void save(T t) {logger.info("-------------->MongoDB save start");this.mongoTemplate.save(t);}/**** 根据id从几何中查询对象* @param id* @return*/public T queryById(Integer id) {Query query = new Query(Criteria.where("_id").is(id));logger.info("-------------->MongoDB find start");return this.mongoTemplate.findOne(query, this.getEntityClass());}/*** 根据条件查询集合** @param object* @return*/public List<T> queryList(T object) {Query query = getQueryByObject(object);logger.info("-------------->MongoDB find start");return mongoTemplate.find(query, this.getEntityClass());}/*** 根据条件查询只返回一个文档** @param object* @return*/public T queryOne(T object) {Query query = getQueryByObject(object);logger.info("-------------->MongoDB find start");return mongoTemplate.findOne(query, this.getEntityClass());}/**** 根据条件分页查询* @param object* @param start 查询起始值* @param size  查询大小* @return*/public List<T> getPage(T object, int start, int size) {Query query = getQueryByObject(object);query.skip(start);query.limit(size);logger.info("-------------->MongoDB queryPage start");return this.mongoTemplate.find(query, this.getEntityClass());}/**** 根据条件查询库中符合条件的记录数量* @param object* @return*/public Long getCount(T object) {Query query = getQueryByObject(object);logger.info("-------------->MongoDB Count start");return this.mongoTemplate.count(query, this.getEntityClass());}/**** 删除对象* @param t* @return*/public int delete(T t) {logger.info("-------------->MongoDB delete start");return (int) this.mongoTemplate.remove(t).getDeletedCount();}/*** 根据id删除** @param id*/public void deleteById(Integer id) {Criteria criteria = Criteria.where("_id").is(id);if (null != criteria) {Query query = new Query(criteria);T obj = this.mongoTemplate.findOne(query, this.getEntityClass());logger.info("-------------->MongoDB deleteById start");if (obj != null) {this.delete(obj);}}}/*MongoDB中更新操作分为三种* 1:updateFirst     修改第一条* 2:updateMulti     修改所有匹配的记录* 3:upsert  修改时如果不存在则进行添加操作* *//*** 修改匹配到的第一条记录** @param srcObj* @param targetObj*/public void updateFirst(T srcObj, T targetObj) {Query query = getQueryByObject(srcObj);Update update = getUpdateByObject(targetObj);logger.info("-------------->MongoDB updateFirst start");this.mongoTemplate.updateFirst(query, update, this.getEntityClass());}/**** 修改匹配到的所有记录* @param srcObj* @param targetObj*/public void updateMulti(T srcObj, T targetObj) {Query query = getQueryByObject(srcObj);Update update = getUpdateByObject(targetObj);logger.info("-------------->MongoDB updateFirst start");this.mongoTemplate.updateMulti(query, update, this.getEntityClass());}/**** 修改匹配到的记录,若不存在该记录则进行添加* @param srcObj* @param targetObj*/public void updateInsert(T srcObj, T targetObj) {Query query = getQueryByObject(srcObj);Update update = getUpdateByObject(targetObj);logger.info("-------------->MongoDB updateInsert start");this.mongoTemplate.upsert(query, update, this.getEntityClass());}/*** 将查询条件对象转换为query** @param object* @return* @author Jason*/private Query getQueryByObject(T object) {Query query = new Query();String[] fileds = getFiledName(object);Criteria criteria = new Criteria();for (int i = 0; i < fileds.length; i++) {String filedName = (String) fileds[i];Object filedValue = getFieldValueByName(filedName, object);if (filedValue != null) {criteria.and(filedName).is(filedValue);}}query.addCriteria(criteria);return query;}/*** 将查询条件对象转换为update** @param object* @return* @author Jason*/private Update getUpdateByObject(T object) {Update update = new Update();String[] fileds = getFiledName(object);for (int i = 0; i < fileds.length; i++) {String filedName = (String) fileds[i];Object filedValue = getFieldValueByName(filedName, object);if (filedValue != null) {update.set(filedName, filedValue);}}return update;}/**** 获取对象属性返回字符串数组* @param o* @return*/private static String[] getFiledName(Object o) {Field[] fields = o.getClass().getDeclaredFields();String[] fieldNames = new String[fields.length];for (int i = 0; i < fields.length; ++i) {fieldNames[i] = fields[i].getName();}return fieldNames;}/**** 根据属性获取对象属性值* @param fieldName* @param o* @return*/private static Object getFieldValueByName(String fieldName, Object o) {try {String e = fieldName.substring(0, 1).toUpperCase();String getter = "get" + e + fieldName.substring(1);Method method = o.getClass().getMethod(getter, new Class[0]);return method.invoke(o, new Object[0]);} catch (Exception var6) {return null;}}
}
package com.zy.entity;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import org.springframework.data.annotation.Id;import java.util.Date;/*** @Author: zy* @Date: 2025-03-05-19:39* @Description:*/
@AllArgsConstructor
@NoArgsConstructor
@Data
public class Book {@Idprivate String id;//价格private Integer price;//书名private String name;//简介private String info;//出版社private String publish;//创建时间private Date createTime;//修改时间private Date updateTime;
}
package com.zy.service;import com.zy.entity.Book;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Service;import java.util.Date;/*** @Author: zy* @Date: 2025-03-05-20:31* @Description:*/
@Service
public class BookMongoDbService {private static final Logger logger = LoggerFactory.getLogger(BookMongoDbService.class);@Autowired@SuppressWarnings("all")private MongoTemplate mongoTemplate;/*** 保存对象** @param book* @return*/public String saveObj(Book book) {logger.info("--------------------->[MongoDB save start]");book.setCreateTime(new Date());book.setUpdateTime(new Date());mongoTemplate.save(book);return "添加成功";}//其他操作方法......
}
package com.zy.service;import com.zy.entity.Book;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Service;import java.util.Date;
import java.util.List;/*** @Author: zy* @Date: 2025-03-05-19:39* @Description: mongoDb service*/
@Service
public class MongoDbService {private static final Logger logger = LoggerFactory.getLogger(MongoDbService.class);private final MongoTemplate mongoTemplate;@SuppressWarnings("all")public MongoDbService(MongoTemplate mongoTemplate) {this.mongoTemplate = mongoTemplate;}/*** 保存对象** @param book 实体类* @return String*/public String saveObj(Book book) {logger.info("--------------------->[MongoDB save start]");book.setCreateTime(new Date());book.setUpdateTime(new Date());mongoTemplate.save(book);return "添加成功";}/*** 查询所有** @return List*/public List<Book> findAll() {logger.info("--------------------->[MongoDB find start]");return mongoTemplate.findAll(Book.class);}/**** 根据id查询* @param id book ID* @return Book*/public Book getBookById(String id) {logger.info("--------------------->[MongoDB find start]");Query query = new Query(Criteria.where("_id").is(id));return mongoTemplate.findOne(query, Book.class);}/*** 根据名称查询** @param name 书名* @return Book*/public Book getBookByName(String name) {logger.info("--------------------->[MongoDB find start]");logger.info("--------------------->[MongoDB name]:" + name);Query query = new Query(Criteria.where("name").is(name));return mongoTemplate.findOne(query, Book.class);}/*** 更新对象** @param book 书* @return String*/public String updateBook(Book book) {logger.info("--------------------->[MongoDB update start]");Query query = new Query(Criteria.where("_id").is(book.getId()));Update update = new Update().set("publish", book.getPublish()).set("info", book.getInfo()).set("updateTime",new Date()).set("name", book.getName());//updateFirst 更新查询返回结果集的第一条mongoTemplate.updateFirst(query, update, Book.class);//updateMulti 更新查询返回结果集的全部//        mongoTemplate.updateMulti(query,update,Book.class);//upsert 更新对象不存在则去添加//        mongoTemplate.upsert(query,update,Book.class);return "success";}/**** 删除对象* @param book 实体类* @return String*/public String deleteBook(Book book) {logger.info("--------------------->[MongoDB delete start]");mongoTemplate.remove(book);return "success";}/*** 根据id删除** @param id ID* @return String*/public String deleteBookById(String id) {logger.info("--------------------->[MongoDB delete start]");//findOneBook book = getBookById(id);//deletedeleteBook(book);return "success";}
}
package com.zy;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;/*** @Author: zy* @Date: 2025-03-05-19:30* @Description:*/
@SpringBootApplication
public class MongoDbApp {public static void main(String[] args) {SpringApplication.run(MongoDbApp.class, args);System.out.println("MongoDbApp started...");}
}
server:port: 8080spring:data:mongodb:host: IP地址username: 用户名database: 你的苦password: 你的密码port: 端口号# 日志打印
logging:level:org.springframework.data.mongodb.core: DEBUG
#    org.springframework.data.mongodb.core.MongoTemplate: DEBUG

Postman 测试接口:

localhost:8080/book/mongo/save{"id": "8","name": "从你的全世界路过5","price": 123,"info": "小说5","publish": "某某出版社5"
}localhost:8080/book/mongo/findAlllocalhost:8080/book/mongo/findOne?id=4localhost:8080/book/mongo/findOneByName?name=从你的全世界路过localhost:8080/book/mongo/update
{"id": "5","name": "从你的全世界路过5-update","price": 123,"info": "小说5-pdate","publish": "某某出版社5-update"
}localhost:8080/book/mongo/delOne{"id": "5","name": "从你的全世界路过5","price": 123,"info": "小说5","publish": "某某出版社5----当时的撒的撒的"
}

相关文章:

springboot 集成 MongoDB 基础篇

demo架构&#xff1a; Book Controller&#xff1a; package com.zy.controller;import com.zy.entity.Book; import com.zy.service.MongoDbService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.Get…...

大白话html语义化标签优势与应用场景

大白话html语义化标签优势与应用场景 大白话解释 语义化标签就是那些名字能让人一看就大概知道它是用来做什么的标签。以前我们经常用<div>来做各种布局&#xff0c;但是<div>本身没有什么实际的含义&#xff0c;就像一个没有名字的盒子。而语义化标签就像是有名…...

恶劣天候三维目标检测论文列表整理

恶劣天候三维目标检测论文列表 图摘自Kradar &#x1f3e0; 介绍 Hi&#xff0c;这是有关恶劣天气下三维目标检测的论文列表。主要是来源于近3年研究过程中认为有意义的文章。希望能为新入门的研究者提供一些帮助。 可能比较简陋&#xff0c;存在一定的遗漏&#xff0c;欢迎…...

conda的环境起的jupyter用不了已经安装的包如何解决

当你在使用Conda环境中的Jupyter Notebook时遇到无法读取某些库或模块的问题&#xff0c;通常是由以下几个原因引起的&#xff1a; 环境未激活&#xff1a;确保你已经在正确的Conda环境中激活了Jupyter Notebook。 库未安装&#xff1a;可能你需要的库没有在当前的Conda环境中…...

蓝桥杯题型

蓝桥杯题型分类 二分 123 传送门 1. 小区间的构成 假设数列的构成是如下形式&#xff1a; 第 1 个区间包含 1 个元素&#xff08;1&#xff09;。第 2 个区间包含 2 个元素&#xff08;1 2&#xff09;。第 3 个区间包含 3 个元素&#xff08;1 2 3&#xff09;。第 4 个区…...

STM32-I2C通信协议

一&#xff1a;I2C通信协议 就是在串口通信上满足四个要求 要求1&#xff1a;删掉一根通信线&#xff0c;防止资源浪费&#xff0c;只能在同一根线上进行发送和接收要求2&#xff1a;需要一个应答机制&#xff0c;没发送一个字节都有一次应答要求3&#xff1a;一根线上能同时…...

taosd 写入与查询场景下压缩解压及加密解密的 CPU 占用分析

在当今大数据时代&#xff0c;时序数据库的应用越来越广泛&#xff0c;尤其是在物联网、工业监控、金融分析等领域。TDengine 作为一款高性能的时序数据库&#xff0c;凭借独特的存储架构和高效的压缩算法&#xff0c;在存储和查询效率上表现出色。然而&#xff0c;随着数据规模…...

uniapp微信小程序vue3自定义tabbar

在App.vue隐藏原生tabbar&#xff0c;也可以在pages.json中配置 二选一就好了 创建 CustomTabBar 公共组件 <template><view class"custom-tab-bar" :style"{paddingBottom: safeAreaHeight px}"><view class"tab-bar-item" :…...

BUUCTF——[GYCTF2020]FlaskApp1 SSTI模板注入/PIN学习

目录 一、网页功能探索 二、SSTI注入 三、方法一 四、方法二 使用PIN码 &#xff08;1&#xff09;服务器运行flask登录所需的用户名 &#xff08;2&#xff09;modename &#xff08;3&#xff09;flask库下app.py的绝对路径 &#xff08;4&#xff09;当前网络的mac地…...

如何用Kimi生成PPT?秒出PPT更高效!

做PPT是不是总是让你头疼&#xff1f;&#x1f629; 快速制作出专业的PPT&#xff0c;今天我们要推荐两款超级好用的AI工具——Kimi 和 秒出PPT&#xff01;我们来看看哪一款更适合你吧&#xff01;&#x1f680; &#x1f947; Kimi&#xff1a;让PPT制作更轻松 Kimi的生成效…...

数据结构(回顾)

数据结构&#xff08;回顾&#xff09; 回顾 不同点顺序表链表存储空间上物理上一定连续逻辑上连续&#xff0c;物理上不一定连续随机访问支持&#xff0c;时间复杂度O(1)不支持&#xff0c;时间复杂度O(N)任意位置插入或者删除元素可能需要挪动元素&#xff0c;效率低&#…...

全国产!瑞芯微3562Mini(2GHz四核A53 NPU)工业开发板规格书

评估板简介 创龙科技 TL3562-MiniEVM 是一款基于瑞芯微 RK3562J/RK3562 处理器设计的四核 AR M Cortex-A53 单核 ARM Cortex-M0 国产工业评估板&#xff0c;主频高达 2.0GHz。评估板由核心板和评估底板组成&#xff0c;核心板 CPU、ROM、RAM、电源、晶振等所有元器件均采用国…...

鸿蒙HarmonyOS评论功能小demo

评论页面小demo 效果展示 1.拆解组件&#xff0c;分层搭建 我们将整个评论页面拆解为三个组件&#xff0c;分别是头部导航&#xff0c;评论项&#xff0c;回复三个部分&#xff0c;然后统一在index界面导入 2.头部导航界面搭建 Preview Component struct HmNavBar {// 属性&a…...

异常(6)

今天我们继续来讲异常的内容,关于异常的捕获和声明,也是在处理异常的的重要方式,话不多说,来看. 异常的捕获 异常的捕获,也就是异常,的具体处理方式,主要有两种,主要有两种&#xff1a;异常声明throws以及try-catch捕获处理. 3.1异常声明throws. 处在方法声明时参数列表之后…...

精选一百道备赛蓝桥杯——2.K倍区间

解题思路 任何两个前缀区间的和对k取模的值相等&#xff0c;则由大的前缀区间减掉小的前缀区间所形成的区间的必定是K倍区间。因此我们可以对具有区间和%k值相等任何两个区间进行组合&#xff0c;再将这些值加起来就得到结果&#xff01;证明&#xff1a; 假设一个数列为a1,a2…...

编译Telegram Desktop

目录 一、前言 二、环境准备 2.1 2.2 2.3 2.4 2.5 2.6 2.7 2.8 三、编译 四、总结和学习 一、前言 Telegram 是一款全球广泛使用的即时通讯软件&#xff0c;以其强大的隐私保护、跨平台同步和丰富的功能而闻名。它支持一对一聊天、群组&#xff08;最多20万成员&am…...

玩转python: 掌握Python数据结构之链表

链表是计算机科学中最基础的数据结构之一&#xff0c;也是许多高级数据结构和算法的基础。本文将带你从零开始&#xff0c;逐步掌握链表的概念、实现和应用。通过丰富的案例和通俗易懂的解释&#xff0c;你将能够轻松理解并应用链表。 什么是链表&#xff1f; 链表是一种线性…...

upload-labs详解(1-12)文件上传分析

目录 uploa-labs-main upload-labs-main第一关 前端防御 绕过前端防御 禁用js Burpsuite抓包改包 upload-labs-main第二关 上传测试 错误类型 upload-labs-env upload-labs-env第三关 上传测试 查看源码 解决方法 重命名&#xff0c;上传 upload-labs-env第四关…...

RAG系统(检索增强生成)的优化策略

RAG(检索增强生成)系统的优化可以从多个方面入手,主要包括数据、查询、检索、生成、框架和评估等几个重要环节。本文将详细介绍这些优化策略,并为每个环节提供具体的操作方法。 一、数据优化 1. 数据清洗和增强 数据质量直接影响检索和生成的效果,因此需要进行细致的数据…...

写毕业论文用哪个AI好?这6款AIGC论文工具给你答案

撰写毕业论文是一项艰巨的任务&#xff0c;AIGC 论文工具的出现为同学们提供了有力支持。以下 6 款工具在功能、适用场景等方面各有优势&#xff0c;助你高效完成毕业论文。 文赋 AI 论文 文赋 AI 论文堪称毕业论文写作的得力助手。它的生成速度令人惊叹&#xff0c;短短 5 分…...

LBE-LEX系列工业语音播放器|预警播报器|喇叭蜂鸣器的上位机配置操作说明

LBE-LEX系列工业语音播放器|预警播报器|喇叭蜂鸣器专为工业环境精心打造&#xff0c;完美适配AGV和无人叉车。同时&#xff0c;集成以太网与语音合成技术&#xff0c;为各类高级系统&#xff08;如MES、调度系统、库位管理、立库等&#xff09;提供高效便捷的语音交互体验。 L…...

shell脚本--常见案例

1、自动备份文件或目录 2、批量重命名文件 3、查找并删除指定名称的文件&#xff1a; 4、批量删除文件 5、查找并替换文件内容 6、批量创建文件 7、创建文件夹并移动文件 8、在文件夹中查找文件...

【力扣数据库知识手册笔记】索引

索引 索引的优缺点 优点1. 通过创建唯一性索引&#xff0c;可以保证数据库表中每一行数据的唯一性。2. 可以加快数据的检索速度&#xff08;创建索引的主要原因&#xff09;。3. 可以加速表和表之间的连接&#xff0c;实现数据的参考完整性。4. 可以在查询过程中&#xff0c;…...

智慧工地云平台源码,基于微服务架构+Java+Spring Cloud +UniApp +MySql

智慧工地管理云平台系统&#xff0c;智慧工地全套源码&#xff0c;java版智慧工地源码&#xff0c;支持PC端、大屏端、移动端。 智慧工地聚焦建筑行业的市场需求&#xff0c;提供“平台网络终端”的整体解决方案&#xff0c;提供劳务管理、视频管理、智能监测、绿色施工、安全管…...

比较数据迁移后MySQL数据库和OceanBase数据仓库中的表

设计一个MySQL数据库和OceanBase数据仓库的表数据比较的详细程序流程,两张表是相同的结构,都有整型主键id字段,需要每次从数据库分批取得2000条数据,用于比较,比较操作的同时可以再取2000条数据,等上一次比较完成之后,开始比较,直到比较完所有的数据。比较操作需要比较…...

Bean 作用域有哪些?如何答出技术深度?

导语&#xff1a; Spring 面试绕不开 Bean 的作用域问题&#xff0c;这是面试官考察候选人对 Spring 框架理解深度的常见方式。本文将围绕“Spring 中的 Bean 作用域”展开&#xff0c;结合典型面试题及实战场景&#xff0c;帮你厘清重点&#xff0c;打破模板式回答&#xff0c…...

【UE5 C++】通过文件对话框获取选择文件的路径

目录 效果 步骤 源码 效果 步骤 1. 在“xxx.Build.cs”中添加需要使用的模块 &#xff0c;这里主要使用“DesktopPlatform”模块 2. 添加后闭UE编辑器&#xff0c;右键点击 .uproject 文件&#xff0c;选择 "Generate Visual Studio project files"&#xff0c;重…...

rknn toolkit2搭建和推理

安装Miniconda Miniconda - Anaconda Miniconda 选择一个 新的 版本 &#xff0c;不用和RKNN的python版本保持一致 使用 ./xxx.sh进行安装 下面配置一下载源 # 清华大学源&#xff08;最常用&#xff09; conda config --add channels https://mirrors.tuna.tsinghua.edu.cn…...

若依项目部署--传统架构--未完待续

若依项目介绍 项目源码获取 #Git工具下载 dnf -y install git #若依项目获取 git clone https://gitee.com/y_project/RuoYi-Vue.git项目背景 随着企业信息化需求的增加&#xff0c;传统开发模式存在效率低&#xff0c;重复劳动多等问题。若依项目通过整合主流技术框架&…...

Shell 解释器​​ bash 和 dash 区别

bash 和 dash 都是 Unix/Linux 系统中的 ​​Shell 解释器​​&#xff0c;但它们在功能、语法和性能上有显著区别。以下是它们的详细对比&#xff1a; ​​1. 基本区别​​ ​​特性​​​​bash (Bourne-Again SHell)​​​​dash (Debian Almquist SHell)​​​​来源​​G…...