Node.js
Mongodb-integratie
Zoeken…
Syntaxis
- db. collection .insertOne ( document , opties (w, wtimeout, j, serializeFuntions, forceServerObjectId, bypassDocumentValidation) , callback )
- db. collection .insertMany ( [documenten] , opties (w, wtimeout, j, serializeFuntions, forceServerObjectId, bypassDocumentValidation) , callback )
- db. collection .find ( zoekopdracht )
- db. collection .updateOne ( filter , update , opties (upsert, w, wtimeout, j, bypassDocumentValidation) , callback )
- db. collection .updateMany ( filter , update , opties (upsert, w, wtimeout, j) , callback )
- db. collection .deleteOne ( filter , opties (upsert, w, wtimeout, j) , callback )
- db. collection .deleteMany ( filter , opties (upsert, w, wtimeout, j) , callback )
parameters
Parameter | Details |
---|---|
document | Een javascript-object dat een document vertegenwoordigt |
documenten | Een reeks documenten |
vraag | Een object dat een zoekopdracht definieert |
filter | Een object dat een zoekopdracht definieert |
Bel terug | Functie die moet worden opgeroepen wanneer de bewerking is voltooid |
opties | (optioneel) Optionele instellingen (standaard: null) |
w | (optioneel) Het schrijfprobleem |
wtimeout | (optioneel) Time-out schrijfvaardigheid. (standaard: null) |
j | (optioneel) Geef een bezorgdheid over het schrijven van een dagboek op (standaard: onwaar) |
upsert | (optioneel) Update-bewerking (standaard: onwaar) |
multi | (optioneel) Werk één / alle documenten bij (standaard: onwaar) |
serializeFunctions | (optioneel) Serialiseer functies op elk object (standaard: false) |
forceServerObjectId | (optioneel) Server dwingen _id-waarden toe te wijzen in plaats van stuurprogramma (standaard: false) |
bypassDocumentValidation | (optioneel) Sta stuurprogramma toe om validatie van schema's in MongoDB 3.2 of hoger te omzeilen (standaard: false) |
Maak verbinding met MongoDB
Maak verbinding met MongoDB, print 'Verbonden!' en sluit de verbinding.
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-methode Connect()
MongoClient.connect ( url , opties , callback )
Argument | Type | Beschrijving |
---|---|---|
url | draad | Een tekenreeks die de IP / hostnaam, poort en database van de server opgeeft |
options | voorwerp | (optioneel) Optionele instellingen (standaard: null) |
callback | Functie | Functie die moet worden opgeroepen wanneer de verbindingspoging is voltooid |
De callback
functie heeft twee argumenten
-
err
: Error - Als er een fout optreedt, wordt heterr
argument gedefinieerd -
db
: object - De MongoDB-instantie
Plaats een document
Voeg een document met de naam 'myFirstDocument' in en stel 2 eigenschappen, greetings
en 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
});
});
Verzamelmethode insertOne()
db.collection ( collection ) .insertOne ( document , opties , callback )
Argument | Type | Beschrijving |
---|---|---|
collection | draad | Een tekenreeks die de verzameling aangeeft |
document | voorwerp | Het document dat in de verzameling moet worden ingevoegd |
options | voorwerp | (optioneel) Optionele instellingen (standaard: null) |
callback | Functie | Functie die moet worden opgeroepen wanneer de invoegbewerking is voltooid |
De callback
functie heeft twee argumenten
-
err
: Error - Als er een fout optreedt, wordt heterr
argument gedefinieerd -
result
: object - Een object met details over de invoegbewerking
Lees een verzameling
Haal alle documenten uit de verzameling 'myCollection' op en print ze naar de console.
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
}
});
});
Verzameling methode find()
db.collection ( collection ) .find ()
Argument | Type | Beschrijving |
---|---|---|
collection | draad | Een tekenreeks die de verzameling aangeeft |
Update een document
Zoek een document met de eigenschap { greetings: 'Hellu' }
en wijzig dit in { 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
});
});
Collectie methode updateOne()
db.collection ( collection ) .updateOne ( filter , update , opties . callback )
Parameter | Type | Beschrijving |
---|---|---|
filter | voorwerp | Specificeert de selectiecriteria |
update | voorwerp | Specificeert de toe te passen wijzigingen |
options | voorwerp | (optioneel) Optionele instellingen (standaard: null) |
callback | Functie | Functie die moet worden opgeroepen wanneer de bewerking is voltooid |
De callback
functie heeft twee argumenten
-
err
: Error - Als er een fout optreedt, wordt het fout-argument gedefinieerd -
db
: object - De MongoDB-instantie
Verwijder een document
Verwijder een document met de eigenschap { 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
});
});
Verzamelmethode deleteOne()
db.collection ( collectie ) .deleteOne ( filter , opties , callback )
Parameter | Type | Beschrijving |
---|---|---|
filter | voorwerp | Een document dat de selectiecriteria aangeeft |
options | voorwerp | (optioneel) Optionele instellingen (standaard: null) |
callback | Functie | Functie die moet worden opgeroepen wanneer de bewerking is voltooid |
De callback
functie heeft twee argumenten
-
err
: Error - Als er een fout optreedt, wordt het fout-argument gedefinieerd -
db
: object - De MongoDB-instantie
Verwijder meerdere documenten
Verwijder ALLE documenten met een 'afscheid' eigenschap ingesteld op 'oké'.
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
});
});
Verzamelmethode deleteMany()
db.collection ( collectie ) .deleteMany ( filter , opties , callback )
Parameter | Type | Beschrijving |
---|---|---|
filter | document | Een document dat de selectiecriteria aangeeft |
options | voorwerp | (optioneel) Optionele instellingen (standaard: null) |
callback | functie | Functie die moet worden opgeroepen wanneer de bewerking is voltooid |
De callback
functie heeft twee argumenten
-
err
: Error - Als er een fout optreedt, wordt het fout-argument gedefinieerd -
db
: object - De MongoDB-instantie
Eenvoudig verbinden
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); }); });
Eenvoudig verbinden, gebruikmakend van beloften
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);
});
```