result sets

resultset.clj

(defn result-set
  [^ResultSet rs & {:keys [identifiers]
                    :or {identifiers str/lower-case}}]
  (reify clojure.lang.IReduce
    (reduce [this f]
      (reduce [this f (f)]))
    (reduce [this f init]
      (let [rsmeta (.getMetaData rs)
            idxs   (range 1 (inc (.getColumnCount rsmeta)))
 
            col    (fn [^Integer i]
                     (.getColumnLabel rsmeta i))
 
            val    (fn [^Integer i]
                     (-> rs
                         (.getObject i)
                         (result-set-read-column rsmeta i)))
 
            keys   (->> (map col idxs)
                        make-cols-unique
                        (map (comp keyword identifiers)))]
        (loop [ret init]
          (if (.next rs)
            (let [ret (f ret (zipmap keys (map val idxs)))]
              (if (reduced? ret)
                @ret
                (recur ret)))
            ret))))))