Capped collection tests now pass
This commit is contained in:
parent
d7902c9618
commit
f02a2b0afc
1 changed files with 17 additions and 25 deletions
|
|
@ -1,33 +1,25 @@
|
||||||
(ns monger.test.capped-collections-test
|
(ns monger.test.capped-collections-test
|
||||||
(:require [monger core util]
|
(:require [monger.core :as mg]
|
||||||
[monger.collection :as mc]
|
[monger.collection :as mc]
|
||||||
[monger.result :as mres]
|
|
||||||
[monger.test.helper :as helper]
|
|
||||||
[clojure.test :refer :all]
|
[clojure.test :refer :all]
|
||||||
[monger.operators :refer :all]
|
[monger.operators :refer :all]))
|
||||||
[monger.test.fixtures :refer :all]))
|
|
||||||
|
|
||||||
(helper/connect!)
|
|
||||||
|
|
||||||
(defn- megabytes
|
(defn- megabytes
|
||||||
[^long n]
|
[^long n]
|
||||||
(* n 1024 1024))
|
(* n 1024 1024))
|
||||||
|
|
||||||
|
(let [conn (mg/connect)
|
||||||
;;
|
db (mg/get-db conn "monger-test")]
|
||||||
;; Tests
|
|
||||||
;;
|
|
||||||
|
|
||||||
(deftest test-inserting-into-capped-collection
|
(deftest test-inserting-into-capped-collection
|
||||||
(let [n 1000
|
(let [n 1000
|
||||||
cname "cached"
|
cname "cached"
|
||||||
_ (mc/drop cname)
|
_ (mc/drop db cname)
|
||||||
coll (mc/create cname {:capped true :size (-> 16 megabytes) :max n})]
|
coll (mc/create db cname {:capped true :size (-> 16 megabytes) :max n})]
|
||||||
(is (= cname (.getName coll)))
|
(is (= cname (.getName coll)))
|
||||||
(mc/insert-batch cname (for [i (range 0 (+ n 100))] {:i i}))
|
(mc/insert-batch db cname (for [i (range 0 (+ n 100))] {:i i}))
|
||||||
(is (= n (mc/count cname)))
|
(is (= n (mc/count db cname)))
|
||||||
;; older elements get replaced by newer ones
|
;; older elements get replaced by newer ones
|
||||||
(is (not (mc/any? cname {:i 1})))
|
(is (not (mc/any? db cname {:i 1})))
|
||||||
(is (not (mc/any? cname {:i 5})))
|
(is (not (mc/any? db cname {:i 5})))
|
||||||
(is (not (mc/any? cname {:i 9})))
|
(is (not (mc/any? db cname {:i 9})))
|
||||||
(is (mc/any? cname {:i (+ n 80)}))))
|
(is (mc/any? db cname {:i (+ n 80)})))))
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue