Docs Menu
Docs Home
/
ガイドを利用する

クエリを使用した MongoDB からのデータの読み取り

前のガイド「MongoDB でのデータの読み取り」では、ドキュメントが満たすべき条件を指定せずに、sample_guides.planets コレクションからすべてのドキュメントを検索しました。

このガイドでは、コレクションに対してクエリを実行し、特定の等価条件を満たすドキュメントを検索します。つまり、指定された 1 つまたは複数のフィールドの値が一致する必要があります。

所要時間: 15 分

1

Tip

このコードブロックには、接続 URI を独自のものに置き換えるためのコメントがあります。URI文字列を独自の Atlas 接続文字列に置き換えます。

Tip

以下は、MongoDB に接続するために最低限必要なコードの概要です。次の数ステップで、データを読み込むための追加を行います。

5 行目で、URI 文字列を独自の Atlas 接続文字列に置き換えます。

CrudRead.cs
1using MongoDB.Bson;
2using MongoDB.Driver;
3
4// Replace the uri string with your MongoDB deployment's connection string.
5var uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority";
6
7var 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 接続文字列に置き換えます。

crudRead.go
1package main
2
3import (
4 "context"
5
6 "go.mongodb.org/mongo-driver/mongo"
7 "go.mongodb.org/mongo-driver/mongo/options"
8)
9
10func 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 接続文字列に置き換えます。

CrudRead.java
1import com.mongodb.client.*;
2import com.mongodb.client.model.Filters.*;
3import org.bson.Document;
4import org.bson.conversions.Bson;
5
6public 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 接続文字列に置き換えます。

crud-read.js
1const { MongoClient } = require("mongodb");
2// Replace the uri string with your MongoDB deployment's connection string.
3const uri =
4 "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority";
5const client = new MongoClient(uri);
6async 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}
17run().catch(console.dir);

Tip

以下は、MongoDB に接続するために最低限必要なコードの概要です。次の数ステップで、データを読み込むための追加を行います。

4 行目で、URI 文字列を独自の Atlas 接続文字列に置き換えます。

CRUD_read.py
1from pymongo import MongoClient
2
3# Replace the uri string with your MongoDB deployment's connection string.
4uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority"
5
6client = 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.
13client.close()

Tip

mongodb+srv

srvオプションを選択した状態で、PyMongo をインストールしておきます。

python3 -m pip install "pymongo[srv]"
2

クエリするデータベースとコレクションに切り替えます。この場合は、sample_guides データベースと planets コレクションを使用します。

CrudRead.cs
// database and collection code goes here
var db = client.GetDatabase("sample_guides");
var coll = db.GetCollection<BsonDocument>("planets");
crudRead.go
1// database and colletion code goes here
2db := client.Database("sample_guides")
3coll := db.Collection("planets")
CrudRead.java
1// database and collection code goes here
2MongoDatabase db = mongoClient.getDatabase("sample_guides");
3MongoCollection<Document> coll = db.getCollection("planets");
crud-read.js
// database and collection code goes here
const db = client.db("sample_guides");
const coll = db.collection("planets");
CRUD_read.py
# database and collection code goes here
db = client.sample_guides
coll = db.planets
3

クエリフィルターを適用することで、コレクションから特定のドキュメントを検索できます。クエリフィルターとは、検索する条件を含むドキュメントです。次の例では、クエリフィルターを使用して、hasRings フィールドの値が true のドキュメントを planets コレクションから検索する方法を示しています。

CrudRead.cs
// find code goes here
var cursor = from planet in coll.AsQueryable()
where planet["hasRings"] == true
select planet;

Tip

BSON.D BSON.D は順序付けされているため、MongoDB にドキュメントを送信するときに使用する必要があります。これは、より複雑な操作において重要です。

crudRead.go
1// find code goes here
2filter := bson.D{{"hasRings", true}}
3cursor, err := coll.Find(context.TODO(), filter)
4if err != nil {
5 panic(err)
6}

MongoDB Java ドライバーには、クエリ(およびその他の操作)の作成プロセスを簡素化するビルダが含まれます。ここでは、Filters.eq ビルダを使用してクエリ ドキュメントを構築します。

CrudRead.java
1// find code goes here
2Bson filter = eq("hasRings", true);
3MongoCursor<Document> cursor = coll.find(filter).iterator();
crud-read.js
// find code goes here
const cursor = coll.find({ hasRings: true });
CRUD_read.py
# find code goes here
cursor = coll.find({"hasRings": True})
4
CrudRead.cs
// iterate code goes here
foreach (var document in cursor.ToEnumerable())
{
Console.WriteLine(document);
}
crudRead.go
1// iterate code goes here
2for 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}
9if err := cursor.Err(); err != nil {
10 panic(err)
11}
CrudRead.java
1// iterate code goes here
2try {
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 とコールバックのガイド」を参照してください。

crud-read.js
// iterate code goes here
await cursor.forEach(console.log);
CRUD_read.py
# iterate code goes here
for doc in cursor:
print(doc)
5

完全なコードとサンプル出力は次のとおりです。

注意

ObjectId 値は表示されている値とは異なります。

完全なコードとサンプル出力は次のとおりです。

CrudRead.cs
1using MongoDB.Bson;
2using MongoDB.Driver;
3
4// Replace the uri string with your MongoDB deployment's connection string.
5var uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority";
6
7var client = new MongoClient(uri);
8
9// database and collection code goes here
10var db = client.GetDatabase("sample_guides");
11var coll = db.GetCollection<BsonDocument>("planets");
12// find code goes here
13var cursor = from planet in coll.AsQueryable()
14 where planet["hasRings"] == true
15 select planet;
16// iterate code goes here
17foreach (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, ... }

完全なコードとサンプル出力は次のとおりです。表示の都合上、ここでは出力されたドキュメントが切り捨てられています。

crudRead.go
1package main
2
3import (
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
12func 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 ... ]]

