クエリを使用した MongoDB からのデータの読み取り
Overview
前のガイド「MongoDB でのデータの読み取り」では、ドキュメントが満たすべき条件を指定せずに、sample_guides.planets
コレクションからすべてのドキュメントを検索しました。
このガイドでは、コレクションに対してクエリを実行し、特定の等価条件を満たすドキュメントを検索します。つまり、指定された 1 つまたは複数のフィールドの値が一致する必要があります。
所要時間: 15 分
必要なもの
MongoDB 配置への 接続文字列。
手順
MongoDB インスタンスに接続します。
Tip
このコードブロックには、接続 URI を独自のものに置き換えるためのコメントがあります。URI文字列を独自の Atlas 接続文字列に置き換えます。
Tip
以下は、MongoDB に接続するために最低限必要なコードの概要です。次の数ステップで、データを読み込むための追加を行います。
5 行目で、URI 文字列を独自の Atlas 接続文字列に置き換えます。
1 using MongoDB.Bson;
2 using MongoDB.Driver;
3
4 // Replace the uri string with your MongoDB deployment's connection string.
5 var uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority";
6
7 var client = new MongoClient(uri);
8
9 // database and collection code goes here
10 // find code goes here
11 // iterate code goes here
12
13
14
Tip
以下は、MongoDB に接続するために最低限必要なコードの概要です。次の数ステップで、データを読み込むための追加を行います。
11 行目の URI 文字列を独自の Atlas 接続文字列に置き換えます。
1 package main 2 3 import ( 4 "context" 5 6 "go.mongodb.org/mongo-driver/mongo" 7 "go.mongodb.org/mongo-driver/mongo/options" 8 ) 9 10 func main() { 11 uri := "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority" 12 13 client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI(uri)) 14 if err != nil { 15 panic(err) 16 } 17 18 defer func() { 19 if err = client.Disconnect(context.TODO()); err != nil { 20 panic(err) 21 } 22 }() 23 24 // database and colletion code goes here 25 // find code goes here 26 // iterate code goes here 27 }
Tip
以下は、MongoDB に接続するために最低限必要なコードの概要です。次の数ステップで、データを読み込むための追加を行います。
8 行目の URI 文字列を独自の Atlas 接続文字列に置き換えます。
1 import com.mongodb.client.*; 2 import com.mongodb.client.model.Filters.*; 3 import org.bson.Document; 4 import org.bson.conversions.Bson; 5 6 public class CrudRead { 7 public static void main(String[] args) { 8 String uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority"; 9 10 try (MongoClient mongoClient = MongoClients.create(uri)) { 11 // database and collection code goes here 12 // find code goes here 13 // iterate code goes here 14 } 15 } 16 }
Tip
以下は、MongoDB に接続するために最低限必要なコードの概要です。次の数ステップで、データを読み込むための追加を行います。
4 行目で、URI 文字列を独自の Atlas 接続文字列に置き換えます。
1 const { MongoClient } = require("mongodb"); 2 // Replace the uri string with your MongoDB deployment's connection string. 3 const uri = 4 "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority"; 5 const client = new MongoClient(uri); 6 async function run() { 7 try { 8 await client.connect(); 9 // database and collection code goes here 10 // find code goes here 11 // iterate code goes here 12 } finally { 13 // Ensures that the client will close when you finish/error 14 await client.close(); 15 } 16 } 17 run().catch(console.dir);
Tip
以下は、MongoDB に接続するために最低限必要なコードの概要です。次の数ステップで、データを読み込むための追加を行います。
4 行目で、URI 文字列を独自の Atlas 接続文字列に置き換えます。
1 from pymongo import MongoClient 2 3 # Replace the uri string with your MongoDB deployment's connection string. 4 uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority" 5 6 client = MongoClient(uri) 7 8 # database and collection code goes here 9 # find code goes here 10 # iterate code goes here 11 12 # Close the connection to MongoDB when you're done. 13 client.close()
Tip
mongodb+srv
srv
オプションを選択した状態で、PyMongo をインストールしておきます。
python3 -m pip install "pymongo[srv]"
データベースとコレクションを取得します。
クエリするデータベースとコレクションに切り替えます。この場合は、sample_guides
データベースと planets
コレクションを使用します。
// database and collection code goes here
var db = client.GetDatabase("sample_guides");
var coll = db.GetCollection<BsonDocument>("planets");
1 // database and colletion code goes here 2 db := client.Database("sample_guides") 3 coll := db.Collection("planets")
1 // database and collection code goes here 2 MongoDatabase db = mongoClient.getDatabase("sample_guides"); 3 MongoCollection<Document> coll = db.getCollection("planets");
// database and collection code goes here const db = client.db("sample_guides"); const coll = db.collection("planets");
# database and collection code goes here db = client.sample_guides coll = db.planets
planets
コレクション内の特定のドキュメントを検索します。
クエリフィルターを適用することで、コレクションから特定のドキュメントを検索できます。クエリフィルターとは、検索する条件を含むドキュメントです。次の例では、クエリフィルターを使用して、hasRings
フィールドの値が true
のドキュメントを planets
コレクションから検索する方法を示しています。
// find code goes here
var cursor = from planet in coll.AsQueryable()
where planet["hasRings"] == true
select planet;
Tip
BSON.D
BSON.D
は順序付けされているため、MongoDB にドキュメントを送信するときに使用する必要があります。これは、より複雑な操作において重要です。
1 // find code goes here 2 filter := bson.D{{"hasRings", true}} 3 cursor, err := coll.Find(context.TODO(), filter) 4 if err != nil { 5 panic(err) 6 }
MongoDB Java ドライバーには、クエリ(およびその他の操作)の作成プロセスを簡素化するビルダが含まれます。ここでは、Filters.eq
ビルダを使用してクエリ ドキュメントを構築します。
1 // find code goes here 2 Bson filter = eq("hasRings", true); 3 MongoCursor<Document> cursor = coll.find(filter).iterator();
// find code goes here const cursor = coll.find({ hasRings: true });
# find code goes here cursor = coll.find({"hasRings": True})
結果を反復処理します。
// iterate code goes here
foreach (var document in cursor.ToEnumerable())
{
Console.WriteLine(document);
}
1 // iterate code goes here 2 for cursor.Next(context.TODO()) { 3 var result bson.M 4 if err := cursor.Decode(&result); err != nil { 5 panic(err) 6 } 7 fmt.Println(result) 8 } 9 if err := cursor.Err(); err != nil { 10 panic(err) 11 }
1 // iterate code goes here 2 try { 3 while (cursor.hasNext()) { 4 System.out.println(cursor.next().toJson()); 5 } 6 } finally { 7 cursor.close(); 8 }
結果を反復処理し、コンソールに出力します。このような操作は MongoDB Node.js ドライバーではデフォルトで非同期です。つまり、Node.js ランタイムは操作の実行終了を待つ間でも、他の操作をブロックしません。
操作を簡単にするために、await
キーワードを指定します。この指定により、ランタイムは操作を待機するようになります。これは、コールバックを指定したり、Promise を連鎖させるよりも簡単な場合があります。
詳細については、「Promise とコールバックのガイド」を参照してください。
// iterate code goes here await cursor.forEach(console.log);
# iterate code goes here for doc in cursor: print(doc)
結果を確認します。
完全なコードとサンプル出力は次のとおりです。
注意
ObjectId
値は表示されている値とは異なります。
完全なコードとサンプル出力は次のとおりです。
1 using MongoDB.Bson;
2 using MongoDB.Driver;
3
4 // Replace the uri string with your MongoDB deployment's connection string.
5 var uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority";
6
7 var client = new MongoClient(uri);
8
9 // database and collection code goes here
10 var db = client.GetDatabase("sample_guides");
11 var coll = db.GetCollection<BsonDocument>("planets");
12 // find code goes here
13 var cursor = from planet in coll.AsQueryable()
14 where planet["hasRings"] == true
15 select planet;
16 // iterate code goes here
17 foreach (var document in cursor)
18 {
19 Console.WriteLine(document);
20 }
21
22
{... 'name': 'Uranus', 'hasRings': True, ...} {... 'name': 'Neptune', 'hasRings': True, ... } {... 'name': 'Jupiter', 'hasRings': True, ... } {... 'name': 'Saturn', 'hasRings': True, ... }
完全なコードとサンプル出力は次のとおりです。表示の都合上、ここでは出力されたドキュメントが切り捨てられています。
1 package main 2 3 import ( 4 "context" 5 "fmt" 6 7 "go.mongodb.org/mongo-driver/bson" 8 "go.mongodb.org/mongo-driver/mongo" 9 "go.mongodb.org/mongo-driver/mongo/options" 10 ) 11 12 func main() { 13 uri := "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority" 14 15 client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI(uri)) 16 if err != nil { 17 panic(err) 18 } 19 20 defer func() { 21 if err = client.Disconnect(context.TODO()); err != nil { 22 panic(err) 23 } 24 }() 25 26 // database and colletion code goes here 27 db := client.Database("sample_guides") 28 coll := db.Collection("planets") 29 30 // find code goes here 31 filter := bson.D{{"hasRings", true}} 32 cursor, err := coll.Find(context.TODO(), filter) 33 if err != nil { 34 panic(err) 35 } 36 37 // iterate code goes here 38 for cursor.Next(context.TODO()) { 39 var result bson.M 40 if err := cursor.Decode(&result); err != nil { 41 panic(err) 42 } 43 fmt.Println(result) 44 } 45 if err := cursor.Err(); err != nil { 46 panic(err) 47 } 48 49 }
map[... hasRings:true name:Uranus ... ]] map[... hasRings:true name:Neptune ... ]] map[... hasRings:true name:Jupiter ... ]] map[... hasRings:true name:Saturn ... ]]
完全なコードとサンプル出力は次のとおりです。
1 import com.mongodb.client.*; 2 import com.mongodb.client.model.Filters.*; 3 import org.bson.Document; 4 import org.bson.conversions.Bson; 5 6 public class CrudRead { 7 public static void main(String[] args) { 8 String uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority"; 9 10 try (MongoClient mongoClient = MongoClients.create(uri)) { 11 // database and collection code goes here 12 MongoDatabase db = mongoClient.getDatabase("sample_guides"); 13 MongoCollection<Document> coll = db.getCollection("planets"); 14 15 // find code goes here 16 Bson filter = eq("hasRings", true); 17 MongoCursor<Document> cursor = coll.find(filter).iterator(); 18 19 // iterate code goes here 20 try { 21 while (cursor.hasNext()) { 22 System.out.println(cursor.next().toJson()); 23 } 24 } finally { 25 cursor.close(); 26 } 27 } 28 } 29 }
{... 'name': 'Uranus', 'hasRings': True, ...} {... 'name': 'Neptune', 'hasRings': True, ... } {... 'name': 'Jupiter', 'hasRings': True, ... } {... 'name': 'Saturn', 'hasRings': True, ... }
完全なコードとサンプル出力は次のとおりです。
1 const { MongoClient } = require("mongodb"); 2 // Replace the uri string with your MongoDB deployment's connection string. 3 const uri = 4 "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority"; 5 const client = new MongoClient(uri); 6 async function run() { 7 try { 8 await client.connect(); 9 // database and collection code goes here 10 const db = client.db("sample_guides"); 11 const coll = db.collection("planets"); 12 13 // find code goes here 14 const cursor = coll.find({ hasRings: true }); 15 16 // iterate code goes here 17 await cursor.forEach(console.log); 18 } finally { 19 // Ensures that the client will close when you finish/error 20 await client.close(); 21 } 22 } 23 run().catch(console.dir);
{... 'name': 'Uranus', 'hasRings': True, ...} {... 'name': 'Neptune', 'hasRings': True, ... } {... 'name': 'Jupiter', 'hasRings': True, ... } {... 'name': 'Saturn', 'hasRings': True, ... }
完全なコードとサンプル出力は次のとおりです。
1 from pymongo import MongoClient 2 3 # Replace the uri string with your MongoDB deployment's connection string. 4 uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority" 5 6 client = MongoClient(uri) 7 8 # database and collection code goes here 9 db = client.sample_guides 10 coll = db.planets 11 # find code goes here 12 cursor = coll.find({"hasRings": True}) 13 # iterate code goes here 14 for doc in cursor: 15 print(doc) 16 17 # Close the connection to MongoDB when you're done. 18 client.close()
{... 'name': 'Uranus', 'hasRings': True, ...} {... 'name': 'Neptune', 'hasRings': True, ... } {... 'name': 'Jupiter', 'hasRings': True, ... } {... 'name': 'Saturn', 'hasRings': True, ... }
複数の条件を使用してクエリを実行します。
複数の条件を使用してコレクションをクエリすることもできます。次の例では、複数の条件を使用して、mainAtmosphere
フィールドにエントリとして、hasRings
フィールドにフィールドの値が false
と Argon(Ar)
を持つドキュメントを planets
コレクションから取得する方法を示しています。
完全なコードとサンプル出力は次のとおりです。
1 // find code goes here
2 var cursor = from planet in coll.AsQueryable()
3 where planet["hasRings"] == false
4 where planet["mainAtmosphere"] == "Ar"
5 select planet;
{..., "name" : "Mars", "mainAtmosphere" : ["CO2", "Ar", "N"], ... } {..., "name" : "Earth", "mainAtmosphere" : ["N", "O2", "Ar"], ... }
完全なコードとサンプル出力は次のとおりです。表示の都合上、ここでは出力されたドキュメントが切り捨てられています。
1 // find code goes here 2 filter := bson.D{ 3 {"$and", 4 bson.A{ 5 bson.D{{"hasRings", false}}, 6 bson.D{{"mainAtmosphere", "Ar"}}, 7 }, 8 }, 9 } 10 cursor, err := coll.Find(context.TODO(), filter) 11 if err != nil { 12 panic(err) 13 }
map[... hasRings:false mainAtmosphere:[CO2 Ar N] ... ]] map[... hasRings:false mainAtmosphere:[N O2 Ar] ... ]]
完全なコードとサンプル出力は次のとおりです。
1 // find code goes here 2 Bson filter = and(eq("hasRings", false), eq("mainAtmosphere", "Ar")); 3 MongoCursor<Document> cursor = coll.find(filter).iterator();
{..., "name" : "Mars", "mainAtmosphere" : ["CO2", "Ar", "N"], ... } {..., "name" : "Earth", "mainAtmosphere" : ["N", "O2", "Ar"], ... }
完全なコードとサンプル出力は次のとおりです。
1 // find code goes here 2 const cursor = coll.find({ hasRings: false, mainAtomsphere: "Ar" });
{..., "name" : "Mars", "mainAtmosphere" : ["CO2", "Ar", "N"], ... } {..., "name" : "Earth", "mainAtmosphere" : ["N", "O2", "Ar"], ... }
1 # find code goes here 2 cursor = coll.find({"hasRings": False, "mainAtmosphere": "Ar"})
{..., "name" : "Mars", "mainAtmosphere" : ["CO2", "Ar", "N"], ... } {..., "name" : "Earth", "mainAtmosphere" : ["N", "O2", "Ar"], ... }
mainAtmosphere
フィールドが配列であっても、MongoDB は配列をファーストクラスの型として扱うため、厳密な等価クエリを使用できます。クエリの実行中、MongoDB は配列の各エントリを指定した値(この場合は "Ar"
)と比較して、ドキュメントが条件に一致しているかどうかを判断します。
概要
このガイドを読み終えたら、特定の等価条件を使って MongoDB からデータを検索したことになります。これは、商品番号、ユーザー名、化学元素など、検索対象が正確にわかっている場合に便利です。
次のガイドでは、比較演算子を使用して MongoDB からデータを読み取り、より広範な条件に一致するドキュメントを検索する方法を学習します。
その他の参照
ここで紹介した概念に関する詳しい情報については、次のリソースを参照してください。
The MongoDB C# ドライバー のドキュメンテーション
The MongoDB Go ドライバーのドキュメンテーション
MongoDB Java(同期)ドライバーのドキュメント
The MongoDB Node.js ドライバーのドキュメンテーション
PyMongo のドキュメンテーション