Add 'close-cursor' to delete a declared cursor explicitly.

src/dbd/postgres.lisp

@@ -133,6 +133,13 @@
                  :connection conn
                  :sql sql))
 
+(defmethod close-cursor-using-connection ((conn dbd-postgres-connection) (cursor dbi-cursor))
+  (when (cursor-declared-p cursor)
+    (exec-query (connection-handle conn)
+                (format nil "CLOSE ~A" (cursor-name cursor)))
+    (setf (cursor-declared-p cursor) nil)
+    t))
+
 (defmethod execute-using-connection ((conn dbd-postgres-connection) (cursor dbi-cursor) params)
   (assert (in-transaction conn))
   (with-accessors ((sql query-sql)

src/driver.lisp

@@ -32,6 +32,8 @@
            #:cursor-formatter
            #:cursor-declared-p
            #:make-cursor
+           #:close-cursor
+           #:close-cursor-using-connection
            #:prepare
            #:prepare-cached
            #:execute
@@ -183,6 +185,10 @@ This method may be overrided by subclasses."
     (error 'dbi-unimplemented-error
            :method-name 'make-cursor)))
 
+(defgeneric close-cursor (cursor)
+  (:method ((cursor dbi-cursor))
+    (close-cursor-using-connection (dbi-connection cursor) cursor)))
+
 (defgeneric execute (query &optional params)
   (:documentation "Execute `query` with `params` and return the results.")
   (:method (object &optional params)
@@ -271,6 +277,11 @@ This method must be implemented in each drivers.")
     (error 'dbi-unimplemented-error
            :method-name 'execute-using-connection)))
 
+(defgeneric close-cursor-using-connection (conn cursor)
+  (:method (conn cursor)
+    (declare (ignore conn cursor))
+    (error 'dbi-unimplemented-error
+           :method-name 'close-cursor-using-connection)))
 
 (defgeneric begin-transaction (conn)
   (:documentation "Start a transaction.")

t/dbd/postgres.lisp

@@ -7,6 +7,7 @@
                 #:do-sql
                 #:with-transaction
                 #:make-cursor
+                #:close-cursor
                 #:execute
                 #:fetch))
 (in-package #:dbd-postgres-test)
@@ -38,8 +39,10 @@
               (make-cursor conn "SELECT * FROM person")))
         (execute cursor)
         (ok (equal (getf (fetch cursor) :|name|) "Woody"))
-        (ok (equal (getf (fetch cursor) :|name|) "Buzz"))))
+        (ok (equal (getf (fetch cursor) :|name|) "Buzz"))
+        (close-cursor cursor)))
     (with-transaction conn
       (let ((cursor (make-cursor conn "SELECT * FROM person WHERE name = 'Trixie'")))
         (execute cursor)
-        (ok (null (fetch cursor)))))))
+        (ok (null (fetch cursor)))
+        (close-cursor cursor)))))