systemLog:
    destination: file
    logAppend: true
    path: D:\Program Files\mongodb\data\logs\mongod.log
storage:
    dbPath: D:\Program Files\mongodb\data\db

D:\Program Files\mongodb\bin>mongod --version
db version v5.0.14
Build Info: {
    "version": "5.0.14",
    "gitVersion": "1b3b0073a0b436a8a502b612f24fb2bd572772e5",
    "modules": [],
    "allocator": "tcmalloc",
    "environment": {
        "distmod": "windows",
        "distarch": "x86_64",
        "target_arch": "x86_64"
    }
}

<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongo-java-driver</artifactId>
    <version>3.8.2</version>
</dependency>

package com.example.demo.utils;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.bson.Document;
import org.bson.conversions.Bson;

import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

public class MongoDBUtil {

    private static MongoClient mongoClient;

    private static MongoClient mongoClientIdentify;

    /**
     * 不通過認(rèn)證獲取連接數(shù)據(jù)庫對(duì)象
     */
    public static MongoDatabase getNoIdentifyConnect(String host, int port, String dbaseName){
        // 連接mongodb服務(wù)
        MongoDBUtil.mongoClient = new MongoClient(host, port);

        // 連接數(shù)據(jù)庫
        MongoDatabase mongoDatabase = MongoDBUtil.mongoClient.getDatabase(dbaseName);

        // 返回連接數(shù)據(jù)庫對(duì)象
        return mongoDatabase;
    }

    /**
     * 通過連接認(rèn)證獲取MongoDB連接
     */
    public static MongoDatabase getIdentifyConnect(String host, int port, String dbaseName, String userName, String password){

        List<ServerAddress> adds = new ArrayList<ServerAddress>();

        ServerAddress serverAddress = new ServerAddress(host, port);
        adds.add(serverAddress);

        List<MongoCredential> credentials = new ArrayList<>();

        MongoCredential mongoCredential = MongoCredential.createScramSha1Credential(userName, dbaseName, password.toCharArray());
        credentials.add(mongoCredential);

        // 通過連接認(rèn)證獲取MongoDB連接
        MongoDBUtil.mongoClientIdentify = new MongoClient(adds, credentials);

        MongoDatabase mongoDatabase = MongoDBUtil.mongoClientIdentify.getDatabase(dbaseName);

        return mongoDatabase;
    }

    /**
     * 關(guān)閉連接
     */
    public static void closeNoIdentifyConnect (){
        MongoDBUtil.mongoClient.close();
    }

    /**
     * 關(guān)閉連接
     */
    public static void closeIdentifyConnect (){
        MongoDBUtil.mongoClientIdentify.close();
    }

    /**
     * 插入一個(gè)文檔
     */
    public static void insertOne (Map<String, Object> data, MongoDatabase mongoDatabase, String col){
        //獲取集合
        MongoCollection<Document> collection = mongoDatabase.getCollection(col);

        //創(chuàng)建文檔
        Document document = new Document();

        for (Map.Entry<String, Object> m : data.entrySet()) {
            document.append(m.getKey(), m.getValue()).append(m.getKey(), m.getValue());
        }

        //插入一個(gè)文檔
        collection.insertOne(document);
    }

    /**
     * 插入多個(gè)文檔
     */
    public static void insertMany (List<Map<String, Object>> listData, MongoDatabase mongoDatabase, String col){
        //獲取集合
        MongoCollection<Document> collection = mongoDatabase.getCollection(col);

        //要插入的數(shù)據(jù)
        List<Document> list = new ArrayList<>();
        for (Map<String, Object> data : listData) {
            //創(chuàng)建文檔
            Document document = new Document();

            for (Map.Entry<String, Object> m : data.entrySet()) {
                document.append(m.getKey(), m.getValue());
            }
            list.add(document);
        }

        //插入多個(gè)文檔
        collection.insertMany(list);
    }

    /**
     * 刪除匹配到的第一個(gè)文檔
     */
    public static void delectOne (String col, String key, Object value, MongoDatabase mongoDatabase){
        //獲取集合
        MongoCollection<Document> collection = mongoDatabase.getCollection(col);
        //申明刪除條件
        Bson filter = Filters.eq(key, value);
        //刪除與篩選器匹配的單個(gè)文檔
        collection.deleteOne(filter);
    }

    /**
     * 刪除匹配的所有文檔
     */
    public static void deleteMany (String col, String key, Object value, MongoDatabase mongoDatabase){
        //獲取集合
        MongoCollection<Document> collection = mongoDatabase.getCollection(col);
        //申明刪除條件
        Bson filter = Filters.eq(key, value);
        //刪除與篩選器匹配的所有文檔
        collection.deleteMany(filter);
    }

    /**
     * 刪除集合中所有文檔
     */
    public static void deleteAllDocument(String col, MongoDatabase mongoDatabase){
        //獲取集合
        MongoCollection<Document> collection = mongoDatabase.getCollection(col);
        collection.deleteMany(new Document());
    }

    /**
     * 刪除文檔和集合。
     */
    public static void deleteAllCollection(String col, MongoDatabase mongoDatabase){
        //獲取集合
        MongoCollection<Document> collection = mongoDatabase.getCollection(col);
        collection.drop();
    }

    /**
     * 修改單個(gè)文檔，修改過濾器篩選出的第一個(gè)文檔
     *
     * @param col 修改的集合
     * @param key 修改條件的鍵
     * @param value 修改條件的值
     * @param eqKey 要修改的鍵，如果eqKey不存在，則新增記錄
     * @param eqValue 要修改的值
     * @param mongoDatabase 連接數(shù)據(jù)庫對(duì)象
     */
    public static void updateOne (String col, String key, Object value,String eqKey, Object eqValue, MongoDatabase mongoDatabase){
        //獲取集合
        MongoCollection<Document> collection = mongoDatabase.getCollection(col);
        //修改過濾器
        Bson filter = Filters.eq(key, value);
        //指定修改的更新文檔
        Document document = new Document("$set", new Document(eqKey, eqValue));
        //修改單個(gè)文檔
        collection.updateOne(filter, document);
    }

