CRUD操作の構成

書込み保証 (write concern)

書込み保証 (write concern) は、挿入やアップデートなどの 書込み (write)操作を確認しなければならないレプリカセット内のデータを保持するノードの数を示します。その後、操作は成功として返されます。デフォルトでは 、プライマリレプリカセットノードのみが確認した場合、書込み操作は成功します。

uri := "mongodb://<hostname>:<port>"
journal := false
cliWC := &writeconcern.WriteConcern{
    W: 2,
    Journal: &journal,
}
clOpts := options.Client().ApplyURI(uri).SetWriteConcern(cliWC)
client, err := mongo.Connect(clOpts)
...
collWC := writeconcern.Majority()
collOpts := options.Collection().SetWriteConcern(collWC)
coll := client.Database("db").Collection("myColl", collOpts)

読み取り保証（read concern）

読み取り保証（read concern）オプションを使用すると、クライアントがクエリから返すデータを決定できます。 デフォルトの読み取り保証 (read concern) レベルは "local" です。つまり、クライアントはインスタンスの最新データを返しますが、そのデータがレプリカセットのノードの過半数に書き込まれたことは保証されません。

rc := readconcern.Majority()
opts := options.Collection().SetReadConcern(rc)
database := client.Database("db")
coll := database.Collection("myCollection", opts)

読み込み設定 (read preference)

読み込み設定（read preference）オプションは、MongoDB クライアントが読み取り操作を レプリカセット のノードにルーティングする方法を指定します。 デフォルトでは、アプリケーションの読み取り操作は、 レプリカセット 内の プライマリ を対象に行われます。

読み込み設定 (read preference) は、読み込み設定 (read preference) モードと、オプションのタグセット リスト、 maxStalenessSecondsオプション、およびヘッジされた読み取りオプションで構成されています。

rp := readpref.Secondary()
opts := options.Database().SetReadPreference(rp)
database := client.Database("db", opts)

照合の指定

照合を指定するには、Collationオブジェクトを作成します。 Collationオブジェクトの Localeフィールドを定義する必要がありますが、他のフィールドはすべて任意です。例、次のコード例では、"en_US"ロケール照合を持つ Collationオブジェクトを指定しています。

myCollation := &options.Collation{Locale: "en_US"}

オブジェクト フィールドの完全なリストについては、 照合 API ドキュメント をご覧くださいCollation 。サポートされているすべてのロケールとLocaleフィールドのデフォルト値を確認するには、 「サポートされている言語とロケール」 をご覧ください。

コレクションまたはビューでの照合の設定

新しいコレクションまたはビューを作成するときに照合を適用できます。 これにより、そのコレクションまたはビューで呼び出される操作のデフォルトの照合方法が定義されます。 CreateCollectionOptionsまたはCreateViewOptionsオブジェクトを介して照合を設定します。 次に、オプション オブジェクトを引数としてCreateCollection()またはCreateView()メソッドを呼び出します。

myCollation := &options.Collation{Locale: "fr", Strength: 1}
opts := options.CreateCollection().SetCollation(myCollation)
err := db.CreateCollection(context.TODO(), "books", opts)
if err != nil {
   panic(err)
}

デフォルトの照合例の使用

booksコレクションで照合を使用する操作を呼び出すと、操作はコレクションの作成例 で指定されたデフォルトの照合を使用します。

booksコレクションには次のドキュメントが含まれているとします。

{"name" : "Emma", "length" : "474"}
{"name" : "Les Misérables", "length": "1462"}
{"name" : "Infinite Jest", "length" : "1104"}
{"name" : "Cryptonomicon", "length" : "918"}
{"name" : "Ça", "length" : "1138"}

次の例では、 Find()メソッドを使用して、 "Infinite Jest"のアルファベット順に先行するname値を持つすべてのドキュメントを返します。

