Node.js MongoDB Tutorial cu exemple

Majoritatea aplicațiilor web moderne au un fel de sistem de stocare a datelor în backend. De exemplu, dacă luăm cazul unui magazin onlineping În aplicație, date precum prețul unui articol ar fi stocate în baza de date.

Cadrul Node js poate funcționa cu baze de date atât cu relații (cum ar fi Oracle și MS SQL Server) și baze de date non-relaționale (cum ar fi MongoDB). În acest tutorial, vom vedea cum putem folosi bazele de date din aplicațiile Node js.

Node.js și baze de date NoSQL

De-a lungul anilor, bazele de date NoSQL, cum ar fi MongoDB și baze de date relaționale, cum ar fi MySQL au devenit destul de populare ca baze de date pentru stocarea datelor. Capacitatea acestor baze de date de a stoca orice tip de date și în special în orice tip de format este ceea ce face ca aceste baze de date să fie utilizate atât de pe scară largă.

Node.js are capacitatea de a lucra cu ambele MySQL și MongoDB ca baze de date. Pentru a utiliza oricare dintre aceste baze de date, trebuie să descărcați și să utilizați modulele necesare utilizând managerul de pachete Node.

Pentru MySQL, modulul necesar se numește „mysql”. Pentru MongoDB, dezvoltatorii pot instala fie versiunea nativă oficială MongoDB driver, care este pachetul utilizat în exemplele de cod din acest articol, sau o bibliotecă bazată pe scheme, cum ar fi Mangustă odată ce aplicația are nevoie de mai multă structură.

Cu aceste module, puteți efectua următoarele operații în Node.js

1. Gestionați gruparea conexiunilor - Aici puteți specifica numărul de MySQL conexiuni la baze de date care ar trebui menținute și salvate de Node.js.
2. Creați și închideți o conexiune la o bază de date. În ambele cazuri, puteți furniza o funcție de apel invers care poate fi apelată ori de câte ori sunt executate metodele de conexiune „creare” și „închidere”.
3. Interogările pot fi executate pentru a obține date din bazele de date respective pentru a prelua date.
4. Manipularea datelor, cum ar fi inserarea datelor, ștergerea și actualizarea datelor, poate fi realizată și cu aceste module.

Pentru subiectele rămase, ne vom uita la modul în care putem lucra MongoDB baze de date din interior Node.js, începând cu o comparație rapidă a celor două modalități cele mai comune de a vorbi cu MongoDB dintr-un proiect Node.js.

MongoDB Driver nativ vs. Mongoose în Node.js

Numele modulelor menționate mai sus pot fi confuze, deoarece Node.js oferă două modalități diferite de comunicare cu MongoDBnativul MongoDB șoferul și Mangustă ODM (biblioteca de modelare a datelor despre obiecte). Fiecare exemplu de cod din acest articol utilizează driverul nativ, instalat cu npm instalați mongodb și accesat prin MongoClientMongoose încorporează același driver și adaugă definiții de schemă, validare și metode de model reutilizabile, ceea ce se potrivește aplicațiilor mai mari care au nevoie de o structură de date previzibilă în mai multe colecții. Înțelegerea diferenței în avans evită confuzia la instalarea pachetelor sau la citirea altor Node.js. MongoDB exemple online. Tabelul de mai jos compară ambele opțiuni, astfel încât un dezvoltator să poată alege instrumentul potrivit pentru un anumit proiect.

Sfat: Rămâi la driverul nativ în timp ce înveți nucleul MongoDB comenzi, apoi treceți la Mangustă odată ce aplicația necesită validarea schemei în mai multe colecții.

Utilizarea MongoDB și Node.js

Odată clarificată terminologia, restul acestui articol folosește exclusiv driverul nativ, exact așa cum apare în exemplele de cod de mai jos. Așa cum s-a discutat în subiectul anterior, MongoDB este una dintre cele mai populare baze de date utilizate împreună cu Node.js.

În acest capitol, vom vedea cum să stabilim conexiuni cu un MongoDB baza de date și cum se efectuează operațiunile normale de citire a datelor dintr-o bază de date, precum și inserarea, ștergerea și actualizarea înregistrărilor într-o MongoDB Bază de date.

