springboot整合mongodb批量修改和添加索引,与设置mongodb保存更新超时时间

1:创建字段索引

collection 是集合名称,keys 是一个包含一个或多个字段名,options是排序方向,1正序,-1倒叙

db.collection.createIndex(keys, options)
#单字段
db.collection.createIndex(name: 1)
#多字段
db.collection.createIndex{name: 1, age: -1}

2:mongodb批量修改

BulkOperations bulkOperations = mongoTemplate.bulkOps(BulkMode.UNORDERED, RealtimeEntity.class);updateList.forEach(realtimeEntity -> {Query query = new Query(Criteria.where("pn").is(realtimeEntity.getPn()));Update update = new Update().set("pnVal", realtimeEntity.getPnVal()).set("tm", realtimeEntity.getTm()).set("rm", realtimeEntity.getRm());bulkOperations.updateOne(query, update);
});
bulkOperations.execute();

注意:必须创建索引这样更新的效率快

3:mongodb保存的时候最好设置一个保存超时时间,因为mongodb本身没有设置保存或者更新超时抛出异常

	public void saveWithTimeout(Object objectToSave, String collectionName) {CompletableFuture<Void> completableFuture = new CompletableFuture<>();mongoTemplate.insert(objectToSave, collectionName).addCallback(result -> completableFuture.complete(null),ex -> completableFuture.completeExceptionally(ex));try {completableFuture.get(10, TimeUnit.SECONDS);} catch (TimeoutException e) {// 超时处理逻辑,例如抛出异常或记录日志throw new RuntimeException("保存超时");} catch (InterruptedException | ExecutionException e) {// 异常处理逻辑throw new RuntimeException("保存失败:" + e.getMessage());}}

4:在Spring Boot中,你可以通过在application.yml或application.properties文件中设置相关属性来配置MongoDB的保存和更新操作的超时时间。

下面是在application.yml文件中配置MongoDB超时时间的示例:

spring:data:mongodb:write-concern:w: majoritywtimeout: 10000

在上述示例中,w: majority表示写操作需要大多数节点确认,wtimeout: 10000表示写操作的超时时间为10秒。

如果你只想设置保存操作的超时时间,可以使用以下配置:

spring:data:mongodb:write-concern:wtimeout: 10000

同样地,如果你只想设置更新操作的超时时间,可以使用以下配置:

spring:data:mongodb:update-timeout: 10000

请根据你的具体需求选择合适的配置方式,并根据实际情况调整超时时间。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/601989.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Flink的检查点算法

Flink的恢复机制基于应用状态的一致检查点。在有状态的流应用中&#xff0c;一个一致性检查点是&#xff1a;在所有tasks处理了一个&#xff08;相同的&#xff09;输入后&#xff0c;当前时间点每个task的state副本。 在为application做一个一致性检查点时&#xff0c;一个基…

PDF.js实现搜索多个不同的关键词高亮显示效果

static\PDF\web\viewer.js 392行左右 // 自定义搜索关键词---------------------------------------- this.searchKeywords = keyword => {if (typeof PDFViewerApplication !== undefined) {PDFViewerApplication.eventBus.dispatch(find, {query: keyword,caseSensitive:…

代码随想录算法训练DAY22|二叉树8

算法训练DAY22|二叉树8 235. 二叉搜索树的最近公共祖先 力扣题目链接(opens new window) 给定一个二叉搜索树, 找到该树中两个指定节点的最近公共祖先。 百度百科中最近公共祖先的定义为&#xff1a;“对于有根树 T 的两个结点 p、q&#xff0c;最近公共祖先表示为一个结点…

PEFT: 在低资源硬件上对十亿规模模型进行参数高效微调

1 引言 最近&#xff0c;深度学习的研究中出现了许多大型预训练模型&#xff0c;例如 GPT-3、BERT 等&#xff0c;这些模型可以在多种自然语言处理任务中取得优异的性能表现。而其中&#xff0c;ChatGPT 模型因为在对话生成方面的表现而备受瞩目&#xff0c;成为了自然语言处理…

sublime text 3 分屏和关闭分屏

有时候需要编辑多个地方的代码&#xff0c;开多个编辑器又太麻烦&#xff0c;那么Sublime自带的分屏快捷键可以解决烦恼。 Altshift2 分为2列 Altshift3 分为3列 Altshift4 分为4列 Altshift5 分为2行2列 Altshift8 分为2行 Altshift9 分为3行 取消分屏&#xff1a;Alts…

Linux系统报错锦集二: engine libaio not loadable

OS&#xff1a;RedHat 9.1 场景&#xff1a;fio 测试 背景&#xff1a;初次使用fio进行IO性能测试&#xff0c;但RedHat不能直接yum安装fio&#xff0c;故github上下载了fio的源码包&#xff0c;configure、make、make install 编译安装。 fio多线程需要libaio引擎&#xff…

基于多反应堆的高并发服务器【C/C++/Reactor】(中)创建一个TcpConnection实例 以及 接收客户端数据

#CSDN 年度征文&#xff5c;回顾 2023&#xff0c;赢专属铭牌等定制奖品# 一、主线程反应堆模型的事件添加和处理详解 >>服务器和客户端建立连接和通信流程&#xff1a; 基于多反应堆模型的服务器结构图&#xff0c;这主要是一个TcpServer&#xff0c;关于HttpServer,…

分布式协调系统

分布式协调系统 分布式协调系统解决的进程间的通信和协作&#xff0c;根据是否在同一时间和是否相互引用分为四个模型。 示例系统Chubby 主功能&#xff1a;让客户端实现同步&#xff0c;方法是加锁服务 介绍一下系统&#xff1a; 系统由五台服务器构成&#xff0c;通过pax…

智慧地球(AI•Earth)社区成立一周年啦!独家福利与惊喜彩蛋等你来拿!

原文&#xff1a;智慧地球&#xff08;AI•Earth&#xff09;社区成立一周年啦&#xff01; 智慧地球社区 一周年庆典&#x1f38a; 独家福利&#x1f381;与惊喜彩蛋&#x1f389;等你来拿&#xff01; 智慧地球&#xff08;AI•Earth&#xff09;社区自2023年1月11日建立以…

app store里面的构建版本在线上传

开发苹果ios应用&#xff0c;无论是用原生开发、用hbuilderx开发还是用其他h5框架开发的app&#xff0c;都需要将打包好的ipa文件上传到app store。 在上架app store的过程中&#xff0c;我们会遇到下图的这样一个问题&#xff1a; 就是它要求我们上传一个构建版本&#xff0c…

如何保障开放网络边界安全?

针对开放式网络&#xff08;办事大厅、视频网络等&#xff09;&#xff0c;如何在内部网络构建起一道安全屏障&#xff0c;有效解决广大用户普遍存在的无法保证网络边界完整、边界安全、公共场所终端摄像头管理、办事大厅智能设备&#xff08;一体机等&#xff09;管理、开放场…

【C语言】Linux实现高并发处理的过程

一、实现高并发的几种策略 C语言本身并没有内建的多线程支持&#xff08;新版C语言支持&#xff0c;但用得不多&#xff09;&#xff0c;但是在多数操作系统中&#xff0c;可以使用库来实现多线程编程。例如&#xff0c;在POSIX兼容系统上&#xff0c;可以使用 pthreads 库来创…

django学习:页面渲染与请求和响应

1.请求过程 2.页面渲染 在app中新建一个目录&#xff08;Directory&#xff09;&#xff0c;文件名命名为templates。该文件名命名是固定的&#xff0c;不可命名出错&#xff0c;如若后续步骤出错&#xff0c;该目录文件名是一个检查的重点项目。在该目录下新建一个html文件&a…

探讨一下WebINFO 下的一些思考

在平时的开发中&#xff0c;我们经常看到一个/WEB-INF 这个目录&#xff0c;这个是web 容器初始化加载的一个标准路径。官方解释&#xff1a;WEB-INF 是 Java 的 web 应用的安全目录。所谓安全就是客户端无法访问&#xff0c;只有服务端可以访问的目录。也就是说&#xff0c;这…

MySQL之视图内连接、外连接、子查询

一、视图 1.1 含义 虚拟表&#xff0c;和普通表一样使用 视图&#xff08;view&#xff09;是一个虚拟表&#xff0c;其内容由查询定义。同真实的表一样&#xff0c;视图包含一系列带有名称的列和行数据。但是&#xff0c;数据库中只存放了视图的定义&#xff0c;而并没有存放…

Jmeter二次开发实操问题汇总(JDK问题,jar包问题)

前提 之前写过一篇文章&#xff1a;https://qa-lsq.blog.csdn.net/article/details/119782694 只是简单尝试了一下生成一个随机手机号码。 但是如果在工作中一个实际场景要用的二次开发&#xff0c;可能会遇到一些问题。 比如这样一个场景&#xff1a; Mobile或者前端调用部分…

地理空间分析1——入门Python地理空间分析

写在开头 地理空间分析是一门涉及地球表面数据处理和解释的科学&#xff0c;通过对地理现象的研究&#xff0c;我们可以更深入地了解地球各个角落的关系。Python作为一种功能强大的编程语言&#xff0c;在地理空间分析领域展现了强大的潜力。本文将带您深入了解入门级别的Pyth…

如何评判一款智能酒精壁炉品质是否优秀

在当今家居设计中&#xff0c;智能酒精壁炉作为一种独特的取暖和装饰方式&#xff0c;受到越来越多人的青睐。然而&#xff0c;如何挑选和选择优质的智能酒精壁炉成为了一个重要的话题&#xff0c;下面将深入探讨哪样的智能酒精壁炉才算得上是品质卓越。 优质的智能酒精壁炉通常…

Guarded Suspension模式--适合等待事件处理

Guarded是被守护、被保卫、被保护的意思&#xff0c; Suspension则是暂停的意思。 如果执行现在的处理会造成问题&#xff0c; 就让执行处理的线程进行等待--- 这就是Guarded Suspension模式。 模式通过让线程等待来保证实例的安全性。 一个线程ClientThread会将请求 Request的…

AWS EKS1.26+kubesphere3.4.1

1、前提准备 1台EC2服务器Amazon Linux2&#xff0c;设置admin的角色 安装 aws cli V2 ​ curl "https://awscli.amazonaws.com/awscli-exe-linux-x86_64.zip" -o "awscliv2.zip"unzip awscliv2.zipsudo ./aws/installexport PATH/usr/local/bin:$PATHsou…