IDEA链接MongoDB数据库-实现增删改查

中间出了一系列莫名其妙的问题，又莫名其妙地好了。

这是我的配置文件，有点乱：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.5.6</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.ya</groupId>
    <artifactId>oeder-logistics-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>oeder-logistics-demo</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>11</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>4.0.2.RELEASE</version>
        </dependency>
        <!--spring data mongodb-->
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-mongodb</artifactId>
            <version>2.0.5.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.jetbrains</groupId>
            <artifactId>annotations</artifactId>
            <version>RELEASE</version>
            <scope>compile</scope>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

还导了两个包：

连接数据库：

package com.ya;

import com.mongodb.*;
import com.mongodb.MongoClient;
import com.mongodb.client.*;
import org.bson.Document;
import java.util.ArrayList;
import java.util.List;
public class MongoDBConnection {
//不认证直接链接数据库
    public MongoClient getConn(){
        MongoClient mongoClient = new MongoClient("localhost",27017);
        //也可使用MongoClientURI
        // MongoClientURI mongoClientURI = new MongoClientURI("mongodb://localhost:27017");
        // MongoClient mongoClient = new MongoClient(mongoClientURI);
        return mongoClient;

    }

//通过用户密码认证链接数据库

    public MongoClient getConnByCredit(){
        String name = "test";//用户名
        String dbName = "Test";//数据库名
        char [] pwd = "test".toCharArray();//用户密码(将字符串转换成字符数组)
        List<ServerAddress> addresses = new ArrayList<>();
        //服务器地址：链接地址,端口号
        ServerAddress address = new ServerAddress("localhost",27017);
        addresses.add(address);
        List<MongoCredential> credentials = new ArrayList<>();
        //认证方法需要三个参数，用户名，数据库名，用户密码
        MongoCredential credential = MongoCredential.createScramSha1Credential(name,dbName,pwd);
        credentials.add(credential);
        //创建链接对象
        MongoClient mongoClient = new MongoClient(addresses,credentials);
        return mongoClient;
    }


    //测试是否连接成功

    public static void main(String[] args) {

        MongoDBConnection mongoDBConnection = new MongoDBConnection();
        MongoDatabase mongoDatabase = null;
        //MongoClient mongoClient = mongoDBConnection.getConn();
         MongoClient mongoClient = mongoDBConnection.getConnByCredit();
        // 查询所有数据库名称
        MongoIterable<String> dbNameList = mongoClient.listDatabaseNames();
        System.out.println("查询所有数据库名称:");
        for(String dbName : dbNameList)
            System.out.println(dbName);
        //创建数据库对象
        mongoDatabase = mongoClient.getDatabase("Test");
        //查询Test数据库中所有集合名称
        MongoIterable<String> colNameList = mongoDatabase.listCollectionNames();
        System.out.println("查询Test数据库中所有集合名称:");
        for(String colName: colNameList)
            System.out.println(colName);
        //关闭连接
        mongoClient.close();

    }

}

结果：

 增删改查：

package com.ya;

import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.client.*;
import com.mongodb.client.model.Filters;
import org.bson.Document;

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

public class MongoTest {

    //查询指定数据库中所有集合
    public void selectCollection(MongoDatabase database) {
        try {
            //查询Test数据库中所有集合名称
            MongoIterable<String> colNameList = database.listCollectionNames();
            for (String colName : colNameList)
                System.out.println(colName);
            System.out.println("[INFO] : Select collection success！");
        } catch (MongoException e) {
            e.printStackTrace();
            System.out.println("[ERROR] : Select collection field！");
        }
    }

    //新建集合

    public void createCollection(MongoDatabase database){

        try{
            //创建新集合
            database.createCollection("testCol");
            System.out.println("[INFO] : Create collection success！");
        }catch(MongoException e){
            e.printStackTrace();
            System.out.println("[ERROR] : Create collection field！");
        }
    }