În scopul acestui capitol, să presupunem că avem cele de mai jos MongoDB date în loc.

Numele bazei de date: EmployeeDB

Numele colecției: Angajat

Documents
{
	{Employeeid : 1, Employee Name : Guru99},
	{Employeeid : 2, Employee Name : Joe},
	{Employeeid : 3, Employee Name : Martin},
}

1. Instalarea modulelor NPM

Aveți nevoie de un driver pentru a accesa Mongo dintr-o aplicație Node. Există o serie de drivere Mongo disponibile, dar MongoDB este printre cele mai populare. Pentru a instala MongoDB modul, rulați comanda de mai jos

npm instalați mongodb

2. Crearea și închiderea unei conexiuni la a MongoDB Bază de date. Fragmentul de cod de mai jos arată cum să creați și să închideți o conexiune la a MongoDB Bază de date.

Code Explicaţie:

1. Primul pas este includerea MongoDB modulul driver, care se realizează prin funcția require. Odată ce acest modul este instalat, putem utiliza funcțiile necesare disponibile în acest modul pentru a crea conexiuni la baza de date.
2. Apoi, specificăm șirul nostru de conexiune la baza de date. În șirul de conectare, există 3 valori cheie care sunt transmise.

• Primul este „mongodb”, care specifică faptul că ne conectăm la o bază de date mongoDB.
• Următorul este „localhost”, ceea ce înseamnă că ne conectăm la o bază de date pe mașina locală.
• Următorul este „EmployeeDB”, care este numele bazei de date definite în nostru MongoDB Bază de date.

3. Următorul pas este conectarea efectivă la baza noastră de date. Funcția connect preia datele noastre URL și are facilitatea de a specifica o funcție de apel invers. Aceasta va fi apelată atunci când conexiunea la baza de date este deschisă. Acest lucru ne oferă posibilitatea de a ști dacă conexiunea la baza de date a avut succes sau nu.
4. În funcție, scriem șirul „Conexiune stabilită” în consolă pentru a indica faptul că a fost creată o conexiune cu succes.
5. În cele din urmă, închidem conexiunea folosind instrucțiunea db.close.

Dacă codul de mai sus este executat corect, șirul „Conectat” va fi scris pe consolă, așa cum se arată mai jos.

3. Interogarea datelor în a MongoDB Baza de date - Folosind MongoDB driver, putem prelua și date de la MongoDB baza de date. Secțiunea de mai jos va arăta cum putem folosi driverul pentru a prelua toate documentele din colecția noastră Employee din baza noastră de date EmployeeDB. Aceasta este colecția din MongoDB baza de date, care conține toate documentele legate de angajați. Fiecare document are un ID de obiect, un nume de angajat și un ID de angajat pentru a defini valorile documentului.

var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost/EmployeeDB';

MongoClient.connect(url, function(err, db) {

var cursor = db.collection('Employee').find();

cursor.each(function(err, doc) {

console.log(doc);

});
});

Code Explicaţie:

1. În primul pas, creăm un cursor (un cursor este un pointer care este utilizat pentru a indica diferitele înregistrări preluate dintr-o bază de date. Cursorul este apoi utilizat pentru a itera prin diferitele înregistrări din baza de date. Aici definim o variabilă numită cursor, care va fi utilizată pentru a stoca pointerul către înregistrările preluate din baza de date) care indică înregistrările care sunt preluate din colecția MongoDb. De asemenea, avem posibilitatea de a specifica colecția „Angajat” din care să se preiau înregistrările. Funcția find() este utilizată pentru a specifica faptul că dorim să preluăm toate documentele din MongoDB de colectare.
2. Acum iterăm prin cursor și pentru fiecare document din cursor vom executa o funcție.
3. Funcția noastră va imprima pur și simplu conținutul fiecărui document pe consolă.

Notă: - De asemenea, este posibil să se preia o anumită înregistrare dintr-o bază de date. Acest lucru se poate face prin specificarea condiției de căutare în funcția find(). De exemplu, să presupunem că ați dori doar să preiați înregistrarea care are numele angajatului ca Guru99, atunci această afirmație poate fi scrisă după cum urmează

