Add MongoCollection and adaptiveCollection abstraction to MongoAdapter.

This commit is contained in:
Nikita Lutsenko
2016-03-01 20:04:15 -08:00
parent 92e51ab4d3
commit 49994b6e87
2 changed files with 57 additions and 0 deletions

View File

@@ -1,4 +1,6 @@
import MongoCollection from './MongoCollection';
let mongodb = require('mongodb');
let MongoClient = mongodb.MongoClient;
@@ -30,6 +32,12 @@ export class MongoStorageAdapter {
});
}
adaptiveCollection(name: string) {
return this.connect()
.then(() => this.database.collection(name))
.then(rawCollection => new MongoCollection(rawCollection));
}
collectionExists(name: string) {
return this.connect().then(() => {
return this.database.listCollections({ name: name }).toArray();