mirror of
https://github.com/moodle/moodle.git
synced 2025-05-04 23:41:50 +02:00
537 lines
16 KiB
PHP
537 lines
16 KiB
PHP
<?php
|
|
/*
|
|
V2.12 12 June 2002 (c) 2000-2002 John Lim (jlim@natsoft.com.my). All rights reserved.
|
|
Released under both BSD license and Lesser GPL library license.
|
|
Whenever there is any discrepancy between the two licenses,
|
|
the BSD license will take precedence.
|
|
Set tabs to 8.
|
|
|
|
Original version derived from Alberto Cerezal (acerezalp@dbnet.es) - DBNet Informatica & Comunicaciones.
|
|
08 Nov 2000 jlim - Minor corrections, removing mysql stuff
|
|
09 Nov 2000 jlim - added insertid support suggested by "Christopher Kings-Lynne" <chriskl@familyhealth.com.au>
|
|
jlim - changed concat operator to || and data types to MetaType to match documented pgsql types
|
|
see http://www.postgresql.org/devel-corner/docs/postgres/datatype.htm
|
|
22 Nov 2000 jlim - added changes to FetchField() and MetaTables() contributed by "raser" <raser@mail.zen.com.tw>
|
|
27 Nov 2000 jlim - added changes to _connect/_pconnect from ideas by "Lennie" <leen@wirehub.nl>
|
|
15 Dec 2000 jlim - added changes suggested by Additional code changes by "Eric G. Werk" egw@netguide.dk.
|
|
31 Jan 2002 jlim - finally installed postgresql. testing
|
|
01 Mar 2001 jlim - Freek Dijkstra changes, also support for text type
|
|
*/
|
|
|
|
class ADODB_postgres64 extends ADOConnection{
|
|
var $databaseType = 'postgres64';
|
|
var $dataProvider = 'postgres';
|
|
var $hasInsertID = true;
|
|
var $_resultid = false;
|
|
var $concat_operator='||';
|
|
var $metaTablesSQL = "select tablename from pg_tables where tablename not like 'pg_%' order by 1";
|
|
var $isoDates = true; // accepts dates in ISO format
|
|
var $sysDate = "CURRENT_DATE";
|
|
var $sysTimeStamp = "CURRENT_TIMESTAMP";
|
|
|
|
/*
|
|
# show tables and views suggestion
|
|
"SELECT c.relname AS tablename FROM pg_class c
|
|
WHERE (c.relhasrules AND (EXISTS (
|
|
SELECT r.rulename FROM pg_rewrite r WHERE r.ev_class = c.oid AND bpchar(r.ev_type) = '1'
|
|
))) OR (c.relkind = 'v') AND c.relname NOT LIKE 'pg_%'
|
|
UNION
|
|
SELECT tablename FROM pg_tables WHERE tablename NOT LIKE 'pg_%' ORDER BY 1"
|
|
*/
|
|
var $metaColumnsSQL = "SELECT a.attname,t.typname,a.attlen,a.atttypmod,a.attnotnull,a.atthasdef,a.attnum FROM pg_class c, pg_attribute a,pg_type t WHERE relkind = 'r' AND c.relname='%s' AND a.attnum > 0 AND a.atttypid = t.oid AND a.attrelid = c.oid ORDER BY a.attnum";
|
|
// get primary key etc -- from Freek Dijkstra
|
|
var $metaKeySQL = "SELECT ic.relname AS index_name, a.attname AS column_name,i.indisunique AS unique_key, i.indisprimary AS primary_key FROM pg_class bc, pg_class ic, pg_index i, pg_attribute a WHERE bc.oid = i.indrelid AND ic.oid = i.indexrelid AND (i.indkey[0] = a.attnum OR i.indkey[1] = a.attnum OR i.indkey[2] = a.attnum OR i.indkey[3] = a.attnum OR i.indkey[4] = a.attnum OR i.indkey[5] = a.attnum OR i.indkey[6] = a.attnum OR i.indkey[7] = a.attnum) AND a.attrelid = bc.oid AND bc.relname = '%s'";
|
|
|
|
var $_hastrans = false;
|
|
var $hasAffectedRows = true;
|
|
var $hasLimit = false; // set to true for pgsql 7 only. support pgsql/mysql SELECT * FROM TABLE LIMIT 10
|
|
// below suggested by Freek Dijkstra
|
|
var $true = 't'; // string that represents TRUE for a database
|
|
var $false = 'f'; // string that represents FALSE for a database
|
|
var $fmtDate = "'Y-m-d'"; // used by DBDate() as the default date format used by the database
|
|
var $fmtTimeStamp = "'Y-m-d G:i:s'"; // used by DBTimeStamp as the default timestamp fmt.
|
|
var $hasMoveFirst = true;
|
|
var $hasGenID = true;
|
|
var $_genIDSQL = "SELECT NEXTVAL('%s')";
|
|
var $_genSeqSQL = "CREATE SEQUENCE %s START %s";
|
|
var $metaDefaultsSQL = "SELECT d.adnum as num, d.adsrc as def from pg_attrdef d, pg_class c where d.adrelid=c.oid and c.relname='%s' order by d.adnum";
|
|
|
|
// The last (fmtTimeStamp is not entirely correct:
|
|
// PostgreSQL also has support for time zones,
|
|
// and writes these time in this format: "2001-03-01 18:59:26+02".
|
|
// There is no code for the "+02" time zone information, so I just left that out.
|
|
// I'm not familiar enough with both ADODB as well as Postgres
|
|
// to know what the concequences are. The other values are correct (wheren't in 0.94)
|
|
// -- Freek Dijkstra
|
|
|
|
function ADODB_postgres64()
|
|
{
|
|
// changes the metaColumnsSQL, adds columns: attnum[6]
|
|
|
|
}
|
|
|
|
// get the last id - never tested
|
|
function pg_insert_id($tablename,$fieldname)
|
|
{
|
|
$result=pg_exec($this->_connectionID, "SELECT last_value FROM ${tablename}_${fieldname}_seq");
|
|
if ($result) {
|
|
$arr = @pg_fetch_row($result,0);
|
|
pg_freeresult($result);
|
|
if (isset($arr[0])) return $arr[0];
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/* Warning from http://www.php.net/manual/function.pg-getlastoid.php:
|
|
Using a OID as a unique identifier is not generally wise.
|
|
Unless you are very careful, you might end up with a tuple having
|
|
a different OID if a database must be reloaded. */
|
|
function _insertid()
|
|
{
|
|
return pg_getlastoid($this->_resultid);
|
|
}
|
|
|
|
// I get this error with PHP before 4.0.6 - jlim
|
|
// Warning: This compilation does not support pg_cmdtuples() in d:/inetpub/wwwroot/php/adodb/adodb-postgres.inc.php on line 44
|
|
function _affectedrows()
|
|
{
|
|
return pg_cmdtuples($this->_resultid);
|
|
}
|
|
|
|
|
|
// returns true/false
|
|
function BeginTrans()
|
|
{
|
|
$this->_hastrans = true;
|
|
return @pg_Exec($this->_connectionID, "begin");
|
|
}
|
|
|
|
function RowLock($tables,$where)
|
|
{
|
|
if (!$this->_hastrans) $this->BeginTrans();
|
|
return $this->GetOne("select 1 as ignore from $tables where $where for update");
|
|
}
|
|
|
|
// returns true/false.
|
|
function CommitTrans($ok=true)
|
|
{
|
|
if (!$ok) return $this->RollbackTrans();
|
|
$this->_hastrans = false;
|
|
return @pg_Exec($this->_connectionID, "commit");
|
|
}
|
|
|
|
// returns true/false
|
|
function RollbackTrans()
|
|
{
|
|
$this->_hastrans = false;
|
|
return @pg_Exec($this->_connectionID, "rollback");
|
|
}
|
|
|
|
/*
|
|
* Load a Large Object from a file
|
|
* - the procedure stores the object id in the table and imports the object using
|
|
* postgres proprietary blob handling routines
|
|
*
|
|
* contributed by Mattia Rossi mattia@technologist.com
|
|
*/
|
|
function UpdateBlobFile($table,$column,$val,$where,$blobtype='BLOB')
|
|
{
|
|
pg_exec ($this->_connectionID, "begin");
|
|
$oid = pg_lo_import ($val);
|
|
pg_exec ($this->_connectionID, "commit");
|
|
$rs = ADOConnection::UpdateBlob($table,$column,$oid,$where,$blobtype);
|
|
$rez = !empty($rs);
|
|
return $rez;
|
|
}
|
|
|
|
/*
|
|
* Reads the real blob from the db using the oid supplied as a parameter
|
|
*
|
|
* contributed by Mattia Rossi mattia@technologist.com
|
|
*/
|
|
function BlobDecode( $blob )
|
|
{
|
|
@pg_exec("begin");
|
|
$fd = @pg_lo_open($blob,"r");
|
|
$realblob = @pg_loreadall($fd);
|
|
@pg_loclose($fd);
|
|
@pg_exec("commit");
|
|
return( $realblob );
|
|
}
|
|
|
|
|
|
// converts table names to lowercase
|
|
function &MetaColumns($table)
|
|
{
|
|
global $ADODB_FETCH_MODE;
|
|
|
|
if (!empty($this->metaColumnsSQL)) {
|
|
// the following is the only difference -- we lowercase it
|
|
$save = $ADODB_FETCH_MODE;
|
|
$ADODB_FETCH_MODE = ADODB_FETCH_NUM;
|
|
|
|
$rs = $this->Execute(sprintf($this->metaColumnsSQL,strtolower($table)));
|
|
|
|
$ADODB_FETCH_MODE = $save;
|
|
|
|
if ($rs === false) return false;
|
|
|
|
if (!empty($this->metaKeySQL)) {
|
|
// If we want the primary keys, we have to issue a separate query
|
|
// Of course, a modified version of the metaColumnsSQL query using a
|
|
// LEFT JOIN would have been much more elegant, but postgres does
|
|
// not support OUTER JOINS. So here is the clumsy way.
|
|
|
|
$ADODB_FETCH_MODE = ADODB_FETCH_NUM;
|
|
|
|
$rskey = $this->Execute(sprintf($this->metaKeySQL,strtolower($table)));
|
|
// fetch all result in once for performance.
|
|
$keys = $rskey->GetArray();
|
|
|
|
$ADODB_FETCH_MODE = $save;
|
|
|
|
$rskey->Close();
|
|
unset($rskey);
|
|
}
|
|
|
|
$rsdefa = array();
|
|
if (!empty($this->metaDefaultsSQL)) {
|
|
$sql = sprintf($this->metaDefaultsSQL, strtolower($table));
|
|
$rsdef = $this->Execute($sql);
|
|
if ($rsdef) {
|
|
while (!$rsdef->EOF) {
|
|
$num = $rsdef->Fields('num');
|
|
$s = $rsdef->Fields('def');
|
|
if (substr($s, 0, 1) == "'") { /* quoted strings hack... for now... fixme */
|
|
$s = substr($s, 1);
|
|
$s = substr($s, 0, strlen($s) - 1);
|
|
}
|
|
|
|
$rsdefa[$num] = $s;
|
|
$rsdef->MoveNext();
|
|
}
|
|
} else {
|
|
print "==> SQL => " . $sql . "\n";
|
|
}
|
|
unset($rsdef);
|
|
}
|
|
|
|
$retarr = array();
|
|
while (!$rs->EOF) { //print_r($rs->fields);
|
|
$fld = new ADOFieldObject();
|
|
$fld->name = $rs->fields[0];
|
|
$fld->type = $rs->fields[1];
|
|
$fld->max_length = $rs->fields[2];
|
|
if ($fld->max_length <= 0) $fld->max_length = $rs->fields[3]-4;
|
|
if ($fld->max_length <= 0) $fld->max_length = -1;
|
|
|
|
// dannym
|
|
// 5 hasdefault; 6 num-of-column
|
|
$fld->has_default = ($rs->fields[5] == 't');
|
|
if ($fld->has_default) {
|
|
$fld->default_value = $rsdefa[$rs->fields[6]];
|
|
}
|
|
|
|
//Freek
|
|
if ($rs->fields[4] == $this->true) {
|
|
$fld->not_null = true;
|
|
}
|
|
|
|
// Freek
|
|
if (is_array($keys)) {
|
|
reset ($keys);
|
|
while (list($x,$key) = each($keys)) {
|
|
if ($fld->name == $key['column_name'] AND $key['primary_key'] == $this->true)
|
|
$fld->primary_key = true;
|
|
if ($fld->name == $key['column_name'] AND $key['unique_key'] == $this->true)
|
|
$fld->unique = true; // What name is more compatible?
|
|
}
|
|
}
|
|
|
|
$retarr[strtoupper($fld->name)] = $fld;
|
|
|
|
$rs->MoveNext();
|
|
}
|
|
$rs->Close();
|
|
return $retarr;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
function &MetaDatabases()
|
|
{
|
|
$arr = array();
|
|
$sql="select datname from pg_database";
|
|
$rs = $this->Execute($sql);
|
|
if (!$rs) return false;
|
|
while (!$rs->EOF) {
|
|
$arr[] = $rs->fields[0];
|
|
$rs->MoveNext();
|
|
}
|
|
|
|
return $arr;
|
|
}
|
|
|
|
|
|
// returns true or false
|
|
//
|
|
// examples:
|
|
// $db->Connect("host=host1 user=user1 password=secret port=4341");
|
|
// $db->Connect('host1','user1','secret');
|
|
function _connect($str,$user='',$pwd='',$db='')
|
|
{
|
|
if ($user || $pwd || $db) {
|
|
if ($str) {
|
|
$host = split(":", $str);
|
|
if ($host[0]) $str = "host=$host[0]";
|
|
else $str = 'localhost';
|
|
if (isset($host[1])) $str .= " port=$host[1]";
|
|
}
|
|
if ($user) $str .= " user=".$user;
|
|
if ($pwd) $str .= " password=".$pwd;
|
|
if ($db) $str .= " dbname=".$db;
|
|
}
|
|
|
|
//if ($user) $linea = "user=$user host=$linea password=$pwd dbname=$db port=5432";
|
|
$this->_connectionID = pg_connect($str);
|
|
if ($this->_connectionID === false) return false;
|
|
$this->Execute("set datestyle='ISO'");
|
|
return true;
|
|
}
|
|
|
|
// returns true or false
|
|
//
|
|
// examples:
|
|
// $db->PConnect("host=host1 user=user1 password=secret port=4341");
|
|
// $db->PConnect('host1','user1','secret');
|
|
function _pconnect($str,$user='',$pwd='',$db='')
|
|
{
|
|
if ($user || $pwd || $db) {
|
|
if ($str) {
|
|
$host = split(":", $str);
|
|
if ($host[0]) $str = "host=$host[0]";
|
|
else $str = 'localhost';
|
|
if (isset($host[1])) $str .= " port=$host[1]";
|
|
}
|
|
if ($user) $str .= " user=".$user;
|
|
if ($pwd) $str .= " password=".$pwd;
|
|
if ($db) $str .= " dbname=".$db;
|
|
}//print $str;
|
|
$this->_connectionID = pg_pconnect($str);
|
|
if ($this->_connectionID === false) return false;
|
|
$this->Execute("set datestyle='ISO'");
|
|
return true;
|
|
}
|
|
|
|
// returns queryID or false
|
|
function _query($sql,$inputarr)
|
|
{
|
|
$this->_resultid= pg_Exec($this->_connectionID,$sql);
|
|
return $this->_resultid;
|
|
}
|
|
|
|
|
|
/* Returns: the last error message from previous database operation */
|
|
function ErrorMsg()
|
|
{
|
|
if (empty($this->_connectionID)) $this->_errorMsg = @pg_errormessage();
|
|
else $this->_errorMsg = @pg_errormessage($this->_connectionID);
|
|
return $this->_errorMsg;
|
|
}
|
|
|
|
// returns true or false
|
|
function _close()
|
|
{
|
|
if ($this->_hastrans) $this->RollbackTrans();
|
|
@pg_close($this->_connectionID);
|
|
$this->_resultid = false;
|
|
$this->_connectionID = false;
|
|
return true;
|
|
}
|
|
|
|
function ActualType($meta)
|
|
{
|
|
switch($meta) {
|
|
case 'C': return 'VARCHAR';
|
|
case 'X': return 'TEXT';
|
|
|
|
case 'C2': return 'VARCHAR';
|
|
case 'X2': return 'TEXT';
|
|
|
|
case 'B': return 'BYTEA';
|
|
|
|
case 'D': return 'DATE';
|
|
case 'T': return 'DATETIME';
|
|
case 'L': return 'SMALLINT';
|
|
case 'R': return 'SERIAL';
|
|
case 'I': return 'INTEGER';
|
|
|
|
case 'F': return 'FLOAT8';
|
|
case 'N': return 'NUMERIC';
|
|
default:
|
|
return false;
|
|
}
|
|
}
|
|
/*
|
|
* Maximum size of C field
|
|
*/
|
|
function CharMax()
|
|
{
|
|
return 1000000000; // should be 1 Gb?
|
|
}
|
|
|
|
/*
|
|
* Maximum size of X field
|
|
*/
|
|
function TextMax()
|
|
{
|
|
return 1000000000; // should be 1 Gb?
|
|
}
|
|
|
|
|
|
}
|
|
|
|
/*--------------------------------------------------------------------------------------
|
|
Class Name: Recordset
|
|
--------------------------------------------------------------------------------------*/
|
|
|
|
class ADORecordSet_postgres64 extends ADORecordSet{
|
|
|
|
var $databaseType = "postgres64";
|
|
var $canSeek = true;
|
|
function ADORecordSet_postgres64($queryID)
|
|
{
|
|
global $ADODB_FETCH_MODE;
|
|
|
|
switch ($ADODB_FETCH_MODE)
|
|
{
|
|
case ADODB_FETCH_NUM: $this->fetchMode = PGSQL_NUM; break;
|
|
case ADODB_FETCH_ASSOC:$this->fetchMode = PGSQL_ASSOC; break;
|
|
default:
|
|
case ADODB_FETCH_DEFAULT:
|
|
case ADODB_FETCH_BOTH:$this->fetchMode = PGSQL_BOTH; break;
|
|
}
|
|
|
|
$this->ADORecordSet($queryID);
|
|
}
|
|
|
|
function &GetRowAssoc($upper=true)
|
|
{
|
|
if ($this->fetchMode == PGSQL_ASSOC && !$upper) return $rs->fields;
|
|
return ADORecordSet::GetRowAssoc($upper);
|
|
}
|
|
|
|
function _initrs()
|
|
{
|
|
global $ADODB_COUNTRECS;
|
|
$this->_numOfRows = ($ADODB_COUNTRECS)? @pg_numrows($this->_queryID):-1;
|
|
$this->_numOfFields = @pg_numfields($this->_queryID);
|
|
}
|
|
|
|
/* Use associative array to get fields array */
|
|
function Fields($colname)
|
|
{
|
|
if ($this->fetchMode != PGSQL_NUM) return @$this->fields[$colname];
|
|
|
|
if (!$this->bind) {
|
|
$this->bind = array();
|
|
for ($i=0; $i < $this->_numOfFields; $i++) {
|
|
$o = $this->FetchField($i);
|
|
$this->bind[strtoupper($o->name)] = $i;
|
|
}
|
|
}
|
|
return $this->fields[$this->bind[strtoupper($colname)]];
|
|
}
|
|
|
|
function &FetchField($fieldOffset = 0)
|
|
{
|
|
$off=$fieldOffset; // offsets begin at 0
|
|
|
|
$o= new ADOFieldObject();
|
|
$o->name = @pg_fieldname($this->_queryID,$off);
|
|
$o->type = @pg_fieldtype($this->_queryID,$off);
|
|
$o->max_length = @pg_fieldsize($this->_queryID,$off);
|
|
//print_r($o);
|
|
//print "off=$off name=$o->name type=$o->type len=$o->max_length<br>";
|
|
return $o;
|
|
}
|
|
|
|
function _seek($row)
|
|
{
|
|
return @pg_fetch_row($this->_queryID,$row);
|
|
}
|
|
|
|
// 10% speedup to move MoveNext to child class
|
|
function MoveNext()
|
|
{
|
|
if (!$this->EOF) {
|
|
$this->_currentRow++;
|
|
$this->fields = @pg_fetch_array($this->_queryID,$this->_currentRow,$this->fetchMode);
|
|
if (is_array($this->fields)) return true;
|
|
}
|
|
$this->EOF = true;
|
|
return false;
|
|
}
|
|
function _fetch()
|
|
{
|
|
$this->fields = @pg_fetch_array($this->_queryID,$this->_currentRow,$this->fetchMode);
|
|
return (is_array($this->fields));
|
|
}
|
|
|
|
function _close() {
|
|
return @pg_freeresult($this->_queryID);
|
|
}
|
|
|
|
function MetaType($t,$len=-1,$fieldobj=false)
|
|
{
|
|
switch (strtoupper($t)) {
|
|
case 'CHAR':
|
|
case 'CHARACTER':
|
|
case 'VARCHAR':
|
|
case 'NAME':
|
|
case 'BPCHAR':
|
|
if ($len <= $this->blobSize) return 'C';
|
|
|
|
case 'TEXT':
|
|
return 'X';
|
|
|
|
case 'IMAGE': // user defined type
|
|
case 'BLOB': // user defined type
|
|
case 'BIT': // This is a bit string, not a single bit, so don't return 'L'
|
|
case 'VARBIT':
|
|
case 'BYTEA':
|
|
return 'B';
|
|
|
|
case 'BOOL':
|
|
case 'BOOLEAN':
|
|
return 'L';
|
|
|
|
case 'DATE':
|
|
return 'D';
|
|
|
|
case 'TIME':
|
|
case 'DATETIME':
|
|
case 'TIMESTAMP':
|
|
return 'T';
|
|
|
|
case 'SMALLINT':
|
|
case 'BIGINT':
|
|
case 'INTEGER':
|
|
case 'INT8':
|
|
case 'INT4':
|
|
case 'INT2':
|
|
if (isset($fieldobj) &&
|
|
empty($fieldobj->primary_key) && empty($fieldobj->unique)) return 'I';
|
|
|
|
case 'OID':
|
|
case 'SERIAL':
|
|
return 'R';
|
|
|
|
default:
|
|
return 'N';
|
|
}
|
|
}
|
|
|
|
}
|
|
?>
|