カーソルからデータにアクセスする

Overview

このガイドでは、カーソルを使用してデータにアクセスする方法を学びます。

カーソルは、アプリケーションがデータベースの結果を反復処理しながら、特定の時点でメモリ内に結果のサブセットのみを保持できるようにするメカニズムです。複数のドキュメントに一致する読み取り操作では、カーソルを使用して、それらのドキュメントを一度にではなくバッチで返します。

cursor, err := coll.Find(context.TODO(), bson.D{})
if err != nil {
	panic(err)
}

ドキュメントを個別に検索する

現在のゴルーチンをブロックしながらカーソルからドキュメントを個別に検索するには、Next() メソッドを使用します。

このメソッドでは、次の条件がすべて満たされた場合にドキュメントが返されます。

• ドキュメントは現在利用可能であるか、または今後利用可能になります。

• ドライバーはエラーをスローしませんでした。

• コンテキストは期限切れになりませんでした。

for cursor.Next(context.TODO()) {
	var result MyStruct
	if err := cursor.Decode(&result); err != nil {
		log.Fatal(err)
	}
	fmt.Printf("%+v\n", result)
}
if err := cursor.Err(); err != nil {
	log.Fatal(err)
}

for {
	if cursor.TryNext(context.TODO()) {
		var result MyStruct
		if err := cursor.Decode(&result); err != nil {
			log.Fatal(err)
		}
		fmt.Printf("%+v\n", result)
		continue
	}
	if err := cursor.Err(); err != nil {
		log.Fatal(err)
	}
	if cursor.ID() == 0 {
		break
	}
}

すべてのドキュメントを検索する

すべてのクエリ結果を配列に取り込むには、All() メソッドを使用します。

var results []MyStruct
if err = cursor.All(context.TODO(), &results); err != nil {
	panic(err)
}
for _, result := range results {
	fmt.Printf("%+v\n", result)
}

カーソルを閉じる

アプリケーションでカーソルが不要になったら、Close() メソッドを使用してカーソルを閉じます。このメソッドは、クライアント アプリケーションと MongoDB サーバーの両方でカーソルが消費するリソースを解放します。

defer cursor.Close(context.TODO())

詳細情報

このガイドで説明した操作の詳細については、次のガイドを参照してください。

• Retrieve Data

• クエリを指定する

• BSON との連携

• テール可能カーソル