Node.js
モンゴブ統合
サーチ…
構文
- db。 コレクション .insertOne( document 、 options(w、wtimeout、j、serializeFuntions、forceServerObjectId、bypassDocumentValidation) 、 コールバック )
- db。 コレクション .insertMany( [documents] 、 options(w、wtimeout、j、serializeFuntions、forceServerObjectId、bypassDocumentValidation) 、 コールバック )
- db。 コレクション .find( クエリ )
- db。 コレクション .updateOne( フィルタ 、 更新 、 オプション(upsert、w、wtimeout、j、bypassDocumentValidation) 、 コールバック )
- db。 コレクション .updateMany( フィルタ 、 更新 、 オプション(upsert、w、wtimeout、j) 、 コールバック )
- db。 コレクション .deleteOne( フィルタ 、 オプション(upsert、w、wtimeout、j) 、 コールバック )
- db。 コレクション .deleteMany( フィルタ 、 オプション(upsert、w、wtimeout、j) 、 コールバック )
パラメーター
パラメータ | 詳細 |
---|---|
資料 | ドキュメントを表すjavascriptオブジェクト |
書類 | ドキュメントの配列 |
クエリ | 検索クエリを定義するオブジェクト |
フィルタ | 検索クエリを定義するオブジェクト |
折り返し電話 | 操作が完了したときに呼び出される関数 |
オプション | (オプション)オプション設定(デフォルト:null) |
w | (オプション)書き込みの問題 |
wtimeout | (オプション)書き込みのタイムアウトが発生します。 (デフォルト:null) |
j | (オプション)ジャーナル書込み問題を指定する(デフォルト:false) |
アップサート | (オプション)操作の更新(デフォルト:false) |
マルチ | (オプション) 1つまたはすべてのドキュメントを更新する(デフォルト:false) |
serializeFunctions | (オプション)任意のオブジェクトの関数をシリアル化する(デフォルト:false) |
forceServerObjectId | (オプション)サーバにドライバの代わりに_id値を割り当てるように強制する(デフォルト:false) |
bypassDocumentValidation | (オプション) MongoDB 3.2以降でドライバがスキーマ検証をバイパスできるようにする(デフォルト:false) |
MongoDBに接続する
MongoDBに接続し、 'Connected!'を印刷します。接続を閉じます。
const MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function(err, db) { // MongoClient method 'connect'
if (err) throw new Error(err);
console.log("Connected!");
db.close(); // Don't forget to close the connection when you are done
});
MongoClientメソッドConnect()
MongoClient.connect( URL 、 オプション 、 コールバック )
引数 | タイプ | 説明 |
---|---|---|
url | 文字列 | サーバーのIP /ホスト名、ポート、およびデータベースを指定する文字列 |
options | オブジェクト | (オプション)オプション設定(デフォルト:null) |
callback | 関数 | 接続試行が完了したときに呼び出される関数 |
callback
関数は2つの引数をとります
-
err
:エラー - エラーが発生した場合、err
引数が定義されます。 -
db
:object - MongoDBインスタンス
文書を挿入する
'myFirstDocument'というドキュメントを挿入し、 2つのプロパティ、 greetings
とfarewell
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function (err, db) {
if (err) throw new Error(err);
db.collection('myCollection').insertOne({ // Insert method 'insertOne'
"myFirstDocument": {
"greetings": "Hellu",
"farewell": "Bye"
}
}, function (err, result) {
if (err) throw new Error(err);
console.log("Inserted a document into the myCollection collection!");
db.close(); // Don't forget to close the connection when you are done
});
});
コレクションメソッドinsertOne()
db.collection( コレクション ).insertOne( ドキュメント 、 オプション 、 コールバック )
引数 | タイプ | 説明 |
---|---|---|
collection | 文字列 | コレクションを指定する文字列 |
document | オブジェクト | コレクションに挿入されるドキュメント |
options | オブジェクト | (オプション)オプション設定(デフォルト:null) |
callback | 関数 | 挿入操作が完了したときに呼び出される関数 |
callback
関数は2つの引数をとります
-
err
:エラー - エラーが発生した場合、err
引数が定義されます。 -
result
:object - 挿入操作の詳細を含むオブジェクト
コレクションを読む
コレクション 'myCollection'内のすべてのドキュメントを取得し、コンソールに出力します。
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function (err, db) {
if (err) throw new Error(err);
var cursor = db.collection('myCollection').find(); // Read method 'find'
cursor.each(function (err, doc) {
if (err) throw new Error(err);
if (doc != null) {
console.log(doc); // Print all documents
} else {
db.close(); // Don't forget to close the connection when you are done
}
});
});
コレクションメソッドfind()
db.collection( collection ).find()
引数 | タイプ | 説明 |
---|---|---|
collection | 文字列 | コレクションを指定する文字列 |
ドキュメントを更新する
{ greetings: 'Hellu' }
プロパティを持つ文書を見つけて{ greetings: 'Whut?' }
変更し{ greetings: 'Whut?' }
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function (err, db) {
if (err) throw new Error(err);
db.collection('myCollection').updateOne({ // Update method 'updateOne'
greetings: "Hellu" },
{ $set: { greetings: "Whut?" }},
function (err, result) {
if (err) throw new Error(err);
db.close(); // Don't forget to close the connection when you are done
});
});
コレクションメソッドupdateOne()
db.collection( collection ).updateOne( フィルタ 、 更新 、 オプション 、 コールバック )
パラメータ | タイプ | 説明 |
---|---|---|
filter | オブジェクト | 選択基準を指定します。 |
update | オブジェクト | 適用する変更を指定します。 |
options | オブジェクト | (オプション)オプション設定(デフォルト:null) |
callback | 関数 | 操作が完了したときに呼び出される関数 |
callback
関数は2つの引数をとります
-
err
:エラー - エラーが発生した場合、err引数が定義されます。 -
db
:object - MongoDBインスタンス
ドキュメントを削除する
{ greetings: 'Whut?' }
プロパティを持つ文書を削除します{ greetings: 'Whut?' }
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function (err, db) {
if (err) throw new Error(err);
db.collection('myCollection').deleteOne(// Delete method 'deleteOne'
{ greetings: "Whut?" },
function (err, result) {
if (err) throw new Error(err);
db.close(); // Don't forget to close the connection when you are done
});
});
コレクションメソッドdeleteOne()
db.collection( collection ).deleteOne( フィルタ 、 オプション 、 コールバック )
パラメータ | タイプ | 説明 |
---|---|---|
filter | オブジェクト | 選択基準を指定する文書 |
options | オブジェクト | (オプション)オプション設定(デフォルト:null) |
callback | 関数 | 操作が完了したときに呼び出される関数 |
callback
関数は2つの引数をとります
-
err
:エラー - エラーが発生した場合、err引数が定義されます。 -
db
:object - MongoDBインスタンス
複数の文書を削除する
「お別れ」プロパティが「大丈夫」に設定されているすべてのドキュメントを削除します。
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, function (err, db) {
if (err) throw new Error(err);
db.collection('myCollection').deleteMany(// MongoDB delete method 'deleteMany'
{ farewell: "okay" }, // Delete ALL documents with the property 'farewell: okay'
function (err, result) {
if (err) throw new Error(err);
db.close(); // Don't forget to close the connection when you are done
});
});
コレクションメソッドdeleteMany()
db.collection( コレクション ).deleteMany( フィルタ 、 オプション 、 コールバック )
パラメータ | タイプ | 説明 |
---|---|---|
filter | 資料 | 選択基準を指定する文書 |
options | オブジェクト | (オプション)オプション設定(デフォルト:null) |
callback | 関数 | 操作が完了したときに呼び出される関数 |
callback
関数は2つの引数をとります
-
err
:エラー - エラーが発生した場合、err引数が定義されます。 -
db
:object - MongoDBインスタンス
シンプルコネクト
MongoDB.connect('mongodb://localhost:27017/databaseName', function(error, database) { if(error) return console.log(error); const collection = database.collection('collectionName'); collection.insert({key: 'value'}, function(error, result) { console.log(error, result); }); });
シンプルな接続、約束を使用
const MongoDB = require('mongodb');
MongoDB.connect('mongodb://localhost:27017/databaseName')
.then(function(database) {
const collection = database.collection('collectionName');
return collection.insert({key: 'value'});
})
.then(function(result) {
console.log(result);
});
```