From e681bf1a1cd8a390656279ee0b4953dc8fe57d65 Mon Sep 17 00:00:00 2001 From: "Michael S. Klishin" Date: Sat, 10 Sep 2011 08:46:10 +0400 Subject: [PATCH] Implement monger.core/command --- src/monger/core.clj | 9 ++++++++- test/monger/test/core.clj | 12 +++++++++++- 2 files changed, 19 insertions(+), 2 deletions(-) diff --git a/src/monger/core.clj b/src/monger/core.clj index 7c1f50c..3f40915 100644 --- a/src/monger/core.clj +++ b/src/monger/core.clj @@ -9,7 +9,9 @@ (ns monger.core (:refer-clojure :exclude [count]) - (:import (com.mongodb Mongo DB WriteConcern))) + (:use [monger.convertion]) + (:import (com.mongodb Mongo DB WriteConcern DBObject) + (java.util Map))) ;; ;; Defaults @@ -50,3 +52,8 @@ com.mongodb.DBCursor (count [^com.mongodb.DBCursor this] (.count this))) + + +(defn command + [^Map cmd] + (.command ^DB *mongodb-database* ^DBObject (to-db-object cmd))) diff --git a/test/monger/test/core.clj b/test/monger/test/core.clj index 030e053..83d1336 100644 --- a/test/monger/test/core.clj +++ b/test/monger/test/core.clj @@ -1,8 +1,14 @@ (ns monger.test.core - (:require [monger.core]) + (:require [monger core collection util]) (:import (com.mongodb Mongo DB)) (:use [clojure.test])) + +(monger.util/with-ns 'monger.core + (defonce ^:dynamic *mongodb-connection* (monger.core/connect)) + (defonce ^:dynamic *mongodb-database* (monger.core/get-db "monger-test"))) + + (deftest connect-to-mongo-with-default-host-and-port (let [connection (monger.core/connect)] (is (instance? com.mongodb.Mongo connection)))) @@ -27,3 +33,7 @@ ;; (let [connection (monger.core/connect) ;; db (monger.core/get-db connection "monger-test" "monger" "test_password")] ;; (is (instance? com.mongodb.DB db)))) + +(deftest issuing-a-profiling-command + (let [collection "things"] + (monger.core/command { :profile 1 })))