var cursor=db.collection('Employee').find({EmployeeName: "guru99"})

Dacă codul de mai sus este executat cu succes, următoarea ieșire va fi afișată în consola dumneavoastră.

ieșire:

Din ieșire,

• Veți putea vedea clar că toate documentele din colecție sunt preluate. Acest lucru este posibil prin utilizarea metodei find() a conexiunii mongoDB (db) și iterarea prin toate documentele folosind cursorul.

4. Inserarea documentelor într-o colecție – Documentele pot fi inserate într-o colecție folosind metoda insertOne oferită de MongoDB bibliotecă. Fragmentul de cod de mai jos arată cum putem insera un document într-o colecție mongoDB.

var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost/EmployeeDB';

MongoClient.connect(url, function(err, db) {

db.collection('Employee').insertOne({
Employeeid: 4,
EmployeeName: "NewEmployee"
});
});

Code Explicaţie:

1. Aici folosim metoda insertOne din MongoDB bibliotecă pentru a insera un document în colecția Employee.
2. Specificăm detaliile documentului cu privire la ceea ce trebuie introdus în colecția Angajat.

Dacă verificați acum conținutul dvs MongoDB baza de date, veți găsi înregistrarea cu Employeeid de 4 și EmployeeName de „NewEmployee” introduse în colecția Employee.

Notă: Consola nu va afișa nicio ieșire deoarece înregistrarea este inserată în baza de date și nicio ieșire nu poate fi afișată aici.

Pentru a verifica dacă datele au fost introduse corect în baza de date, trebuie să executați următoarele comenzi în MongoDB

1. Utilizați EmployeeDB
2. db.Employee.find({Employeeid :4 })

Prima declarație asigură că sunteți conectat la baza de date EmployeeDb. A doua declarație caută înregistrarea care are ID-ul de angajat 4.

5. Actualizarea documentelor dintr-o colecție – Documentele pot fi actualizate într-o colecție folosind metoda updateOne oferită de MongoDB bibliotecă. Fragmentul de cod de mai jos arată cum să actualizați un document dintr-o colecție mongoDB.

var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost/EmployeeDB';

MongoClient.connect(url, function(err, db) {

db.collection('Employee').updateOne({
"EmployeeName": "NewEmployee"
}, {
$set: {
"EmployeeName": "Mohan"
}
});
});

Code Explicaţie:

1. Aici folosim metoda „updateOne” din MongoDB bibliotecă, care este folosită pentru a actualiza un document dintr-o colecție mongoDB.
2. Specificăm criteriile de căutare pentru care document trebuie actualizat. În cazul nostru, dorim să găsim documentul care are EmployeeName de „NewEmployee”.
3. Apoi vrem să setăm valoarea EmployeeName al documentului de la „NewEmployee” la „Mohan”.

Dacă verificați acum conținutul dvs MongoDB baza de date, veți găsi înregistrarea cu Employeeid de 4 și EmployeeName lui „Mohan” actualizate în colecția Employee.

Pentru a verifica dacă datele au fost actualizate corect în baza de date, trebuie să executați următoarele comenzi în MongoDB

1. Utilizați EmployeeDB
2. db.Employee.find({Employeeid :4 })

Prima declarație asigură că sunteți conectat la baza de date EmployeeDb. A doua declarație caută înregistrarea care are ID-ul de angajat 4.

6. Ștergerea documentelor dintr-o colecție – Documentele pot fi șterse dintr-o colecție folosind metoda „deleteOne” oferită de MongoDB bibliotecă. Fragmentul de cod de mai jos arată cum să ștergeți un document dintr-o colecție mongoDB.

var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost/EmployeeDB';

MongoClient.connect(url, function(err, db) {

db.collection('Employee').deleteOne(

{
"EmployeeName": "Mohan"
}

);
});

Code Explicaţie:

1. Aici folosim metoda „deleteOne” din MongoDB bibliotecă, care este folosită pentru a șterge un document dintr-o colecție mongoDB.
2. Specificăm criteriile de căutare pentru care document trebuie șters. În cazul nostru, dorim să găsim documentul care are EmployeeName „Mohan” și să ștergem acest document.

