springboot整合MongoDB

分类：MongoDB作者：编程之家用户

简介
MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。

MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。

运行环境
开发工具：intellij idea
JDK版本：1.8
项目管理工具：Maven 4.0.0

整合：
pom.xml配置依赖

在这里插入图片描述


在application.yml中添加配置

在这里插入图片描述


technology是数据库的名字
需要在MongoDB中添加数据库名字
我用的是Navicat 远程连接MongoDB，添加数据库名称

在这里插入图片描述


现在需要些相关的代码
我这边些了一个日志模块拿来
实体类：
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;

import java.io.Serializable;
import java.util.Map;

@Data
public class DataCenterLog implements Serializable {

@Id
private String id;//id

private int user_id;//用户id

private String request_url;//请求地址

private String params;//传入参数

private String request_method;//请求方法

private String create_date;//新建时间

private String operation;//操作

private String content;//内容

private String ip_address;//ip

private String name;//用户名

private String role_name;//角色

private String returned_content;//返回值

private String exception_name;//异常名

private String exception_msg;//异常内容

/**
 * 设置请求参数
 * @param paramMap
 */
public void setMapToParams(Map<String, String[]> paramMap) {
    if (paramMap == null){
        return;
    }
    StringBuilder params = new StringBuilder();
    for (Map.Entry<String, String[]> param : ((Map<String, String[]>)paramMap).entrySet()){
        params.append(("".equals(params.toString()) ? "" : "&") + param.getKey() + "=");
        String paramValue = (param.getValue() != null && param.getValue().length > 0 ? param.getValue()[0] : "");

// params.append(StringUtils.abbr(StringUtils.endsWithIgnoreCase(param.getKey(), “password”) ? “” : paramValue, 100));
}
this.params = params.toString();
}

}

接口：

public interface SysLogService {

boolean add(DataCenterLog syslog);

}

实现类：需要添加 private MongoTemplate mongoTemplate;

import io.terminus.boot.rpc.common.annotation.RpcProvider;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Service;

@Service
@RpcProvider
public class SysLogServiceImpl implements SysLogService {

@Autowired
private MongoTemplate mongoTemplate;

public boolean add(DataCenterLog syslog) {
    mongoTemplate.insert(syslog);
    return true;
}

}

调用接口：

import io.terminus.boot.rpc.common.annotation.RpcConsumer;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import java.net.InetAddress;
import java.text.SimpleDateFormat;
import java.util.Arrays;
import java.util.Date;

