脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → java连接mongoDB并进行增删改查

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

 更新时间：2019年04月02日 11:24:36   作者：Xuych_  
这篇文章主要介绍了java连接mongoDB并进行增删改查操作,结合实例形式详细分析了java环境下MongoDB扩展包的下载、安装及操作MongoDB连接、增删改查等相关操作技巧,需要的朋友可以参考下

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

1、安装 MongoDB JDBC驱动程序

在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包下载地址：

   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<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 对象作为要插入的数据

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

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

//删除与筛选器匹配的单个文档
@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 的的对象作为过滤器筛选出需要删除的文档。然后删除所有筛选出的文档。

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

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

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

查找集合中的所有文档

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

指定查询过滤器查询

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

//取出查询到的第一个文档
@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相关内容感兴趣的读者可查看本站专题：《Java使用JDBC操作数据库技巧总结》、《Java+MySQL数据库程序设计总结》、《Java数据结构与算法教程》、《Java文件与目录操作技巧汇总》、《Java操作DOM节点技巧总结》和《Java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。

您可能感兴趣的文章:

相关文章

  • Java实现接月饼小游戏的示例代码

    Java实现接月饼小游戏的示例代码

    本文将用Java语言自制一个小游戏：《接月饼小游戏》，游戏规则为不要被月亮砸到，尽可能地多接月饼。文中的实现代码讲解清晰，感兴趣的可以动手试一试
    2022-02-02
  • SpringBoot 整合 Netty 多端口监听的操作方法

    SpringBoot 整合 Netty 多端口监听的操作方法

    Netty提供异步的、基于事件驱动的网络应用程序框架,用以快速开发高性能、高可靠性的网络 IO 程序,是目前最流行的 NIO 框架,这篇文章主要介绍了SpringBoot 整和 Netty 并监听多端口,需要的朋友可以参考下
    2023-10-10
  • Java深入数据结构理解掌握抽象类与接口

    Java深入数据结构理解掌握抽象类与接口

    在类中没有包含足够的信息来描绘一个具体的对象，这样的类称为抽象类，接口是Java中最重要的概念之一，它可以被理解为一种特殊的类，不同的是接口的成员没有执行体，是由全局常量和公共的抽象方法所组成，本文给大家介绍Java抽象类和接口，感兴趣的朋友一起看看吧
    2022-05-05
  • java中实体类和JSON对象之间相互转化

    java中实体类和JSON对象之间相互转化

    Java中关于Json格式转化Object,Map,Collection类型和String类型之间的转化在我们实际项目中应用的很是普遍和广泛。最近工作的过程中也是经常有，因此,自己封装了一个类分享给大家。
    2015-05-05
  • MyBatis使用自定义TypeHandler转换类型的实现方法

    MyBatis使用自定义TypeHandler转换类型的实现方法

    这篇文章主要介绍了MyBatis使用自定义TypeHandler转换类型的实现方法，本文介绍使用TypeHandler 实现日期类型的转换，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2018-10-10
  • Java中documentHelper解析xml获取想要的数据

    Java中documentHelper解析xml获取想要的数据

    本文主要介绍了Java中documentHelper解析xml获取想要的数据，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2023-02-02
  • spring mvc 读取xml文件数据库配置参数的方法

    spring mvc 读取xml文件数据库配置参数的方法

    下面小编就为大家带来一篇spring mvc 读取xml文件数据库配置参数的方法。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-10-10
  • springmvc 获取@Requestbody转换的异常处理方式

    springmvc 获取@Requestbody转换的异常处理方式

    这篇文章主要介绍了springmvc 获取@Requestbody转换的异常处理方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-07-07
  • Java String中的split方法使用总结

    Java String中的split方法使用总结

    这篇文章主要介绍了Java String中的split方法使用总结，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-08-08
  • java基于Apache FTP点断续传的文件上传和下载

    java基于Apache FTP点断续传的文件上传和下载

    本篇文章主要介绍了java基于Apache FTP点断续传的文件上传和下载，利用FTP实现文件的上传和下载，具有一定的参考价值，感兴趣的小伙伴们可以参考一下。
    2016-11-11

最新评论