node.js MongoDB Handledning med exempel

De flesta moderna webbapplikationer har någon form av datalagringssystem i backend-systemet. Om du till exempel tar fallet med en webbutik.ping applikation skulle data som priset på en vara lagras i databasen.

Node js-ramverket kan fungera med databaser med både relationella (som t.ex Oracle och MS SQL Server) och icke-relationella databaser (t.ex MongoDB). I den här handledningen kommer vi att se hur vi kan använda databaser från Node js-applikationer.

Node.js och NoSQL-databaser

Under årens lopp har NoSQL-databaser som MongoDB och relationsdatabaser som t.ex. MySQL har blivit ganska populära som databaser för att lagra data. Databasernas förmåga att lagra alla typer av data, och särskilt i alla typer av format, är det som gör att de används så ofta.

Node.js har förmågan att arbeta med båda MySQL och MongoDB som databaser. För att använda någon av dessa databaser måste du ladda ner och använda de nödvändiga modulerna med hjälp av Node-pakethanteraren.

För MySQL, den obligatoriska modulen heter "mysql". För MongoDB, kan utvecklare installera antingen den officiella inbyggda mongodb drivrutinen, vilket är paketet som används i alla kodexempel i den här artikeln, eller ett schemabaserat bibliotek som Mungo när applikationen behöver mer struktur.

Med dessa moduler kan du utföra följande operationer i Node.js

1. Hantera anslutningspoolningen – Här kan du ange antalet MySQL databasanslutningar som bör underhållas och sparas av Node.js.
2. Skapa och stäng en anslutning till en databas. I båda fallen kan du tillhandahålla en återuppringningsfunktion som kan anropas närhelst anslutningsmetoderna "skapa" och "stäng" exekveras.
3. Frågor kan utföras för att hämta data från respektive databaser för att hämta data.
4. Datamanipulering, såsom att infoga data, radera och uppdatera data kan också uppnås med dessa moduler.

För resterande ämnen ska vi titta på hur vi kan arbeta med MongoDB databaser inom node.js, med början i en snabb jämförelse av de två vanligaste sätten att prata med MongoDB från ett Node.js-projekt.

MongoDB Native Driver vs Mongoose i Node.js

Modulnamnen som nämns ovan kan vara förvirrande, eftersom Node.js erbjuder två olika sätt att kommunicera med MongoDB: den infödda mongodb föraren och Mungo ODM (Object Data Modeling-bibliotek). Varje kodexempel senare i den här artikeln använder den inbyggda drivrutinen, installerad med npm installera mongodb och nås via MongoClientMongoose paketerar samma drivrutin och lägger till schemadefinitioner, validering och återanvändbara modellmetoder, vilket passar större applikationer som behöver en förutsägbar datastruktur över många samlingar. Att förstå skillnaden i förväg undviker förvirring vid installation av paket eller läsning av andra Node.js-program. MongoDB exempel online. Tabellen nedan jämför båda alternativen så att en utvecklare kan välja rätt verktyg för ett givet projekt.

Dricks: Håll dig till den inbyggda drivrutinen medan du lär dig kärnan MongoDB kommandon, gå sedan vidare till Mungo när applikationen behöver schemavalidering över flera samlingar.

Använda MongoDB och Node.js

Med terminologin förtydligad använder resten av den här artikeln uteslutande den inbyggda drivrutinen, exakt som den visas i kodexemplen nedan. Som diskuterats i det tidigare ämnet, MongoDB är en av de mest populära databaserna som används tillsammans med Node.js.

Under det här kapitlet ska vi se hur man etablerar kontakter med en MongoDB databas, och hur man utför de normala operationerna för att läsa data från en databas samt infoga, ta bort och uppdatera poster i en MongoDB databas.

För syftet med detta kapitel, låt oss anta att vi har nedanstående MongoDB data på plats.

Databasnamn: EmployeeDB

Samlingens namn: Anställd

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

1. Installation av NPM-moduler

Du behöver en drivrutin för att komma åt Mongo från en Node-applikation. Det finns ett antal Mongo-drivrutiner tillgängliga, men MongoDB är bland de mest populära. För att installera MongoDB modul, kör kommandot nedan

