服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|JavaScript|易语言|

服务器之家 - 编程语言 - Java教程 - java连接mongoDB并进行增删改查操作实例详解

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

2021-07-28 11:30Xuych_ Java教程

这篇文章主要介绍了java连接mongoDB并进行增删改查操作,结合实例形式详细分析了java环境下MongoDB扩展包的下载、安装及操作MongoDB连接、增删改查等相关操作技巧,需要的朋友可以参考下

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

1、安装 mongodb jdbc驱动程序

 

在java中使用mongodb之前,首先需要拥有java连接mongodb的第三方驱动包(jar包)

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

?
1
2
3
4
5
6
7
<dependencies>
  <dependency>
   <groupid>org.mongodb</groupid>
   <artifactid>mongo-java-driver</artifactid>
   <version>3.0.4</version>
  </dependency>
</dependencies>

2)非maven项目jar包下载地址:

   mongodb jar包

2、连接数据库

 

将mongodb jdbc驱动加入到项目之后,就可以对mongodb进行操作了。

1)不通过认证连接mongodb服务

?
1
2
//连接到 mongodb 服务
mongoclient mongoclient = new mongoclient("localhost", 27017);

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

?
1
2
//连接到 mongodb 服务,默认端口号为27017
mongoclient mongoclient = new mongoclient("localhost");

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

?
1
2
//连接到 mongodb 服务,默认连接到localhost服务器,端口号为27017
mongoclient mongoclient = new mongoclient();

2)通过认证连接mongodb服务

?
1
2
3
4
5
6
7
8
9
10
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)连接到数据库

?
1
2
//连接到数据库
mongodatabase mongodatabase = mongoclient.getdatabase("test");

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

4)封装成工具类

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
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操作首先要获取到操作的集合。

?
1
2
//获取集合
mongocollection<document> collection = mongodbutil.getconnect().getcollection("user");

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

2)创建文档

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

?
1
2
3
4
//创建文档
document document = new document("name","张三")
.append("sex", "男")
.append("age", 18);

3)插入文档

插入一个文档,使用 mongocollection 对象的 insertone() 方法,该方法接收一个 document 对象作为要插入的数据

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
//插入一个文档
@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 对象作为要插入的数据

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
//插入多个文档
@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 类。

?
1
2
3
4
5
6
7
8
9
10
11
12
//删除与筛选器匹配的单个文档
@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 的的对象作为过滤器筛选出需要删除的文档。然后删除所有筛选出的文档。

?
1
2
3
4
5
6
7
8
9
10
11
12
//删除与筛选器匹配的所有文档
@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 指定如何修改筛选出的文档。然后修改过滤器筛选出的第一个文档。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
//修改单个文档
@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 指定如何修改筛选出的文档。然后修改过滤器筛选出的所有文档。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
//修改多个文档
@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 类型的对象,可通过该对象遍历出查询到的所有文档。

查找集合中的所有文档

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
//查找集合中的所有文档
@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());
  }
}

指定查询过滤器查询

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
//指定查询过滤器查询
@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() 方法取出查询到的第一个文档

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
//取出查询到的第一个文档
@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程序设计有所帮助。

延伸 · 阅读

精彩推荐