| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128 |
- 'use strict';
- /**
- * Module dependencies
- */
- const Collection = require('./collection');
- class NodeCollection extends Collection {
- constructor(col) {
- super();
- this.collection = col;
- this.collectionName = col.collectionName;
- }
- /**
- * find(match, options)
- */
- async find(match, options) {
- const cursor = this.collection.find(match, options);
- return cursor.toArray();
- }
- /**
- * findOne(match, options)
- */
- async findOne(match, options) {
- return this.collection.findOne(match, options);
- }
- /**
- * countDocuments(match, options)
- */
- async countDocuments(match, options) {
- return this.collection.countDocuments(match, options);
- }
- /**
- * estimatedDocumentCount(match, options)
- */
- async estimatedDocumentCount(match, options) {
- return this.collection.estimatedDocumentCount(match, options);
- }
- /**
- * distinct(prop, match, options)
- */
- async distinct(prop, match, options) {
- return this.collection.distinct(prop, match, options);
- }
- /**
- * updateMany(match, update, options)
- */
- async updateMany(match, update, options) {
- return this.collection.updateMany(match, update, options);
- }
- /**
- * updateOne(match, update, options)
- */
- async updateOne(match, update, options) {
- return this.collection.updateOne(match, update, options);
- }
- /**
- * replaceOne(match, update, options)
- */
- async replaceOne(match, update, options) {
- return this.collection.replaceOne(match, update, options);
- }
- /**
- * deleteOne(match, options)
- */
- async deleteOne(match, options) {
- return this.collection.deleteOne(match, options);
- }
- /**
- * deleteMany(match, options)
- */
- async deleteMany(match, options) {
- return this.collection.deleteMany(match, options);
- }
- /**
- * findOneAndDelete(match, options, function(err[, result])
- */
- async findOneAndDelete(match, options) {
- return this.collection.findOneAndDelete(match, options);
- }
- /**
- * findOneAndUpdate(match, update, options)
- */
- async findOneAndUpdate(match, update, options) {
- return this.collection.findOneAndUpdate(match, update, options);
- }
- /**
- * findOneAndReplace(match, update, options)
- */
- async findOneAndReplace(match, update, options) {
- return this.collection.findOneAndReplace(match, update, options);
- }
- /**
- * var cursor = findCursor(match, options)
- */
- findCursor(match, options) {
- return this.collection.find(match, options);
- }
- /**
- * aggregation(operators...)
- * TODO
- */
- }
- /**
- * Expose
- */
- module.exports = exports = NodeCollection;
|