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

唐伯虎

本文实例讲述了java连接mongodb并进行增删改查操作。分享给大家供大家参考，具体如下：
1、安装 mongodb jdbc驱动程序
在java中使用mongodb之前，首先需要拥有java连接mongodb的第三方驱动包（jar包）
1）maven项目可通过在pom.xml中添加依赖
1234567<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服务
12//连接到 mongodb 服务mongoclient mongoclient = new mongoclient("localhost", 27017);这里的 "localhost" 表示连接的服务器地址，27017 为端口号。可以省略端口号不写，系统将默认端口号为 27017。如：
12//连接到 mongodb 服务，默认端口号为27017mongoclient mongoclient = new mongoclient("localhost");也可以将服务器地址和端口号都省略，系统默认服务器地址为 "localhost"，端口号为 27017。如：
12//连接到 mongodb 服务，默认连接到localhost服务器，端口号为27017mongoclient mongoclient = new mongoclient();2）通过认证连接mongodb服务
12345678910list<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）连接到数据库
12//连接到数据库mongodatabase mongodatabase = mongoclient.getdatabase("test");这里的 "test" 表示数据库名，若指定的数据库不存在，mongodb将会在你第一次插入文档时创建数据库。
4）封装成工具类
由于所有连接数据库操作都需要执行这两步操作，我们可以将这两步操作封装成工具类。
12345678910111213141516171819202122232425262728293031import 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操作首先要获取到操作的集合。
12//获取集合mongocollection<document> collection = mongodbutil.getconnect().getcollection("user");这里的 "user" 表示集合的名字，如果指定的集合不存在，mongodb将会在你第一次插入文档时创建集合。
2）创建文档
要插入文档首先需要创建文档对象
1234//创建文档document document = new document("name","张三").append("sex", "男").append("age", 18);3）插入文档
插入一个文档，使用 mongocollection 对象的 insertone() 方法，该方法接收一个 document 对象作为要插入的数据
1234567891011121314//插入一个文档@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 对象作为要插入的数据
123456789101112131415161718//插入多个文档@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 类。
123456789101112//删除与筛选器匹配的单个文档@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 的的对象作为过滤器筛选出需要删除的文档。然后删除所有筛选出的文档。
123456789101112//删除与筛选器匹配的所有文档@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 指定如何修改筛选出的文档。然后修改过滤器筛选出的第一个文档。
1234567891011121314//修改单个文档@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 指定如何修改筛选出的文档。然后修改过滤器筛选出的所有文档。
1234567891011121314//修改多个文档@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 类型的对象，可通过该对象遍历出查询到的所有文档。
查找集合中的所有文档
1234567891011121314//查找集合中的所有文档@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());  }}指定查询过滤器查询
12345678910111213141516//指定查询过滤器查询@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() 方法取出查询到的第一个文档
1234567891011121314//取出查询到的第一个文档@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);}4、总结
到这里，java对mongodb的一些基本操作就介绍完了。实现的步骤为：添加驱动==>连接到服务==>连接到数据库==>选择集合==>对集合进行crud操作。
希望本文所述对大家java程序设计有所帮助。

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

相关帖子

电脑竖屏了变回来如何操作

win7拨号连接步骤

笔记本连接投影没反应解决方法

添加页眉页脚如何操作

无法连接windows服务解决方法

电力猫怎么配对 TP-Link电力猫和扩展器配对教程

电力猫配对 TP-Link电力猫和扩展器配对教程

js数组之间如何进行连接

怎么在JavaScript中加注释

阿里云服务器CentOS系统注释磁盘命令

唐伯虎 LV4