java连接连接mongoDB并进行增删改查操作实例详解 并进行增删改查操作实例详解 主要介绍了java连接mongoDB并进行增删改查操作,结合实例形式详细分析了java环境下MongoDB扩展包的下 载、安装及操作MongoDB连接、增删改查等相关操作技巧,需要的朋友可以参考下 本文实例讲述了java连接mongoDB并进行增删改查操作。分享给大家供大家参考，具体如下： 1、安装、安装 MongoDB JDBC驱动程序 驱动程序 在java中使用mongoDB之前，首先需要拥有java连接mongoDB的第三方驱动包（jar包） 1））maven项目可通过在 项目可通过在pom.xml中添加依赖 中添加依赖 org.mongodb mongo-java-driver 3.0.4 2）非）非maven项目项目jar包下载地址： 包下载地址： mongoDB jar包 2、连接数据库 、连接数据库 将mongoDB JDBC驱动加入到项目之后，就可以对mongoDB进行操作了。 1）不通过认证连接 ）不通过认证连接mongoDB服务服务 //连接到 mongodb 服务 MongoClient mongoClient = new MongoClient("localhost", 27017); 这里的 "localhost" 表示连接的服务器地址，27017 为端口号。可以省略 端口号 不写，系统将默认端口号为 27017。如： //连接到 mongodb 服务，默认端口号为27017 MongoClient mongoClient = new MongoClient("localhost"); 也可以将 服务器地址 和 端口号 都省略，系统默认服务器地址为 "localhost"，端口号为 27017。如： //连接到 mongodb 服务，默认连接到localhost服务器，端口号为27017 MongoClient mongoClient = new MongoClient(); 2）通过认证连接 ）通过认证连接mongoDB服务服务 List adds = new ArrayList<>(); //ServerAddress()两个参数分别为 服务器地址 和 端口 ServerAddress serverAddress = new ServerAddress("localhost", 27017); adds.add(serverAddress); List 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 adds = new ArrayList<>(); //ServerAddress()两个参数分别为 服务器地址 和 端口 ServerAddress serverAddress = new ServerAddress("localhost", 27017); adds.add(serverAddress); List 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 collection = MongoDBUtil.getConnect().getCollection("user"); 这里的 "user" 表示集合的名字，如果指定的集合不存在，mongoDB将会在你第一次插入文档时创建集合。 2）创建文档 ）创建文档 要插入文档首先需要创建文档对象 //创建文档 Document document = new Document("name","张三") .append("sex", "男") .append("age", 18); 3）插入文档 ）插入文档 插入一个文档，使用 MongoCollection 对象的 insertOne() 方法，该方法接收一个 Document 对象作为要插入的数据 //插入一个文档 @Test public void insertOneTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 

MongoCollection collection = mongoDatabase.getCollection("user"); //要插入的数据 Document document = new Document("name","张三") .append("sex", "男") .append("age", 18); //插入一个文档 collection.insertOne(document); } 插入多个文档，使用 MongoCollection 对象的 insertMany() 方法，该方法接收一个 数据类型为 Document 的 List 对象作为要插 入的数据 //插入多个文档 @Test public void insertManyTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection collection = mongoDatabase.getCollection("user"); //要插入的数据 List 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 类。 //删除与筛选器匹配的单个文档 @Test public void deleteOneTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection collection = mongoDatabase.getCollection("user"); //申明删除条件 Bson filter = Filters.eq("age",18); //删除与筛选器匹配的单个文档 collection.deleteOne(filter); } 删除与筛选器匹配的所有文档，使用 MongoCollection 对象的 deleteMany() 方法，该方法接收一个数据类型为 Bson 的的对象 作为过滤器筛选出需要删除的文档。然后删除所有筛选出的文档。 //删除与筛选器匹配的所有文档 @Test public void deleteManyTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection collection = mongoDatabase.getCollection("user"); //申明删除条件 Bson filter = Filters.eq("age",18); //删除与筛选器匹配的所有文档 collection.deleteMany(filter); } 5）修改文档 ）修改文档 修改单个文档，使用 MongoCollection 对象的 updateOne() 方法，该方法接收两个参数，第一个数据类型为 Bson 的过滤器筛选 出需要修改的文档，第二个参数数据类型为 Bson 指定如何修改筛选出的文档。然后修改过滤器筛选出的第一个文档。 //修改单个文档 @Test public void updateOneTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); 

//获取集合 MongoCollection 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 指定如何修改筛选出的文档。然后修改过滤器筛选出的所有文档。 //修改多个文档 @Test public void updateManyTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection 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 类型的对象，可通过该 对象遍历出查询到的所有文档。 查找集合中的所有文档 //查找集合中的所有文档 @Test public void findTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection collection = mongoDatabase.getCollection("user"); //查找集合中的所有文档 FindIterable findIterable = collection.find(); MongoCursor cursor = findIterable.iterator(); while (cursor.hasNext()) { System.out.println(cursor.next()); } } 指定查询过滤器查询 //指定查询过滤器查询 @Test public void FilterfindTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection 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() 方法取出查询到的第一个文档 //取出查询到的第一个文档 @Test public void findTest(){ 

//获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection collection = mongoDatabase.getCollection("user"); //查找集合中的所有文档 FindIterable findIterable = collection.find(); //取出查询到的第一个文档 Document document = (Document) findIterable.first(); //打印输出 System.out.println(document); } 4、总结、总结 到这里，java对mongoDB的一些基本操作就介绍完了。实现的步骤为：添加驱动==>连接到服务==>连接到数据库==>选择集 合==>对集合进行CRUD操作。 更多关于java相关内容感兴趣的读者可查看本站专题：《Java使用JDBC操作数据库技巧总结》、《Java+MySQL数据库程序 设计总结》、《Java数据结构与算法教程》、《Java文件与目录操作技巧汇总》、《Java操作DOM节点技巧总结》和《Java 缓存操作技巧汇总》 希望本文所述对大家java程序设计有所帮助。