From 356f845abc4ed17322c7afc904ba4a67718327d2 Mon Sep 17 00:00:00 2001
From: "Paul S. Owen" <psotfx@users.sourceforge.net>
Date: Tue, 3 Jul 2001 22:47:26 +0000
Subject: Transaction capability moved to DB classes

git-svn-id: file:///svn/phpbb/trunk@546 89ea8834-ac86-4346-8a33-228a782c2dd0
---
 phpBB/db/postgres7.php | 43 ++++++++++++++++++++++++++++++++++++++++---
 1 file changed, 40 insertions(+), 3 deletions(-)

(limited to 'phpBB/db/postgres7.php')

diff --git a/phpBB/db/postgres7.php b/phpBB/db/postgres7.php
index 08f065f0e7..981439cc10 100644
--- a/phpBB/db/postgres7.php
+++ b/phpBB/db/postgres7.php
@@ -28,7 +28,8 @@ class sql_db
 {
 
 	var $db_connect_id;
-	var $query_result;
+	var $query_result; 
+	var $in_transaction = 0;
 	var $row;
 	var $rownum = array();
 
@@ -115,7 +116,7 @@ class sql_db
 	//
 	// Query method
 	//
-	function sql_query($query="")
+	function sql_query($query = "", $transaction = FALSE)
 	{
 		// Remove any pre-existing queries
 		unset($this->query_result);
@@ -123,11 +124,32 @@ class sql_db
 		{
 			$query = preg_replace("/LIMIT ([0-9]+),([ 0-9]+)/", "LIMIT \\2, \\1", $query);
 
+			if($transaction == BEGIN_TRANSACTION)
+			{
+				$result = @pg_exec($this->db_connect_id, "BEGIN");
+				if(!$result)
+				{
+					return false;
+				}
+			}
+
 			$this->query_result = @pg_exec($this->db_connect_id, $query);
 			if($this->query_result)
 			{
+				if($transaction == END_TRANSACTION)
+				{
+					$result = @pg_exec($this->db_connect_id, "COMMIT");
+					if(!$result)
+					{
+						@pg_exec($this->db_connect_id, "ROLLBACK");
+						return false;
+					}
+					$this->in_transaction = FALSE;
+				}
+
 				$this->last_query_text[$this->query_result] = $query;
 				$this->rownum[$this->query_result] = 0;
+
 				unset($this->row[$this->query_result]);
 				unset($this->rowset[$this->query_result]);
 
@@ -135,11 +157,26 @@ class sql_db
 			}
 			else
 			{
+				if($this->in_transaction)
+				{
+					@pg_exec($this->db_connect_id, "ROLLBACK");
+				}
 				return false;
 			}
 		}
 		else
 		{
+			if($transaction == END_TRANSACTION)
+			{
+				$result = @pg_exec($this->db_connect_id, "COMMIT");
+				if(!$result)
+				{
+					@pg_exec($this->db_connect_id, "ROLLBACK");
+					return false;
+				}
+				$this->in_transaction = FALSE;
+			}
+
 			return false;
 		}
 	}
@@ -391,4 +428,4 @@ class sql_db
 
 } // if ... defined
 
-?>
+?>
\ No newline at end of file
-- 
cgit v1.2.1