diff --git a/src/next/jdbc/transaction.clj b/src/next/jdbc/transaction.clj index 1c6ce80..768c48a 100644 --- a/src/next/jdbc/transaction.clj +++ b/src/next/jdbc/transaction.clj @@ -113,9 +113,12 @@ (catch Exception _)))))))) (defn- raw-connection ^Connection [^Connection con] - (if (.isWrapperFor con Connection) - (.unwrap con Connection) - con)) + (try ; because some drivers do not implement this :( + (if (.isWrapperFor con Connection) + (.unwrap con Connection) + con) + (catch Exception _ + con))) (extend-protocol p/Transactable java.sql.Connection