[!!!][TASK] Doctrine: Remove ext:dbal
[Packages/TYPO3.CMS.git] / typo3 / sysext / adodb / adodb / drivers / adodb-postgres7.inc.php
index 842b524..0b8fdd3 100644 (file)
@@ -1,11 +1,13 @@
 <?php
 /*
 <?php
 /*
- V4.80 8 Mar 2006  (c) 2000-2006 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, 
+ @version   v5.20.3  01-Jan-2016
+ @copyright (c) 2000-2013 John Lim (jlim#natsoft.com). All rights reserved.
+ @copyright (c) 2014      Damien Regad, Mark Newnham and the ADOdb community
+  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 4.
   the BSD license will take precedence.
   Set tabs to 4.
-  
+
   Postgres7 support.
   28 Feb 2001: Currently indicate that we support LIMIT
   01 Dec 2001: dannym added support for default values
   Postgres7 support.
   28 Feb 2001: Currently indicate that we support LIMIT
   01 Dec 2001: dannym added support for default values
@@ -17,36 +19,108 @@ if (!defined('ADODB_DIR')) die();
 include_once(ADODB_DIR."/drivers/adodb-postgres64.inc.php");
 
 class ADODB_postgres7 extends ADODB_postgres64 {
 include_once(ADODB_DIR."/drivers/adodb-postgres64.inc.php");
 
 class ADODB_postgres7 extends ADODB_postgres64 {
-       var $databaseType = 'postgres7';        
+       var $databaseType = 'postgres7';
        var $hasLimit = true;   // set to true for pgsql 6.5+ only. support pgsql/mysql SELECT * FROM TABLE LIMIT 10
        var $ansiOuter = true;
        var $charSet = true; //set to true for Postgres 7 and above - PG client supports encodings
        var $hasLimit = true;   // set to true for pgsql 6.5+ only. support pgsql/mysql SELECT * FROM TABLE LIMIT 10
        var $ansiOuter = true;
        var $charSet = true; //set to true for Postgres 7 and above - PG client supports encodings
-       
-       function ADODB_postgres7() 
+
+       // Richard 3/18/2012 - Modified SQL to return SERIAL type correctly AS old driver no longer return SERIAL as data type.
+       var $metaColumnsSQL = "
+               SELECT
+                       a.attname,
+                       CASE
+                               WHEN x.sequence_name != ''
+                               THEN 'SERIAL'
+                               ELSE t.typname
+                       END AS typname,
+                       a.attlen, a.atttypmod, a.attnotnull, a.atthasdef, a.attnum
+               FROM
+                       pg_class c,
+                       pg_attribute a
+               JOIN pg_type t ON a.atttypid = t.oid
+               LEFT JOIN (
+                       SELECT
+                               c.relname as sequence_name,
+                               c1.relname as related_table,
+                               a.attname as related_column
+                       FROM pg_class c
+                       JOIN pg_depend d ON d.objid = c.oid
+                       LEFT JOIN pg_class c1 ON d.refobjid = c1.oid
+                       LEFT JOIN pg_attribute a ON (d.refobjid, d.refobjsubid) = (a.attrelid, a.attnum)
+                       WHERE c.relkind = 'S' AND c1.relname = '%s'
+               ) x ON x.related_column= a.attname
+               WHERE
+                       c.relkind in ('r','v')
+                       AND (c.relname='%s' or c.relname = lower('%s'))
+                       AND a.attname not like '....%%'
+                       AND a.attnum > 0
+                       AND a.attrelid = c.oid
+               ORDER BY
+                       a.attnum";
+
+       // used when schema defined
+       var $metaColumnsSQL1 = "
+               SELECT
+                       a.attname,
+                       CASE
+                               WHEN x.sequence_name != ''
+                               THEN 'SERIAL'
+                               ELSE t.typname
+                       END AS typname,
+                       a.attlen, a.atttypmod, a.attnotnull, a.atthasdef, a.attnum
+               FROM
+                       pg_class c,
+                       pg_namespace n,
+                       pg_attribute a
+               JOIN pg_type t ON a.atttypid = t.oid
+               LEFT JOIN (
+                       SELECT
+                               c.relname as sequence_name,
+                               c1.relname as related_table,
+                               a.attname as related_column
+                       FROM pg_class c
+                       JOIN pg_depend d ON d.objid = c.oid
+                       LEFT JOIN pg_class c1 ON d.refobjid = c1.oid
+                       LEFT JOIN pg_attribute a ON (d.refobjid, d.refobjsubid) = (a.attrelid, a.attnum)
+                       WHERE c.relkind = 'S' AND c1.relname = '%s'
+               ) x ON x.related_column= a.attname
+               WHERE
+                       c.relkind in ('r','v')
+                       AND (c.relname='%s' or c.relname = lower('%s'))
+                       AND c.relnamespace=n.oid and n.nspname='%s'
+                       AND a.attname not like '....%%'
+                       AND a.attnum > 0
+                       AND a.atttypid = t.oid
+                       AND a.attrelid = c.oid
+               ORDER BY a.attnum";
+
+
+       function __construct()
        {
        {
-               $this->ADODB_postgres64();
-               if (ADODB_ASSOC_CASE !== 2) {
+               parent::__construct();
+               if (ADODB_ASSOC_CASE !== ADODB_ASSOC_CASE_NATIVE) {
                        $this->rsPrefix .= 'assoc_';
                }
                $this->_bindInputArray = PHP_VERSION >= 5.1;
        }
 
                        $this->rsPrefix .= 'assoc_';
                }
                $this->_bindInputArray = PHP_VERSION >= 5.1;
        }
 
-       
-       // the following should be compat with postgresql 7.2, 
+
+       // the following should be compat with postgresql 7.2,
        // which makes obsolete the LIMIT limit,offset syntax
        // which makes obsolete the LIMIT limit,offset syntax
-        function &SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs2cache=0) 
-        {
-                $offsetStr = ($offset >= 0) ? " OFFSET ".((integer)$offset) : '';
-                $limitStr  = ($nrows >= 0)  ? " LIMIT ".((integer)$nrows) : '';
-                if ($secs2cache)
-                       $rs =& $this->CacheExecute($secs2cache,$sql."$limitStr$offsetStr",$inputarr);
-                else
-                       $rs =& $this->Execute($sql."$limitStr$offsetStr",$inputarr);
-               
+       function SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs2cache=0)
+       {
+               $offsetStr = ($offset >= 0) ? " OFFSET ".((integer)$offset) : '';
+               $limitStr  = ($nrows >= 0)  ? " LIMIT ".((integer)$nrows) : '';
+               if ($secs2cache)
+                       $rs = $this->CacheExecute($secs2cache,$sql."$limitStr$offsetStr",$inputarr);
+               else
+                       $rs = $this->Execute($sql."$limitStr$offsetStr",$inputarr);
+
                return $rs;
                return $rs;
-        }
-       /*
-       function Prepare($sql)
+       }
+
+       /*
+       function Prepare($sql)
        {
                $info = $this->ServerInfo();
                if ($info['version']>=7.3) {
        {
                $info = $this->ServerInfo();
                if ($info['version']>=7.3) {
@@ -54,11 +128,78 @@ class ADODB_postgres7 extends ADODB_postgres64 {
                }
                return $sql;
        }
                }
                return $sql;
        }
-       */
+       */
 
 
-       // from  Edward Jaramilla, improved version - works on pg 7.4
+       /**
+        * Generate the SQL to retrieve MetaColumns data
+        * @param string $table Table name
+        * @param string $schema Schema name (can be blank)
+        * @return string SQL statement to execute
+        */
+       protected function _generateMetaColumnsSQL($table, $schema)
+       {
+               if ($schema) {
+                       return sprintf($this->metaColumnsSQL1, $table, $table, $table, $schema);
+               }
+               else {
+                       return sprintf($this->metaColumnsSQL, $table, $table, $schema);
+               }
+       }
+
+       /**
+        * @returns assoc array where keys are tables, and values are foreign keys
+        */
        function MetaForeignKeys($table, $owner=false, $upper=false)
        {
        function MetaForeignKeys($table, $owner=false, $upper=false)
        {
+               # Regex isolates the 2 terms between parenthesis using subexpressions
+               $regex = '^.*\((.*)\).*\((.*)\).*$';
+               $sql="
+                       SELECT
+                               lookup_table,
+                               regexp_replace(consrc, '$regex', '\\2') AS lookup_field,
+                               dep_table,
+                               regexp_replace(consrc, '$regex', '\\1') AS dep_field
+                       FROM (
+                               SELECT
+                                       pg_get_constraintdef(c.oid) AS consrc,
+                                       t.relname AS dep_table,
+                                       ft.relname AS lookup_table
+                               FROM pg_constraint c
+                               JOIN pg_class t ON (t.oid = c.conrelid)
+                               JOIN pg_class ft ON (ft.oid = c.confrelid)
+                               JOIN pg_namespace nft ON (nft.oid = ft.relnamespace)
+                               LEFT JOIN pg_description ds ON (ds.objoid = c.oid)
+                               JOIN pg_namespace n ON (n.oid = t.relnamespace)
+                               WHERE c.contype = 'f'::\"char\"
+                               ORDER BY t.relname, n.nspname, c.conname, c.oid
+                               ) constraints
+                       WHERE
+                               dep_table='".strtolower($table)."'
+                       ORDER BY
+                               lookup_table,
+                               dep_table,
+                               dep_field";
+               $rs = $this->Execute($sql);
+
+               if (!$rs || $rs->EOF) return false;
+
+               $a = array();
+               while (!$rs->EOF) {
+                       if ($upper) {
+                               $a[strtoupper($rs->Fields('lookup_table'))][] = strtoupper(str_replace('"','',$rs->Fields('dep_field').'='.$rs->Fields('lookup_field')));
+                       } else {
+                               $a[$rs->Fields('lookup_table')][] = str_replace('"','',$rs->Fields('dep_field').'='.$rs->Fields('lookup_field'));
+                       }
+                       $rs->MoveNext();
+               }
+
+               return $a;
+
+       }
+
+       // from  Edward Jaramilla, improved version - works on pg 7.4
+       function _old_MetaForeignKeys($table, $owner=false, $upper=false)
+       {
                $sql = 'SELECT t.tgargs as args
                FROM
                pg_trigger t,pg_class c,pg_proc p
                $sql = 'SELECT t.tgargs as args
                FROM
                pg_trigger t,pg_class c,pg_proc p
@@ -70,32 +211,35 @@ class ADODB_postgres7 extends ADODB_postgres64 {
                c.relname = \''.strtolower($table).'\'
                ORDER BY
                        t.tgrelid';
                c.relname = \''.strtolower($table).'\'
                ORDER BY
                        t.tgrelid';
-               
-               $rs =& $this->Execute($sql);
-               
-               if ($rs && !$rs->EOF) {
-                       $arr =& $rs->GetArray();
-                       $a = array();
-                       foreach($arr as $v)
-                       {
-                               $data = explode(chr(0), $v['args']);
-                               if ($upper) {
-                                       $a[strtoupper($data[2])][] = strtoupper($data[4].'='.$data[5]);
-                               } else {
-                               $a[$data[2]][] = $data[4].'='.$data[5];
-                               }
+
+               $rs = $this->Execute($sql);
+
+               if (!$rs || $rs->EOF) return false;
+
+               $arr = $rs->GetArray();
+               $a = array();
+               foreach($arr as $v) {
+                       $data = explode(chr(0), $v['args']);
+                       $size = count($data)-1; //-1 because the last node is empty
+                       for($i = 4; $i < $size; $i++) {
+                               if ($upper)
+                                       $a[strtoupper($data[2])][] = strtoupper($data[$i].'='.$data[++$i]);
+                               else
+                                       $a[$data[2]][] = $data[$i].'='.$data[++$i];
                        }
                        }
-                       return $a;
                }
                }
-               return false;
+               return $a;
        }
 
        }
 
-       function _query($sql,$inputarr)
+       function _query($sql,$inputarr=false)
        {
                if (! $this->_bindInputArray) {
                        // We don't have native support for parameterized queries, so let's emulate it at the parent
                        return ADODB_postgres64::_query($sql, $inputarr);
                }
        {
                if (! $this->_bindInputArray) {
                        // We don't have native support for parameterized queries, so let's emulate it at the parent
                        return ADODB_postgres64::_query($sql, $inputarr);
                }
+
+               $this->_pnum = 0;
+               $this->_errorMsg = false;
                // -- added Cristiano da Cunha Duarte
                if ($inputarr) {
                        $sqlarr = explode('?',trim($sql));
                // -- added Cristiano da Cunha Duarte
                if ($inputarr) {
                        $sqlarr = explode('?',trim($sql));
@@ -107,23 +251,23 @@ class ADODB_postgres7 extends ADODB_postgres64 {
                                else $sql .= $v.' $'.$i;
                                $i++;
                        }
                                else $sql .= $v.' $'.$i;
                                $i++;
                        }
-                       
+
                        $rez = pg_query_params($this->_connectionID,$sql, $inputarr);
                } else {
                        $rez = pg_query($this->_connectionID,$sql);
                }
                // check if no data returned, then no need to create real recordset
                        $rez = pg_query_params($this->_connectionID,$sql, $inputarr);
                } else {
                        $rez = pg_query($this->_connectionID,$sql);
                }
                // check if no data returned, then no need to create real recordset
-               if ($rez && pg_numfields($rez) <= 0) {
+               if ($rez && pg_num_fields($rez) <= 0) {
                        if (is_resource($this->_resultid) && get_resource_type($this->_resultid) === 'pgsql result') {
                        if (is_resource($this->_resultid) && get_resource_type($this->_resultid) === 'pgsql result') {
-                               pg_freeresult($this->_resultid);
+                               pg_free_result($this->_resultid);
                        }
                        $this->_resultid = $rez;
                        return true;
                        }
                        $this->_resultid = $rez;
                        return true;
-               }               
+               }
                return $rez;
        }
                return $rez;
        }
