kumarshantanu / clj-dbcp Goto Github PK

#!/bin/bash lein-exec
(use '[leiningen.exec :only (deps)])
(deps '[[org.clojure/java.jdbc "0.2.3"]
        [postgresql/postgresql "8.4-702.jdbc4"]
        [clj-http "0.5.6"]
        [clj-dbcp "0.8.0"]])

(require '[clj-dbcp.core     :as dbcp])
(require '[clj-http.client   :as client])
(require '[clojure.java.jdbc :as sql])


(defn query
  [addr #^String query]
    (sql/with-connection addr
                         (sql/transaction
                           (sql/with-query-results results
                                                   [{:fetch-size 100
                                                     :concurrency :read-only
                                                     :result-type :forward-only}
                                                    query] 
                                                   (into [] results)))))



(def db-config (dbcp/make-datasource (dbcp/parse-url "postgresql://[email protected]/mydb")))
(println (take 10 (query db-config "SELECT * FROM forum_posts LIMIT 10")))

...
(println (take 10 (query "postgresql://[email protected]/mydb") "SELECT * FROM table LIMIT 10")))