Maîtriser complètement les fonctions d'ajout, de suppression, de modification et de requête de nodejs exploitant mongodb-js tutoriel-php.cn

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

小云云

Libérer： 2017-12-23 09:11:47

original

1939 Les gens l'ont consulté

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

Copier après la connexion

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: &#39;mongodb://localhost:27017/jk&#39;,
    MongoClient:require(&#39;mongodb&#39;).MongoClient,
    assert:require(&#39;assert&#39;)
  };
  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;

Copier après la connexion

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

Copier après la connexion

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

let server = new Server();

Copier après la connexion

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

Copier après la connexion

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

Ajouter une méthode

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

Copier après la connexion

Méthode de mise à jour

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

Copier après la connexion

Supprimer la méthode

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

Copier après la connexion

Rechercher la méthode

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

Copier après la connexion

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

Copier après la connexion

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!