Maîtriser complètement les fonctions d'ajout, de suppression, de modification et de requête de nodejs exploitant mongodb

Cet article présente principalement les fonctions d'ajout, de suppression, de modification et de requête de nodejs dans l'exploitation de mongodb. Il analyse brièvement l'installation du module mongodb et analyse les compétences d'implémentation associées de nodejs dans l'exploitation de la base de données mongodb pour effectuer des ajouts, des suppressions, modification et requête sous forme d'exemples. Les amis qui en ont besoin peuvent s'y référer. J'espère que cela pourra aider tout le monde.

Installer les modules pertinents

Si vous l'utilisez, vous devez d'abord installer vous-même les modules requis et entrer

dans le répertoire racine

npm install mongodb --save

Installez le module Une fois l'installation réussie, vous pouvez procéder aux étapes suivantes.

Introduction des fichiers

Ce qui suit est le code pertinent que j'ai écrit, mettez-le dans le répertoire pertinent que vous pouvez citer, je le mets à la racine du répertoire express

function Mongo(options) {
  this.settings = {
    url: 'mongodb://localhost:27017/jk',
    MongoClient:require('mongodb').MongoClient,
    assert:require('assert')
  };
  for(let i in options){
    this.settings[i] = options[i];
  }
  this._run = function (fun) {
    let that = this;
    let settings = this.settings;
    this.settings.MongoClient.connect(this.settings.url, function (err, db) {
      settings.assert.equal(null, err);
      console.log("Connected correctly to server");
      fun(db, function () {
        db.close();
      });
    });
  };
  this.insert = function (collectionName, data, func) {
    //增加数据
    let insertDocuments = function (db, callback) {
      let collection = db.collection(collectionName);
      collection.insertMany([
        data
      ], function (err, result) {
        if (!err) {
          func(true);
        } else {
          func(false);
        }
        callback(result);
      });
    };
    this._run(insertDocuments);
  };
  this.update = function (collectionName, updateData, data, func) {
    //更新数据
    let updateDocument = function (db, callback) {
      let collection = db.collection(collectionName);
      collection.updateOne(updateData
        , {$set: data}, function (err, result) {
          if (!err) {
            func(true);
          } else {
            func(false);
          }
          callback(result);
        });
    };
    this._run(updateDocument);
  };
  this.delete = function (collectionName, data, func) {
    //删除数据
    let deleteDocument = function (db, callback) {
      let collection = db.collection(collectionName);
      collection.deleteOne(data, function (err, result) {
        if (!err) {
          func(true);
        } else {
          func(false);
        }
        callback(result);
      });
    };
    this._run(deleteDocument);
  };
  this.find = function (collectionName, data, func) {
    //查找数据
    let findDocuments = function (db, callback) {
      // Get the documents collection
      let collection = db.collection(collectionName);
      // Find some documents
      collection.find(data).toArray(function (err, docs) {
        if (!err) {
          func(true,docs);
        }
        else {
          func(false, err);
        }
        callback(docs);
      });
    };
    this._run(findDocuments);
  };
}
module.exports = Mongo;

Je l'ai enregistré dans un fichier nommé server.js

en utilisant

Nous introduisons d'abord le module lorsque nous devons utiliser la page. Par exemple, je l'ai introduit dans le fichier de routage index.js :

const Server = require("../server.js");

Ensuite, nous avons besoin d'un objet instance, comme suit :

let server = new Server();

Si vous devez configurer des informations associées, vous pouvez transmettre une configuration d'objet lors de l'instanciation, et vous pouvez configurer l'adresse de la base de données :

let server = new Server({url:"mongodb://localhost:27017/mydb"});

encapsule quatre méthodes, ajouter, supprimer, modifier et vérifier, à savoir

Ajouter une méthode

server.insert(数据表名,需要插入的数据（键值对的对象）,回调函数);

Méthode de mise à jour

server.update(数据表名,查询的数据（对象）,更新的数据（对象）,回调函数);

Supprimer la méthode

server.delete(数据表名,查询的数据（对象）,回调函数);

Rechercher la méthode

server.find(数据表名,查询的数据（对象）,回调函数);

La fonction de rappel renverra deux valeurs. Un type booléen, si le traitement est réussi, la deuxième valeur, la recherche renvoie le numéro trouvé, et d'autres renvoient le nombre de traitements réussis (maintenant un seul est traité à la fois)

Cas d'utilisation

Par exemple, si j'ai besoin de trouver des données dans un itinéraire, j'ai besoin de ceci :

server.find("users",{username:"username"},function (bool,data) {
    if(bool){
      console.log("查询到数据为"+data.length+"条");
    }
    else{
      console.log(data);
    }
  });
});

Le code ci-dessus Il interroge les données du champ où le nom d'utilisateur est le nom d'utilisateur dans la table des utilisateurs. En cas de succès, les données renverront un tableau plus tard. Si une erreur se produit, une erreur de données sera renvoyée directement. .

Recommandations associées :

Méthodes d'ajout, de suppression, de modification et de requête de base de données PHP

Méthode d'ajout, de suppression, de modification et de requête d'AngularJs

Mise en œuvre de la méthode d'écriture de base d'ajout, de suppression, de modification et d'interrogation de MySql dans NodeJS

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!