filter := bson.D{{"name", bson.D{{"$lt", "Infinite Jest"}}}}
cursor, err := coll.Find(context.TODO(), filter)
if err != nil {
   panic(err)
}
var results []bson.D
if err = cursor.All(context.TODO(), &results); err != nil {
   panic(err)
}
for _, result := range results {
   res, _ := bson.MarshalExtJSON(result, false, false)
   fmt.Println(string(res))
}

{"name":"Emma","length":"474"}
{"name":"Cryptonomicon","length":"918"}
{"name":"Ça","length":"1138"}

コードでデフォルトのbooks 照合が指定されていない場合、Find() メソッドはデフォルトのバイナリ照合ルールに従って、"Infinite Jest" に先行する name 値を決定します。これらのルールでは、"$" で始まる単語が、"I" で始まる単語の後に配置されます。出力は、次のようになります。

{"name":"Emma","length":"474"}
{"name":"Cryptonomicon","length":"918"}

Find()メソッドについて詳しくは、「 ドキュメントの検索 」を参照してください。

インデックスでの照合の設定

コレクションに新しいインデックスを作成するときに、照合を適用できます。 インデックスはコレクション内のドキュメントの順序付けられた表現を保存するため、MongoDB インスタンスはメモリ内でソート操作の順序付けを実行しません。

操作でインデックスを使用するには、インデックスで指定された照合と同じ照合を使用する必要があります。 さらに、操作が照合を含むインデックスでカバーされていることを確認してください。 IndexOptionsオブジェクトを通じて照合を設定し、このオブジェクトをCreateOne()メソッドの引数として渡します。

 myCollation := &options.Collation{Locale: "en_US"}
 opts := options.Index().SetCollation(myCollation)
 indexModel := mongo.IndexModel{
   Keys:    bson.D{{"name", 1}},
   Options: opts,
 }
 name, err := coll.Indexes().CreateOne(context.TODO(), indexModel)
 if err != nil {
   panic(err)
 }
 fmt.Println("Name of Index Created: " + name)

 Name of Index Created: name_1

操作での照合の設定

コレクションからドキュメントを読み取り、更新、削除する操作では、照合を使用できます。 操作に照合を適用すると、コレクションに対して以前に定義されたデフォルトの照合は上書きされます。

インデックスの照合とは異なる操作に新しい照合を適用する場合、そのインデックスは使用できません。 その結果、操作は、インデックスによってカバーされる操作ほどパフォーマンスが良くない可能性があります。 インデックスで説明されていないソート操作の悪影響の詳細については、「クエリ結果をソートするためにインデックスを使用する」を参照してください。 照合をサポートする操作のリストについては、 MongoDB マニュアルを参照してください。

filter := bson.D{{"length", bson.D{{"$gt", "1000"}}}}
myCollation := &options.Collation{Locale: "en_US", NumericOrdering: true}
opts := options.Find().SetCollation(myCollation)
cursor, err := coll.Find(context.TODO(), filter, opts)
if err != nil {
   panic(err)
}
var results []bson.D
if err = cursor.All(context.TODO(), &results); err != nil {
   panic(err)
}
for _, result := range results {
   res, _ := bson.MarshalExtJSON(result, false, false)
   fmt.Println(string(res))
}

{"name":"Les Misérables","length":"1462"}
{"name":"Infinite Jest","length":"1104"}
{"name":"Ça","length":"1138"}

{"name":"Emma","length":"474"}
{"name":"Les Misérables","length":"1462"}
{""name":"Infinite Jest","length":"1104"}
{"name":"Cryptonomicon","length":"918"}
{"name":"Ça","length":"1138"}

API ドキュメント

このガイドで説明されているメソッドの詳細については、次の API ドキュメントを参照してください。

• WriteConcern

• ReadConcern

• ReadPref

• 照合

• CreateCollectionOptions

• IndexModel

• CreateOne()

• インデックス オプション

• UpdateOneOptions

• UpdateManyOptions