Node.js
Монгодская интеграция
Поиск…
Синтаксис
- дб. collection .insertOne ( document , options (w, wtimeout, j, serializeFuntions, forceServerObjectId, bypassDocumentValidation) , обратный вызов )
- дб. коллекция .insertMany ( [документы] , параметры (w, wtimeout, j, serializeFuntions, forceServerObjectId, bypassDocumentValidation) , обратный вызов )
- дб. коллекция .find ( запрос )
- дб. коллекция .updateOne ( фильтр , обновление , опции (upsert, w, wtimeout, j, bypassDocumentValidation) , обратный вызов )
- дб. коллекция .updateMany ( фильтр , обновление , опции (upsert, w, wtimeout, j) , обратный вызов )
- дб. коллекция .deleteOne ( фильтр , опции (upsert, w, wtimeout, j) , обратный вызов )
- дб. коллекция .deleteMany ( фильтр , опции (upsert, w, wtimeout, j) , обратный вызов )
параметры
параметр | подробности |
---|---|
документ | Объект javascript, представляющий документ |
документы | Массив документов |
запрос | Объект, определяющий поисковый запрос |
фильтр | Объект, определяющий поисковый запрос |
Перезвоните | Функция, вызываемая при выполнении операции |
опции | (необязательно) Дополнительные настройки (по умолчанию: null) |
вес | (необязательно) |
wtimeout | (необязательно) Тайм-аут ожидания записи. (по умолчанию: null) |
J | (необязательно) Укажите проблему записи журнала (по умолчанию: false) |
upsert | (необязательно) Операция обновления (по умолчанию: false) |
много | (необязательно) Обновление одного / всех документов (по умолчанию: 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 , options , callback )
аргументация | Тип | Описание |
---|---|---|
url | строка | Строка, указывающая сервер ip / hostname, порт и база данных |
options | объект | (необязательно) Дополнительные настройки (по умолчанию: null) |
callback | функция | Функция, вызываемая при попытке подключения |
Функция callback
принимает два аргумента
-
err
: Ошибка - при возникновении ошибки аргументerr
будет определен -
db
: объект - экземпляр 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 ( collection ) .insertOne ( документ , параметры , обратный вызов )
аргументация | Тип | Описание |
---|---|---|
collection | строка | Строка, указывающая коллекцию |
document | объект | Документ, который необходимо вставить в сборник |
options | объект | (необязательно) Дополнительные настройки (по умолчанию: null) |
callback | функция | Функция, вызываемая при выполнении операции вставки |
Функция callback
принимает два аргумента
-
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?' }
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
принимает два аргумента
-
err
: Ошибка - при возникновении ошибки аргумент err будет определен -
db
: объект - экземпляр MongoDB
Удаление документа
Удалить документ с помощью свойства { 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
принимает два аргумента
-
err
: Ошибка - при возникновении ошибки аргумент err будет определен -
db
: объект - экземпляр MongoDB
Удаление нескольких документов
Удалите ВСЕ документы с «прощальным» свойством, установленным в «okay».
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 ( collection ) .deleteMany ( фильтр , параметры , обратный вызов )
параметр | Тип | Описание |
---|---|---|
filter | документ | Документ, определяющий критерий выбора |
options | объект | (необязательно) Дополнительные настройки (по умолчанию: null) |
callback | функция | Функция, вызываемая при выполнении операции |
Функция callback
принимает два аргумента
-
err
: Ошибка - при возникновении ошибки аргумент err будет определен -
db
: объект - экземпляр 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);
});
```