Proyectos de Subversion Moodle

<?php
/**
 * FileDescription
 *
 * Currently unsupported: MetaDatabases, MetaTables and MetaColumns,
 * and also inputarr in Execute.
 * Native types have been converted to MetaTypes.
 * Transactions not supported yet.
 *
 * Limitation of url length. For IIS, see MaxClientRequestBuffer registry value.
 *
 * 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();

if (! defined("_ADODB_CSV_LAYER")) {
 define("_ADODB_CSV_LAYER", 1 );

include_once(ADODB_DIR.'/adodb-csvlib.inc.php');

class ADODB_csv extends ADOConnection {
        var $databaseType = 'csv';
        var $databaseProvider = 'csv';
        var $hasInsertID = true;
        var $hasAffectedRows = true;
        var $fmtTimeStamp = "'Y-m-d H:i:s'";
        var $_affectedrows=0;
        var $_insertid=0;
        var $_url;
        var $replaceQuote = "''"; // string to use to replace quotes
        var $hasTransactions = false;
        var $_errorNo = false;

        protected function _insertID($table = '', $column = '')
        {
                return $this->_insertid;
        }

        function _affectedrows()
        {
                return $this->_affectedrows;
        }

        function MetaDatabases()
        {
                return false;
        }


        // returns true or false
        function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
        {
                if (strtolower(substr($argHostname,0,7)) !== 'http://') return false;
                $this->_url = $argHostname;
                return true;
        }

        // returns true or false
        function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
        {
                if (strtolower(substr($argHostname,0,7)) !== 'http://') return false;
                $this->_url = $argHostname;
                return true;
        }

        function MetaColumns($table, $normalize=true)
        {
                return false;
        }


        // parameters use PostgreSQL convention, not MySQL
        function SelectLimit($sql, $nrows = -1, $offset = -1, $inputarr = false, $secs2cache = 0)
        {
                global $ADODB_FETCH_MODE;

                $nrows = (int) $nrows;
                $offset = (int) $offset;
                $url = $this->_url.'?sql='.urlencode($sql)."&nrows=$nrows&fetch=".
                        (($this->fetchMode !== false)?$this->fetchMode : $ADODB_FETCH_MODE).
                        "&offset=$offset";
                $err = false;
                $rs = csv2rs($url,$err,false);

                if ($this->debug) print "$url<br><i>$err</i><br>";

                $at = strpos($err,'::::');
                if ($at === false) {
                        $this->_errorMsg = $err;
                        $this->_errorNo = (integer)$err;
                } else {
                        $this->_errorMsg = substr($err,$at+4,1024);
                        $this->_errorNo = -9999;
                }
                if ($this->_errorNo)
                        if ($fn = $this->raiseErrorFn) {
                                $fn($this->databaseType,'EXECUTE',$this->ErrorNo(),$this->ErrorMsg(),$sql,'');
                        }

                if (is_object($rs)) {

                        $rs->databaseType='csv';
                        $rs->fetchMode = ($this->fetchMode !== false) ?  $this->fetchMode : $ADODB_FETCH_MODE;
                        $rs->connection = $this;
                }
                return $rs;
        }

        // returns queryID or false
        function _Execute($sql,$inputarr=false)
        {
        global $ADODB_FETCH_MODE;

                if (!$this->_bindInputArray && $inputarr) {
                        $sqlarr = explode('?',$sql);
                        $sql = '';
                        $i = 0;
                        foreach($inputarr as $v) {

                                $sql .= $sqlarr[$i];
                                if (gettype($v) == 'string')
                                        $sql .= $this->qstr($v);
                                else if ($v === null)
                                        $sql .= 'NULL';
                                else
                                        $sql .= $v;
                                $i += 1;

                        }
                        $sql .= $sqlarr[$i];
                        if ($i+1 != sizeof($sqlarr))
                                print "Input Array does not match ?: ".htmlspecialchars($sql);
                        $inputarr = false;
                }

                $url =  $this->_url.'?sql='.urlencode($sql)."&fetch=".
                        (($this->fetchMode !== false)?$this->fetchMode : $ADODB_FETCH_MODE);
                $err = false;


                $rs = csv2rs($url,$err,false);
                if ($this->debug) print urldecode($url)."<br><i>$err</i><br>";
                $at = strpos($err,'::::');
                if ($at === false) {
                        $this->_errorMsg = $err;
                        $this->_errorNo = (integer)$err;
                } else {
                        $this->_errorMsg = substr($err,$at+4,1024);
                        $this->_errorNo = -9999;
                }

                if ($this->_errorNo)
                        if ($fn = $this->raiseErrorFn) {
                                $fn($this->databaseType,'EXECUTE',$this->ErrorNo(),$this->ErrorMsg(),$sql,$inputarr);
                        }
                if (is_object($rs)) {
                        $rs->fetchMode = ($this->fetchMode !== false) ?  $this->fetchMode : $ADODB_FETCH_MODE;

                        $this->_affectedrows = $rs->affectedrows;
                        $this->_insertid = $rs->insertid;
                        $rs->databaseType='csv';
                        $rs->connection = $this;
                }
                return $rs;
        }

        /*      Returns: the last error message from previous database operation        */
        function ErrorMsg()
        {
                return $this->_errorMsg;
        }

        /*      Returns: the last error number from previous database operation */
        function ErrorNo()
        {
                return $this->_errorNo;
        }

        // returns true or false
        function _close()
        {
                return true;
        }
} // class

class ADORecordset_csv extends ADORecordSet {

        function _close()
        {
                return true;
        }
}

} // define