12345678910111213141516171819202122232425262728 |
- var assert = require('assert');
- var mongo = require('mongodb');
- var uri = process.env.MQUERY_URI || 'mongodb://localhost/mquery';
- var client;
- var db;
- exports.getCollection = function(cb) {
- mongo.MongoClient.connect(uri, function(err, _client) {
- assert.ifError(err);
- client = _client;
- db = client.db();
- var collection = db.collection('stuff');
- // clean test db before starting
- db.dropDatabase(function() {
- cb(null, collection);
- });
- });
- };
- exports.dropCollection = function(cb) {
- db.dropDatabase(function() {
- client.close(cb);
- });
- };
|