javaでmongodbのクラスターに接続する方法

2年 ago
結衣, 春花
1 minute

MongoDBクラスタに接続するにはMongoDBのJavaドライバを使用することができる。

まず、プロジェクトにMongoDB Javaドライバの依存関係を追加する必要があります。依存関係の追加には、MavenまたはGradleを使用できます。

Maven の場合は、pom.xml ファイルに依存性の追加を行います。

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

Gradle の場合は、プロジェクトの build.gradle ファイルに次の依存関係を追加できます。

dependencies {
    implementation 'org.mongodb:mongodb-driver-sync:4.4.3'
}

その後、以下のコードを使用して MongoDB クラスタに接続できます。

import com.mongodb.ConnectionString;
import com.mongodb.MongoClientSettings;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;

public class MongoDBConnection {
    public static void main(String[] args) {
        // 定义 MongoDB 连接字符串
        String connectionString = "mongodb://hostname1:port1,hostname2:port2,hostname3:port3/?replicaSet=myReplicaSet";

        // 创建 MongoDB 连接字符串对象
        ConnectionString connString = new ConnectionString(connectionString);

        // 创建 MongoDB 客户端设置
        MongoClientSettings settings = MongoClientSettings.builder()
                .applyConnectionString(connString)
                .build();

        // 创建 MongoDB 客户端
        MongoClient mongoClient = MongoClients.create(settings);

        // 使用 mongoClient 进行操作
        // ...
        
        // 关闭 MongoDB 客户端
        mongoClient.close();
    }
}

上のコードでは、hostname1:port1, hostname2:port2, hostname3:port3 を実際 mongoDB クラスタにあるホスト名と、ポート番号に置き換える必要があります。replicaSet=myReplicaSet は省略可能で、クラスタのレプリカセット名を指定します。

mongoClientオブジェクトでは、ドキュメントの追加、照会、更新、削除など、様々なMongoDB操作を実行できます。

最後にMongoDBクライアントの操作が終わったら、クライアントを閉じることを忘れないようにしましょう。

お役に立てれば幸いです！

bannerAds