java连接mongoDB并进行增删改查操作实例详解

2023-08-25 04:23:04 52

本文实例讲述了java连接mongoDB并进行增删改查操作。分享给大家供大家参考，具体如下：

1、安装MongoDBJDBC驱动程序

在java中使用mongoDB之前，首先需要拥有java连接mongoDB的第三方驱动包（jar包）

1）maven项目可通过在pom.xml中添加依赖



org.mongodb
mongo-java-driver
3.0.4

2）非maven项目jar包下载地址：

mongoDBjar包

2、连接数据库

将mongoDBJDBC驱动加入到项目之后，就可以对mongoDB进行操作了。

1）不通过认证连接mongoDB服务

//连接到mongodb服务
MongoClientmongoClient=newMongoClient("localhost",27017);

这里的"localhost"表示连接的服务器地址，27017为端口号。可以省略端口号不写，系统将默认端口号为27017。如：

//连接到mongodb服务，默认端口号为27017
MongoClientmongoClient=newMongoClient("localhost");

也可以将服务器地址和端口号都省略，系统默认服务器地址为"localhost"，端口号为27017。如：

//连接到mongodb服务，默认连接到localhost服务器，端口号为27017
MongoClientmongoClient=newMongoClient();

2）通过认证连接mongoDB服务

Listadds=newArrayList<>();
//ServerAddress()两个参数分别为服务器地址和端口
ServerAddressserverAddress=newServerAddress("localhost",27017);
adds.add(serverAddress);
Listcredentials=newArrayList<>();
//MongoCredential.createScramSha1Credential()三个参数分别为用户名数据库名称密码
MongoCredentialmongoCredential=MongoCredential.createScramSha1Credential("username","databaseName","password".toCharArray());
credentials.add(mongoCredential);
//通过连接认证获取MongoDB连接
MongoClientmongoClient=newMongoClient(adds,credentials);

ServerAddress()两个参数"localhost"，27017分别为服务器地址和端口。

MongoCredential.createScramSha1Credential()三个参数"username","databaseName","password".toCharArray()分别为用户名数据库名称密码。

3）连接到数据库

//连接到数据库
MongoDatabasemongoDatabase=mongoClient.getDatabase("test");

这里的"test"表示数据库名，若指定的数据库不存在，mongoDB将会在你第一次插入文档时创建数据库。

4）封装成工具类

由于所有连接数据库操作都需要执行这两步操作，我们可以将这两步操作封装成工具类。

importcom.mongodb.MongoClient;
importcom.mongodb.client.MongoDatabase;
//mongodb连接数据库工具类
publicclassMongoDBUtil{
//不通过认证获取连接数据库对象
publicstaticMongoDatabasegetConnect(){
//连接到mongodb服务
MongoClientmongoClient=newMongoClient("localhost",27017);
//连接到数据库
MongoDatabasemongoDatabase=mongoClient.getDatabase("test");
//返回连接数据库对象
returnmongoDatabase;
}
//需要密码认证方式连接
publicstaticMongoDatabasegetConnect2(){
Listadds=newArrayList<>();
//ServerAddress()两个参数分别为服务器地址和端口
ServerAddressserverAddress=newServerAddress("localhost",27017);
adds.add(serverAddress);
Listcredentials=newArrayList<>();
//MongoCredential.createScramSha1Credential()三个参数分别为用户名数据库名称密码
MongoCredentialmongoCredential=MongoCredential.createScramSha1Credential("username","databaseName","password".toCharArray());
credentials.add(mongoCredential);
//通过连接认证获取MongoDB连接
MongoClientmongoClient=newMongoClient(adds,credentials);
//连接到数据库
MongoDatabasemongoDatabase=mongoClient.getDatabase("test");
//返回连接数据库对象
returnmongoDatabase;
}
}

3、对数据库进行CRUD

mongoDB中的数据都是通过文档（对应于关系型数据库表中的一行）保存的，而文档又保存在集合（对应于关系型数据库的表）中。

1）获取集合

要对数据进行CRUD操作首先要获取到操作的集合。

//获取集合
MongoCollectioncollection=MongoDBUtil.getConnect().getCollection("user");

这里的"user"表示集合的名字，如果指定的集合不存在，mongoDB将会在你第一次插入文档时创建集合。

2）创建文档

要插入文档首先需要创建文档对象

//创建文档
Documentdocument=newDocument("name","张三")
.append("sex","男")
.append("age",18);

3）插入文档

插入一个文档，使用MongoCollection对象的insertOne()方法，该方法接收一个Document对象作为要插入的数据

//插入一个文档
@Test
publicvoidinsertOneTest(){
//获取数据库连接对象
MongoDatabasemongoDatabase=MongoDBUtil.getConnect();
//获取集合
MongoCollectioncollection=mongoDatabase.getCollection("user");
//要插入的数据
Documentdocument=newDocument("name","张三")
.append("sex","男")
.append("age",18);
//插入一个文档
collection.insertOne(document);
}

插入多个文档，使用MongoCollection对象的insertMany()方法，该方法接收一个数据类型为Document的List对象作为要插入的数据

//插入多个文档
@Test
publicvoidinsertManyTest(){
//获取数据库连接对象
MongoDatabasemongoDatabase=MongoDBUtil.getConnect();
//获取集合
MongoCollectioncollection=mongoDatabase.getCollection("user");
//要插入的数据
Listlist=newArrayList<>();
for(inti=1;i<=3;i++){
Documentdocument=newDocument("name","张三")
.append("sex","男")
.append("age",18);
list.add(document);
}
//插入多个文档
collection.insertMany(list);
}

