本文实例讲述了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包下载地址:
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程序设计有所帮助。