X-Git-Url: http://git.kpe.io/?a=blobdiff_plain;f=db-mysql%2Fmysql-sql.lisp;h=503da2a71ddd5f3a16150e76248f67e94ea9e6cb;hb=1a446890f95ab363af82529a133546d722ef21b1;hp=14d20bc8e245e30e3e084261a9e51f81a289e7b1;hpb=4121952d2aa95c8611bf70b25b7772b5867c7666;p=clsql.git

diff --git a/db-mysql/mysql-sql.lisp b/db-mysql/mysql-sql.lisp
index 14d20bc..503da2a 100644
--- a/db-mysql/mysql-sql.lisp
+++ b/db-mysql/mysql-sql.lisp
@@ -97,8 +97,8 @@
 (defmethod database-name-from-spec (connection-spec (database-type (eql :mysql)))
   (check-connection-spec connection-spec database-type
                          (host db user password &optional port options))
-  (destructuring-bind (host db user password &optional port) connection-spec
-    (declare (ignore password))
+  (destructuring-bind (host db user password &optional port options) connection-spec
+    (declare (ignore password options))
     (concatenate 'string
                  (etypecase host
                    (null "localhost")
@@ -131,19 +131,27 @@
           (let ((option-code (lookup-option-code option)))
             (when option-code
               (mysql-options mysql-ptr option-code uffi:+null-cstring-pointer+)))
-          (destructuring-bind (name value) option
+          (destructuring-bind (name . value) option
             (let ((option-code (lookup-option-code name)))
               (when option-code
                 (case (lookup-option-type name)
                   (:none
                    (mysql-options mysql-ptr option-code uffi:+null-cstring-pointer+))
                   (:char-ptr
-                   (uffi:with-foreign-string (fs value)
-                       (mysql-options mysql-ptr option-code fs)))
+                   (if (stringp value)
+                       (uffi:with-foreign-string (fs value)
+                           (mysql-options mysql-ptr option-code fs))
+                       (warn "Expecting string argument for mysql option ~A, got ~A ~
+- ignoring.~%"
+                             name value)))
                   (:uint-ptr
-                   (uffi:with-foreign-object (fo :unsigned-int)
-                     (setf (uffi:deref-pointer fo :unsigned-int) value)
-                     (mysql-options mysql-ptr option-code fo)))
+                   (if (integerp value)
+                       (uffi:with-foreign-object (fo :unsigned-int)
+                         (setf (uffi:deref-pointer fo :unsigned-int) value)
+                         (mysql-options mysql-ptr option-code fo))
+                       (warn "Expecting integer argument for mysql option ~A, got ~A ~
+- ignoring.~%"
+                             name value)))
                   (:boolean-ptr
                    (uffi:with-foreign-object (fo :byte)
                      (setf (uffi:deref-pointer fo :byte)
@@ -479,6 +487,12 @@
                         (%sequence-name-to-table sequence-name))
            database :auto nil))))
 
+(defmethod database-last-auto-increment-id ((database mysql-database) table column)
+  (declare (ignore table column))
+  (car (query "SELECT LAST_INSERT_ID();"
+             :flatp t :field-names nil
+             :database database)))
+
 (defmethod database-create (connection-spec (type (eql :mysql)))
   (destructuring-bind (host name user password) connection-spec
     (let ((database (database-connect (list host "" user password)
@@ -503,7 +517,8 @@
     t))
 
 (defmethod database-list (connection-spec (type (eql :mysql)))
-  (destructuring-bind (host name user password &optional port) connection-spec
+  (destructuring-bind (host name user password &optional port options) connection-spec
+    (declare (ignore options))
     (let ((database (database-connect (list host (or name "mysql")
                                             user password port) type)))
       (unwind-protect