ホームページ  >  記事  >  ウェブフロントエンド  >  mongodbを操作するnodejsの追加・削除・変更・クエリ機能を完全マスター

mongodbを操作するnodejsの追加・削除・変更・クエリ機能を完全マスター

小云云
小云云オリジナル
2017-12-23 09:11:471865ブラウズ

この記事では、mongodbを操作するnodejsの追加、削除、変更、クエリ機能を主に紹介し、mongodbモジュールのインストールを簡単に分析し、形式でmongodbデータベースを操作するnodejsの関連実装スキルを分析します。必要な友人が参考になれば幸いです。

関連モジュールをインストールします

これを使用する場合は、最初に必要なモジュールをインストールする必要があります。インストールが成功したら、ルートディレクトリに


npm install mongodb --save

と入力して、モジュールをインストールできます。次の手順に進みます。

ファイルの紹介

以下は私が書いた関連コードで、引用して良いディレクトリに置き、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;

のルートディレクトリに保存しました。 js ファイル名に

を使用します。たとえば、ルーティング ファイルの Index.js にモジュールを導入します。 次に、次のようにオブジェクトをインスタンス化する必要があります:

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

関連情報を構成する必要がある場合は、インスタンス化するときにオブジェクト構成を渡し、データベース アドレスを構成できます:

let server = new Server();


Addメソッド



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

Updateメソッド


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

Deleteメソッド

の4つのメソッド、add、delete、modify、checkをカプセル化しています。
りー

Find メソッド


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

コールバック関数は、処理が成功したかどうかの 2 つの値を返します。2 番目の値は、検索で見つかった数を返します。その他の関数は、成功した処理の数を返します (現在は 1 つだけです)。

ユースケース


たとえば、私 ルート内のデータを見つける必要がある場合、これが必要です:

server.delete(数据表名,查询的数据(对象),回调函数);
上記のコードは、フィールドのデータをクエリします。 username は users テーブルの username です。成功した場合、後続のデータは配列を返します。エラーが発生した場合は、データ エラーを直接返します。

関連する推奨事項:

PHPデータベースの追加、削除、変更、確認メソッド

AngularJsの追加、削除、変更、確認メソッド

MySqlの基本的な書き方の実装追加、削除、変更、確認メソッドNodeJS で

以上がmongodbを操作するnodejsの追加・削除・変更・クエリ機能を完全マスターの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明:
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。