Comment faire fonctionner le module de remplissage, de suppression, de modification et de requête de mongodb à l'aide de nodejs

Ci-dessous, je partagerai avec vous un exemple de production et d'introduction du module de remplissage, de suppression, de modification et de vérification pour que nodejs fasse fonctionner mongodb. Il a une bonne valeur de référence et j'espère qu'il sera utile à 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

Utiliser

us Lorsque vous devez utiliser la page, introduisez d'abord le module. Par exemple, je l'ai introduit dans le fichier de routage index.js :

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

Ensuite, vous devez instancier l'objet, 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"});

Il y a quatre méthodes encapsulées dedans, ajouter, supprimer, modifier et vérifier respectivement Oui

Ajouter une méthode

serveur. .insert (nom de la table de données, données à insérer (objet paire clé-valeur), fonction de rappel);

Méthode de mise à jour

serveur .update (nom de la table de données, données interrogées (objet), données mises à jour (objet)), fonction de rappel);

Méthode de suppression

server.delete (nom de la table de données, données interrogées (objet), fonction de rappel) ;

Méthode de recherche

server.find(table de données nom, données interrogées (objet), fonction de rappel);

La fonction de rappel renverra deux valeurs, la première de type booléen, si le traitement est réussi, la deuxième valeur, la recherche renvoie le numéro trouvé, et le 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 interroge les utilisateurs. Si le nom d'utilisateur correspond aux données du champ de la table, en cas de succès, les données renverront un tableau. Si une erreur se produit, l'erreur de données sera. être restitué directement.

J'ai compilé ce qui précède pour vous, j'espère que cela vous sera utile à l'avenir.

Articles connexes :

MySQL modifie le mot de passe root

Comment écrire du code JS de qualité

Utilisation associée de la réduction du tableau js

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!