nedb/lib/cursor.js

/**
 * Manage access to data, be it to find, update or remove it
 */
var model = require('./model');

 

/**
 * Create a new cursor for this collection
 * @param {Datastore} db - The datastore this cursor is bound to
 * @param {Query} query - The query this cursor will operate on
 */
function Cursor (db, query) {
  this.db = db;
  this.query = query || {};
}


/**
 * Set a limit the number of results
 */
Cursor.prototype.limit = function(limit) {
  this._limit = limit;
};


/**
 * Sort results of the query
 * @Param {SortQuery} sortQuery - SortQuery is { field: order }, field can use the dot-notation, order is 1 for ascending and -1 for descending
 */
Cursor.prototype.sort = function(sortQuery) {
  this._sort = sortQuery;
};


/**
 * Get all matching elements
 * @param {Function} callback - Signature: err, results
 */
 Cursor.prototype.exec = function(callback) {
  var candidates = this.db.getCandidates(this.query)
    , res = [], added = 0, self = this
    , i
    ;
  
  try {
    for (i = 0; i < candidates.length; i += 1) {
      if (model.match(candidates[i], this.query)) {
        res.push(model.deepCopy(candidates[i]));
        
        if (!this._sort) {   // If a sort is defined, wait for the results to be sorted before applying limit and skip
          added += 1;
          if (this._limit && this._limit <= added) { break; }        
        }
      }
    }
  } catch (err) {
    return callback(err);
  }

  // Apply all sorts
  if (this._sort) {
    Object.keys(this._sort).forEach(function(key) {
      res.sort(function(a, b) {
        return self._sort[key] * model.compareThings(model.getDotValue(a, key), model.getDotValue(b, key));
      });
    });
  }

  return callback(null, res);
};


// Interface
module.exports = Cursor;