4）删除文档

删除与筛选器匹配的单个文档，使用MongoCollection对象的deleteOne()方法，该方法接收一个数据类型为Bson的的对象作为过滤器筛选出需要删除的文档。然后删除第一个。为了便于创建过滤器对象，JDBC驱动程序提供了Filters类。

//删除与筛选器匹配的单个文档
@Test
publicvoiddeleteOneTest(){
//获取数据库连接对象
MongoDatabasemongoDatabase=MongoDBUtil.getConnect();
//获取集合
MongoCollectioncollection=mongoDatabase.getCollection("user");
//申明删除条件
Bsonfilter=Filters.eq("age",18);
//删除与筛选器匹配的单个文档
collection.deleteOne(filter);
}

删除与筛选器匹配的所有文档，使用MongoCollection对象的deleteMany()方法，该方法接收一个数据类型为Bson的的对象作为过滤器筛选出需要删除的文档。然后删除所有筛选出的文档。

//删除与筛选器匹配的所有文档
@Test
publicvoiddeleteManyTest(){
//获取数据库连接对象
MongoDatabasemongoDatabase=MongoDBUtil.getConnect();
//获取集合
MongoCollectioncollection=mongoDatabase.getCollection("user");
//申明删除条件
Bsonfilter=Filters.eq("age",18);
//删除与筛选器匹配的所有文档
collection.deleteMany(filter);
}

5）修改文档

修改单个文档，使用MongoCollection对象的updateOne()方法，该方法接收两个参数，第一个数据类型为Bson的过滤器筛选出需要修改的文档，第二个参数数据类型为Bson指定如何修改筛选出的文档。然后修改过滤器筛选出的第一个文档。

//修改单个文档
@Test
publicvoidupdateOneTest(){
//获取数据库连接对象
MongoDatabasemongoDatabase=MongoDBUtil.getConnect();
//获取集合
MongoCollectioncollection=mongoDatabase.getCollection("user");
//修改过滤器
Bsonfilter=Filters.eq("name","张三");
//指定修改的更新文档
Documentdocument=newDocument("$set",newDocument("age",100));
//修改单个文档
collection.updateOne(filter,document);
}

修改多个文档，使用MongoCollection对象的updateMany()方法，该方法接收两个参数，第一个数据类型为Bson的过滤器筛选出需要修改的文档，第二个参数数据类型为Bson指定如何修改筛选出的文档。然后修改过滤器筛选出的所有文档。

//修改多个文档
@Test
publicvoidupdateManyTest(){
//获取数据库连接对象
MongoDatabasemongoDatabase=MongoDBUtil.getConnect();
//获取集合
MongoCollectioncollection=mongoDatabase.getCollection("user");
//修改过滤器
Bsonfilter=Filters.eq("name","张三");
//指定修改的更新文档
Documentdocument=newDocument("$set",newDocument("age",100));
//修改多个文档
collection.updateMany(filter,document);
}

6）查询文档

使用MongoCollection对象的find()方法，该方法有多个重载方法，可以使用不带参数的find()方法查询集合中的所有文档，也可以通过传递一个Bson类型的过滤器查询符合条件的文档。这几个重载方法均返回一个FindIterable类型的对象，可通过该对象遍历出查询到的所有文档。

查找集合中的所有文档

//查找集合中的所有文档
@Test
publicvoidfindTest(){
//获取数据库连接对象
MongoDatabasemongoDatabase=MongoDBUtil.getConnect();
//获取集合
MongoCollectioncollection=mongoDatabase.getCollection("user");
//查找集合中的所有文档
FindIterablefindIterable=collection.find();
MongoCursorcursor=findIterable.iterator();
while(cursor.hasNext()){
System.out.println(cursor.next());
}
}

指定查询过滤器查询

//指定查询过滤器查询
@Test
publicvoidFilterfindTest(){
//获取数据库连接对象
MongoDatabasemongoDatabase=MongoDBUtil.getConnect();
//获取集合
MongoCollectioncollection=mongoDatabase.getCollection("user");
//指定查询过滤器
Bsonfilter=Filters.eq("name","张三");
//指定查询过滤器查询
FindIterablefindIterable=collection.find(filter);
MongoCursorcursor=findIterable.iterator();
while(cursor.hasNext()){
System.out.println(cursor.next());
}
}

可通过first()方法取出查询到的第一个文档

//取出查询到的第一个文档
@Test
publicvoidfindTest(){
//获取数据库连接对象
MongoDatabasemongoDatabase=MongoDBUtil.getConnect();
//获取集合
MongoCollectioncollection=mongoDatabase.getCollection("user");
//查找集合中的所有文档
FindIterablefindIterable=collection.find();
//取出查询到的第一个文档
Documentdocument=(Document)findIterable.first();
//打印输出
System.out.println(document);
}

4、总结

到这里，java对mongoDB的一些基本操作就介绍完了。实现的步骤为：添加驱动==>连接到服务==>连接到数据库==>选择集合==>对集合进行CRUD操作。

更多关于java相关内容感兴趣的读者可查看本站专题：《Java使用JDBC操作数据库技巧总结》、《Java+MySQL数据库程序设计总结》、《Java数据结构与算法教程》、《Java文件与目录操作技巧汇总》、《Java操作DOM节点技巧总结》和《Java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。