MongoDB
 sql >> Baza danych >  >> NoSQL >> MongoDB

Node.js ponowne użycie odniesienia MongoDB

mydb.js :

var mongodb= require('mongodb'),
  server = new mongodb.Server('staff.mongohq.com', 10030, {
    auto_reconnect: true
  }),
  db1 = new mongodb.Db('mydb', server);


// callback: (err, db)
function openDatabase(callback) {
  db1.open(function(err, db) {
    if (err)
      return callback(err);

    console.log('Database connected');

    return callback(null, db);
  });
}

// callback: (err, collection)
function authenticate(db, username, password, callback) {
  db.authenticate(username, password, function(err, result) {
    if (err) {
      return callback (err);
    }
    if (result) {
      var collection = new mongodb.Collection(db, 'test');

      // always, ALWAYS return the error object as the first argument of a callback
      return callback(null, collection);
    } else {
      return callback (new Error('authentication failed'));
    }
  });
}

exports.openDatabase = openDatabase;
exports.authenticate = authenticate;

use.js :

var mydb = require('./mydb');
// open the database once
mydb.openDatabase(function(err, db) {
  if (err) {
    console.log('ERROR CONNECTING TO DATABASE');
    console.log(err);
    process.exit(1);
  }

  // authenticate once after you opened the database. What's the point of 
  // authenticating on-demand (for each query)?
  mydb.authenticate(db, 'usernsame', 'password', function(err, collection) {
    if (err) {
      console.log('ERROR AUTHENTICATING');
      console.log(err);
      process.exit(1);
    }

    // use the returned collection as many times as you like INSIDE THE CALLBACK
    collection.find({}, {limit: 10})
    .toArray(function(err, docs) {
      console.log('\n------ 1 ------');
      console.log(docs);
    });

    collection.find({}, {limit: 10})
    .toArray(function(err, docs) {
      console.log('\n------ 2 ------');
      console.log(docs);
    });
  });
});

Wynik:

o sukcesie:

w przypadku niepowodzenia:

[Oryginalna odpowiedź]:

Otwierasz db wiele razy (raz w każdym query ). Powinieneś otworzyć bazę danych tylko raz i użyć db obiekt w wywołaniu zwrotnym do późniejszego wykorzystania.

Wielokrotnie używasz tej samej nazwy zmiennej, co może spowodować pewne zamieszanie.

var mongodb = require('mongodb'),
    server = new mongodb.Server('staff.mongohq.com', 10030, {
        auto_reconnect: true
    }),
    db1 = new mongodb.Db('mydb', server);

function authenticateAndGo(db, handle) {
    db.authenticate('username', 'password', function(err) {
        if (err) {
            console.log(err);
            return;
        }
        console.log('Database user authenticated');

        var collection = new mongodb.Collection(db, 'test');

        handle(collection);
    });
}

function query(handle) {
    db1.open(function(err, db2) {
        if( err ) {
            console.log(err);
            return;
        }
        console.log('Database connected');

        authenticateAndGo(db2, handle);
    });
};
exports.query = query;

Zmieniłem trochę powyższy kod (db1 dla oryginalnej bazy danych, db2 dla otwartego db). Jak widzisz, otwierasz db1 wielokrotnie, co nie jest dobre. wyodrębnij kod do otwarcia do innej metody i użyj go RAZ i użyj db2 przykład dla wszystkich zapytań/aktualizacji/usunięć/...



  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. zaktualizuj głęboko zagnieżdżoną tablicę mongodb

  2. E:Nie można znaleźć pakietu mongodb-org

  3. Zapytanie MongoDB porównujące 2 pola w tej samej kolekcji bez $where

  4. Refaktoryzacja kodu oprogramowania pośredniego projektu NodeJS z wykorzystaniem tras, kontrolerów i modeli

  5. Błąd Mongo na poprawce kontroluję