X-Git-Url: http://git.kpe.io/?a=blobdiff_plain;f=db-postgresql%2Fpostgresql-sql.lisp;h=76cab66a214f27e70cf4ec8d18cacb7609561945;hb=c4da3cfcbb955395d8a556e1f89aadad696302b7;hp=373d55ce9da2ca50dd143a7f0f8cab8da8e8c6e6;hpb=5691bb90517d7c565a141d131da76c3de1f8d566;p=clsql.git diff --git a/db-postgresql/postgresql-sql.lisp b/db-postgresql/postgresql-sql.lisp index 373d55c..76cab66 100644 --- a/db-postgresql/postgresql-sql.lisp +++ b/db-postgresql/postgresql-sql.lisp @@ -93,6 +93,7 @@ (declare (ignore password options tty)) (concatenate 'string (etypecase host + (null "localhost") (pathname (namestring host)) (string host)) (when port @@ -476,28 +477,59 @@ (concatenate 'string "SELECT LAST_VALUE ('" sequence-name "')") database nil))))) +(defmethod database-create (connection-spec (type (eql :postgresql))) + (destructuring-bind (host name user password) connection-spec + (declare (ignore password)) + (let ((asdf::*verbose-out* (make-string-output-stream))) + (unwind-protect + (let* ((status (asdf:run-shell-command + "su -c ~A createdb -h~A ~A" + user + (if host host "localhost") + name)) + (result (get-output-stream-string asdf::*verbose-out*))) + + (if (search "database creation failed: ERROR:" result) + (error 'clsql-access-error + :connection-spec connection-spec + :database-type type + :error + (format nil "database-create failed: ~s" result)) + t)) + (close asdf::*verbose-out*))))) + +(defmethod database-destroy (connection-spec (type (eql :postgresql))) + (destructuring-bind (host name user password) connection-spec + (declare (ignore password)) + (let ((asdf::*verbose-out* (make-string-output-stream))) + (unwind-protect + (let* ((status (asdf:run-shell-command + "su -c ~A dropdb -h~A ~A" + user + (if host host "localhost") + name)) + (result (get-output-stream-string asdf::*verbose-out*))) + + (if (search "database removal failed: ERROR:" result) + (error 'clsql-access-error + :connection-spec connection-spec + :database-type type + :error + (format nil "database-destroy failed: ~s" result)) + t)) + (close asdf::*verbose-out*))))) + + +(defmethod database-probe (connection-spec (type (eql :postgresql))) + (destructuring-bind (host name user password) connection-spec + (let ((database (database-connect (list host "template1" user password) + type))) + (unwind-protect + (find name (database-query "select datname from pg_database" + database :auto) + :key #'car :test #'string-equal) + (database-disconnect database))))) -;; Functions depending upon high-level CommonSQL classes/functions -#| -(defmethod database-output-sql ((expr clsql-sys::sql-typecast-exp) - (database postgresql-database)) - (with-slots (clsql-sys::modifier clsql-sys::components) - expr - (if clsql-sys::modifier - (progn - (clsql-sys::output-sql clsql-sys::components database) - (write-char #\: clsql-sys::*sql-stream*) - (write-char #\: clsql-sys::*sql-stream*) - (write-string (symbol-name clsql-sys::modifier) - clsql-sys::*sql-stream*))))) - -(defmethod database-output-sql-as-type ((type (eql 'integer)) val - (database postgresql-database)) - (when val ;; typecast it so it uses the indexes - (make-instance 'clsql-sys::sql-typecast-exp - :modifier 'int8 - :components val))) -|# (when (clsql-base-sys:database-type-library-loaded :postgresql) (clsql-base-sys:initialize-database-type :database-type :postgresql))