MongoDB 3.6独立Java应用：如何用JUnit编写连接检查测试

首先，先明确你的连接方法该返回什么：

• 如果你的方法是用来获取MongoDB连接实例的，直接返回MongoClient就好——这是MongoDB 3.x驱动的核心连接类，后续操作数据库都靠它。
• 如果是专门做连接状态检查的工具方法，返回boolean最直观：成功连接返回true，连接失败（比如网络问题、服务未启动）返回false。

接下来给你两种测试思路，分别对应测试真实MongoDB实例和嵌入式Mongo（适合单元测试，不用依赖外部服务）：

一、测试真实MongoDB实例的连接 #

假设你的连接代码类似这样（3.x驱动的标准写法）：

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;

public class MongoConnector {
    public MongoClient getMongoClient() {
        // 替换成你的MongoDB连接地址
        MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
        return new MongoClient(uri);
    }

    // 专门的连接检查方法
    public boolean isConnected() {
        try (MongoClient client = getMongoClient()) {
            // 执行ping命令验证连接——这是MongoDB内置的轻量验证方式
            client.getDatabase("admin").runCommand(new org.bson.Document("ping", 1));
            return true;
        } catch (Exception e) {
            // 捕获所有连接相关异常（比如连接超时、服务不可达）
            return false;
        }
    }
}

对应的JUnit 4测试代码可以这么写：

import org.junit.Test;
import static org.junit.Assert.*;

public class MongoConnectorTest {
    private MongoConnector connector = new MongoConnector();

    @Test
    public void testGetMongoClient() {
        // 尝试获取连接并执行ping命令
        try (MongoClient client = connector.getMongoClient()) {
            client.getDatabase("admin").runCommand(new org.bson.Document("ping", 1));
            // 走到这里说明没抛异常，连接正常
            assertTrue("MongoDB连接成功", true);
        } catch (Exception e) {
            // 连接失败时断言失败，并输出错误信息
            fail("MongoDB连接失败：" + e.getMessage());
        }
    }

    @Test
    public void testIsConnected() {
        // 直接断言连接检查方法返回true
        assertTrue("MongoDB应该能正常连接", connector.isConnected());
    }
}

二、用嵌入式Mongo做单元测试（推荐） #

如果不想依赖外部的MongoDB服务，可以用嵌入式Mongo库，它会在测试时启动一个临时的MongoDB实例，测试结束后自动销毁。

首先需要在pom.xml（Maven）里加依赖（对应MongoDB 3.6版本）：

<dependency>
    <groupId>de.flapdoodle.embed</groupId>
    <artifactId>de.flapdoodle.embed.mongo</artifactId>
    <version>2.2.0</version>
    <scope>test</scope>
</dependency>

然后写测试代码：

import com.mongodb.MongoClient;
import de.flapdoodle.embed.mongo.MongodExecutable;
import de.flapdoodle.embed.mongo.MongodProcess;
import de.flapdoodle.embed.mongo.MongodStarter;
import de.flapdoodle.embed.mongo.config.MongodConfigBuilder;
import de.flapdoodle.embed.mongo.config.Net;
import de.flapdoodle.embed.mongo.distribution.Version;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import static org.junit.Assert.*;

public class EmbeddedMongoTest {
    private MongodExecutable mongodExecutable;
    private MongoClient mongoClient;

    @Before
    public void setUp() throws Exception {
        // 启动嵌入式MongoDB 3.6实例
        MongodStarter starter = MongodStarter.getDefaultInstance();
        MongodConfigBuilder configBuilder = new MongodConfigBuilder()
                .version(Version.Main.V3_6)
                .net(new Net("localhost", 27018, false)); // 用非默认端口避免冲突

        mongodExecutable = starter.prepare(configBuilder.build());
        MongodProcess mongodProcess = mongodExecutable.start();

        // 创建连接到嵌入式实例
        mongoClient = new MongoClient("localhost", 27018);
    }

    @Test
    public void testEmbeddedMongoConnection() {
        // 执行ping验证连接
        mongoClient.getDatabase("test_db").runCommand(new org.bson.Document("ping", 1));
        assertTrue("嵌入式MongoDB连接成功", true);
    }

    @After
    public void tearDown() throws Exception {
        // 清理资源：关闭连接和嵌入式Mongo进程
        if (mongoClient != null) {
            mongoClient.close();
        }
        if (mongodExecutable != null) {
            mongodExecutable.stop();
        }
    }
}

关键注意点 #

• MongoDB 3.x驱动的MongoClient实现了AutoCloseable，所以可以用try-with-resources语法自动关闭连接，避免资源泄漏。
• 验证连接的核心是执行ping命令——这个命令不会修改数据，只是确认服务能正常响应，是最可靠的连接检查方式。

内容的提问来源于stack exchange，提问作者Rose