    //删除集合
    public void deleteCollection(MongoDatabase database){
        try{
            //删除集合
            MongoCollection mongoCollection = database.getCollection("testCol");
            mongoCollection.drop();
            System.out.println("[INFO] : Drop collection success！");
        }catch(MongoException e){
            e.printStackTrace();
            System.out.println("[ERROR] : Drop collection field！");
        }
    }

    //查询文档数据
    public void selectData(MongoDatabase database){
        try{
            //获取数据库中的user集合
            MongoCollection<Document> collection = database.getCollection("user");
            //获取user集合中的文档
            FindIterable<org.bson.Document> iterable = collection.find();
            //通过迭代器遍历找到的文档中的信息
            MongoCursor<org.bson.Document> iterator = iterable.iterator();
            while(iterator.hasNext()){
                System.out.println(iterator.next().toJson());
            }
            System.out.println("[INFO] : Select data success！");
        }catch(MongoException e){
            e.printStackTrace();
            System.out.println("[ERROR] : Select data field！");
        }
    }

    //插入数据
    public void insertData(MongoDatabase database){
        try {
            MongoCollection mongoCollection = database.getCollection("user");
            //一次插入一条数据
            Document document = new Document("user_id","4")
                    .append("user_name","test")
                    .append("user_pwd","test");
            mongoCollection.insertOne(document);
            //一次插入多条数据
            Document document1 = new Document("user_id","5")
                    .append("user_name","test")
                    .append("user_pwd","test1");
            Document document2 = new Document("user_id","6")
                    .append("user_name","test")
                    .append("user_pwd","test2");
            List<Document> documents = new ArrayList<>();
            documents.add(document1);
            documents.add(document2);
            mongoCollection.insertMany(documents);
            System.out.println("[INFO] : Insert data success！");
        }catch(MongoException e){
            e.printStackTrace();
            System.out.println("[ERROR] : Insert data field！");
        }
    }

    //修改数据
    public void updateData(MongoDatabase database){
        try {
            MongoCollection mongoCollection = database.getCollection("user");
            //修改满足条件的第一条数据
            mongoCollection.updateOne(Filters.eq("user_name","test"),new Document("$set",new Document("user_pwd","tttt")));
            //修改满足条件的所有数据
            mongoCollection.updateMany(Filters.eq("user_name","test"),new Document("$set",new Document("user_pwd","tttt")));
            System.out.println("[INFO] : Update data success！");
        }catch(MongoException e){
            e.printStackTrace();
            System.out.println("[ERROR] : Update data field！");
        }
    }

    //删除数据
    public void deleteData(MongoDatabase database){
        try {
            MongoCollection mongoCollection = database.getCollection("user");
            //删除满足条件的第一条记录
            mongoCollection.deleteOne(Filters.eq("user_name","test"));
            //删除满足条件的所有数据
            mongoCollection.deleteMany(Filters.eq("user_name","test"));
            System.out.println("[INFO] : Delete data success！");
        }catch(MongoException e){
            e.printStackTrace();
            System.out.println("[ERROR] : Delete data field！");
        }
    }
    public static void main(String args[]){
        MongoTest mongoTest =new MongoTest();
        MongoDBConnection mongoDBConnection = new MongoDBConnection();
        //新建链接
        MongoClient mongoClient = mongoDBConnection.getConn();
        //创建数据库对象
        MongoDatabase mongoDatabase = mongoClient.getDatabase("Test");


        //在Test里新建集合
        //mongoTest.createCollection(mongoDatabase);

        //删除集合
        //mongoTest.deleteCollection(mongoDatabase);


        //查询Test数据库中所有集合名称
        mongoTest.selectCollection(mongoDatabase);

        //插入数据
        //mongoTest.insertData(mongoDatabase);

        //修改数据
        //mongoTest.updateData(mongoDatabase);

        //删除数据
        //mongoTest.deleteData(mongoDatabase);

        //查询数据文档
        //mongoTest.selectData(mongoDatabase);

        //关闭连接
        mongoClient.close();

    }
}