Mongodb连接测试程序【Java版】

先导入Maven依赖

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

import com.mongodb.MongoClientSettings;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoDatabase;

import java.util.Collections;

public class MongoDBConnectionTest {
    public static void main(String[] args) {
        // MongoDB连接参数
        String username = "";
        String password = "";
        String authenticationDatabase = "";
        String host = "";
        int port = 27017;
        String databaseName = "";
        String replicaSet = "";

        // 创建凭据，使用SCRAM-SHA-1
        MongoCredential credential = MongoCredential.createScramSha1Credential(username, authenticationDatabase, password.toCharArray());

        // 创建MongoDB客户端设置
        MongoClientSettings settings = MongoClientSettings.builder()
                .applyToClusterSettings(builder ->
                        builder.hosts(Collections.singletonList(new ServerAddress(host, port)))
                                .requiredReplicaSetName(replicaSet)
                )
                .credential(credential)
                .build();

        try (MongoClient mongoClient = MongoClients.create(settings)) {
            // 获取数据库
            MongoDatabase database = mongoClient.getDatabase(databaseName);
            // 尝试连接数据库，打印集合名称
            for (String name : database.listCollectionNames()) {
                System.out.println("Collection: " + name);
            }
            System.out.println("连接成功");
        } catch (Exception e) {
            System.out.println("连接失败: " + e.getMessage());
            e.printStackTrace();
        }
    }
}

代码亲测可以