Clojure / SQLServer:如何使用 C3P0 连接池调用存储过程

Dav*_*ams 5 sql-server clojure c3p0

按照这个例子

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)
Run Code Online (Sandbox Code Playgroud)

我知道如何使用连接来制作选择和插入语句等,我的问题是我将如何使用它来调用存储过程并收集可能是各种形状和大小的记录的输出?

;; ### 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("...")}"))
Run Code Online (Sandbox Code Playgroud)

Jer*_*emy 3

对于不需要 OUT 参数的基本存储过程,您可以使用db-do-prepared.

(require '[clojure.java.jdbc :as j])
(j/db-do-prepared (connection) "EXEC YourStoredProc ?" [COLUMN_NAME])
Run Code Online (Sandbox Code Playgroud)

它调用您的connection函数,该函数与文档中所说的调用的函数相同。

我已经开始致力于向 JDBC 添加完整的可调用语句支持,但我还没有时间完成这项工作。这是Clojue 的 JIRA 中的JDBC-48问题,我的进展在我的 fork 的 sprocs 分支中