Dacă verificați acum conținutul dvs MongoDB baza de date, veți găsi înregistrarea cu Employeeid de 4 și EmployeeName de „Mohan” șterse din colecția Employee.

Pentru a verifica dacă datele au fost actualizate corect în baza de date, trebuie să executați următoarele comenzi în MongoDB

1. Utilizați EmployeeDB
2. db.Employee.find()

Prima declarație asigură că sunteți conectat la baza de date EmployeeDb. A doua declarație caută și afișează toate înregistrările din colecția angajaților. Aici puteți vedea dacă înregistrarea a fost ștearsă sau nu.

Async/Așteptare modernă MongoDB Conexiuni în Node.js

MongoClient.connect(url, apel invers) Modelul folosit în acest articol corespunde cu MongoDB Versiunea driverului Node.js care era actuală la momentul scrierii exemplelor de mai sus. Versiunile recente de drivere încă acceptă acest stil de apel invers, dar majoritatea proiectelor noi preferă acum promises și async/await, deoarece codul rezultat se citește de sus în jos, fără apeluri inverse imbricate. Pașii de mai jos rescriu aceeași conexiune Employee folosind sintaxa modernă.

1. Creați o singură instanță MongoClient în afara oricărei funcții, transmițând șirul de conexiune o singură dată, de exemplu const client = new MongoClient(url);
2. Apel așteaptă clientul.connect() în interiorul unei funcții asincrone pentru a deschide conexiunea în loc să transmită un apel invers.
3. Obțineți baza de date cu client.db('EmployeeDB') în loc să se bazeze pe obiectul returnat în interiorul unui callback.
4. Executați interogări cu astept, De exemplu, așteaptă db.collection('Angajat').find().toArray(), care returnează direct un tablou în loc să necesite o funcție de apel invers al cursorului.
5. Închideți conexiunea cu așteaptă clientul.close() în interiorul unui bloc finally, astfel încât să ruleze întotdeauna, chiar dacă o interogare generează o eroare.

const { MongoClient } = require('mongodb');

const url = 'mongodb://localhost:27017';
const client = new MongoClient(url);

async function run() {
try {
await client.connect();
const db = client.db('EmployeeDB');
const employees = await db.collection('Employee').find().toArray();
console.log(employees);
} finally {
await client.close();
}
}

run().catch(console.error);

Ambele stiluri se conectează la aceeași bază de date EmployeeDB și la aceeași colecție Employee, astfel încât codul existent bazat pe callback nu trebuie rescris imediat. Cele două abordări pot coexista în timp ce un proiect migrează treptat, iar alegerea depinde în mare măsură de care MongoDB Versiunea driverului Node.js include deja un fișier package.json.

Cum să construiți o aplicație Node Express cu MongoDB pentru a stoca și a difuza conținut

Având în vedere ambele stiluri de conexiune acoperite, următoarea secțiune aplică modelul clasic de apel invers în cadrul unei aplicații Express complete, deoarece aceasta este sintaxa utilizată de serverul exemplu original de mai jos. Construirea unei aplicații cu o combinație de Express și MongoDB este destul de comună în zilele noastre.

Când lucrați cu JavaScenariu În cazul aplicațiilor bazate pe web, se va auzi în mod normal de termenul MEAN stack.

• Termenul MEAN stack se referă la o colecție de JavaTehnologii bazate pe scripturi utilizate pentru a dezvolta aplicații web.
• MEAN este un acronim pentru MongoDB, ExpressJS, AngularJSși Node.js.

Prin urmare, este întotdeauna bine să înțelegeți cum Node.js și MongoDB lucrează împreună pentru a furniza aplicații care interacționează cu bazele de date backend.

Să ne uităm la un exemplu simplu despre cum putem folosi „express” și „MongoDB” împreună. Exemplul nostru va folosi aceeași colecție de angajați în MongoDB Baza de date EmployeeDB.

Acum vom încorpora Express pentru a afișa datele pe pagina noastră web atunci când sunt solicitate de utilizator. Când aplicația noastră rulează pe Node.js, ar putea fi necesar să navigați la URL http://localhost:3000/Employeeid.

