java使用原生语句操作mongo_Java 中 MongoDB 使用指南

MongoDB是当今非常流行的一款NoSQL数据库,本文介绍如何使用MongoDB的Java驱动来操作MongoDB。

3fc2a6cd38d3dddd9e36645af4ece813.png

一、引入MongoDB Java Driver包

如果需要操作MongoDB的Java项目是一个Maven项目,可以在依赖中加上以下的配置。

<dependencies><dependency><groupId>org.mongodb</groupId><artifactId>mongo-java-driver</artifactId><version>2.13.2</version></dependency>
</dependencies>

或者通过直接下载jar包的方式使用,下载地址:mongo-java-driver-2.13.2.jar。

详细的如何引入MongoDB jar包的方法可以参考官方文档。

二、连接MongoDB

可以使用MongoClient来连接MongoDB,MongoClient的使用方式如下:

MongoClient mongoClient = new MongoClient("localhost", 27017);
DB db = mongoClient.getDB("mydb");

上面的代码连接了localhost:27017上MongoDB服务,并指定使用mydb数据库。连接后便可以对这个数据库作进一步的操作。

需要指出的是,MongoClient是线程安全的,可以在多程程环境中共享同一个MongoClient。通常来说,一个应用程序中,只需要生成一个全局的MongoClient实例,然后在程序的其他地方使用这个实例即可。

三、认证

可以使用多种方式对连接进行认证,下面介绍两种方式。

1. 方式一:MongoCredential

MongoCredential类的createCredential方法可以指定认证的用户名,密码,以及使用的数据库,并返回一个MongoCredential对象。其方法的声明如下:

static MongoCredential createCredential(String userName, String database, char[] password)

例如

