一篇文章带你使用 Java 操作 MongoDB

╰半夏微凉° 2022-11-30 15:49 204阅读 0赞

### 文章目录 ###

*   *  一、前期准备
     *  二、获取集合
     *   *  1. 增加操作
         *  2. 修改操作
         *  3. 删除操作
         *  4. 查询操作
         *  5. 验证问题
         *  6. 其他配置

## 一、前期准备 ##

首先我们需要驱动，MongoDB的Java驱动我们可以直接在Maven中央仓库去下载，也可以创建Maven工程添加如下依赖：

<dependency>
        <groupId>org.mongodb</groupId>
        <artifactId>mongodb-driver</artifactId>
        <version>3.5.0</version>
    </dependency>

建议通过Maven来添加依赖，如果自己下载jar，需要下载如下三个jar：

> 1.org.mongodb:bson:jar:3.5.0  
> 2.org.mongodb:mongodb-driver-core:jar:3.5.0  
> 3.org.mongodb:mongodb-driver:jar:3.5.0

另外，在使用 Java 操作 MongoDB 之前，记得启动 MongoDB

## 二、获取集合 ##

所有准备工作完成之后，我们首先需要一个MongoClient，如下：

MongoClient client = new MongoClient("192.168.248.136", 27017);

然后通过如下方式获取一个数据库，如果要获取的数据库本身就存在，直接获取到，不存在MongoDB会自动创建：

MongoDatabase sang = client.getDatabase("sang");

然后通过如下方式获取一个名为c1的集合，这个集合存在的话就直接获取到，不存在的话MongoDB会自动创建出来，如下：

MongoCollection<Document> c = sang.getCollection("c1");

有了集合之后，我们就可以向集合中插入数据了。

### 1. 增加操作 ###

和在shell中的操作一样，我们可以一条一条的添加数据，也可以批量添加，添加单条数据操作如下：

Document d1 = new Document();
    d1.append("name", "三国演义").append("author", "罗贯中");
    c.insertOne(d1);

添加多条数据的操作如下：

List<Document> collections = new ArrayList<Document>();
    Document d1 = new Document();
    d1.append("name", "三国演义").append("author", "罗贯中");
    collections.add(d1);
    Document d2 = new Document();
    d2.append("name", "红楼梦").append("author", "曹雪芹");
    collections.add(d2);
    c.insertMany(collections);

当然也可以通过 Robo 3T查看修改结果：`db.集合名.find()`  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmh1YWliZWlhbg_size_16_color_FFFFFF_t_70_pic_center]

### 2. 修改操作 ###

可以修改查到的第一条数据，操作如下：

c.updateOne(Filters.eq("author", "罗贯中"), new Document("$set", new Document("name", "三国演义123")));

上例中小伙伴们也看到了修改器要如何使用，不管是inc，用法都一致，我这里不再一个一个演示。也可以修改查到的所有数据，如下：

c.updateMany(Filters.eq("author", "罗贯中"), new Document("$set", new Document("name", "三国演义456")));

### 3. 删除操作 ###

可以删除查到的一条数据，如下：

c.deleteOne(Filters.eq("author", "罗贯中"));

也可以删除查到的所有数据：

c.deleteMany(Filters.eq("author", "罗贯中"));

Filters里边还有其他的查询条件，都是见名知意，不赘述。

### 4. 查询操作 ###

可以直接查询所有文档：

FindIterable<Document> documents = c.find();
    MongoCursor<Document> iterator = documents.iterator();
    while (iterator.hasNext()) { 
        System.out.println(iterator.next());
    }

也可以按照条件查询：

FindIterable<Document> documents = c.find(Filters.eq("author", "罗贯中"));
    MongoCursor<Document> iterator = documents.iterator();
    while (iterator.hasNext()) { 
        System.out.println(iterator.next());
    }

其他的方法基本都是见名知意，这里不再赘述。

### 5. 验证问题 ###

上面我们演示的获取一个集合是不需要登录MongoDB数据库的，如果需要登录，我们获取集合的方式改为下面这种：

MongoCredential是一个凭证，第一个参数为用户名，第二个参数是要在哪个数据库中验证，第三个参数是密码的char数组，然后将登录地址封装成一个ServerAddress，最后将两个参数都传入MongoClient中实现登录功能。

### 6. 其他配置 ###

其他配置  
在连接数据库的时候也可以设置连接超时等信息，在MongoClientOptions中设置即可，设置方式如下：

ServerAddress serverAddress = new ServerAddress("192.168.248.128", 27017);
    List<MongoCredential> credentialsList = new ArrayList<MongoCredential>();
    MongoCredential mc = MongoCredential.createScramSha1Credential("rwuser","sang","123".toCharArray());
    credentialsList.add(mc);
    MongoClientOptions options = MongoClientOptions.builder()
            //设置连接超时时间为10s
            .connectTimeout(1000*10)
            //设置最长等待时间为10s
            .maxWaitTime(1000*10)
            .build();
    MongoClient client = new MongoClient(serverAddress,credentialsList,options);
    MongoDatabase sang = client.getDatabase("sang");
    c = sang.getCollection("c1");

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmh1YWliZWlhbg_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/beec8d3907524e578e9d5fb4d30a06f2.png