diff options
Diffstat (limited to 'src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/github.com/mongodb/mongo-tools-common/db/query.go')
-rw-r--r-- | src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/github.com/mongodb/mongo-tools-common/db/query.go | 38 |
1 files changed, 0 insertions, 38 deletions
diff --git a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/github.com/mongodb/mongo-tools-common/db/query.go b/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/github.com/mongodb/mongo-tools-common/db/query.go deleted file mode 100644 index 4c098d5539c..00000000000 --- a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/github.com/mongodb/mongo-tools-common/db/query.go +++ /dev/null @@ -1,38 +0,0 @@ -package db - -import ( - "go.mongodb.org/mongo-driver/bson" - "go.mongodb.org/mongo-driver/mongo" - mopt "go.mongodb.org/mongo-driver/mongo/options" -) - -// DeferredQuery represents a deferred query -type DeferredQuery struct { - Coll *mongo.Collection - Filter interface{} - Hint interface{} - LogReplay bool -} - -// EstimatedDocumentCount issues a count command. -func (q *DeferredQuery) EstimatedDocumentCount() (int, error) { - opt := mopt.EstimatedDocumentCount() - c, err := q.Coll.EstimatedDocumentCount(nil, opt) - return int(c), err -} - -// Iter executes a find query and returns a cursor. -func (q *DeferredQuery) Iter() (*mongo.Cursor, error) { - opts := mopt.Find() - if q.Hint != nil { - opts.SetHint(q.Hint) - } - if q.LogReplay { - opts.SetOplogReplay(true) - } - filter := q.Filter - if filter == nil { - filter = bson.D{} - } - return q.Coll.Find(nil, filter, opts) -} |