按照这个例子
https://github.com/clojure/java.jdbc/blob/master/doc/clojure/java/jdbc/ConnectionPooling.md
的 jdbc 连接池,我在 Clojure 应用程序中设置了一个连接池到 SQLServer,如下所示
;; Database Connection Handling.
(ns myapp.db
(:import [com.mchange.v2.c3p0 ComboPooledDataSource]))
;; ### specification
;; Defines the database connection parameters.
(def specification {
:classname "com.microsoft.sqlserver.jdbc.SQLServerDriver"
:subprotocol "sqlserver"
:subname "//some;info;here"
})
;; ### pooled-data-source
;; Creates a database connection pool using the
;; <a href="https://github.com/swaldman/c3p0">c3p0</a> JDBC
;; connection pooling library.
(defn pooled-data-source [specification]
(let [datasource (ComboPooledDataSource.)]
(.setDriverClass datasource (:classname specification))
(.setJdbcUrl datasource (str "jdbc:" (:subprotocol specification) ":" (:subname specification)))
(.setUser datasource (:user specification))
(.setPassword datasource (:password specification))
(.setMaxIdleTimeExcessConnections datasource (* 30 60))
(.setMaxIdleTime datasource (* 3 60 60))
{:datasource datasource}))
;; ### connection-pool
;; Creates the connection pool when first called.
(def connection-pool
(delay
(pooled-data-source specification)))
;; ### connection
;; Get a connection from the connection pool.
(defn connection [] @connection-pool)
我知道如何使用连接进行选择和插入语句等,我的问题是我将如何使用它来调用存储过程并收集输出,这些输出可能是各种形状和大小的记录?
;; ### Definitions of queries.
(ns myapp.query
(:require [myapp.db]))
;; HOW DO I CALL THIS PROC THROUGH A POOLED CONNECTION?
(defn call-the-stored-proc []
(str "{ call someStoredProcForMyApp("...")}"))