npm installera mongodb

2. Skapa och stänga en anslutning till en MongoDB databas. Nedanstående kodavsnitt visar hur du skapar och stänger en anslutning till en MongoDB databas.

Code Förklaring:

1. Det första steget är att inkludera MongoDB drivrutinsmodulen, vilket görs via require-funktionen. När den här modulen är på plats kan vi använda de nödvändiga funktionerna som finns i den här modulen för att skapa kopplingar till databasen.
2. Därefter anger vi vår anslutningssträng till databasen. I anslutningssträngen finns det 3 nyckelvärden som skickas.

• Den första är 'mongodb' som anger att vi ansluter till en mongoDB-databas.
• Nästa är 'localhost' vilket betyder att vi ansluter till en databas på den lokala maskinen.
• Nästa är 'EmployeeDB' som är namnet på databasen som definieras i vår MongoDB databas.

3. Nästa steg är att faktiskt ansluta till vår databas. Funktionen connect tar in våra URL och har möjlighet att ange en callback-funktion. Den anropas när anslutningen till databasen öppnas. Detta ger oss möjlighet att veta om databasanslutningen lyckades eller inte.
4. I funktionen skriver vi strängen "Anslutning upprättad" till konsolen för att indikera att en framgångsrik anslutning skapades.
5. Slutligen stänger vi anslutningen med db.close-satsen.

Om ovanstående kod exekveras korrekt, kommer strängen "Connected" att skrivas till konsolen som visas nedan.

3. Söka efter data i en MongoDB databas - Använda MongoDB drivrutinen kan vi också hämta data från MongoDB databas. Avsnittet nedan visar hur vi kan använda drivrutinen för att hämta alla dokument från vår Employee-samling i vår EmployeeDB-databas. Detta är samlingen i vår MongoDB databas, som innehåller alla anställdas relaterade dokument. Varje dokument har ett objekt-id, anställds namn och anställd-id för att definiera värdena för dokumentet.

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 Förklaring:

1. I det första steget skapar vi en markör (en markör är en pekare som används för att peka på de olika posterna som hämtats från en databas. Markören används sedan för att iterera genom de olika posterna i databasen. Här definierar vi ett variabelnamn som heter markör, vilket kommer att användas för att lagra pekaren till posterna som hämtats från databasen) som pekar på posterna som hämtas från MongoDb-samlingen. Vi har också möjlighet att ange samlingen 'Anställd' som posterna ska hämtas från. Funktionen find() används för att ange att vi vill hämta alla dokument från MongoDB samling.
2. Vi itererar nu genom vår markör och för varje dokument i markören ska vi köra en funktion.
3. Vår funktion är helt enkelt att skriva ut innehållet i varje dokument till konsolen.

Notera: - Det är också möjligt att hämta en specifik post från en databas. Detta kan göras genom att ange sökvillkoret i find()-funktionen. Anta till exempel att du bara vill hämta posten som har den anställdes namn som Guru99, så kan detta påstående skrivas enligt följande

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

Om ovanstående kod exekveras framgångsrikt, kommer följande utdata att visas i din konsol.

Produktion:

Från utgången,

• Du kommer tydligt att kunna se att alla dokument från samlingen är hämtade. Detta är möjligt genom att använda metoden find() för mongoDB-anslutningen (db) och iterera genom alla dokument med hjälp av markören.

4. Infoga dokument i en samling – Dokument kan infogas i en samling med metoden insertOne som tillhandahålls av MongoDB bibliotek. Nedanstående kodavsnitt visar hur vi kan infoga ett dokument i en mongoDB-samling.

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 Förklaring:

1. Här använder vi metoden insertOne från MongoDB bibliotek för att infoga ett dokument i anställds samling.
2. Vi specificerar dokumentdetaljerna för vad som behöver infogas i personalsamlingen.

Om du nu kontrollerar innehållet i din MongoDB databas, hittar du posten med anställd 4 och anställds namn på "Ny anställd" infogat i anställd samling.

Obs: Konsolen kommer inte att visa någon utdata eftersom posten infogas i databasen och ingen utdata kan visas här.

För att kontrollera att data har infogats korrekt i databasen måste du utföra följande kommandon i MongoDB

