/** * Transaction Functions */ /** * @access private */ function Begin() { return mysql_query("START TRANSACTION", $this->db); } /** * @access private */ function Commit() { return mysql_query("COMMIT", $this->db); } /** * @access private */ function Rollback() { return mysql_query("ROLLBACK", $this->db); } /** * @return TRUE on success * @param array of sql queries $array */ function Transaction($array) { $success = 1; $this->Begin(); foreach($array as $query) { $result = mysql_query($guery['query'], $this->db); if(mysql_affected_rows($this->db) == 0) { $success = 0; } } if($success == 0) { $this->Rollback(); return FALSE; } else { $this->Commit(); return TRUE; } }