WebSVN – Moodle – /lib/adodb/drivers/adodb-postgres7.inc.php

<?php
/**
 * ADOdb PostgreSQL 7 driver
 *
 * This file is part of ADOdb, a Database Abstraction Layer library for PHP.
 *
 * @package ADOdb
 * @link https://adodb.org Project's web site and documentation
 * @link https://github.com/ADOdb/ADOdb Source code and issue tracker
 *
 * The ADOdb Library is dual-licensed, released under both the BSD 3-Clause
 * and the GNU Lesser General Public Licence (LGPL) v2.1 or, at your option,
 * any later version. This means you can use it in proprietary products.
 * See the LICENSE.md file distributed with this source code for details.
 * @license BSD-3-Clause
 * @license LGPL-2.1-or-later
 *
 * @copyright 2000-2013 John Lim
 * @copyright 2014 Damien Regad, Mark Newnham and the ADOdb community
 */

// security - hide paths
if (!defined('ADODB_DIR')) die();

include_once(ADODB_DIR."/drivers/adodb-postgres64.inc.php");

class ADODB_postgres7 extends ADODB_postgres64 {
        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

        // 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()
        {
                parent::__construct();
                if (ADODB_ASSOC_CASE !== ADODB_ASSOC_CASE_NATIVE) {
                        $this->rsPrefix .= 'assoc_';
                }
                $this->_bindInputArray = true;
        }


        // the following should be compat with postgresql 7.2,
        // which makes obsolete the LIMIT limit,offset syntax
        function SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs2cache=0)
        {
                $nrows = (int) $nrows;
                $offset = (int) $offset;
                $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;
        }

        /*
        function Prepare($sql)
        {
                $info = $this->ServerInfo();
                if ($info['version']>=7.3) {
                        return array($sql,false);
                }
                return $sql;
        }
        */

        /**
         * 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);
                }
        }

        public function metaForeignKeys($table, $owner = '', $upper = false, $associative = 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) {
                        $lookup_table = $rs->fields('lookup_table');
                        $fields = $rs->fields('dep_field') . '=' . $rs->fields('lookup_field');
                        if ($upper) {
                                $lookup_table = strtoupper($lookup_table);
                                $fields = strtoupper($fields);
                        }
                        $a[$lookup_table][] = str_replace('"','', $fields);

                        $rs->MoveNext();
                }

                return $a;
        }

        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);
                }

                $this->_pnum = 0;
                $this->_errorMsg = false;
                // -- added Cristiano da Cunha Duarte
                if ($inputarr) {
                        $sqlarr = explode('?',trim($sql));
                        $sql = '';
                        $i = 1;
                        $last = sizeof($sqlarr)-1;
                        foreach($sqlarr as $v) {
                                if ($last < $i) $sql .= $v;
                                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
                if ($rez && pg_num_fields($rez) <= 0) {
                        if ($this->_resultid !== false) {
                                pg_free_result($this->_resultid);
                        }
                        $this->_resultid = $rez;
                        return true;
                }
                return $rez;
        }

        /**
         * Retrieve the client connection's current character set.

         * If no charsets were compiled into the server, the function will always
         * return 'SQL_ASCII'.
         * @see https://www.php.net/manual/en/function.pg-client-encoding.php
         *
         * @return string|false The character set, or false if it can't be determined.
         */
        function getCharSet()
        {
                if (!$this->_connectionID) {
                        return false;
                }
                $this->charSet = pg_client_encoding($this->_connectionID);
                return $this->charSet ?: false;
        }

        /**
         * Sets the client-side character set (encoding).
         *
         * Allows managing client encoding - very important if the database and
         * the output target (i.e. HTML) don't match; for instance, you may have a
         * UNICODE database and server your pages as WIN1251, etc.
         *
         * Supported on PostgreSQL 7.0 and above. Available charsets depend on
         * PostgreSQL version and the distribution's compile flags.
         *
         * @param string $charset The character set to switch to.
         *
         * @return bool True if the character set was changed successfully, false otherwise.
         */
        function setCharSet($charset)
        {
                if ($this->charSet !== $charset) {
                        if (!$this->_connectionID || pg_set_client_encoding($this->_connectionID, $charset) != 0) {
                                return false;
                        }
                        $this->getCharSet();
                }
                return true;
        }

}

/*--------------------------------------------------------------------------------------
        Class Name: Recordset
--------------------------------------------------------------------------------------*/

class ADORecordSet_postgres7 extends ADORecordSet_postgres64{

        var $databaseType = "postgres7";

        // 10% speedup to move MoveNext to child class
        function MoveNext()
        {
                if (!$this->EOF) {
                        $this->_currentRow++;
                        if ($this->_numOfRows < 0 || $this->_numOfRows > $this->_currentRow) {
                                $this->_prepfields();
                                if ($this->fields !== false) {
                                        return true;
                                }
                        }
                        $this->fields = false;
                        $this->EOF = true;
                }
                return false;
        }

}

class ADORecordSet_assoc_postgres7 extends ADORecordSet_postgres64{

        var $databaseType = "postgres7";


        function _fetch()
        {
                if ($this->_currentRow >= $this->_numOfRows && $this->_numOfRows >= 0) {
                        return false;
                }

                $this->_prepfields();
                if ($this->fields !== false) {
                        $this->_updatefields();
                        return true;
                }

                return false;
        }

        function MoveNext()
        {
                if (!$this->EOF) {
                        $this->_currentRow++;
                        if ($this->_numOfRows < 0 || $this->_numOfRows > $this->_currentRow) {
                                $this->_prepfields();
                                if ($this->fields !== false) {
                                        $this->_updatefields();
                                        return true;
                                }
                        }

                        $this->fields = false;
                        $this->EOF = true;
                }
                return false;
        }
}
Proyectos de Subversion Moodle

(root)/lib/adodb/drivers/adodb-postgres7.inc.php @ 427 – Rev 1