1. Använd EmployeeDB
2. db.Employee.find({Employeeid :4 })

Det första uttalandet säkerställer att du är ansluten till EmployeeDb-databasen. Det andra påståendet söker efter posten som har anställd-id 4.

5. Uppdatera dokument i en samling – Dokument kan uppdateras i en samling med updateOne-metoden som tillhandahålls av MongoDB bibliotek. Nedanstående kodavsnitt visar hur man uppdaterar ett dokument i en mongoDB-samling.

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 Förklaring:

1. Här använder vi metoden "updateOne" från MongoDB bibliotek, som används för att uppdatera ett dokument i en mongoDB-samling.
2. Vi specificerar sökkriterierna för vilket dokument som behöver uppdateras. I vårt fall vill vi hitta dokumentet som har EmployeeName som "NewEmployee."
3. Vi vill sedan ställa in värdet på EmployeeName för dokumentet från "NewEmployee" till "Mohan".

Om du nu kontrollerar innehållet i din MongoDB databas, hittar du posten med anställd på 4 och anställds namn på "Mohan" uppdaterad i anställningssamlingen.

För att kontrollera att data har uppdaterats korrekt i databasen måste du utföra följande kommandon i MongoDB

1. Använd EmployeeDB
2. db.Employee.find({Employeeid :4 })

Det första uttalandet säkerställer att du är ansluten till EmployeeDb-databasen. Det andra påståendet söker efter posten som har anställd-id 4.

6. Ta bort dokument i en samling – Dokument kan raderas i en samling med "deleteOne"-metoden som tillhandahålls av MongoDB bibliotek. Nedanstående kodavsnitt visar hur man tar bort ett dokument i en mongoDB-samling.

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

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

db.collection('Employee').deleteOne(

{
"EmployeeName": "Mohan"
}

);
});

Code Förklaring:

1. Här använder vi metoden "deleteOne" från MongoDB bibliotek, som används för att radera ett dokument i en mongoDB-samling.
2. Vi specificerar sökkriterierna för vilket dokument som ska raderas. I vårt fall vill vi hitta dokumentet som har anställdsnamnet "Mohan" och ta bort detta dokument.

Om du nu kontrollerar innehållet i din MongoDB databas, hittar du posten med anställd på 4 och anställds namn på "Mohan" raderad från anställd samling.

För att kontrollera att data har uppdaterats korrekt i databasen måste du utföra följande kommandon i MongoDB

1. Använd EmployeeDB
2. db.Employee.find()

Det första uttalandet säkerställer att du är ansluten till EmployeeDb-databasen. Det andra uttalandet söker igenom och visar alla poster i anställds samling. Här kan du se om posten har raderats eller inte.

Modern Async/Avvakta MongoDB Anslutningar i Node.js

Ocuco-landskapet MongoClient.connect(url, återuppringning) mönstret som används i hela artikeln matchar MongoDB Node.js-drivrutinsversion som var aktuell när exemplen ovan skrevs. Nyligen utgivna drivrutiner stöder fortfarande den återanropsstilen, men de flesta nya projekt föredrar nu promises och async/await, eftersom den resulterande koden läses uppifrån och ner utan kapslade återanrop. Stegen nedan skriver om samma Employee-anslutning med modern syntax.

1. Skapa en enda MongoClient-instans utanför valfri funktion, och skicka anslutningssträngen en gång, till exempel const klient = new MongoKlient(url);
2. Ring upp vänta på klient.connect() inuti en async-funktion för att öppna anslutningen istället för att skicka en återanrop.
3. Hämta databasen med klient.db('Medarbetardatabasen') istället för att förlita sig på objektet som returneras i en återanrop.
4. Kör frågor med vänta, till exempel await db.collection('Anställd').find().toArray(), vilket returnerar en array direkt istället för att kräva ett marköranrop.
5. Stäng anslutningen med vänta på klient.close() inuti ett finally-block så att det alltid körs, även om en fråga ger ett fel.

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);

Båda stilarna ansluter till samma EmployeeDB-databas och samma Employee-samling, så befintlig callback-baserad kod behöver inte skrivas om omedelbart. De två metoderna kan samexistera medan ett projekt migreras gradvis, och valet beror mestadels på vilken MongoDB Node.js-drivrutinsversionen av package.json-filen är redan fäst.