MongoCredential credential = MongoCredential.createCredential("user", "mydb", "password".toCharArray();

上面创建了一个用户名为user,密码为password,数据库为mydb的MongoCredential对象。

将生成MongoCredential的对象作为MongoClient构造函数的参数。由于MongoClient构造函数的为List<MongoCredential>类型,所以需要先构造成一个List再传递。完整的认证的例子如下:

MongoCredential credential = MongoCredential.createCredential("user", "mydb", "password".toCharArray()); 
ServerAddress serverAddress = new ServerAddress("localhost", 27017); 
MongoClient mongoClient = new MongoClient(serverAddress, Arrays.asList(credential)); 
DB db = mongoClient.getDB("mydb");

2. 方式二:MongoClientURI

亦可以使用MongoClientURI完成MongoDB的认证,它代表了一个URI对象。MongoClientURI的构造函数接受一个String类型的字符串,这个字符串的格式如下:

mongodb://[username:password@]host1[:port1][,host2[:port2],…[,hostN[:portN]]][/[database][?options]]

生成的MongoClientURI对象作为MongoClient构造函数的参数,完整的认证例子如下:

String sURI = String.format("mongodb://%s:%s@%s:%d/%s", "user", "password", "localhost", 27017, "mydb"); 
MongoClientURI uri = new MongoClientURI(sURI); 
MongoClient mongoClient = new MongoClient(uri); 
DB db = mongoClient.getDB("mydb");

四、获取一个集合

DBCollection coll = db.getCollection("mycol");

然后可以对指定的集合进行操作,例如,插入,删除,查找,更新文档等。

五、插入文档

例如,一个文档以Json来表示如下,

{ “name”: “mongo”, “info”: { “ver”: “3.0” } }

现在需要插入到集合mycol中。为了插入到集合中,可以使用BasicDBObject构造一个文档。

BasicDBObject doc = new BasicDBObject("name", "mongo").append("info", new BasicDBObject("ver", "3.0"));
coll.insert(doc);

六、查找文档

1. 通过findOne查找一个符合条件文档

通过findOne可以查找一个符合条件的文档。例如,对于上面的mycol集合,执行以下命令:

DBObject myDoc = coll.findOne();
System.out.println(myDoc);

将输出mycol集合中的第一个文档。也可以通过指定findOne的查找参数,来查找符合查找条件的一个文档。

2. 通过find查找所有符合条件的文档

find用来查找符合条件的文档,它返回一个DBCursor对象,通过遍历DBCursor对象,可以获得所有符合查找条件的文档。
为了说明和测试,我们先插入一批以下格式的文档

{ “i”: value }
for (int i=0; i < 100; i++) {coll.insert(new BasicDBObject("i", i));
}

find的使用示例如下:

DBCursor cursor = coll.find();
try {while(cursor.hasNext()) {System.out.println(cursor.next());}
} finally {cursor.close();
}

会输出mycol集合中所有的文档。

也可以指定查找的条件,例如:

BasicDBObject query = new BasicDBObject("i", 71);DBCursor cursor = coll.find(query);try {while(cursor.hasNext()) {System.out.println(cursor.next());}
} finally {cursor.close();
}

对于查找条件中包括$操作符的情形,例如以下一条mongo shell命令:

db.coll.find({i: {$gte: 50}});

可以使用DBObject生成查找条件,

// find all where i >= 50
BasicDBObject query = new BasicDBObject("i", new BasicDBObject("$gte", 50));DBCursor cursor = coll.find(query);
try {while (cursor.hasNext()) {System.out.println(cursor.next());}
} finally {cursor.close();
}

七、更新文档

BasicDBObject query = new BasicDBObject("i", 70);
BasicDBObject up = new BasicDBObject("$set", new BasicDBObject("i", 100));
coll.update(query, up);

上面的语句将i为70的文档更新i的值等于100。

与我们常用的更新文档的mongo语句一样,DBCollection还包含了savefindAndModify等更新文档的方法,其使用方法在此不再赘述,可以参考API说明文档即可。

八、删除文档

可以通过生成一个DBObject对象来删除指定的文档,例如:

BasicDBObject query = new BasicDBObject("i", 71);
coll.remove(query);

上面的语句删除i为71的文档。

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

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

相关文章

LeetCode 1863. 找出所有子集的异或总和再求和(DFS)

文章目录1. 题目2. 解题1. 题目 一个数组的 异或总和 定义为数组中所有元素按位 XOR 的结果&#xff1b;如果数组为 空 &#xff0c;则异或总和为 0 。 例如&#xff0c;数组 [2,5,6] 的 异或总和 为 2 XOR 5 XOR 6 1 。 给你一个数组 nums &#xff0c;请你求出 nums 中每个…

【Python基础知识-pycharm版】第六节-控制语句

第六节 控制语句选择结构多分支选择结构选择结构的嵌套循环结构while循环for循环和可迭代对象遍历range 对象嵌套循环breakcontinueelse语句循环代码优化使用zip推导式创建序列列表推导式字典推导式集合推导式生成器推导式综合练习绘制不同颜色的多个同心圆选择结构 选择结构通…

天池 在线编程 回文子串(区间动态规划)

文章目录1. 题目2. 解题1. 题目 描述 小明喜欢玩文字游戏&#xff0c;今天他希望在一个字符串的子串中找到回文串。 回文串是从左往右和从右往左读相同的字符串&#xff0c;例如121和tacocat。子串是一个字符串中任意几个连续的字符构成的字符串。 现在给你一个字符串s, 求…

【Python基础知识-pycharm版】第七节-函数

函数函数函数定义与调用形参和实参变量的作用域&#xff08;全局变量和局部变量&#xff09;局部变量和全局变量的测试参数的传递参数的几种类型位置参数默认值参数命名参数可变参数强制命名参数lambda表达式和匿名函数eval()函数用法递归函数_函数调用内存分析_栈帧的创建嵌套…

天池 在线编程 停车困境(双指针)

文章目录1. 题目2. 解题1. 题目 描述 停车场里停着许多汽车。 停车位是一条很长的直线&#xff0c;每米都有一个停车位。 当前很多汽车停放&#xff0c;您想通过建造屋顶来遮雨挡雨。 要求至少有k辆车的车顶被车顶遮盖&#xff0c;要覆盖k辆车的车顶的最小长度是多少&#xff…

《maven实战》笔记(2)----一个简单maven项目的搭建,测试和打包

参照《maven实战》在本地创建对应的基本项目helloworld&#xff0c;在本地完成后项目结构如下&#xff1a; 可以看到maven项目的骨架&#xff1a;src/main/java&#xff08;javaz主代码&#xff09;src/test/java&#xff08;测试代码&#xff09;src/main/resuources&#xff…

【Python基础知识-pycharm版】第八节-面向对象编程/类

面向对象编程面向对象和面向过程的区别_执行者思维_设计者思维类的定义构造函数__init__实例属性_内存分析实例方法_内存分析类对象类属性_内存分析创建类和对象的底层类方法_静态方法_内存分析图示__del__()析构方法和垃圾回收机制__call__()方法和可调用对象面向对象和面向过…

天池 在线编程 推荐朋友(哈希)

文章目录1. 题目2. 解题1. 题目 描述 给n个人的朋友名单&#xff0c;告诉你user是谁&#xff0c;请找出user最可能认识的人。&#xff08;他和user有最多的共同好友且他不是user的朋友&#xff09; n < 500。 好友关系是相互的。&#xff08;b若出现在a的好友名单中&#…

mr图像翻转的原因_MR的特殊检查脂肪抑制

让学习成为一种好习惯正文开始脂肪抑制脂肪抑制是指在MR成像中通过调整采集参数而选择性的抑制脂肪信号&#xff0c;使其失去高信号变为低信号&#xff0c;以区分同样为高信号的不同结构&#xff0c;在临床诊断上具有重要的意义&#xff0c;主要表现在&#xff1a;(1)减少运动伪…

Qt 图形特效(Graphics Effect)介绍

原文链接:Qt 图形特效(Graphics Effect)介绍 QGraphicsEffect也是Qt-4.6引入的一个新功能。它让给图形元素QGraphicsItem增加更佳视觉效果的编程变得非常简单。 先来看几张效果图。 上图中最上面的那个图片是没有使用QGraphicsEffect处理的原图&#xff0c;下面的四个图片分别代…

小米usb3.0修复补丁_今日热闻 | Redmi 10X系列发布、小米手环5产品外观曝光、Win10补丁导致蓝屏、AXON 11 SE 6月发布...

今日热点新闻realme X50 Pro 玩家版发布realme 通过线上发布会推出包括真我 X50 Pro 玩家版在内的 8 款新品。其中真我 X50 Pro 玩家版搭载高通骁龙 865 移动平台、6.44 寸 90Hz 刷新率 AMOLED 屏幕和 1216 超线性双扬声器&#xff0c;配备 VC 液冷散热、线性马达和 4200mAh 电…

【Python基础知识-pycharm版】第九节_面向对象的三大特征

第九节方法方法没有重载私有属性和私有方法&#xff08;实现封装&#xff09;property装饰器_get和set方法面向对象的三大特征说明(封装、继承、多态)继承方法的重写&#xff08;类成员的继承和重写&#xff09;查看类的继承结构object根类_dir() 查看对象属性重写__str__()方法…

LeetCode 1869. 哪种连续子字符串更长

文章目录1. 题目2. 解题1. 题目 给你一个二进制字符串 s 。如果字符串中由 1 组成的 最长 连续子字符串 严格长于 由 0 组成的 最长 连续子字符串&#xff0c;返回 true &#xff1b;否则&#xff0c;返回 false 。 例如&#xff0c;s "110100010" 中&#xff0c;…

如何通过像素点找到世界坐标_如何通过阅读来找到自己理论研究的“视域”?...

理论研究多用演绎法&#xff0c;也就是说&#xff0c;理论研究一般始于一个独特的概念、理论视角&#xff0c;或者判断。用刘良华的观点来说&#xff0c;这些都是理论研究的“视域”&#xff0c;也是理论研究得以展开的“大前提”。因此&#xff0c;理论研究最为关键的问题&…

任务并行VS数据并行

并行计算中&#xff0c;有两种并行的方法&#xff1a;任务并行&#xff08;task-parallelism&#xff09;和数据并行&#xff08;data-parallelism&#xff09;。任务并行&#xff1a;将许多可以解决问题的任务分割&#xff0c;然后分布在一个或者多个核上进行程序的执行。数据…

【Python基础知识-pycharm版】第十节_异常

第十节异常异常机制本质异常解决的关键&#xff1a;定位try... 一个 except 结构try... 多个 except 结构try...except...else 结 构try...except...finally 结构return 语句和异常处理问题常见异常的解决常见异常汇总with 上下文管理trackback 模块自定义异常类异常 在实际工…

k8s挂载目录_拥抱云原生,如何将开源项目用k8s部署?

k8s以及云原生相关概念近年来一直比较火热&#xff0c;阿丸最近搞了个相关项目&#xff0c;小结一下。本文将重点分享阿里开源项目otter适配k8s部署的改造过程&#xff0c;其中的改造过程和技巧应该适用于将大多数开源项目改造到k8s进行部署。1.背景otter是阿里开源的分布式数据…

LeetCode 1870. 准时到达的列车最小时速(二分查找)

文章目录1. 题目2. 解题2.1 模拟超时2.2 二分查找1. 题目 给你一个浮点数 hour &#xff0c;表示你到达办公室可用的总通勤时间。 要到达办公室&#xff0c;你必须按给定次序乘坐 n 趟列车。 另给你一个长度为 n 的整数数组 dist &#xff0c;其中 dist[i] 表示第 i 趟列车的行…

【Python基础知识-pycharm版】第十一节-文件操作(IO技术)

第十一节-文件操作&#xff08;IO技术&#xff09;文本文件和二进制文件文件操作相关模块概述创建文件对象 open()文本文件的写入基本的文件写入操作常用编码介绍ASCIIISO8859-1GB2312,GBK,GB18030中文乱码问题write()/writelines()写入数据close()关闭文件流with 语句(上下文管…

LeetCode 1871. 跳跃游戏 VII(贪心)

文章目录1. 题目2. 解题1. 题目 给你一个下标从 0 开始的二进制字符串 s 和两个整数 minJump 和 maxJump 。 一开始&#xff0c;你在下标 0 处&#xff0c;且该位置的值一定为 0 。 当同时满足如下条件时&#xff0c;你可以从下标 i 移动到下标 j 处&#xff1a; i minJump …