r9403: Rework conditions to be CommonSQL backward compatible
[clsql.git] / db-postgresql-socket / postgresql-socket-sql.lisp
index 24597c0d6459f8cd0c4c77afcbaa02a1a2a3b626..0bfc01b5a025796d259c92fc52b17dbc8490b080 100644 (file)
@@ -20,7 +20,7 @@
 (in-package #:cl-user)
 
 (defpackage :clsql-postgresql-socket
-    (:use #:common-lisp #:clsql-base #:postgresql-socket)
+    (:use #:common-lisp #:clsql-sys #:postgresql-socket)
     (:export #:postgresql-socket-database)
     (:documentation "This is the CLSQL socket interface to PostgreSQL."))
 
@@ -29,7 +29,7 @@
 ;; interface foreign library loading routines
 
 
-(clsql-base:database-type-load-foreign :postgresql-socket)
+(clsql-sys:database-type-load-foreign :postgresql-socket)
 
 
 ;; Field type conversion
@@ -106,10 +106,10 @@ doesn't depend on UFFI."
 (defun convert-to-clsql-warning (database condition)
   (ecase *backend-warning-behavior*
     (:warn
-     (warn 'clsql-database-warning :database database
+     (warn 'sql-database-warning :database database
           :message (postgresql-condition-message condition)))
     (:error
-     (error 'clsql-sql-error :database database
+     (error 'sql-database-error :database database
            :message (format nil "Warning upgraded to error: ~A" 
                             (postgresql-condition-message condition))))
     ((:ignore nil)
@@ -117,10 +117,11 @@ doesn't depend on UFFI."
      )))
 
 (defun convert-to-clsql-error (database expression condition)
-  (error 'clsql-sql-error :database database
+  (error 'sql-database-data-error
+        :database database
         :expression expression
-        :errno (type-of condition)
-        :error (postgresql-condition-message condition)))
+        :error-id (type-of condition)
+        :message (postgresql-condition-message condition)))
 
 (defmacro with-postgresql-handlers
     ((database &optional expression)
@@ -191,11 +192,11 @@ doesn't depend on UFFI."
                                      :password password))
       (postgresql-error (c)
        ;; Connect failed
-       (error 'clsql-connect-error
+       (error 'sql-connection-error
               :database-type database-type
               :connection-spec connection-spec
-              :errno (type-of c)
-              :error (postgresql-condition-message c)))
+              :error-id (type-of c)
+              :message (postgresql-condition-message c)))
       (:no-error (connection)
                 ;; Success, make instance
                 (make-instance 'postgresql-socket-database
@@ -217,11 +218,11 @@ doesn't depend on UFFI."
          (wait-for-query-results connection)
        (unless (eq status :cursor)
          (close-postgresql-connection connection)
-         (error 'clsql-sql-error
+         (error 'sql-database-data-error
                 :database database
                 :expression expression
-                :errno 'missing-result
-                :error "Didn't receive result cursor for query."))
+                :error-id "missing-result"
+                :message "Didn't receive result cursor for query."))
        (setq result-types (canonicalize-types result-types cursor))
         (values
          (loop for row = (read-cursor-row cursor result-types)
@@ -230,11 +231,11 @@ doesn't depend on UFFI."
                finally
                (unless (null (wait-for-query-results connection))
                  (close-postgresql-connection connection)
-                 (error 'clsql-sql-error
+                 (error 'sql-database-data-error
                         :database database
                         :expression expression
-                        :errno 'multiple-results
-                        :error "Received multiple results for query.")))
+                        :error-id "multiple-results"
+                        :message "Received multiple results for query.")))
          (when field-names
           (mapcar #'car (postgresql-cursor-fields cursor))))))))
 
@@ -258,19 +259,19 @@ doesn't depend on UFFI."
         ((eq status :completed)
          (unless (null (wait-for-query-results connection))
             (close-postgresql-connection connection)
-            (error 'clsql-sql-error
+            (error 'sql-database-data-error
                    :database database
                    :expression expression
-                   :errno 'multiple-results
-                   :error "Received multiple results for command."))
+                   :error-id "multiple-results"
+                   :message "Received multiple results for command."))
          result)
          (t
           (close-postgresql-connection connection)
-          (error 'clsql-sql-error
+          (error 'sql-database-data-error
                  :database database
                  :expression expression
-                 :errno 'missing-result
-                 :error "Didn't receive completion for command.")))))))
+                 :errno "missing-result"
+                 :message "Didn't receive completion for command.")))))))
 
 (defstruct postgresql-socket-result-set
   (done nil)
@@ -288,11 +289,11 @@ doesn't depend on UFFI."
          (wait-for-query-results connection)
        (unless (eq status :cursor)
          (close-postgresql-connection connection)
-         (error 'clsql-sql-error
+         (error 'sql-database-data-error
                 :database database
                 :expression expression
-                :errno 'missing-result
-                :error "Didn't receive result cursor for query."))
+                :error-id "missing-result"
+                :message "Didn't receive result cursor for query."))
        (values (make-postgresql-socket-result-set
                 :done nil 
                 :cursor cursor
@@ -392,16 +393,15 @@ doesn't depend on UFFI."
                            owner-clause)
                    database nil nil))))
     (if result
-       (reverse
-         (remove-if #'(lambda (it) (member it '("cmin"
-                                                "cmax"
-                                                "xmax"
-                                                "xmin"
-                                               "oid"
-                                                "ctid"
-                                               ;; kmr -- added tableoid
-                                               "tableoid") :test #'equal)) 
-                   result)))))
+        (remove-if #'(lambda (it) (member it '("cmin"
+                                               "cmax"
+                                               "xmax"
+                                               "xmin"
+                                               "oid"
+                                               "ctid"
+                                               ;; kmr -- added tableoid
+                                               "tableoid") :test #'equal)) 
+                   result))))
 
 (defmethod database-attribute-type (attribute (table string)
                                    (database postgresql-socket-database)
@@ -494,12 +494,12 @@ doesn't depend on UFFI."
                                      type)))
       (unwind-protect
           (progn
-            (setf (slot-value database 'clsql-base::state) :open)
+            (setf (slot-value database 'clsql-sys::state) :open)
             (mapcar #'car (database-query "select datname from pg_database" 
                                           database :auto nil)))
        (progn
          (database-disconnect database)
-         (setf (slot-value database 'clsql-base::state) :closed))))))
+         (setf (slot-value database 'clsql-sys::state) :closed))))))
 
 (defmethod database-describe-table ((database postgresql-socket-database) 
                                    table)
@@ -525,5 +525,5 @@ doesn't depend on UFFI."
 (defmethod db-type-default-case ((db-type (eql :postgresql-socket)))
   :lower)
 
-(when (clsql-base:database-type-library-loaded :postgresql-socket)
-  (clsql-base:initialize-database-type :database-type :postgresql-socket))
+(when (clsql-sys:database-type-library-loaded :postgresql-socket)
+  (clsql-sys:initialize-database-type :database-type :postgresql-socket))