📄 postgres7_driver.inc
字号:
<?php
/**
* ADOdb Lite is a PHP class to encapsulate multiple database APIs and is compatible with
* a subset of the ADODB Command Syntax.
* Currently supports Frontbase, MaxDB, miniSQL, MSSQL, MSSQL Pro, MySQLi, MySQLt, MySQL, PostgresSQL,
* PostgresSQL64, PostgresSQL7, SqLite and Sybase.
*
*/
class postgres7_ADOConnection extends ADOConnection
{
function postgres7_ADOConnection( $dbtype )
{
$this->dbtype = strtolower( $dbtype );
}
/**
* Connection to database server and selected database
*
* @access private
*/
function _connect($host = "", $username = "", $password = "", $database = "", $persistent, $forcenew)
{
if (!function_exists('pg_connect')) return false;
if ($host != "") $this->host = $host;
if ($username != "") $this->username = $username;
if ($password != "") $this->password = $password;
if ($database != "") $this->database = $database;
$this->persistent = $persistent;
$this->forcenewconnection = $forcenew;
$this->_makeconnection();
if ($this->connectionId === false) return $this->SelectDB( $this->database );
return true;
}
function _makeconnection()
{
if($this->persistent == 1)
{
$this->connectionId = @pg_pconnect( "host=$this->host dbname=$this->database user=$this->username password=$this->password" );
}
else
{
if($this->forcenewconnection)
{
$this->connectionId = @pg_connect( "host=$this->host dbname=$this->database user=$this->username password=$this->password" );
}
else
{
$this->connectionId = @pg_connect( "host=$this->host dbname=$this->database user=$this->username password=$this->password", PGSQL_CONNECT_FORCE_NEW );
}
}
}
/**
* Choose a database to connect.
*
* @param dbname is the name of the database to select
* @return true or false
* @access public
*/
function SelectDB($dbname)
{
$this->database = $dbname;
if ($this->connectionId === false)
{
if($this->createdatabase == true)
{
$this->connectionId = @pg_pconnect( "host=$this->host user=$this->username password=$this->password" );
$result = @pg_query($this->connectionId, "CREATE DATABASE " . $this->database );
if ($result === false) { // error handling if query fails
$this->connectionId = false;
return false;
}
$this->_makeconnection();
if($this->connectionId === false)
{
$this->connectionId = false;
return false;
}
else
{
return true;
}
}
$this->connectionId = false;
return false;
}
else
{
return true;
}
}
/**
* Return database error message
* Usage: $errormessage =& $db->ErrorMsg();
*
* @access public
*/
function ErrorMsg()
{
return @pg_last_error($this->connectionId);
}
/**
* Return database error number
* Usage: $errorbo =& $db->ErrorNo();
*
* @access public
*/
function ErrorNo()
{
$error = @pg_last_error( $this->connectionId );
return strlen($error) ? $error : 0;
}
/**
* PEAR DB Compat - do not use internally
*/
function ErrorNative()
{
return $this->ErrorNo();
}
/**
* Returns # of affected rows from insert/delete/update query
*
* @access public
* @return integer Affected rows
*/
function Affected_Rows()
{
return @pg_affected_rows( $this->connectionId );
}
/**
* Returns the last record id of an inserted item
* Usage: $db->Insert_ID();
*
* @access public
*/
function Insert_ID()
{
return @pg_getlastoid($this->record_set->connectionId);
}
/**
* Correctly quotes a string so that all strings are escape coded.
* An example is $db->qstr("Haven't a clue.");
*
* @param string the string to quote
* @param [magic_quotes] if $s is GET/POST var, set to get_magic_quotes_gpc().
*
* @return single-quoted string IE: 'Haven\'t a clue.'
*/
function qstr($string, $magic_quotes=false)
{
if (!$magic_quotes) {
$string = str_replace("'", "\\'", str_replace('\\', '\\\\', str_replace("\0", "\\\0", $string)));
return "'" . $string . "'";
}
return "'" . str_replace('\\"', '"', $string) . "'";
}
/**
* PEAR DB Compat - do not use internally
*/
function Quote($string)
{
return $this->qstr($string, false);
}
function QMagic($string)
{
return $this->qstr($string, get_magic_quotes_gpc());
}
/**
* Returns concatenated string
* Usage: $db->Concat($str1,$str2);
*
* @return concatenated string
*/
function Concat()
{
$arr = func_get_args();
return implode("||", $arr);
}
function IfNull( $field, $ifNull )
{
return " coalesce($field, $ifNull) ";
}
/**
* Closes database connection
* Usage: $db->close();
*
* @access public
*/
function Close()
{
@pg_close( $this->connectionId );
$this->connectionId = false;
}
}
class postgres7Statement
{
var $connection;
var $offset;
var $nrows;
var $sql;
var $inputarr;
var $extention;
/**
* mysqlStatement Constructor
*
* @access private
* @param string $connection
* @param string $parameters
* @param string $sql
*/
function postgres7Statement( $sql, &$connection, $offset, $nrows, $inputarr=false )
{
$this->connection = &$connection;
$this->offset = $offset;
$this->nrows = $nrows;
$this->sql = $sql;
$this->inputarr = $inputarr;
}
/**
* Executes SQL query and instantiates resultset methods
*
* @access private
* @return mixed Resultset methods
*/
function &do_query()
{
global $ADODB_FETCH_MODE;
$false = false;
$offsetStr = '';
$limitStr = '';
if ($this->offset != -1 || $this->nrows != -1)
{
$offsetStr = ($this->offset >= 0) ? " OFFSET " . $this->offset : '';
$limitStr = ($this->nrows >= 0) ? " LIMIT " . $this->nrows : '';
}
if ($this->inputarr && is_array($this->inputarr)) {
$sqlarr = explode('?', $this->sql);
if (!is_array(reset($this->inputarr))) $this->inputarr = array($this->inputarr);
foreach($this->inputarr as $arr) {
$sql = ''; $i = 0;
foreach($arr as $v) {
$sql .= $sqlarr[$i];
switch(gettype($v)){
case 'string':
$sql .= $this->extention->qstr($v);
break;
case 'double':
$sql .= str_replace(',', '.', $v);
break;
case 'boolean':
$sql .= $v ? 't' : 'f';
break;
default:
if ($v === null)
$sql .= 'NULL';
else $sql .= $v;
}
$i += 1;
}
$sql .= $sqlarr[$i];
if ($i+1 != sizeof($sqlarr))
return $false;
$resultId = @pg_query( $sql . "$limitStr$offsetStr");
if($this->extention->debug)
{
$this->extention->debugoutput($sql . "$limitStr$offsetStr");
}
if ($resultId === false) return $false;
}
}
else
{
$resultId = @pg_query( $this->sql . "$limitStr$offsetStr");
if($this->extention->debug)
{
$this->extention->debugoutput($this->sql . "$limitStr$offsetStr");
}
}
if ($resultId === false) { // error handling if query fails
return $false;
}
if ($resultId === true) { // return simplified recordset for inserts/updates/deletes with lower overhead
$rs =& new ADORecordSet_empty();
return $rs;
}
$recordset = new postgres7ResultSet( $resultId, $this->connection );
$recordset->_currentRow = 0;
switch ($ADODB_FETCH_MODE)
{
case ADODB_FETCH_NUM: $recordset->fetchMode = PGSQL_NUM; break;
case ADODB_FETCH_ASSOC:$recordset->fetchMode = PGSQL_ASSOC; break;
default:
case ADODB_FETCH_DEFAULT:
case ADODB_FETCH_BOTH:$recordset->fetchMode = PGSQL_BOTH; break;
}
$recordset->_numOfRows = @pg_numrows( $resultId );
$recordset->_numOfFields = @pg_numfields( $resultId );
$recordset->_fetch();
return $recordset;
}
}
/**
* Empty result record set for updates, inserts, ect
*
* @access private
*/
class ADORecordSet_empty
{
var $fields = false;
var $EOF = true;
function MoveNext() {return;}
function RecordCount() {return 0;}
function FieldCount() {return 0;}
function EOF(){return TRUE;}
function Close(){return true;}
}
class ADOFieldObject {
var $name = '';
var $max_length=0;
var $type="";
}
class postgres7ResultSet
{
var $connectionId;
var $fields;
var $resultId;
var $_currentRow = 0;
var $_numOfRows = -1;
var $_numOfFields = -1;
var $fetchMode;
var $EOF;
/**
* pgsqlResultSet Constructor
*
* @access private
* @param string $record
* @param string $resultId
*/
function postgres7ResultSet( $resultId, $connectionId )
{
$this->fields = array();
$this->connectionId = $connectionId;
$this->record = array();
$this->resultId = $resultId;
$this->EOF = false;
}
/**
* Frees resultset
*
* @access public
*/
function close()
{
pg_free_result( $this->resultId );
$this->fields = array();
$this->resultId = false;
}
/**
* PEAR DB Compatable Command
*/
function Free()
{
return $this->Close();
}
/**
* Returns field name from select query
*
* @access public
* @param string $field
* @return string Field name
*/
function fields( $field )
{
return $this->fields[$field];
}
/**
* Returns numrows from select query
*
* @access public
* @return integer Numrows
*/
function RecordCount()
{
return $this->_numOfRows;
}
/**
* PEAR DB Compatable Command
*/
function NumRows()
{
return $this->_numOfRows;
}
/**
* Returns num of fields from select query
*
* @access public
* @return integer numfields
*/
function FieldCount()
{
return $this->_numOfFields;
}
/**
* PEAR DB Compatable Command
*/
function NumCols()
{
return $this->_numOfFields;
}
/**
* Returns next record
*
* @access public
*/
function MoveNext()
{
if (@$this->fields = pg_fetch_array($this->resultId, NULL, $this->fetchMode)) {
$this->_currentRow += 1;
return true;
}
if (!$this->EOF) {
$this->_currentRow += 1;
$this->EOF = true;
}
return false;
}
/**
* Move to the first row in the recordset. Many databases do NOT support this.
*
* @return true or false
*/
function MoveFirst()
{
if ($this->_currentRow == 0) return true;
return $this->Move(0);
}
/**
* Returns the Last Record
*
* @access public
*/
function MoveLast()
{
if ($this->EOF) return false;
while (!$this->EOF) {
$fields = $this->fields;
$this->MoveNext();
}
$this->fields = $fields;
return true;
}
/**
* Random access to a specific row in the recordset. Some databases do not support
* access to previous rows in the databases (no scrolling backwards).
*
* @param rowNumber is the row to move to (0-based)
*
* @return true if there still rows available, or false if there are no more rows (EOF).
*/
function Move($rowNumber = 0)
{
$this->EOF = false;
if ($rowNumber == $this->_currentRow) return true;
if ($rowNumber >= $this->_numOfRows)
if ($this->_numOfRows != -1) $rowNumber = $this->_numOfRows-2;
if ($this->_seek($rowNumber)) {
$this->_currentRow = $rowNumber;
if ($this->_fetch()) {
return true;
}
} else {
$this->EOF = true;
return false;
}
}
/**
* Perform Seek to specific row
*
* @access private
*/
function _seek($row)
{
if ($this->_numOfRows == 0) return false;
return @pg_result_seek($this->resultId,$row);
}
/**
* Fills field array with first database element when query initially executed
*
* @access private
*/
function _fetch()
{
$this->fields = @pg_fetch_array($this->resultId, NULL, $this->fetchMode);
if( $this->_numOfRows == 0)
{
$this->EOF = true;
}
return is_array($this->fields);
}
/**
* Check to see if last record reached
*
* @access public
*/
function EOF()
{
if( $this->_currentRow < $this->_numOfRows)
{
return false;
}
else
{
$this->EOF = true;
return true;
}
}
/**
* Returns All Records in an array
*
* @access public
* @param [nRows] is the number of rows to return. -1 means every row.
*/
function GetArray($nRows = -1)
{
$results = array();
$cnt = 0;
while (!$this->EOF && $nRows != $cnt) {
$results[] = $this->fields;
$this->MoveNext();
$cnt++;
}
return $results;
}
function &GetRows($nRows = -1)
{
$arr =& $this->GetArray($nRows);
return $arr;
}
function &GetAll($nRows = -1)
{
$arr =& $this->GetArray($nRows);
return $arr;
}
/**
* Fetch a row, returning false if no more rows.
* PEAR DB Compatable Command
*
* @return false or array containing the current record
*/
function FetchRow()
{
if ($this->EOF) {
$false = false;
return $false;
}
$arr = $this->fields;
$this->_currentRow++;
if (!$this->_fetch()) $this->EOF = true;
return $arr;
}
/**
* Fetch a row, returning PEAR_Error if no more rows.
* PEAR DB Compatable Command
*
*/
function FetchInto(&$arr)
{
$false = false;
$true = 1;
if ($this->EOF) return $false;
$arr = $this->fields;
$this->MoveNext();
return $true;
}
/**
* Fetch field information for a table.
*
* @return object containing the name, type and max_length
*/
function FetchField($fieldOffset = -1)
{
$fieldObject= new ADOFieldObject();
$fieldObject->name = @pg_fieldname($this->resultId, $fieldOffset);
$fieldObject->type = @pg_fieldtype($this->resultId, $fieldOffset);
$fieldObject->max_length = @pg_fieldsize($this->resultId, $fieldOffset);
return $fieldObject;
}
}
?>⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -