<?php/**************************************************************************** postgres7.php* -------------------* begin : Saturday, Feb 13, 2001* copyright : (C) 2001 The phpBB Group* email : supportphpbb.com** $Id: postgres7.php,v 1.19.2.3 2005/05/06 20:50:10 acydburn Exp $****************************************************************************//***************************************************************************** This program is free software; you can redistribute it and/or modify* it under the terms of the GNU General Public License as published by* the Free Software Foundation; either version 2 of the License, or* (at your option) any later version.****************************************************************************/if(!defined("SQL_LAYER")){define("SQL_LAYER","postgresql");class sql_db{var $db_connect_id;var $query_result;var $in_transaction = 0;var $row = array();var $rowset = array();var $rownum = array();var $num_queries = 0;//// Constructor//function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency = true){$this->connect_string = "";if( $sqluser ){$this->connect_string .= "user=$sqluser ";}if( $sqlpassword ){$this->connect_string .= "password=$sqlpassword ";}if( $sqlserver ){if( ereg(":", $sqlserver) ){list($sqlserver, $sqlport) = split(":", $sqlserver);$this->connect_string .= "host=$sqlserver port=$sqlport ";}else{if( $sqlserver != "localhost" ){$this->connect_string .= "host=$sqlserver ";}}}if( $database ){$this->dbname = $database;$this->connect_string .= "dbname=$database";}$this->persistency = $persistency;$this->db_connect_id = ( $this->persistency ) ? pg_pconnect($this->connect_string) : pg_connect($this->connect_string);return ( $this->db_connect_id ) ? $this->db_connect_id : false;}//// Other base methods//function sql_close(){if( $this->db_connect_id ){//// Commit any remaining transactions//if( $this->in_transaction ){@pg_exec($this->db_connect_id, "COMMIT");}if( $this->query_result ){@pg_freeresult($this->query_result);}return @pg_close($this->db_connect_id);}else{return false;}}//// Query method//function sql_query($query = "", $transaction = false){//// Remove any pre-existing queries//unset($this->query_result);if( $query != "" ){$this->num_queries++;$query = preg_replace("/LIMIT ([0-9]+),([ 0-9]+)/", "LIMIT \\2 OFFSET \\1", $query);if( $transaction == BEGIN_TRANSACTION && !$this->in_transaction ){$this->in_transaction = TRUE;if( !@pg_exec($this->db_connect_id, "BEGIN") ){return false;}}$this->query_result = @pg_exec($this->db_connect_id, $query);if( $this->query_result ){if( $transaction == END_TRANSACTION ){$this->in_transaction = FALSE;if( !@pg_exec($this->db_connect_id, "COMMIT") ){@pg_exec($this->db_connect_id, "ROLLBACK");return 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]);return $this->query_result;}else{if( $this->in_transaction ){@pg_exec($this->db_connect_id, "ROLLBACK");}$this->in_transaction = FALSE;return false;}}else{if( $transaction == END_TRANSACTION && $this->in_transaction ){$this->in_transaction = FALSE;if( !@pg_exec($this->db_connect_id, "COMMIT") ){@pg_exec($this->db_connect_id, "ROLLBACK");return false;}}return true;}}//// Other query methods//function sql_numrows($query_id = 0){if( !$query_id ){$query_id = $this->query_result;}return ( $query_id ) ? @pg_numrows($query_id) : false;}function sql_numfields($query_id = 0){if( !$query_id ){$query_id = $this->query_result;}return ( $query_id ) ? @pg_numfields($query_id) : false;}function sql_fieldname($offset, $query_id = 0){if( !$query_id ){$query_id = $this->query_result;}return ( $query_id ) ? @pg_fieldname($query_id, $offset) : false;}function sql_fieldtype($offset, $query_id = 0){if( !$query_id ){$query_id = $this->query_result;}return ( $query_id ) ? @pg_fieldtype($query_id, $offset) : false;}function sql_fetchrow($query_id = 0){if( !$query_id ){$query_id = $this->query_result;}if($query_id){$this->row = @pg_fetch_array($query_id, $this->rownum[$query_id]);if( $this->row ){$this->rownum[$query_id]++;return $this->row;}}return false;}function sql_fetchrowset($query_id = 0){if( !$query_id ){$query_id = $this->query_result;}if( $query_id ){unset($this->rowset[$query_id]);unset($this->row[$query_id]);$this->rownum[$query_id] = 0;while( $this->rowset = @pg_fetch_array($query_id, $this->rownum[$query_id], PGSQL_ASSOC) ){$result[] = $this->rowset;$this->rownum[$query_id]++;}return $result;}return false;}function sql_fetchfield($field, $row_offset=-1, $query_id = 0){if( !$query_id ){$query_id = $this->query_result;}if( $query_id ){if( $row_offset != -1 ){$this->row = @pg_fetch_array($query_id, $row_offset, PGSQL_ASSOC);}else{if( $this->rownum[$query_id] ){$this->row = @pg_fetch_array($query_id, $this->rownum[$query_id]-1, PGSQL_ASSOC);}else{$this->row = @pg_fetch_array($query_id, $this->rownum[$query_id], PGSQL_ASSOC);if( $this->row ){$this->rownum[$query_id]++;}}}return $this->row[$field];}return false;}function sql_rowseek($offset, $query_id = 0){if(!$query_id){$query_id = $this->query_result;}if( $query_id ){if( $offset > -1 ){$this->rownum[$query_id] = $offset;return true;}else{return false;}}return false;}function sql_nextid(){$query_id = $this->query_result;if($query_id && $this->last_query_text[$query_id] != ""){if( preg_match("/^INSERT[\t\n ]+INTO[\t\n ]+([a-z0-9\_\-]+)/is", $this->last_query_text[$query_id], $tablename) ){$query = "SELECT currval('" . $tablename[1] . "_id_seq') AS last_value";$temp_q_id = @pg_exec($this->db_connect_id, $query);if( !$temp_q_id ){return false;}$temp_result = @pg_fetch_array($temp_q_id, 0, PGSQL_ASSOC);return ( $temp_result ) ? $temp_result['last_value'] : false;}}return false;}function sql_affectedrows($query_id = 0){if( !$query_id ){$query_id = $this->query_result;}return ( $query_id ) ? @pg_cmdtuples($query_id) : false;}function sql_freeresult($query_id = 0){if( !$query_id ){$query_id = $this->query_result;}return ( $query_id ) ? @pg_freeresult($query_id) : false;}function sql_error($query_id = 0){if( !$query_id ){$query_id = $this->query_result;}$result['message'] = @pg_errormessage($this->db_connect_id);$result['code'] = -1;return $result;}} // class ... db_sql} // if ... defined?>