From 2d6fb0f7c104f4db272f61cdd0d217155c7a30da Mon Sep 17 00:00:00 2001
From: Dries Buytaert <dries@buytaert.net>
Date: Fri, 12 Oct 2001 18:19:41 +0000
Subject: - added a few missing rollback()'s and corrected a typo

---
 includes/node.inc | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

(limited to 'includes')

diff --git a/includes/node.inc b/includes/node.inc
index 0fac085e3..07781de26 100644
--- a/includes/node.inc
+++ b/includes/node.inc
@@ -136,6 +136,7 @@ function node_save($node, $filter) {
       $result = db_query("BEGIN");
       if (db_error($result)) {
         watchdog("error", "database: ". $result->getMessage() ."\nquery: ". htmlspecialchars("BEGIN"));
+        $db_handle->rollback();
       }
       else {
 
@@ -145,16 +146,18 @@ function node_save($node, $filter) {
         $result = db_query("INSERT INTO node ($f1, nid, lid) VALUES ($v1, '$nid', '$lid')");
         if (db_error($result)) {
           watchdog("warning", "node: added $filter[type] '$node[title]' - failed");
+          $db_handle->rollback();
         }
         else {
           $result = db_query("INSERT INTO $filter[type] ($f2, nid, lid) VALUES ($v2, '$nid', '$lid')");
           if (db_error($result)) {
             watchdog("warning", "node: added $filter[type] '$node[title]' - failed");
+            $db_handle->rollback();
           }
           else {
             $result = db_query("COMMIT");
             if (db_error($result)) {
-              watchdog("error", "database: ". $result->getMessage() ."\nquery: ". htmlspecialchars("BEGIN"));
+              watchdog("error", "database: ". $result->getMessage() ."\nquery: ". htmlspecialchars("COMMIT"));
               $db_handle->rollback();
             }
             watchdog("special", "node: added $filter[type] '$node[title]'");
-- 
cgit v1.2.3