@Aspect
@Component
public class WebLogAspect {

private final Logger logger = LoggerFactory.getLogger(WebLogAspect.class);

@RpcConsumer
SysLogService sysLogService;

@Pointcut("execution(* com.yankuang.*..*Controller.*(..))")
public void webLog() {
}

@Pointcut("execution( * com.yankuang.*..*Controller.*(..)) && !execution(* com.yankuang.*..*.add*(..)) && !execution(* com.yankuang.*..*.update*(..)) " +
        "&& !execution(* com.yankuang.*..*.delete*(..)) && !execution(* com.yankuang.*..*.find*(..))")
public void sysLog() {
}

/**
 * 添加业务逻辑方法切入点
 */
@Pointcut("execution(* com.yankuang.*..*.add*(..)) ")
public void insertCell() {
}

/**
 * 修改业务逻辑方法切入点
 */
@Pointcut("execution(* com.yankuang.*..*.update*(..)) ")
public void updateCell() {
}

/**
 * 删除业务逻辑方法切入点
 */
@Pointcut("execution(* com.yankuang.*..*.delete*(..)) ")
public void deleteCell() {
}

/**
 * 查询业务逻辑方法切入点
 */
@Pointcut("execution(* com.yankuang.*..*.find*(..)) ")
public void findCell() {
}

/**
 * 拦截异常处理
 */
@Pointcut("execution(* com.yankuang.*..restful.*Controller(..))") //切点
public void webExceptionLog() {
}


@Before("webLog()")
public void doBefore(JoinPoint joinPoint) throws Throwable {
    // 接收到请求，记录请求内容
    ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
    HttpServletRequest request = attributes.getRequest();

    // 记录下请求内容
    logger.info("访问地址 : " + request.getRequestURL().toString());// 访问地址
    logger.info("请求方式 : " + request.getMethod());// 请求方式
    logger.info("访问IP : " + InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
    logger.info("执行了" + joinPoint.getTarget().getClass().getName() + "类的" + joinPoint.getSignature().getName() + "方法");// 获取哪个类哪个方法
    logger.info("传入参数 : " + Arrays.toString(joinPoint.getArgs()));//获取传入目标方法的参数对象
    logger.info("请求token : " + request.getHeader("token"));// 请求token
}

/**
 * 除增删改查（add,delete,update,find）之外的操作日志(后置通知)
 *
 * @param joinPoint
 * @param object
 */
@AfterReturning(returning = "object", pointcut = "sysLog()")
public void sysLog(JoinPoint joinPoint, Object object) throws Throwable {
    // 判断参数
    if (joinPoint.getArgs() == null) {// 没有参数
        return;
    }
    DataCenterLog syslog = new DataCenterLog();
    syslog.setContent(opContent(joinPoint));
    syslog.setCreate_date(DateUtils());
    syslog.setIp_address(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));

    syslog.setReturned_content("返回内容为：" + object);
    sysLogService.add(syslog);
}

/**
 * 添加操作日志(后置通知)
 *
 * @param joinPoint
 * @param object
 */
@AfterReturning(returning = "object", pointcut = "insertCell()")
public void insertLog(JoinPoint joinPoint, Object object) throws Throwable {
    // 判断参数
    if (joinPoint.getArgs() == null) {// 没有参数
        return;
    }
    DataCenterLog syslog = new DataCenterLog();
    syslog.setContent(opContent(joinPoint));
    syslog.setCreate_date(DateUtils());
    syslog.setOperation("添加");
    syslog.setIp_address(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
    //JSONObject json = JSONObject.fromObject(object);//将java对象转换为json对象
    syslog.setReturned_content("返回内容为：" + object);
    sysLogService.add(syslog);
}

/**
 * 管理员删除操作日志(后置通知)
 *
 * @param joinPoint
 * @param object
 * @throws Throwable
 */
@AfterReturning(value = "deleteCell()", returning = "object")
public void deleteLog(JoinPoint joinPoint, Object object) throws Throwable {
    // 判断参数
    if (joinPoint.getArgs() == null) {// 没有参数
        return;
    }
    // 创建日志对象
    DataCenterLog syslog = new DataCenterLog();
    syslog.setContent(opContent(joinPoint));
    syslog.setCreate_date(DateUtils());
    syslog.setOperation("删除");
    syslog.setIp_address(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));

    syslog.setReturned_content("返回内容为：" + object);
    sysLogService.add(syslog);
}

/**
 * 管理员修改操作日志(后置通知)
 *
 * @param joinPoint
 * @param object
 * @throws Throwable
 */
@AfterReturning(value = "updateCell()", returning = "object")
public void updateLog(JoinPoint joinPoint, Object object) throws Throwable {
    // 判断参数
    if (joinPoint.getArgs() == null) {// 没有参数
        return;
    }
    // 创建日志对象
    DataCenterLog syslog = new DataCenterLog();
    syslog.setContent(opContent(joinPoint));
    syslog.setCreate_date(DateUtils());
    syslog.setOperation("修改");
    syslog.setIp_address(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
    //JSONObject json = JSONObject.fromObject(object);//将java对象转换为json对象
    syslog.setReturned_content("返回内容为：" + object);
    sysLogService.add(syslog);
}


/**
 * 管理员查找操作日志(后置通知)
 *
 * @param joinPoint
 * @param object
 * @throws Throwable
 */
@AfterReturning(value = "findCell()", returning = "object")
public void findLog(JoinPoint joinPoint, Object object) throws Throwable {
    // 判断参数
    if (joinPoint.getArgs() == null) {// 没有参数
        return;
    }
    // 创建日志对象
    DataCenterLog syslog = new DataCenterLog();
    syslog.setContent(opContent(joinPoint));
    syslog.setCreate_date(DateUtils());
    syslog.setOperation("查询");
    syslog.setIp_address(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
    //JSONObject json = JSONObject.fromObject(object);//将java对象转换为json对象
    syslog.setReturned_content("返回内容为：" + object);
    sysLogService.add(syslog);
}

/**
 * 异常通知 用于拦截异常日志
 *
 * @param joinPoint
 * @param e
 */
@AfterThrowing(pointcut = "webExceptionLog()", throwing = "e")
public void doAfterThrowing(JoinPoint joinPoint, Throwable e) {
    HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
    HttpSession session = request.getSession();
    //获取请求ip
    String ip = request.getRemoteAddr();
    //获取用户请求方法的参数并序列化为JSON格式字符串
    try {

        // 创建日志对象
        DataCenterLog syslog = new DataCenterLog();
        syslog.setContent(opContent(joinPoint));
        syslog.setCreate_date(DateUtils());
        syslog.setIp_address(InetAddress.getLocalHost().toString().substring(InetAddress.getLocalHost().toString().lastIndexOf("/") + 1));
        syslog.setException_name(e.getClass().getName());
        syslog.setException_msg(e.getMessage());
        //保存数据库
        sysLogService.add(syslog);
    } catch (Exception ex) {
        //记录本地异常日志
        e.printStackTrace();
    }
}

/**
 * 获取执行的操作的信息
 *
 * @param joinPoint
 * @return
 */
public String opContent(JoinPoint joinPoint) {
    //获取类名
    String className = joinPoint.getTarget().getClass().getName();
    //获取方法名
    String methodName = joinPoint.getSignature().getName();
    String str = "执行了" + className + "类的" + methodName + "方法";
    return str;
}

public String DateUtils() {
    Date d = new Date();
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    String dateNowStr = sdf.format(d);
    return dateNowStr;
}

}

postman调用接口进行测试
写一个测试类：

在这里插入图片描述


执行后控制台会出现log日志

在这里插入图片描述


随之，查看Navicat 相应的数据库中会多个一个表，就是刚刚创建的实体类的名字

在这里插入图片描述


将数据已经添加到了表里：

在这里插入图片描述


结束！

原文地址：https://blog.csdn.net/qq_37833810/article/details/86624183

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

mongodb-gridfs下载文件报Sort exceeded memory limit of 104857600 bytes异常
文章浏览阅读552次。com.mongodb.MongoQueryException: Query failed with error code 292 and error message 'Executor error during find command :: caused by :: Sort exceeded memory limit of 104857600 bytes, but did not opt in to external sorting.' on server 11.51.141.63:27017 _mongodb 大文件 下载失败
数据库_mongoDB
文章浏览阅读635次，点赞9次，收藏8次。MongoDB 是一种 NoSQL 数据库，它将每个数据存储为一个文档，这里的文档类似于 JSON/BSON 对象，具体数据结构由键值（key/value）对组成。
MongoDB的日期类型
文章浏览阅读2.1k次。和。_mongodb 日期类型
MongoDB Atlas Vector Search与Amazon Bedrock集成，推动在AWS上构建下一代应用程序
文章浏览阅读1.7k次。Scalestack等客户期待使用MongoDB Atlas Vector Search和Amazon Bedrock构建下一代应用程序
SpringBoot--中间件技术-3：整合mongodb，整合ElasticSearch，附案例含代码(简单易懂)
文章浏览阅读970次。SpringBoot整合中间件mongodb、ES_springboot3 elasticsearch json数据
尚医通 (二十二) --------- MongoDB 简介
文章浏览阅读673次。MongoDB 简介_尚医通sql
Linux中安装MongoDB与使用C#连接Mongo相关经验记录与总结
文章浏览阅读1k次，点赞8次，收藏9次。官网下载MongoDB安装包后进行解压（因了解并不深入，故暂不进行详细说明，自行查找其他安装方法，后期了解深入后将进行该教程的完善）在bin目录下使用命令启动：./mongod --config …/mongodb.conf。该文章任然处于完善中，如果存在错误遗漏的地方，欢迎私信联系。安装相关的nuget包后即可通过以下方法连接数据。YX9010_0@的第二十篇文章。
足够详细的MongoDB教程(1)
文章浏览阅读1.2k次，点赞17次，收藏26次。社交场景, 使用 MongoDB 存储存储用户信息, 以及用户发表的朋友圈信息, 通过地理位置索引实现附近的人, 地点等功能.游戏场景, 使用 MongoDB 存储游戏用户信息, 用户的装备, 积分等直接以内嵌文档的形式存储, 方便查询, 高效率存储和访问.物流场景, 使用 MongoDB 存储订单信息, 订单状态在运送过程中会不断更新, 以 MongoDB 内嵌数组的形式来存储, 一次查询就能将订单所有的变更读取出来.物联网场景, 使用 MongoDB 存储所有接入的智能设备信息, 以及设备汇报的日
【Python语言基础】——Python MongoDB 更新
文章浏览阅读686次。您可以使用 update_one() 方法来更新 MongoDB 中调用的记录或文档。update_one() 方法的第一个参数是 query 对象，用于定义要更新的文档。注释：如果查询找到多个记录，则仅更新第一个匹配项。第二个参数是定义文档新值的对象。_python 更新 mongodb 数据
MONGODB 的基础 NOSQL注入基础
文章浏览阅读1.3k次。首先来学习一下nosql这里安装就不进行介绍 只记录一下让自己了解mongodb。_nosql注入
MongoDB（Windows版）安装
文章浏览阅读4.1k次，点赞8次，收藏7次。在data的目录下，创建一个db文件。因为启动MongoDB服务之前必须创建数据库文件的存放文件夹，否则命令不会自动创建，而且不能启动成功。第一步：安装时，Custom是指可以自定义安装路径，然后傻瓜式安装即可（注意：先不要安装图形化工具，否则安装时间会特别长）：如果要想连接成功，必须要开服务，即mongod -dbpath C:MongoDBdatadb的cmd要一直开着。然后回车，ctrl+F输入port找到端口号，一般为：27017。打开命令行，然后找到bin文件地址，并输入。_mongodb windows安装
【数据库】MongoDB数据库详解
文章浏览阅读5.1k次，点赞3次，收藏43次。详细介绍MongoDB数据库的基本知识，安装方法，基本操作，_mongodb数据库
navicat 连接远程mongodb数据库
文章浏览阅读3.2k次。安装教程翻看以往文章。_navicat 连接mongodb
【已解决】mongodb远程连接不上
文章浏览阅读426次，点赞9次，收藏12次。win10开放端口：https://blog.csdn.net/m0_43605481/article/details/119255256。我的是阿里云服务器，所以直接在安全组中加入规则，端口范围：27017，授权对象：0.0.0.0。windows在mongodb安装文件夹的bin文件夹中的mongod.cfg。数据库名字是test，打算创建一个用户，账号aaa，密码bbb，权限readWrite。因为该用户是创建在test数据库的，所以在最后要加上test。O了，然后恢复了test的数据。
【详细教程】一文参透 MongoDB 聚合查询
文章浏览阅读1.1k次。聚合操作主要用于处理数据并返回计算结果。聚合操作将来自多个文档的值组合在一起，按条件分组后，再进行一系列操作（如求和、平均值、最大值、最小值）以返回单个结果。MongoDB的聚合查询​聚合是MongoDB的高级查询语言，它允许我们通过转化合并由多个文档的数据来生成新的在单个文档里不存在的文档信息。MongoDB中聚合(aggregate)主要用于处理数据（例如分组统计平均值、求和、最大值等），并返回计算后的数据结果，有点类似sql语句中的count(*)、groupby。..._如何将几个db的数据统整在一起做查询
springboot mongodb简单教程
文章浏览阅读680次，点赞7次，收藏8次。（2）application.properties配置文件。（4）UserService类。（5）测试和测试结果。
Studio 3T 2023.9 发布 - MongoDB 的专业 GUI、IDE 和 客户端，支持自然语言查询
文章浏览阅读1k次，点赞17次，收藏25次。Studio 3T 2023.9 (macOS, Linux, Windows) - MongoDB 的专业 GUI、IDE 和 客户端，支持自然语言查询_mongodb客户端
探寻MongoDB的世界：面试前必知的关键要点与深度洞察
文章浏览阅读1.1k次，点赞32次，收藏27次。插件式的存储引擎架构可以实现 Server 层和存储引擎层的解耦，可以支持多种存储引擎，如 MySQL 既可以支持 B-Tree 结构的 InnoDB 存储引擎，还可以支持 LSM 结构的 RocksDB 存储引擎。MongoDB 中的记录就是一个 BSON 文档，它是由键值对组成的数据结构，类似于 JSON 对象，是 MongoDB 中的基本数据单元。的简称，是 JSON 文档的二进制表示，支持将文档和数组嵌入到其他文档和数组中，还包含允许表示不属于 JSON 规范的数据类型的扩展。
基于STM32的多功能温控风扇设计
文章浏览阅读5.1k次，点赞6次，收藏96次。本文设计了一种基于智能室内温度控制的自动调速风扇。以STM32系列单片机为核心主控板，通过程序代码驱动和使用温度传感器模块实现对环境温度的实时监测，并可以实时显示环境温度。同时，可以设置温度检测的上下警告值，根据需求自行调节。_stm32 温控风扇
深入了解 Python MongoDB 查询：find 和 find_one 方法完全解析
文章浏览阅读898次，点赞13次，收藏21次。在MongoDB中，我们使用find()和find_one()方法来在集合中查找数据，就像在MySQL数据库中使用SELECT语句来在表中查找数据一样。_pymongo find_one
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot