java连接mongoDB并进行增删改查操作实例详解
本文实例讲述了java连接mongoDB并进行增删改查操作。分享给大家供大家参考，具体如下：
1、安装 MongoDB JDBC驱动程序
在java中使用mongoDB之前，首先需要拥有java连接mongoDB的第三方驱动包（jar包）
1）maven项目可通过在pom.xml中添加依赖
<dependencies> <dependency> <groupId>org.mongodb</groupId> <artifactId>mongo-java-driver</artifactId> <version>3.0.4</version> </dependency> </dependencies>
2）非maven项目jar包下载地址：
2、连接数据库
将mongoDB JDBC驱动加入到项目之后，就可以对mongoDB进行操作了。
1）不通过认证连接mongoDB服务
//连接到 mongodb 服务
MongoClient mongoClient = new MongoClient("localhost", 27017);
这里的 "localhost" 表示连接的服务器地址，27017 为端口号。可以省略 端口号 不写，系统将默认端口号为 27017。如：
//连接到 mongodb 服务，默认端口号为27017
MongoClient mongoClient = new MongoClient("localhost");
也可以将 服务器地址 和 端口号 都省略，系统默认服务器地址为 "localhost"，端口号为 27017。如：
//连接到 mongodb 服务，默认连接到localhost服务器，端口号为27017 MongoClient mongoClient = new MongoClient();
2）通过认证连接mongoDB服务
List<ServerAddress> adds = new ArrayList<>();
//ServerAddress()两个参数分别为 服务器地址 和 端口
ServerAddress serverAddress = new ServerAddress("localhost", 27017);
adds.add(serverAddress);
List<MongoCredential> credentials = new ArrayList<>();
//MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码
MongoCredential mongoCredential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());
credentials.add(mongoCredential);
//通过连接认证获取MongoDB连接
MongoClient mongoClient = new MongoClient(adds, credentials);
ServerAddress()两个参数 "localhost" ， 27017 分别为 服务器地址 和 端口。
MongoCredential.createScramSha1Credential()三个参数 "username", "databaseName", "password".toCharArray() 分别为 用户名 数据库名称 密码。
3）连接到数据库
//连接到数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("test");
这里的 "test" 表示数据库名，若指定的数据库不存在，mongoDB将会在你第一次插入文档时创建数据库。
4）封装成工具类
由于所有连接数据库操作都需要执行这两步操作，我们可以将这两步操作封装成工具类。
import com.mongodb.MongoClient;
import com.mongodb.client.MongoDatabase;
//mongodb 连接数据库工具类
public class MongoDBUtil {
//不通过认证获取连接数据库对象
public static MongoDatabase getConnect(){
//连接到 mongodb 服务
MongoClient mongoClient = new MongoClient("localhost", 27017);
//连接到数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("test");
//返回连接数据库对象
return mongoDatabase;
}
//需要密码认证方式连接
public static MongoDatabase getConnect2(){
List<ServerAddress> adds = new ArrayList<>();
//ServerAddress()两个参数分别为 服务器地址 和 端口
ServerAddress serverAddress = new ServerAddress("localhost", 27017);
adds.add(serverAddress);
List<MongoCredential> credentials = new ArrayList<>();
//MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码
MongoCredential mongoCredential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());
credentials.add(mongoCredential);
//通过连接认证获取MongoDB连接
MongoClient mongoClient = new MongoClient(adds, credentials);
//连接到数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("test");
//返回连接数据库对象
return mongoDatabase;
}
}
3、对数据库进行CRUD
mongoDB中的数据都是通过文档（对应于关系型数据库表中的一行）保存的，而文档又保存在集合（对应于关系型数据库的表）中。
1）获取集合
要对数据进行CRUD操作首先要获取到操作的集合。
//获取集合
MongoCollection<Document> collection = MongoDBUtil.getConnect().getCollection("user");
这里的 "user" 表示集合的名字，如果指定的集合不存在，mongoDB将会在你第一次插入文档时创建集合。
2）创建文档
要插入文档首先需要创建文档对象
//创建文档
Document document = new Document("name","张三")
.append("sex", "男")
.append("age", 18);
3）插入文档
插入一个文档，使用 MongoCollection 对象的 insertOne() 方法，该方法接收一个 Document 对象作为要插入的数据
//插入一个文档
@Test
public void insertOneTest(){
//获取数据库连接对象
MongoDatabase mongoDatabase = MongoDBUtil.getConnect();
//获取集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
//要插入的数据
Document document = new Document("name","张三")
.append("sex", "男")
.append("age", 18);
//插入一个文档
collection.insertOne(document);
}
插入多个文档，使用 MongoCollection 对象的 insertMany() 方法，该方法接收一个 数据类型为 Document 的 List 对象作为要插入的数据
//插入多个文档
@Test
public void insertManyTest(){
//获取数据库连接对象
MongoDatabase mongoDatabase = MongoDBUtil.getConnect();
//获取集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
//要插入的数据
List<Document> list = new ArrayList<>();
for(int i = 1; i <= 3; i++) {
Document document = new Document("name", "张三")
.append("sex", "男")
.append("age", 18);
list.add(document);
}
//插入多个文档
collection.insertMany(list);
}
4）删除文档
删除与筛选器匹配的单个文档，使用 MongoCollection 对象的 deleteOne() 方法，该方法接收一个数据类型为 Bson 的的对象作为过滤器筛选出需要删除的文档。然后删除第一个。为了便于创建过滤器对象，JDBC驱动程序提供了 Filters 类。
//删除与筛选器匹配的单个文档
@Test
public void deleteOneTest(){
//获取数据库连接对象
MongoDatabase mongoDatabase = MongoDBUtil.getConnect();
//获取集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
//申明删除条件
Bson filter = Filters.eq("age",18);
//删除与筛选器匹配的单个文档
collection.deleteOne(filter);
}
删除与筛选器匹配的所有文档，使用 MongoCollection 对象的 deleteMany() 方法，该方法接收一个数据类型为 Bson 的的对象作为过滤器筛选出需要删除的文档。然后删除所有筛选出的文档。
//删除与筛选器匹配的所有文档
@Test
public void deleteManyTest(){
//获取数据库连接对象
MongoDatabase mongoDatabase = MongoDBUtil.getConnect();
//获取集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
//申明删除条件
Bson filter = Filters.eq("age",18);
//删除与筛选器匹配的所有文档
collection.deleteMany(filter);
}
5）修改文档
修改单个文档，使用 MongoCollection 对象的 updateOne() 方法，该方法接收两个参数，第一个数据类型为 Bson 的过滤器筛选出需要修改的文档，第二个参数数据类型为 Bson 指定如何修改筛选出的文档。然后修改过滤器筛选出的第一个文档。
//修改单个文档
@Test
public void updateOneTest(){
//获取数据库连接对象
MongoDatabase mongoDatabase = MongoDBUtil.getConnect();
//获取集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
//修改过滤器
Bson filter = Filters.eq("name", "张三");
//指定修改的更新文档
Document document = new Document("$set", new Document("age", 100));
//修改单个文档
collection.updateOne(filter, document);
}
修改多个文档，使用 MongoCollection 对象的 updateMany() 方法，该方法接收两个参数，第一个数据类型为 Bson 的过滤器筛选出需要修改的文档，第二个参数数据类型为 Bson 指定如何修改筛选出的文档。然后修改过滤器筛选出的所有文档。
//修改多个文档
@Test
public void updateManyTest(){
//获取数据库连接对象
MongoDatabase mongoDatabase = MongoDBUtil.getConnect();
//获取集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
//修改过滤器
Bson filter = Filters.eq("name", "张三");
//指定修改的更新文档
Document document = new Document("$set", new Document("age", 100));
//修改多个文档
collection.updateMany(filter, document);
}
6）查询文档
使用 MongoCollection 对象的 find() 方法，该方法有多个重载方法，可以使用不带参数的 find() 方法查询集合中的所有文档，也可以通过传递一个 Bson 类型的 过滤器查询符合条件的文档。这几个重载方法均返回一个 FindIterable 类型的对象，可通过该对象遍历出查询到的所有文档。
查找集合中的所有文档
//查找集合中的所有文档
@Test
public void findTest(){
//获取数据库连接对象
MongoDatabase mongoDatabase = MongoDBUtil.getConnect();
//获取集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
//查找集合中的所有文档
FindIterable findIterable = collection.find();
MongoCursor cursor = findIterable.iterator();
while (cursor.hasNext()) {
System.out.println(cursor.next());
}
}
指定查询过滤器查询
//指定查询过滤器查询
@Test
public void FilterfindTest(){
//获取数据库连接对象
MongoDatabase mongoDatabase = MongoDBUtil.getConnect();
//获取集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
//指定查询过滤器
Bson filter = Filters.eq("name", "张三");
//指定查询过滤器查询
FindIterable findIterable = collection.find(filter);
MongoCursor cursor = findIterable.iterator();
while (cursor.hasNext()) {
System.out.println(cursor.next());
}
}
可通过 first() 方法取出查询到的第一个文档
//取出查询到的第一个文档
@Test
public void findTest(){
//获取数据库连接对象
MongoDatabase mongoDatabase = MongoDBUtil.getConnect();
//获取集合
MongoCollection<Document> collection = mongoDatabase.getCollection("user");
//查找集合中的所有文档
FindIterable findIterable = collection.find();
//取出查询到的第一个文档
Document document = (Document) findIterable.first();
//打印输出
System.out.println(document);
}
4、总结
到这里，java对mongoDB的一些基本操作就介绍完了。实现的步骤为：添加驱动==>连接到服务==>连接到数据库==>选择集合==>对集合进行CRUD操作。
更多关于java相关内容感兴趣的读者可查看本站专题：《Java使用JDBC操作数据库技巧总结》、《Java+MySQL数据库程序设计总结》、《Java数据结构与算法教程》、《Java文件与目录操作技巧汇总》、《Java操作DOM节点技巧总结》和《Java缓存操作技巧汇总》
希望本文所述对大家java程序设计有所帮助。
相关文章
这篇文章主要介绍了java中hashmap容量的初始化实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-11-11
本文主要介绍了Java abstract关键字不能和哪些关键字共存，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-10-10
栈（stack）又名堆栈，它是一种运算受限的线性表。限定仅在表尾进行插入和删除操作的线性表。这一端被称为栈顶，相对地，把另一端称为栈底，栈是基础中的基础，如果你还没掌握透彻就来接着往下看吧2022-02-02
这篇文章主要介绍了idea mac版打开是出现打开失败问题及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-09-09
这篇文章主要介绍了Java虚拟机类加载器之双亲委派机制模型案例,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下2021-08-08
这篇文章主要介绍了SpringBoot2开启Actuator端点监控的相关资料,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-06-06
这篇文章主要介绍了Springboot 实现数据库备份还原的方法，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-09-09
这篇文章主要介绍了java中用数组实现环形队列的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-04-04
这篇文章主要介绍了基于Struts2实现防止表单重复提交,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-10-10
这篇文章主要介绍了关于MyBatis各种SQL操作详解，MyBatis 是一款优秀的半自动的ORM持久层框架，它支持自定义 SQL、存储过程以及高级映射,需要的朋友可以参考下2023-05-05
最新评论