    /**
     * 修改多個(gè)文檔
     *
     * @param col 修改的集合
     * @param key 修改條件的鍵
     * @param value 修改條件的值
     * @param eqKey 要修改的鍵，如果eqKey不存在，則新增記錄
     * @param eqValue 要修改的值
     * @param mongoDatabase 連接數(shù)據(jù)庫對(duì)象
     */
    public static void updateMany (String col, String key, Object value, String eqKey, Object eqValue, MongoDatabase mongoDatabase){
        //獲取集合
        MongoCollection<Document> collection = mongoDatabase.getCollection(col);
        //修改過濾器
        Bson filter = Filters.eq(key, value);
        //指定修改的更新文檔
        Document document = new Document("$set", new Document(eqKey, eqValue));
        //修改多個(gè)文檔
        collection.updateMany(filter, document);
    }

    /**
     * 查找集合中的所有文檔
     */
    public static MongoCursor<Document> find (String col, MongoDatabase mongoDatabase){
        //獲取集合
        MongoCollection<Document> collection = mongoDatabase.getCollection(col);
        //查找集合中的所有文檔
        FindIterable<Document> findIterable = collection.find();
        MongoCursor<Document> cursorIterator = findIterable.iterator();
        return cursorIterator;
    }

    /**
     * 按條件查找集合中文檔
     */
    public static MongoCursor<Document> Filterfind (String col,String key, Object value, MongoDatabase mongoDatabase){
        //獲取集合
        MongoCollection<Document> collection = mongoDatabase.getCollection(col);
        //指定查詢過濾器
        Bson filter = Filters.eq(key, value);

        //指定查詢過濾器查詢
        FindIterable<Document> findIterable = collection.find(filter);
        MongoCursor<Document> cursorIterator = findIterable.iterator();
        return cursorIterator;
    }
}

<dependency>
   <groupId>junit</groupId>
    <artifactId>junit</artifactId>
    <version>4.12</version>
</dependency>

package com.example.demo.utils;

import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import org.junit.Test;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class MongoDBTest {

    // 獲取數(shù)據(jù)庫連接對(duì)象
    MongoDatabase mongoDatabase = MongoDBUtil.getNoIdentifyConnect("127.0.0.1", 27017, "test");

    @Test
    public void insertOne(){
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("姓名", "哪吒編程");
        map.put("性別", "男");
        map.put("年齡", 18);
        MongoDBUtil.insertOne(map, mongoDatabase, "worker");
        MongoDBUtil.closeNoIdentifyConnect();
    }

    @Test
    public void insertMany(){
        Map<String, Object> map1 = new HashMap<String, Object>();
        map1.put("姓名", "哪吒編程2");
        map1.put("性別", "男");
        map1.put("年齡", 18);
        Map<String, Object> map2 = new HashMap<String, Object>();
        map2.put("姓名", "妲己");
        map2.put("性別", "女");
        map2.put("年齡", 18);
        List<Map<String, Object>> listData = new ArrayList<>();
        listData.add(map1);
        listData.add(map2);
        MongoDBUtil.insertMany(listData, mongoDatabase, "worker");
        MongoDBUtil.closeNoIdentifyConnect();
    }

    @Test
    public void delectOne(){
        MongoDBUtil.delectOne("worker", "姓名", "妲己", mongoDatabase);

        MongoDBUtil.closeNoIdentifyConnect();
    }

    @Test
    public void deleteMany(){

        MongoDBUtil.deleteMany("worker", "姓名", "哪吒編程", mongoDatabase);
        MongoDBUtil.deleteMany("worker", "姓名", "妲己", mongoDatabase);

        MongoDBUtil.closeNoIdentifyConnect();
    }

    @Test
    public void deleteAllDocument(){
        MongoDBUtil.deleteAllDocument("worker", mongoDatabase);

        MongoDBUtil.closeNoIdentifyConnect();
    }

    @Test
    public void deleteAllCollection(){

        MongoDBUtil.deleteAllCollection("worker", mongoDatabase);

        MongoDBUtil.closeNoIdentifyConnect();
    }

    @Test
    public void updateOne(){

        MongoDBUtil.updateOne("worker", "姓名", "哪吒編程2","姓名", "哪吒編程", mongoDatabase);

        MongoDBUtil.closeNoIdentifyConnect();
    }

    @Test
    public void updateMany(){

        MongoDBUtil.updateMany("worker", "姓名", "哪吒編程2","姓名", "哪吒編程", mongoDatabase);

        MongoDBUtil.closeNoIdentifyConnect();
    }

    @Test
    public void find(){
        MongoCursor<Document> mongoCursor = MongoDBUtil.find("worker", mongoDatabase);

        while (mongoCursor.hasNext()) {
            Document document = mongoCursor.next();
            System.out.println(document + "  size: " + document.size());
        }
        MongoDBUtil.closeNoIdentifyConnect();
    }

    @Test
    public void filterfind(){
        MongoCursor<Document> mongoCursor = MongoDBUtil.Filterfind("worker", "姓名", "哪吒編程", mongoDatabase);

        while (mongoCursor.hasNext()) {
            Document document = mongoCursor.next();
            System.out.println(document + "  size: " + document.size());
        }
        MongoDBUtil.closeNoIdentifyConnect();
    }
}