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

MongoDB でのデータの読み取り

このガイドでは、MongoDB からデータを取得する方法を学びます。

所要時間: 10 分

  • stringMongoDB配置への 接続 。

  • クラスターにロードされたサンプル データセット。

  • インストールされた MongoDB ドライバー。

1

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]"

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

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
CrudRead.cs
// find code goes here
var cursor = coll.AsQueryable();

すべてのドキュメントを取得するには、Find() メソッドを使用します。別のガイドでは、同じメソッドを使用して特定の基準に一致するドキュメントを取得する方法を学習します。

Tip

すべてのドキュメントとマッチングするためには、空の bson.D{} が必要です。

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

すべてのドキュメントを取得するには、find() メソッドを使用します。別のガイドでは、同じメソッドを使用して特定の基準に一致するドキュメントを取得する方法を学習します。

CrudRead.java
1// find code goes here
2MongoCursor<Document> cursor = coll.find().iterator();

すべてのドキュメントを取得するには、find() メソッドを使用します。別のガイドでは、同じメソッドを使用して特定の基準に一致するドキュメントを取得する方法を学習します。

crud-read.js
// find code goes here
const cursor = coll.find();

すべてのドキュメントを取得するには、find() メソッドを使用します。別のガイドでは、同じメソッドを使用して特定の基準に一致するドキュメントを取得する方法を学習します。

CRUD_read.py
# find code goes here
cursor = coll.find()
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 = coll.AsQueryable();
14// iterate code goes here
15foreach (var document in cursor)
16{
17 Console.WriteLine(document);
18}
19
20
{
'_id': ObjectId('621ff30d2a3e781873fcb65c'),
'name': 'Mercury',
'orderFromSun': 1,
'hasRings': False,
'mainAtmosphere': [],
'surfaceTemperatureC': {'min': -173, 'max': 427, 'mean': 67}
},
...

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

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 cursor, err := coll.Find(context.TODO(), bson.D{})
32 if err != nil {
33 panic(err)
34 }
35
36 // iterate code goes here
37 for cursor.Next(context.TODO()) {
38 var result bson.M
39 if err := cursor.Decode(&result); err != nil {
40 panic(err)
41 }
42 fmt.Println(result)
43 }
44 if err := cursor.Err(); err != nil {
45 panic(err)
46 }
47
48}
map[_id:ObjectID("621ff30d2a3e781873fcb65c") hasRings:false mainAtmosphere:[] name:Mercury orderFromSun:1 surfaceTemperatureC:map[max:427 mean:67 min:-173]]
...

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

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 MongoCursor<Document> cursor = coll.find().iterator();
17
18 // iterate code goes here
19 try {
20 while (cursor.hasNext()) {
21 System.out.println(cursor.next().toJson());
22 }
23 } finally {
24 cursor.close();
25 }
26 }
27 }
28}
{"_id": {"$oid": "621ff30d2a3e781873fcb65c"}, "name": "Mercury", "orderFromSun": 1, "hasRings": false, "mainAtmosphere": [], "surfaceTemperatureC": {"min": -173, "max": 427, "mean": 67}}
...

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

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();
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);
{
'_id': ObjectId('621ff30d2a3e781873fcb65c'),
'name': 'Mercury',
'orderFromSun': 1,
'hasRings': False,
'mainAtmosphere': [],
'surfaceTemperatureC': {'min': -173, 'max': 427, 'mean': 67}
},
...

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

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()
{
'_id': ObjectId('621ff30d2a3e781873fcb65c'),
'name': 'Mercury',
'orderFromSun': 1,
'hasRings': False,
'mainAtmosphere': [],
'surfaceTemperatureC': {'min': -173, 'max': 427, 'mean': 67}
},
...

このガイドの手順を正常に完了すると、MongoDB からデータを取得したことになります。

次のガイドでは、条件を使用して MongoDB からデータを取得する方法を学びます。

その他の CRUD ガイド:

次のステップ
クエリを使用した MongoDB からのデータの読み取り
15 分

クエリを使用して、MongoDB 内のどのドキュメントを取得するかを指定します。

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