X-Git-Url: http://git.kpe.io/?a=blobdiff_plain;f=sql%2Ftransaction.lisp;h=a9d94c9d0ea159605838487be1fd690ef6cf985f;hb=30186614582039bdc3d3f86bc5165ef300c5d3e0;hp=b7673d80c9c61bbe4c40313b584557d1f07746cd;hpb=c41d81c0d1233372012a1de93fcdfd6b2a6e5618;p=clsql.git diff --git a/sql/transaction.lisp b/sql/transaction.lisp index b7673d8..a9d94c9 100644 --- a/sql/transaction.lisp +++ b/sql/transaction.lisp @@ -1,8 +1,6 @@ ;;;; -*- Mode: LISP; Syntax: ANSI-Common-Lisp; Base: 10 -*- ;;;; ************************************************************************* ;;;; -;;;; $Id$ -;;;; ;;;; Transaction support ;;;; ;;;; This file is part of CLSQL. @@ -18,9 +16,9 @@ ((commit-hooks :initform () :accessor commit-hooks) (rollback-hooks :initform () :accessor rollback-hooks) (previous-autocommit :initarg :previous-autocommit - :reader previous-autocommit) + :reader previous-autocommit) (status :initform nil :accessor transaction-status - :documentation "nil or :committed"))) + :documentation "nil or :committed"))) (defun add-transaction-commit-hook (commit-hook &key (database *default-database*)) @@ -41,8 +39,8 @@ is called on DATABASE which defaults to *DEFAULT-DATABASE*." (defmethod database-start-transaction ((database database)) (unless (transaction database) (setf (transaction database) - (make-instance 'transaction :previous-autocommit - (database-autocommit database)))) + (make-instance 'transaction :previous-autocommit + (database-autocommit database)))) (setf (database-autocommit database) nil) (when (= (incf (transaction-level database)) 1) (let ((transaction (transaction database))) @@ -60,31 +58,33 @@ is called on DATABASE which defaults to *DEFAULT-DATABASE*." (defmethod database-commit-transaction ((database database)) (with-slots (transaction transaction-level autocommit) database (if (plusp transaction-level) - (when (zerop (decf transaction-level)) - (case (database-underlying-type database) - (:mssql (execute-command "COMMIT TRANSACTION" :database database)) - (t (execute-command "COMMIT" :database database))) - (setf autocommit (previous-autocommit transaction)) - (map nil #'funcall (commit-hooks transaction))) + (if (zerop (decf transaction-level)) + (progn + (case (database-underlying-type database) + (:mssql (execute-command "COMMIT TRANSACTION" :database database)) + (t (execute-command "COMMIT" :database database))) + (setf autocommit (previous-autocommit transaction)) + (map nil #'funcall (commit-hooks transaction))) + (setf (transaction-status (transaction database)) nil)) (warn 'sql-warning :message - (format nil "Cannot commit transaction against ~A because there is no transaction in progress." - database))))) + (format nil "Cannot commit transaction against ~A because there is no transaction in progress." + database))))) (defmethod database-abort-transaction ((database database)) (with-slots (transaction transaction-level autocommit) database (if (plusp transaction-level) (when (zerop (decf transaction-level)) (unwind-protect - (case (database-underlying-type database) - (:mssql (execute-command "ROLLBACK TRANSACTION" :database database)) - (t (execute-command "ROLLBACK" :database database))) - (setf autocommit (previous-autocommit transaction)) + (case (database-underlying-type database) + (:mssql (execute-command "ROLLBACK TRANSACTION" :database database)) + (t (execute-command "ROLLBACK" :database database))) + (setf autocommit (previous-autocommit transaction)) (map nil #'funcall (rollback-hooks transaction)))) (warn 'sql-warning - :message - (format nil "Cannot abort transaction against ~A because there is no transaction in progress." - database))))) + :message + (format nil "Cannot abort transaction against ~A because there is no transaction in progress." + database))))) (defun mark-transaction-committed (database) (when (and (transaction database)