Add new directory structure. Tags will contain current and past releases, and stable will contain any bug fixes to the current stable release so users won't have to get the potentially broken trunk build to fix a screwup in stable.

Trunk updated to 0.9

git-svn-id: http://kusabax.cultnet.net/svn/repo/stable@176 73d99b7e-4f53-4972-b7b7-2ecd3c4d89ee

lib/adodb/adodbSQL_drivers/postgres8/postgres8_transaction_module.inc

@@ -0,0 +1,128 @@
+<?php
+/**
+ * ADOdb Lite Transaction Module for Postgres
+ *
+ */
+
+eval('class postgres8_transaction_EXTENDER extends '. $last_module . '_ADOConnection { }');
+
+class postgres8_transaction_ADOConnection extends postgres8_transaction_EXTENDER
+{
+	var $autoCommit = true;
+	var $transOff = 0;
+	var $transCnt = 0;
+	var $transaction_status = true;
+
+	function StartTrans($errfn = 'ADODB_TransMonitor')
+	{
+		if ($this->transOff > 0) {
+			$this->transOff += 1;
+			return;
+		}
+		$this->transaction_status = true;
+
+		if ($this->debug && $this->transCnt > 0)
+			ADOConnection::outp("Bad Transaction: StartTrans called within BeginTrans");
+
+		$this->BeginTrans();
+		$this->transOff = 1;
+	}
+
+	function BeginTrans()
+	{
+		if ($this->transOff)
+			return true;
+
+		$this->transCnt += 1;
+		return @pg_Exec($this->connectionId, "begin");
+	}
+
+	function CompleteTrans($autoComplete = true)
+	{
+		if ($this->transOff > 1) {
+			$this->transOff -= 1;
+			return true;
+		}
+		$this->transOff = 0;
+		if ($this->transaction_status && $autoComplete) {
+			if (!$this->CommitTrans()) {
+				$this->transaction_status = false;
+				if ($this->debug)
+					ADOConnection::outp("Smart Commit failed");
+			} else
+				if ($this->debug)
+					ADOConnection::outp("Smart Commit occurred");
+		} else {
+			$this->RollbackTrans();
+			if ($this->debug)
+				ADOCOnnection::outp("Smart Rollback occurred");
+		}
+		return $this->transaction_status;
+	}
+
+	function CommitTrans($ok=true)
+	{
+		if ($this->transOff)
+			return true;
+
+		if (!$ok)
+			return $this->RollbackTrans();
+
+		$this->transCnt -= 1;
+		return @pg_Exec($this->connectionId, "commit");
+	}
+
+	function RollbackTrans()
+	{
+		if ($this->transOff)
+			return true;
+
+		$this->transCnt -= 1;
+		return @pg_Exec($this->connectionId, "rollback");
+	}
+
+	function FailTrans()
+	{
+		if ($this->debug)
+			if ($this->transOff == 0) {
+				ADOConnection::outp("FailTrans outside StartTrans/CompleteTrans");
+			} else {
+				ADOConnection::outp("FailTrans was called");
+			}
+		$this->transaction_status = false;
+	}
+
+	function HasFailedTrans()
+	{
+		if ($this->transOff > 0)
+			return $this->transaction_status == false;
+
+		return false;
+	}
+
+	function RowLock($tables,$where,$flds='1 as ignore')
+	{
+		if (!$this->transCnt)
+			$this->BeginTrans();
+
+		return $this->GetOne("select $flds from $tables where $where for update");
+	}
+
+	function CommitLock($table)
+	{
+		return $this->CommitTrans();
+	}
+
+	function RollbackLock($table)
+	{
+		return $this->RollbackTrans();
+	}
+
+}
+
+eval('class postgres8_transaction_resultset_EXTENDER extends '. $last_module . '_ResultSet { }');
+
+class postgres8_transaction_ResultSet extends postgres8_transaction_resultset_EXTENDER
+{
+}
+?>