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

Switch monger.core to alter-var-root

Browse source 
Previous implementation was almost literally my first code in Clojure. Needless to say it sucked.
This commit is contained in:
Michael S. Klishin 2012-02-28 20:23:50 +04:00
parent d768b843a9
commit 63d40179fe
1 changed files with 11 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
src/monger/core.clj
View file

@ -142,23 +142,26 @@
(set! (. mo fsync) fsync)) (set! (. mo fsync) fsync))
mo)) mo))
(defn connect!
"Connect to MongoDB, store connection in the *mongodb-connection* var"
^Mongo [& args]
(def ^:dynamic *mongodb-connection* (apply connect args)))
(defn set-connection! (defn set-connection!
"Sets given MongoDB connection as default by altering *mongodb-connection* var" "Sets given MongoDB connection as default by altering *mongodb-connection* var"
^Mongo [^Mongo conn] ^Mongo [^Mongo conn]
(def ^:dynamic *mongodb-connection* conn)) (alter-var-root (var *mongodb-connection*) (constantly conn)))
(defn connect!
"Connect to MongoDB, store connection in the *mongodb-connection* var"
^Mongo [& args]
(let [c (apply connect args)]
(set-connection! c)))
(defn set-db! (defn set-db!
"Sets *mongodb-database* var to given db, updates *mongodb-gridfs* var state. Recommended to be used for "Sets *mongodb-database* var to given db, updates *mongodb-gridfs* var state. Recommended to be used for
applications that only use one database." applications that only use one database."
[db] [db]
(def ^:dynamic *mongodb-database* db) (alter-var-root (var *mongodb-database*) (constantly db))
(def ^:dynamic *mongodb-gridfs* (GridFS. db))) (alter-var-root (var *mongodb-gridfs*) (constantly (GridFS. db))))
(defn set-default-write-concern! (defn set-default-write-concern!
@ -226,8 +229,7 @@
([^Map cmd] ([^Map cmd]
(.command ^DB *mongodb-database* ^DBObject (to-db-object cmd))) (.command ^DB *mongodb-database* ^DBObject (to-db-object cmd)))
([^DB database ^Map cmd] ([^DB database ^Map cmd]
(.command ^DB database ^DBObject (to-db-object cmd))) (.command ^DB database ^DBObject (to-db-object cmd))))
)
(defprotocol Countable (defprotocol Countable
(count [this] "Returns size of the object")) (count [this] "Returns size of the object"))