luciano/monger
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Support aggregation options, closes #102

Browse source
This commit is contained in:
Michael Klishin 2015-06-23 22:01:06 +03:00
parent aeab2851c1
commit 94029c7f6c
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/clojure/monger/collection.clj
View file

@ -523,11 +523,13 @@
"Executes an aggregation query. MongoDB 2.2+ only. "Executes an aggregation query. MongoDB 2.2+ only.
See http://docs.mongodb.org/manual/applications/aggregation/ to learn more." See http://docs.mongodb.org/manual/applications/aggregation/ to learn more."
[^DB db ^String coll stages] ([^DB db ^String coll stages]
(let [res (mc/command db {:aggregate coll :pipeline stages})] (aggregate db coll stages {}))
;; this is what DBCollection#distinct does. Turning a blind's eye! ([^DB db ^String coll stages opts]
(.throwOnError res) (let [res (mc/command db (merge {:aggregate coll :pipeline stages} opts))]
(map #(from-db-object % true) (.get res "result")))) ;; this is what DBCollection#distinct does. Turning a blind's eye!
(.throwOnError res)
(map #(from-db-object % true) (.get res "result")))))
;; ;;