#17: Support connection validation

dev/user.clj

@@ -6,7 +6,8 @@
   (pg/open-db {:hostname "localhost"
                :database "postgres"
                :username "postgres"
-               :password "postgres"}))
+               :password "postgres"
+               :validation-query "select 1"}))
 
 (defn reload []
   (repl/refresh))

project.clj

@@ -7,7 +7,7 @@
         :url "http://github.com/alaisi/postgres.async.git"}
   :dependencies [[org.clojure/clojure "1.6.0"]
                  [org.clojure/core.async "0.1.346.0-17112a-alpha"]
-                 [com.github.alaisi.pgasync/postgres-async-driver "0.6"]
+                 [com.github.alaisi.pgasync/postgres-async-driver "0.7-SNAPSHOT"]
                  [cheshire "5.5.0" :scope "provided"]]
   :lein-release {:deploy-via :clojars}
   :global-vars {*warn-on-reflection* true}

src/postgres/async.clj

@@ -18,7 +18,8 @@
 
 (defn open-db
   "Creates a db connection pool"
-  [{:keys [hostname port username password database pool-size ssl] :as config}]
+  [{:keys [hostname port username password database pool-size ssl validation-query]
+    :as config}]
   (doseq [param [:hostname :username :password :database]]
     (when (nil? (param config))
       (throw (IllegalArgumentException. (str param " is required")))))
@@ -30,6 +31,7 @@
       (.password password)
       (.ssl (boolean ssl))
       (.poolSize (or pool-size 25))
+      (.validationQuery validation-query)
       (.dataConverter (create-converter))
       (.build)))