完全なコードとサンプル出力は次のとおりです。

CrudRead.java
1import com.mongodb.client.*;
2import com.mongodb.client.model.Filters.*;
3import org.bson.Document;
4import org.bson.conversions.Bson;
5
6public 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, ... }

完全なコードとサンプル出力は次のとおりです。

crud-read.js
1const { MongoClient } = require("mongodb");
2// Replace the uri string with your MongoDB deployment's connection string.
3const uri =
4 "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority";
5const client = new MongoClient(uri);
6async 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}
23run().catch(console.dir);
{... 'name': 'Uranus', 'hasRings': True, ...}
{... 'name': 'Neptune', 'hasRings': True, ... }
{... 'name': 'Jupiter', 'hasRings': True, ... }
{... 'name': 'Saturn', 'hasRings': True, ... }

完全なコードとサンプル出力は次のとおりです。

CRUD_read.py
1from pymongo import MongoClient
2
3# Replace the uri string with your MongoDB deployment's connection string.
4uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority"
5
6client = MongoClient(uri)
7
8# database and collection code goes here
9db = client.sample_guides
10coll = db.planets
11# find code goes here
12cursor = coll.find({"hasRings": True})
13# iterate code goes here
14for doc in cursor:
15 print(doc)
16
17# Close the connection to MongoDB when you're done.
18client.close()
{... 'name': 'Uranus', 'hasRings': True, ...}
{... 'name': 'Neptune', 'hasRings': True, ... }
{... 'name': 'Jupiter', 'hasRings': True, ... }
{... 'name': 'Saturn', 'hasRings': True, ... }
6

複数の条件を使用してコレクションをクエリすることもできます。次の例では、複数の条件を使用して、mainAtmosphere フィールドにエントリとして、hasRings フィールドにフィールドの値が falseArgon(Ar) を持つドキュメントを planets コレクションから取得する方法を示しています。

完全なコードとサンプル出力は次のとおりです。

CrudRead.cs
1// find code goes here
2var 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"], ... }

完全なコードとサンプル出力は次のとおりです。表示の都合上、ここでは出力されたドキュメントが切り捨てられています。

crudRead.go
1// find code goes here
2filter := bson.D{
3 {"$and",
4 bson.A{
5 bson.D{{"hasRings", false}},
6 bson.D{{"mainAtmosphere", "Ar"}},
7 },
8 },
9}
10cursor, err := coll.Find(context.TODO(), filter)
11if err != nil {
12 panic(err)
13}
map[... hasRings:false mainAtmosphere:[CO2 Ar N] ... ]]
map[... hasRings:false mainAtmosphere:[N O2 Ar] ... ]]

完全なコードとサンプル出力は次のとおりです。

CrudRead.java
1// find code goes here
2Bson filter = and(eq("hasRings", false), eq("mainAtmosphere", "Ar"));
3MongoCursor<Document> cursor = coll.find(filter).iterator();
{..., "name" : "Mars", "mainAtmosphere" : ["CO2", "Ar", "N"], ... }
{..., "name" : "Earth", "mainAtmosphere" : ["N", "O2", "Ar"], ... }

完全なコードとサンプル出力は次のとおりです。

crud-read.js
1// find code goes here
2const cursor = coll.find({ hasRings: false, mainAtomsphere: "Ar" });
{..., "name" : "Mars", "mainAtmosphere" : ["CO2", "Ar", "N"], ... }
{..., "name" : "Earth", "mainAtmosphere" : ["N", "O2", "Ar"], ... }
CRUD_read.py
1# find code goes here
2cursor = coll.find({"hasRings": False, "mainAtmosphere": "Ar"})
{..., "name" : "Mars", "mainAtmosphere" : ["CO2", "Ar", "N"], ... }
{..., "name" : "Earth", "mainAtmosphere" : ["N", "O2", "Ar"], ... }

mainAtmosphere フィールドが配列であっても、MongoDB は配列をファーストクラスの型として扱うため、厳密な等価クエリを使用できます。クエリの実行中、MongoDB は配列の各エントリを指定した値(この場合は "Ar")と比較して、ドキュメントが条件に一致しているかどうかを判断します。

このガイドを読み終えたら、特定の等価条件を使って MongoDB からデータを検索したことになります。これは、商品番号、ユーザー名、化学元素など、検索対象が正確にわかっている場合に便利です。

次のガイドでは、比較演算子を使用して MongoDB からデータを読み取り、より広範な条件に一致するドキュメントを検索する方法を学習します。

ここで紹介した概念に関する詳しい情報については、次のリソースを参照してください。

次のステップ
演算子と複合クエリを使用したデータの読み取り
20 分

演算子や複合クエリを使って MongoDB のドキュメントを検索します。

スタート ガイド
第 2 章
CRUD
  • MongoDB ドライバーの追加
  • MongoDB でのデータの読み取り
  • クエリを使用した MongoDB からのデータの読み取り
  • 演算子と複合クエリを使用したデータの読み取り
  • MongoDB へのデータの挿入
  • MongoDB でのデータのアップデート
  • MongoDB からのデータの削除