MongoDB に接続する

MongoClient

MongoClient クラスを使用して MongoDB に接続し、通信することができます。

MongoClient を構築するには、MongoClient.create() メソッドを使用します。

ドライバーで接続プールがどのように機能するかについて詳しくは、 FAQ ページ をご覧ください。

最大接続数などのすべてのリソース使用制限は、個々の MongoClient インスタンスに適用されます。

MongoClient の動作を制御するために使用できるさまざまな設定の詳細については、「MongoClient 設定」のガイドを参照してください。

接続URI

接続 URI は、ドライバが MongoDB 配置に接続するための指示のセットを提供します。このセットで、ドライバーに MongoDB への接続方法と接続中の動作を指示します。次の図は、サンプル接続 URI の各部分について説明しています。

この図では、プロトコルに標準接続string形式の mongodb を使用しています。 配置の柔軟性を高め、クライアントを再構成せずにサーバーをローテーションで変更する機能が必要な場合は、 DNS シード リスト接続形式、 mongodb+srvを使用することもできます。

パスワードベースの認証メカニズムを使用している場合、接続 URI の次の部分には認証情報が含まれます。 userの値をデータベースユーザー名に置き換え、 passの値をデータベースユーザーのパスワードに置き換えます。 認証メカニズムで認証情報が必要ない場合は、接続 URI のこの部分を省略します。

接続 URI の次の部分では、ホスト名または IP アドレスを指定し、その後に MongoDB インスタンスのポートを指定します。この例では、sample.host はホスト名を表し、27017 はポート番号を表します。これらの値を置き換えて、MongoDB インスタンスを参照します。

接続 URI の最後の部分には、パラメータとして接続オプションが含まれます。 この例では、 maxPoolSize=20とw=majorityの 2 つの接続オプションを設定しています。 接続オプションの詳細については、このガイドの「接続オプション 」セクションに進んでください。

Atlas 接続例

Atlas 上の MongoDB 配置に接続するには、クライアントを作成します。MongoClientSettings オブジェクトを MongoClient.create() メソッドに渡すことで、接続文字列とその他のクライアント オプションを使用するクライアントを作成できます。

MongoClientSettings オブジェクトをインスタンス化するには、ビルダ メソッドを使用して接続文字列とその他のクライアント オプションを指定し、build() メソッドを呼び出します。接続 URI を指定するには、applyConnectionString() メソッドをビルダにチェーンします。

新しいサーバー バージョンにアップグレードするときに重大な変更を回避するために、Stable API バージョンのクライアント オプションを設定できます。 Stable API 機能について詳しくは、「 Stable API 」ページをご覧ください。

次のコードは、Atlas 上の MongoDB 配置に接続するときに接続文字列と Stable API クライアント オプションを指定し、接続が成功したことを確認する方法を示します。

// Replace the placeholder with your Atlas connection string
val uri = "<connection string>"
// Construct a ServerApi instance using the ServerApi.builder() method
val serverApi = ServerApi.builder()
    .version(ServerApiVersion.V1)
    .build()
val settings = MongoClientSettings.builder()
    .applyConnectionString(ConnectionString(uri))
    .serverApi(serverApi)
    .build()
// Create a new client and connect to the server
val mongoClient = MongoClient.create(settings)
val database = mongoClient.getDatabase("admin")
try {
    // Send a ping to confirm a successful connection
    val command = Document("ping", BsonInt64(1))
    val commandResult = database.runCommand(command)
    println("Pinged your deployment. You successfully connected to MongoDB!")
} catch (me: MongoException) {
    System.err.println(me)
}

MongoDB に接続する他の方法

Atlas でホストされていない単一の MongoDB 配置またはレプリカセットに接続する場合は、次のセクションで接続方法を確認してください。

val connectionString = ConnectionString("mongodb://host1:27017,host2:27017,host3:27017/")
val mongoClient = MongoClient.create(connectionString)

val seed1 = ServerAddress("host1", 27017)
val seed2 = ServerAddress("host2", 27017)
val seed3 = ServerAddress("host3", 27017)
val settings = MongoClientSettings.builder()
    .applyToClusterSettings { builder ->
        builder.hosts(
            listOf(seed1, seed2, seed3)
        )
    }
    .build()
val mongoClient = MongoClient.create(settings)