Implementierung der Verbindung zur Mongodb-Datenbank mithilfe von Nodejs

In diesem Artikel wird hauptsächlich der Implementierungscode für die Verwendung von Nodejs zum Herstellen einer Verbindung zur Mongodb-Datenbank vorgestellt

Ein einfaches Beispiel für die Verbindung von Nodejs mit Mongodb, aus dem offiziellen Beispiel von Mongodb

1. Erstellen Sie package.json

Erstellen Sie zunächst unser Projektverzeichnis connect-mongodb und verwenden Sie es als unser aktuelles Verzeichnis

mkdir connect-mongodb
cd connect-mongodb

Geben Sie den Befehl npm init ein, um package.json

npm init

zu erstellen. Installieren Sie dann den NodeJS-Versionstreiber von mongodb

npm install mongodb --save

Das Mongodb-Treiberpaket wird in node_modules im aktuellen Verzeichnis installiert

2. Starten Sie MongoDB Server

Installieren Sie MongoDB und starten Sie den MongoDB-Datenbankdienst. Weitere Informationen finden Sie in meinem vorherigen Artikel oder in der offiziellen MongoDB-Dokumentation

3 MongoDB

Erstellen Sie eine app.js-Datei und fügen Sie den folgenden Code hinzu, um eine Verbindung zur Datenbank namens myNewDatabase auf der Serveradresse 192.168.0.243 und dem Mongodb-Port 27017 herzustellen

var MongoClient = require('mongodb').MongoClient,
  assert = require('assert');
// Connection URL
var url = 'mongodb://192.168.0.243:27017/myNewDatabase';
MongoClient.connect(url,function(err,db){
  assert.equal(null,err);
  console.log("Connection successfully to server");
  db.close();
});

Geben Sie den folgenden Befehl in der Befehlszeile ein, um app.js auszuführen

node app.js

4 . Dokument einfügen

Fügen Sie den folgenden Code in app.js hinzu und verwenden Sie die Methode insertMany, um 3 Dokumente zur Dokumentensammlung hinzuzufügen

var insertDocuments = function(db, callback){
  // get ths documents collection
  var collection = db.collection('documents');
  // insert some documents
  collection.insertMany([
    {a:1},{a:2},{a:3}
  ],function(err,result){
    assert.equal(err,null);
    assert.equal(3,result.result.n);
    assert.equal(3,result.ops.length);
    console.log("Inserted 3 documents into the collection");
    callback(result);
  });
};

Der Einfügebefehl gibt ein Objekt zurück, das die folgenden Eigenschaften enthält:

• Ergebnis Dokumentergebnis zurückgegeben von MongoDB

• ops Dokument mit _id Feld hinzugefügt

• Verbindung Die Verbindung, die zum Ausführen des Einfügevorgangs verwendet wird

Aktualisieren Sie den folgenden Code in app.js, um die Methode insertDocuments aufzurufen

var MongoClient = require('mongodb').MongoClient
 , assert = require('assert');
// Connection URL
var url = 'mongodb://localhost:27017/myproject';
// Use connect method to connect to the server
MongoClient.connect(url, function(err, db) {
 assert.equal(null, err);
 console.log("Connected successfully to server");
 insertDocuments(db, function() {
  db.close();
 });
});

Verwenden Sie node app.js in der Befehlszeile, um

5 auszuführen. Fragen Sie alle Dokumente ab

FindDocuments-Funktion hinzufügen

var findDocuments = function(db,callback){
  // get the documents collection
  var collection = db.collection('documents');
  // find some documents
  collection.find({}).toArray(function(err,docs){
    assert.equal(err,null);
    console.log("Found the following records");
    console.log(docs);
    callback(docs);
  });
};

Die FindDocuments-Funktion fragt alle Dokumente in allen „Dokumenten“-Sammlungen ab und fügt diese Funktion der Rückruffunktion hinzu von MongoClient.connect

var MongoClient = require('mongodb').MongoClient
 , assert = require('assert');
// Connection URL
var url = 'mongodb://localhost:27017/myproject';
// Use connect method to connect to the server
MongoClient.connect(url, function(err, db) {
 assert.equal(null, err);
 console.log("Connected correctly to server");
 insertDocuments(db, function() {
  findDocuments(db, function() {
   db.close();
  });
 });
});

6. Abfragefilter zum Abfragen von Dokumenten verwenden

Abfrage Dokumente für 'a':3

var findDocuments = function(db, callback) {
 // Get the documents collection
 var collection = db.collection('documents');
 // Find some documents
 collection.find({'a': 3}).toArray(function(err, docs) {
  assert.equal(err, null);
  console.log("Found the following records");
  console.log(docs);
  callback(docs);
 });   
}

7. Dokument aktualisieren

var updateDocument = function(db,callback){
  // get the documents collection
  var collection = db.collection('documents');
  // update document where a is 2, set b equal to 1
  collection.updateOne({a:2},{
    $set:{b:1}
  },function(err,result){
    assert.equal(err,null);
    assert.equal(1,result.result.n);
    console.log("updated the document with the field a equal to 2");
    callback(result);
  });
};

UpdateDocument-Methodenaktualisierung Fügen Sie für das erste Dokument, das die Bedingung erfüllt, dass a 2 ist, ein b-Attribut hinzu und setzen Sie es auf 1.

Fügen Sie die updateDocument-Methode zum Rückruf der MongoClient.connect-Methode hinzu

MongoClient.connect(url,function(err,db){
  assert.equal(null,err);
  console.log("Connection successfully to server");
  insertDocuments(db,function(){
    updateDocument(db,function(){
      db.close();
    });
  });
});

8. Löschen Sie das Dokument

var removeDocument = function(db,callback){
  // get the documents collection
  var collection = db.collection('documents');
  // remove some documents
  collection.deleteOne({a:3},function(err,result){
    assert.equal(err,null);
    assert.equal(1,result.result.n);
    console.log("removed the document with the field a equal to 3");
    callback(result);
  });
};

Zu app.js hinzufügen

var MongoClient = require('mongodb').MongoClient
 , assert = require('assert');
// Connection URL
var url = 'mongodb://localhost:27017/myproject';
// Use connect method to connect to the server
MongoClient.connect(url, function(err, db) {
 assert.equal(null, err);
 console.log("Connected successfully to server");
 insertDocuments(db, function() {
  updateDocument(db, function() {
   removeDocument(db, function() {
    db.close();
   });
  });
 });
});

9. Erstellen Sie Indizes

Indizes können die Anwendungsleistung verbessern. Unten fügt Ihr Code einen Index für das „a“-Attribut hinzu:

var indexCollection = function(db,callback){
  db.collection('documents').createIndex({
    a:1
  },null,function(err,results){
    console.log(results);
    callback();
  });
};

Update app.js

MongoClient.connect(url,function(err,db){
  assert.equal(null,err);
  console.log("Connection successfully to server");
  insertDocuments(db,function(){
    indexCollection(db,function(){
      db.close();
    });
  });
});

Das Obige ist der gesamte Inhalt dieses Artikels. Ich hoffe, er wird für das Studium aller hilfreich sein. Weitere verwandte Inhalte finden Sie auf der chinesischen PHP-Website.

Verwandte Empfehlungen:

Methoden zur Verhinderung der SQL-Injection in Node-MySQL

NodeJs-Formulardatenformat zum Übertragen von Dateien Methode

Das obige ist der detaillierte Inhalt vonImplementierung der Verbindung zur Mongodb-Datenbank mithilfe von Nodejs. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!