当前位置：首页 > news >正文

Mongodb连接测试程序【Java版】

news 2025/8/9 2:39:30

先导入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-1MongoCredential 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();}}
}