-       
-        // this is a set of functions for managing client encoding - very important if the encodings
+
+       // this is a set of functions for managing client encoding - very important if the encodings
        // of your database and your output target (i.e. HTML) don't match
        //for instance, you may have UNICODE database and server it on-site as WIN1251 etc.
        // GetCharSet - get the name of the character set the client is using now
        // of your database and your output target (i.e. HTML) don't match
        //for instance, you may have UNICODE database and server it on-site as WIN1251 etc.
        // GetCharSet - get the name of the character set the client is using now
@@ -140,7 +284,7 @@ class ADODB_postgres7 extends ADODB_postgres64 {
                        return $this->charSet;
                }
        }
                        return $this->charSet;
                }
        }
-       
+
        // SetCharSet - switch the client encoding
        function SetCharSet($charset_name)
        {
        // SetCharSet - switch the client encoding
        function SetCharSet($charset_name)
        {
@@ -154,29 +298,29 @@ class ADODB_postgres7 extends ADODB_postgres64 {
        }
 
 }
        }
 
 }
-       
+
 /*--------------------------------------------------------------------------------------
 /*--------------------------------------------------------------------------------------
-        Class Name: Recordset
+       Class Name: Recordset
 --------------------------------------------------------------------------------------*/
 
 class ADORecordSet_postgres7 extends ADORecordSet_postgres64{
 
        var $databaseType = "postgres7";
 --------------------------------------------------------------------------------------*/
 
 class ADORecordSet_postgres7 extends ADORecordSet_postgres64{
 
        var $databaseType = "postgres7";
-       
-       
-       function ADORecordSet_postgres7($queryID,$mode=false) 
+
+
+       function __construct($queryID, $mode=false)
        {
        {
-               $this->ADORecordSet_postgres64($queryID,$mode);
+               parent::__construct($queryID, $mode);
        }
        }
-       
-               // 10% speedup to move MoveNext to child class
-       function MoveNext() 
+
+       // 10% speedup to move MoveNext to child class
+       function MoveNext()
        {
                if (!$this->EOF) {
                        $this->_currentRow++;
                        if ($this->_numOfRows < 0 || $this->_numOfRows > $this->_currentRow) {
                                $this->fields = @pg_fetch_array($this->_queryID,$this->_currentRow,$this->fetchMode);
        {
                if (!$this->EOF) {
                        $this->_currentRow++;
                        if ($this->_numOfRows < 0 || $this->_numOfRows > $this->_currentRow) {
                                $this->fields = @pg_fetch_array($this->_queryID,$this->_currentRow,$this->fetchMode);
-                       
+
                                if (is_array($this->fields)) {
                                        if ($this->fields && isset($this->_blobArr)) $this->_fixblobs();
                                        return true;
                                if (is_array($this->fields)) {
                                        if ($this->fields && isset($this->_blobArr)) $this->_fixblobs();
                                        return true;
@@ -186,77 +330,57 @@ class ADORecordSet_postgres7 extends ADORecordSet_postgres64{
                        $this->EOF = true;
                }
                return false;
                        $this->EOF = true;
                }
                return false;
-       }               
+       }
 
 }
 
 class ADORecordSet_assoc_postgres7 extends ADORecordSet_postgres64{
 
        var $databaseType = "postgres7";
 
 }
 
 class ADORecordSet_assoc_postgres7 extends ADORecordSet_postgres64{
 
        var $databaseType = "postgres7";
-       
-       
-       function ADORecordSet_assoc_postgres7($queryID,$mode=false) 
+
+
+       function __construct($queryID, $mode=false)
        {
        {
-               $this->ADORecordSet_postgres64($queryID,$mode);
+               parent::__construct($queryID, $mode);
        }
        }
-       
+
        function _fetch()
        {
        function _fetch()
        {
-               if ($this->_currentRow >= $this->_numOfRows && $this->_numOfRows >= 0)
-               return false;
+               if ($this->_currentRow >= $this->_numOfRows && $this->_numOfRows >= 0) {
+                       return false;
+               }
 
                $this->fields = @pg_fetch_array($this->_queryID,$this->_currentRow,$this->fetchMode);
 
                $this->fields = @pg_fetch_array($this->_queryID,$this->_currentRow,$this->fetchMode);
-               
+
                if ($this->fields) {
                        if (isset($this->_blobArr)) $this->_fixblobs();
                        $this->_updatefields();
                }
                if ($this->fields) {
                        if (isset($this->_blobArr)) $this->_fixblobs();
                        $this->_updatefields();
                }
-                       
+
                return (is_array($this->fields));
        }
                return (is_array($this->fields));
        }
-       
-               // Create associative array
-       function _updatefields()
-       {
-               if (ADODB_ASSOC_CASE == 2) return; // native
-       
-               $arr = array();
-               $lowercase = (ADODB_ASSOC_CASE == 0);
-               
-               foreach($this->fields as $k => $v) {
-                       if (is_integer($k)) $arr[$k] = $v;
-                       else {
-                               if ($lowercase)
-                                       $arr[strtolower($k)] = $v;
-                               else
-                                       $arr[strtoupper($k)] = $v;
-                       }
-               }
-               $this->fields = $arr;
-       }
-       
-       function MoveNext() 
+
+       function MoveNext()
        {
                if (!$this->EOF) {
                        $this->_currentRow++;
                        if ($this->_numOfRows < 0 || $this->_numOfRows > $this->_currentRow) {
                                $this->fields = @pg_fetch_array($this->_queryID,$this->_currentRow,$this->fetchMode);
        {
                if (!$this->EOF) {
                        $this->_currentRow++;
                        if ($this->_numOfRows < 0 || $this->_numOfRows > $this->_currentRow) {
                                $this->fields = @pg_fetch_array($this->_queryID,$this->_currentRow,$this->fetchMode);
-                       
+
                                if (is_array($this->fields)) {
                                        if ($this->fields) {
                                                if (isset($this->_blobArr)) $this->_fixblobs();
                                if (is_array($this->fields)) {
                                        if ($this->fields) {
                                                if (isset($this->_blobArr)) $this->_fixblobs();
-                                       
+
                                                $this->_updatefields();
                                        }
                                        return true;
                                }
                        }
                                                $this->_updatefields();
                                        }
                                        return true;
                                }
                        }
-                       
-                       
+
+
                        $this->fields = false;
                        $this->EOF = true;
                }
                return false;
        }
 }
                        $this->fields = false;
                        $this->EOF = true;
                }
                return false;
        }
 }
-?>
\ No newline at end of file