Hur man bygger en node express-app med MongoDB att lagra och servera innehåll

Med båda anslutningsstilarna täckta tillämpar nästa avsnitt det klassiska återanropsmönstret i en komplett Express-applikation, eftersom det är den syntax som den ursprungliga exempelservern nedan använder. Bygga en applikation med en kombination av både Express och MongoDB är ganska vanligt nuförtiden.

När du arbetar med JavaScript webbaserade applikationer hör man normalt talas om termen MEAN-stack.

• Termen MEAN stack syftar på en samling av JavaSkriptbaserad teknik som används för att utveckla webbapplikationer.
• MEAN är en akronym för MongoDB, ExpressJS, AngularJSoch Node.js.

Därför är det alltid bra att förstå hur Node.js och MongoDB arbeta tillsammans för att leverera applikationer som interagerar med backend-databaser.

Låt oss titta på ett enkelt exempel på hur vi kan använda "express" och "MongoDB" tillsammans. Vårt exempel kommer att använda samma anställd samling i MongoDB EmployeeDB-databas.

Vi kommer nu att integrera Express för att visa data på vår webbsida när användaren begär det. När vår applikation körs på Node.js kan man behöva bläddra till URL http://localhost:3000/Employeeid.

När sidan är lanserad kommer alla anställda id i anställningssamlingen att visas. Så låt oss se kodavsnittet i avsnitt som gör att vi kan uppnå detta.

Steg 1) Definiera alla bibliotek som behöver användas i vår applikation, som i vårt fall är både MongoDB och expressbibliotek.

Code Förklaring:

1. Vi håller på att definiera vårt "express"-bibliotek, som kommer att användas i vår applikation.
2. Vi definierar vårMongoDB' bibliotek, som kommer att användas i vår applikation för att ansluta till vår MongoDB databas.
3. Här definierar vi URL av vår databas att ansluta till.
4. Slutligen definierar vi en sträng som kommer att användas för att lagra vår samling av medarbetar-id som måste visas i webbläsaren senare.

Steg 2) I det här steget ska vi nu hämta alla poster i vår "Anställd"-samling och arbeta med dem därefter.

Code Förklaring:

1. Vi skapar en väg till vår applikation som heter "Anställd". Så närhelst någon surfar till http://localhost:3000/Employeeid av vår applikation kommer kodavsnittet som definierats för denna rutt att köras.
2. Här får vi alla poster i vår 'Employee'-samling genom kommandot db.collection('Employee').find(). Vi tilldelar sedan denna samling till en variabel som kallas markör. Med denna markörvariabel kommer vi att kunna bläddra igenom alla poster i samlingen.
3. Vi använder nu funktionen cursor.each() för att navigera genom alla poster i vår samling. För varje post kommer vi att definiera ett kodavsnitt om vad som ska göras när varje post nås.
4. Slutligen ser vi att om posten som returneras inte är null, så tar vi den anställde via kommandot "artikel.Anställd". Resten av koden är bara för att konstruera en riktig HTML-kod som gör att våra resultat kan visas korrekt i webbläsaren.

Steg 3) I det här steget kommer vi att skicka vår utdata till webbsidan och få vår applikation att lyssna på en viss port.

Code Förklaring:

1. Här skickar vi hela innehållet som skapades i det tidigare steget till vår webbsida. Parametern 'res' tillåter oss att skicka innehåll till vår webbsida som ett svar.
2. Vi får hela vår Node.js-applikation att lyssna på port 3000.

Produktion:

Från utgången,

• Det visar tydligt att alla anställdas id i anställningssamlingen hämtades. Detta beror på att vi använder MongoDB drivrutinen för att ansluta till databasen och hämta alla anställdas poster och använde sedan "express" för att visa posterna.

Här är koden som referens

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() {});

Obs: cursor.each kanske utfasas baserat på version av din MongoDB förare. Du kan lägga till //noinspection JSDeprecatedSymbols före cursor.each för att kringgå problemet. Alternativt kan du använda forEach. Nedan är exempelkoden som använder 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() {});

Vanliga frågor