La lansarea paginii, vor fi afișate toate ID-urile angajatului din colecția Employee. Deci, să vedem fragmentul de cod în secțiuni care ne vor permite să realizăm acest lucru.

Pas 1) Definiți toate bibliotecile care trebuie utilizate în aplicația noastră, care în cazul nostru este atât MongoDB și bibliotecă expresă.

Code Explicaţie:

1. Definim biblioteca noastră „express”, care va fi folosită în aplicația noastră.
2. Ne definim "MongoDB', care va fi folosită în aplicația noastră pentru conectarea la sistemul nostru MongoDB Bază de date.
3. Aici definim URL din baza noastră de date la care să se conecteze.
4. În cele din urmă, definim un șir care va fi folosit pentru a stoca colecția noastră de id-uri de angajați care trebuie să fie afișate în browser mai târziu.

Pas 2) În acest pas, acum vom obține toate înregistrările din colecția noastră „Angajați” și vom lucra cu ele în consecință.

Code Explicaţie:

1. Creăm o rută către aplicația noastră numită „Employeeid”. Deci ori de câte ori cineva navighează la http://localhost:3000/Employeeid al aplicației noastre, fragmentul de cod definit pentru această rută va fi executat.
2. Aici obținem toate înregistrările din colecția noastră „Angajat” prin comanda db.collection(„Angajat”).find(). Apoi atribuim această colecție unei variabile numite cursor. Folosind această variabilă de cursor, vom putea naviga prin toate înregistrările colecției.
3. Acum folosim funcția cursor.each() pentru a naviga prin toate înregistrările colecției noastre. Pentru fiecare înregistrare, vom defini un fragment de cod despre ce trebuie făcut atunci când fiecare înregistrare este accesată.
4. În cele din urmă, vedem că dacă înregistrarea returnată nu este nulă, atunci luăm angajatul prin comanda „item.Employeeid”. Restul codului este doar pentru a construi un cod HTML adecvat, care va permite ca rezultatele noastre să fie afișate corect în browser.

Pas 3) În acest pas, vom trimite rezultatele noastre către pagina web și vom face ca aplicația noastră să asculte pe un anumit port.

Code Explicaţie:

1. Aici trimitem întregul conținut care a fost construit în pasul anterior către pagina noastră web. Parametrul „res” ne permite să trimitem conținut către pagina noastră web ca răspuns.
2. Facem ca întreaga noastră aplicație Node.js să asculte pe portul 3000.

ieșire:

Din ieșire,

• Arată în mod clar că toate datele angajaților din colecția Employee au fost recuperate. Acest lucru se datorează faptului că folosim MongoDB driver pentru a se conecta la baza de date și a prelua toate înregistrările angajaților și, ulterior, a folosit „express” pentru a afișa înregistrările.

Iată codul pentru referință

var express = require('express');
var app = express();
var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost/EmployeeDB';
var str = "";

app.route('/Employeeid').get(function(req, res)

{
MongoClient.connect(url, function(err, db) {
var cursor = db.collection('Employee').find();
//noinspection JSDeprecatedSymbols
cursor.each(function(err, item) {

if (item != null) {
str = str + " Employee id " + item.Employeeid + "</br>";
}
});
res.send(str);
db.close();
});
});

var server = app.listen(3000, function() {});

Notă: cursor.each poate depreciat în funcție de versiunea dvs MongoDB conducător auto. Puteți adăuga //noinspection JSDeprecatedSymbols înainte de cursor.each pentru a evita problema. Alternativ, puteți utiliza forEach. Mai jos este exemplul de cod folosind forEach

var express = require('express');
var app = express();
var MongoClient = require('mongodb').MongoClient;
var url = 'mongodb://localhost/EmployeeDB';
var str = "";

app.route('/Employeeid').get(function(req, res) {
MongoClient.connect(url, function(err, db) {
var collection = db.collection('Employee');
var cursor = collection.find({});
str = "";
cursor.forEach(function(item) {
if (item != null) {
str = str + "    Employee id  " + item.Employeeid + "</br>";
}
}, function(err) {
res.send(err);
db.close();
}
);
});
});
var server = app.listen(8080, function() {});

Întrebări frecvente