В этой статье объект todo object (с атрибутами {id, name}) будет храниться в Mongodb и тестироваться на удаление запроса (Create Remove Delete = CRD). Этот тест включает в себя использование оболочки Mongodb, использование кода доступа в классическом стиле CallBack и использование кода в современном стиле Await/Async. Пройдя эту проверку, вы сможете освоить самый предварительный Mongodb.
Я использую Nodejs версии 10.7. Среда операционной системы — Mac OS X High Sierra.
Подготовьте среду
Установите и запустите демон MongoDB.
brew install mongodb
mongodb
проверка доступа
Сначала запустите оболочку MongoDB:
mongo
Введите команду для запроса списка базы данных:
> show dbs
local 0.000GB
создать базу данных
use todos
(Если база данных не существует, она будет создана. Если вы выйдете, ничего не делая, MongoDB удалит базу данных)
db.todos.insert({id:1,name:"reco"})
db.todos.insert({id:2,name:"rita"})
Запрос:
db.todos.find()
{ "_id" : ObjectId("5b727c0846b6c71a98d3af52"), "id" : 1, "name" : "reco" }
{ "_id" : ObjectId("5b727c7046b6c71a98d3af53"), "id" : 2, "name" : "reta" }
Удалить запись:
db.todo.remove({id:1})
удалить базу данных
db.todo.drop()
Доступ к MongoDB с помощью nodejs
Используйте nodejs для выполнения CRD, аналогичного объекту Shell, код выглядит следующим образом:
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/todos";
MongoClient.connect(url, function(err, db) {
if (err) throw err;
console.log("Database created!");
var dbo = db.db("todos");
// var myobj = { id: 1, name: "reco" };
// dbo.collection("todo").insertOne(myobj, function(err, res) {
// if (err) throw err;
// console.log("1 document inserted");
// db.close();
// });
var myobj = [
{ id: 1, name: 'reco'},
{ id: 2, name: 'rita'},
];
dbo.collection("todo").insertMany(myobj, function(err, res) {
if (err) throw err;
console.log("Number of documents inserted: " + res.insertedCount);
dbo.collection("todo").find({}).toArray(function(err, result) {
if (err) throw err;
console.log(result);
var myquery = { id: 1 };
dbo.collection("todo").deleteMany(myquery, function(err, obj) {
if (err) throw err;
console.log("document deleted");
db.close();
});
});
});
})
Код очень прост и не требует дополнительных пояснений. Этот код использует модуль mongodb, который необходимо сначала установить:
npm init -y
npm i mongodb --save
затем используйтеnode index.js
Запустите, чтобы увидеть эффект:
Database created!
Number of documents inserted: 2
[ { _id: 5b72ab9e3245f169ef5f43d2, id: 1, name: 'reco' },
{ _id: 5b72ab9e3245f169ef5f43d3, id: 2, name: 'rita' } ]
document deleted
Воспользуйтесь расширенными асинхронными функциями
Использование функции Await/Async может эффективно уменьшить ад обратных вызовов в вашем коде. Та же функциональность может быть использована с таким кодом:
const MongoClient = require('mongodb').MongoClient;
const connectionString = 'mongodb://localhost:27017';
(async () => {
const client = await MongoClient.connect(connectionString,
{ useNewUrlParser: true });
const dbo = client.db('todos');
try {
var res = await dbo.collection('todo').insertMany(
[{id:1,name:"reco"}, {id:2,name:"rita"}]);
console.log("Number of documents inserted: " + res.insertedCount);
var r = await dbo.collection("todo").find().toArray()
console.log(r);
var myquery = { id: 1 };
var r = await dbo.collection("todo").deleteMany(myquery)
console.log("document deleted");
}
finally {
client.close();
}
})().catch(err => console.error(err));
Выполняя этот код, вывод выглядит следующим образом:
Number of documents inserted: 2
[ { _id: 5b72ae8a1c674a6ac1c5aa6e, id: 1, name: 'reco' },
{ _id: 5b72ae8a1c674a6ac1c5aa6f, id: 2, name: 'rita' } ]
document deleted