今天扣丁学堂Java培训老师给大家分享一篇关于java连接mongoDB并进行增删改查操作,结合实例形式详细分析了java环境下MongoDB扩展包的下载、安装及操作MongoDB连接、增删改查等相关操作技巧。

1、安装MongoDBJDBC驱动程序

在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、连接数据库

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

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

//连接到 mongodb 服务MongoClient mongoClient = new MongoClient("localhost", 27017);

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

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

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

//连接到 mongodb 服务，默认连接到localhost服务器，端口号为27017MongoClient 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对象作为要插入的数据

//插入一个文档@Testpublic 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对象作为要插入的数据

//插入多个文档@Testpublic 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类。

//删除与筛选器匹配的单个文档@Testpublic void deleteOneTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection<Document> collection = mongoDatabase.getCollection("user"); //申明删除条件 Bson filter = Filters.eq("age",18); //删除与筛选器匹配的单个文档 collection.deleteOne(filter);}

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

//删除与筛选器匹配的所有文档@Testpublic 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指定如何修改筛选出的文档。然后修改过滤器筛选出的第一个文档。

//修改单个文档@Testpublic 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指定如何修改筛选出的文档。然后修改过滤器筛选出的所有文档。

//修改多个文档@Testpublic 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类型的对象，可通过该对象遍历出查询到的所有文档。

查找集合中的所有文档

//查找集合中的所有文档@Testpublic 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()); }}

指定查询过滤器查询

//指定查询过滤器查询@Testpublic 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()方法取出查询到的第一个文档

//取出查询到的第一个文档@Testpublic 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);}

以上就是关于扣丁学堂java培训之连接mongoDB并进行增删改查操作实例详解，想要学好Java开发小编给大家推荐口碑良好的扣丁学堂，扣丁学堂有专业老师制定的Java学习路线图辅助学员学习，此外还有与时俱进的Java视频教程供大家学习，想要学好Java开发技术的小伙伴快快行动吧。