<?php/* vim: set expandtab tabstop=4 shiftwidth=4 foldmethod=marker: */// +----------------------------------------------------------------------+// | PHP Version 4                                                        |// +----------------------------------------------------------------------+// | Copyright (c) 1997-2004 The PHP Group                                |// +----------------------------------------------------------------------+// | This source file is subject to version 2.02 of the PHP license,      |// | that is bundled with this package in the file LICENSE, and is        |// | available at through the world-wide-web at                           |// | http://www.php.net/license/2_02.txt.                                 |// | If you did not receive a copy of the PHP license and are unable to   |// | obtain it through the world-wide-web, please send a note to          |// | license@php.net so we can mail you a copy immediately.               |// +----------------------------------------------------------------------+// | Author: Stig Bakken <ssb@php.net>                                    |// | Maintainer: Daniel Convissor <danielc@php.net>                       |// +----------------------------------------------------------------------+//// $Id: mysqlc.php,v 1.2 2005/07/22 05:10:13 max Exp $//// THis is modified and extended to have following functions check for the//  cached files first.//  getRow//  getCol//  getAll//  getAssociated//  getOne// THis cache mechanism is using Delayed Connection Mechanism//// XXX legend://// XXX ERRORMSG: The error message from the mysql function should//               be registered here.//// TODO/wishlist:// longReadlen// binmoderequire_once PEAR_DIR . 'DB/common.php';/** * Database independent query interface definition for PHP's MySQL * extension. * * This is for MySQL versions 4.0 and below. * * @package  DB * @version  $Id: mysql.php,v 1.2 2005/07/22 05:10:13 max Exp $ * @category Database * @author   Stig Bakken <ssb@php.net> */class DB_mysqlc extends DB_common{    // {{{ properties    var $connection;    var $phptype, $dbsyntax;    var $prepare_tokens = array();    var $prepare_types = array();    var $num_rows = array();    var $transaction_opcount = 0;    var $autocommit = true;    var $fetchmode = DB_FETCHMODE_ORDERED; /* Default fetch mode */    var $_db = false;	var $cached_tables = array();	var $dsn = array();	var $_dsninfo = array();	var $_dboptions = array();	var $_connected;    // }}}    // {{{ constructor    /**     * DB_mysql constructor.     *     * @access public     */    function DB_mysqlc()    {        $this->DB_common();        $this->dbsyntax = 'mysql';        $this->features = array(            'prepare' => false,            'pconnect' => true,            'transactions' => true,            'limit' => 'alter'        );        $this->errorcode_map = array(            1004 => DB_ERROR_CANNOT_CREATE,            1005 => DB_ERROR_CANNOT_CREATE,            1006 => DB_ERROR_CANNOT_CREATE,            1007 => DB_ERROR_ALREADY_EXISTS,            1008 => DB_ERROR_CANNOT_DROP,            1022 => DB_ERROR_ALREADY_EXISTS,            1046 => DB_ERROR_NODBSELECTED,            1050 => DB_ERROR_ALREADY_EXISTS,            1051 => DB_ERROR_NOSUCHTABLE,            1054 => DB_ERROR_NOSUCHFIELD,            1062 => DB_ERROR_ALREADY_EXISTS,            1064 => DB_ERROR_SYNTAX,            1100 => DB_ERROR_NOT_LOCKED,            1136 => DB_ERROR_VALUE_COUNT_ON_ROW,            1146 => DB_ERROR_NOSUCHTABLE,            1048 => DB_ERROR_CONSTRAINT,            1216 => DB_ERROR_CONSTRAINT        );    }    // }}}    // {{{ connect()    /**     * Connect to a database and log in as the specified user.     *     * @param $dsn the data source name (see DB::parseDSN for syntax)     * @param $persistent (optional) whether the connection should     *        be persistent     * @access public     * @return int DB_OK on success, a DB error on failure     *///    function connect($dsninfo, $persistent = false)    function connect()    {        if (!DB::assertExtension('mysql')) {            return $this->raiseError(DB_ERROR_EXTENSION_NOT_FOUND);        }//        if ($dsninfo['phptype'] == 'mysqlc') $dsninfo['phptype'] = 'mysql';        $this->dsn = $dsninfo = $this->_dsninfo;        if ($dsninfo['protocol'] && $dsninfo['protocol'] == 'unix') {            $dbhost = ':' . $dsninfo['socket'];        } else {            $dbhost = $dsninfo['hostspec'] ? $dsninfo['hostspec'] : 'localhost';            if ($dsninfo['port']) {                $dbhost .= ':' . $dsninfo['port'];            }        }        $connect_function = $persistent ? 'mysql_pconnect' : 'mysql_connect';        if ($dbhost && $dsninfo['username'] && isset($dsninfo['password'])) {            $conn = @$connect_function($dbhost, $dsninfo['username'],                                       $dsninfo['password']);        } elseif ($dbhost && $dsninfo['username']) {            $conn = @$connect_function($dbhost, $dsninfo['username']);        } elseif ($dbhost) {            $conn = @$connect_function($dbhost);        } else {            $conn = false;        }        if (!$conn) {            if (($err = @mysql_error()) != '') {                return $this->raiseError(DB_ERROR_CONNECT_FAILED, null, null,                                         null, $err);            } elseif (empty($php_errormsg)) {                return $this->raiseError(DB_ERROR_CONNECT_FAILED);            } else {                return $this->raiseError(DB_ERROR_CONNECT_FAILED, null, null,                                         null, $php_errormsg);            }        }        if ($dsninfo['database']) {            if (!@mysql_select_db($dsninfo['database'], $conn)) {               switch(mysql_errno($conn)) {                        case 1049:                            return $this->raiseError(DB_ERROR_NOSUCHDB, null, null,                                                     null, @mysql_error($conn));                        case 1044:                             return $this->raiseError(DB_ERROR_ACCESS_VIOLATION, null, null,                                                      null, @mysql_error($conn));                        default:                            return $this->raiseError(DB_ERROR, null, null,                                                     null, @mysql_error($conn));                    }            }            // fix to allow calls to different databases in the same script            $this->_db = $dsninfo['database'];        }        $this->connection = $conn;        return DB_OK;    }    // }}}    // {{{ disconnect()    /**     * Log out and disconnect from the database.     *     * @access public     *     * @return bool true on success, false if not connected.     */    function disconnect()    {		if ($this->_connected) {	        $ret = @mysql_close($this->connection);	        $this->connection = null;	        return $ret;		}    }    // }}}    // {{{ simpleQuery()    /**     * Send a query to MySQL and return the results as a MySQL resource     * identifier.     *     * @param the SQL query     *     * @access public     *     * @return mixed returns a valid MySQL result for successful SELECT     * queries, DB_OK for other successful queries.  A DB error is     * returned on failure.     */    function simpleQuery($query)    {        $ismanip = DB::isManip($query);        $this->last_query = $query;        $query = $this->modifyQuery($query);		$this->dbconnect();        if ($this->_db) {            if (!@mysql_select_db($this->_db, $this->connection)) {                return $this->mysqlRaiseError(DB_ERROR_NODBSELECTED);            }        }        if (!$this->autocommit && $ismanip) {            if ($this->transaction_opcount == 0) {                $result = @mysql_query('SET AUTOCOMMIT=0', $this->connection);                $result = @mysql_query('BEGIN', $this->connection);                if (!$result) {                    return $this->mysqlRaiseError();                }            }            $this->transaction_opcount++;        }        $result = @mysql_query($query, $this->connection);        if (!$result) {            return $this->mysqlRaiseError();        }        if (is_resource($result)) {            $numrows = $this->numrows($result);            if (is_object($numrows)) {                return $numrows;            }            $this->num_rows[(int)$result] = $numrows;            return $result;        }        return DB_OK;    }    // }}}    // {{{ nextResult()    /**     * Move the internal mysql result pointer to the next available result     *     * This method has not been implemented yet.     *     * @param a valid sql result resource     *     * @access public     *     * @return false     */    function nextResult($result)    {        return false;    }    // }}}    // {{{ fetchInto()    /**     * Fetch a row and insert the data into an existing array.     *     * Formating of the array and the data therein are configurable.     * See DB_result::fetchInto() for more information.     *     * @param resource $result    query result identifier     * @param array    $arr       (reference) array where data from the row     *                            should be placed     * @param int      $fetchmode how the resulting array should be indexed     * @param int      $rownum    the row number to fetch     *     * @return mixed DB_OK on success, null when end of result set is     *               reached or on failure     *     * @see DB_result::fetchInto()     * @access private     */    function fetchInto($result, &$arr, $fetchmode, $rownum=null)    {        if ($rownum !== null) {            if (!@mysql_data_seek($result, $rownum)) {                return null;            }        }        if ($fetchmode & DB_FETCHMODE_ASSOC) {            $arr = @mysql_fetch_array($result, MYSQL_ASSOC);            if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE && $arr) {                $arr = array_change_key_case($arr, CASE_LOWER);            }        } else {            $arr = @mysql_fetch_row($result);        }        if (!$arr) {            // See: http://bugs.php.net/bug.php?id=22328            // for why we can't check errors on fetching            return null;            /*            $errno = @mysql_errno($this->connection);            if (!$errno) {                return null;            }            return $this->mysqlRaiseError($errno);            */        }        if ($this->options['portability'] & DB_PORTABILITY_RTRIM) {            /*             * Even though this DBMS already trims output, we do this because             * a field might have intentional whitespace at the end that             * gets removed by DB_PORTABILITY_RTRIM under another driver.             */            $this->_rtrimArrayValues($arr);        }        if ($this->options['portability'] & DB_PORTABILITY_NULL_TO_EMPTY) {            $this->_convertNullArrayValuesToEmpty($arr);        }        return DB_OK;    }    // }}}    // {{{ freeResult()    /**     * Free the internal resources associated with $result.     *     * @param $result MySQL result identifier     *     * @access public     *     * @return bool true on success, false if $result is invalid     */    function freeResult($result)    {        unset($this->num_rows[(int)$result]);        return @mysql_free_result($result);    }    // }}}    // {{{ numCols()    /**     * Get the number of columns in a result set.     *     * @param $result MySQL result identifier     *     * @access public     *     * @return int the number of columns per row in $result     */    function numCols($result)    {        $cols = @mysql_num_fields($result);        if (!$cols) {            return $this->mysqlRaiseError();        }        return $cols;    }    // }}}    // {{{ numRows()    /**     * Get the number of rows in a result set.     *     * @param $result MySQL result identifier     *     * @access public     *     * @return int the number of rows in $result     */    function numRows($result)    {        $rows = @mysql_num_rows($result);        if ($rows === null) {            return $this->mysqlRaiseError();        }        return $rows;    }    // }}}    // {{{ autoCommit()    /**     * Enable/disable automatic commits     */    function autoCommit($onoff = false)    {        // XXX if $this->transaction_opcount > 0, we should probably        // issue a warning here.        $this->autocommit = $onoff ? true : false;        return DB_OK;    }    // }}}    // {{{ commit()    /**     * Commit the current transaction.     */    function commit()    {        if ($this->transaction_opcount > 0) {            if ($this->_db) {                if (!@mysql_select_db($this->_db, $this->connection)) {                    return $this->mysqlRaiseError(DB_ERROR_NODBSELECTED);                }            }            $result = @mysql_query('COMMIT', $this->connection);            $result = @mysql_query('SET AUTOCOMMIT=1', $this->connection);            $this->transaction_opcount = 0;            if (!$result) {                return $this->mysqlRaiseError();            }        }        return DB_OK;    }    // }}}    // {{{ rollback()    /**     * Roll back (undo) the current transaction.     */    function rollback()    {        if ($this->transaction_opcount > 0) {            if ($this->_db) {                if (!@mysql_select_db($this->_db, $this->connection)) {