/src/typo3_src-4.2.0alpha1/typo3/sysext/adodb/adodb/adodb.inc.php

<?php 
/*
 * Set tabs to 4 for best viewing.
 * 
 * Latest version is available at http://adodb.sourceforge.net
 * 
 * This is the main include file for ADOdb.
 * Database specific drivers are stored in the adodb/drivers/adodb-*.inc.php
 *
 * The ADOdb files are formatted so that doxygen can be used to generate documentation.
 * Doxygen is a documentation generation tool and can be downloaded from http://doxygen.org/
 */

 if (!defined('_ADODB_LAYER')) {
        define('_ADODB_LAYER',1);
        
        //==============================================================================================        
        // CONSTANT DEFINITIONS
        //==============================================================================================        


        if (!defined('ADODB_DIR')) define('ADODB_DIR',dirname(__FILE__));
        
        //==============================================================================================        
        // GLOBAL VARIABLES
        //==============================================================================================        

        GLOBAL 
                $ADODB_vers,            // database version
                $ADODB_COUNTRECS,       // count number of records returned - slows down query
                $ADODB_CACHE_DIR,       // directory to cache recordsets
                $ADODB_EXTENSION,   // ADODB extension installed
                $ADODB_COMPAT_FETCH, // If $ADODB_COUNTRECS and this is true, $rs->fields is available on EOF
                $ADODB_FETCH_MODE,      // DEFAULT, NUM, ASSOC or BOTH. Default follows native driver default...
                $ADODB_QUOTE_FIELDNAMES; // Allows you to force quotes (backticks) around field names in queries generated by getinsertsql and getupdatesql.    
        
        //==============================================================================================        
        // GLOBAL SETUP
        //==============================================================================================        
        
        $ADODB_EXTENSION = defined('ADODB_EXTENSION');
        
        //********************************************************//
        /*
        Controls $ADODB_FORCE_TYPE mode. Default is ADODB_FORCE_VALUE (3).
        Used in GetUpdateSql and GetInsertSql functions. Thx to Niko, nuko#mbnet.fi

                0 = ignore empty fields. All empty fields in array are ignored.
                1 = force null. All empty, php null and string 'null' fields are changed to sql NULL values.
                2 = force empty. All empty, php null and string 'null' fields are changed to sql empty '' or 0 values.
                3 = force value. Value is left as it is. Php null and string 'null' are set to sql NULL values and empty fields '' are set to empty '' sql values.
        */
        define('ADODB_FORCE_IGNORE',0);
        define('ADODB_FORCE_NULL',1);
        define('ADODB_FORCE_EMPTY',2);
        define('ADODB_FORCE_VALUE',3);
    //********************************************************//


        if (!$ADODB_EXTENSION || ADODB_EXTENSION < 4.0) {
                
                define('ADODB_BAD_RS','<p>Bad $rs in %s. Connection or SQL invalid. Try using $connection->debug=true;</p>');
        
        // allow [ ] @ ` " and . in table names
                define('ADODB_TABLE_REGEX','([]0-9a-z_\:\"\`\.\@\[-]*)');
        
        // prefetching used by oracle
                if (!defined('ADODB_PREFETCH_ROWS')) define('ADODB_PREFETCH_ROWS',10);
        
        
        /*
        Controls ADODB_FETCH_ASSOC field-name case. Default is 2, use native case-names.
        This currently works only with mssql, odbc, oci8po and ibase derived drivers.
        
                0 = assoc lowercase field names. $rs->fields['orderid']
                1 = assoc uppercase field names. $rs->fields['ORDERID']
                2 = use native-case field names. $rs->fields['OrderID']
        */
        
                define('ADODB_FETCH_DEFAULT',0);
                define('ADODB_FETCH_NUM',1);
                define('ADODB_FETCH_ASSOC',2);
                define('ADODB_FETCH_BOTH',3);
                
                if (!defined('TIMESTAMP_FIRST_YEAR')) define('TIMESTAMP_FIRST_YEAR',100);
        
                // PHP's version scheme makes converting to numbers difficult - workaround
                $_adodb_ver = (float) PHP_VERSION;
                if ($_adodb_ver >= 5.2) {
                        define('ADODB_PHPVER',0x5200);
                } else if ($_adodb_ver >= 5.0) {
                        define('ADODB_PHPVER',0x5000);
                } else if ($_adodb_ver > 4.299999) { # 4.3
                        define('ADODB_PHPVER',0x4300);
                } else if ($_adodb_ver > 4.199999) { # 4.2
                        define('ADODB_PHPVER',0x4200);
                } else if (strnatcmp(PHP_VERSION,'4.0.5')>=0) {
                        define('ADODB_PHPVER',0x4050);
                } else {
                        define('ADODB_PHPVER',0x4000);
                }
        }
        
        //if (!defined('ADODB_ASSOC_CASE')) define('ADODB_ASSOC_CASE',2);

        
        function ADODB_str_replace($src, $dest, $data)
        {
                if (ADODB_PHPVER >= 0x4050) return str_replace($src,$dest,$data);
                
                $s = reset($src);
                $d = reset($dest);
                while ($s !== false) {
                        $data = str_replace($s,$d,$data);
                        $s = next($src);
                        $d = next($dest);
                }
                return $data;
        }
        
        function ADODB_Setup()
        {
        GLOBAL 
                $ADODB_vers,            // database version
                $ADODB_COUNTRECS,       // count number of records returned - slows down query
                $ADODB_CACHE_DIR,       // directory to cache recordsets
                $ADODB_FETCH_MODE,
                $ADODB_FORCE_TYPE,
                $ADODB_QUOTE_FIELDNAMES;
                
                $ADODB_FETCH_MODE = ADODB_FETCH_DEFAULT;
                $ADODB_FORCE_TYPE = ADODB_FORCE_VALUE;


                if (!isset($ADODB_CACHE_DIR)) {
                        $ADODB_CACHE_DIR = '/tmp'; //(isset($_ENV['TMP'])) ? $_ENV['TMP'] : '/tmp';
                } else {
                        // do not accept url based paths, eg. http:/ or ftp:/
                        if (strpos($ADODB_CACHE_DIR,'://') !== false) 
                                die("Illegal path http:// or ftp://");
                }
                
                        
                // Initialize random number generator for randomizing cache flushes
                // -- note Since PHP 4.2.0, the seed  becomes optional and defaults to a random value if omitted.
                 srand(((double)microtime())*1000000);
                
                $ADODB_vers = 'V4.94 23 Jan 2007 (c) 2000-2007 John Lim (jlim#natsoft.com.my). All rights reserved. Released BSD & LGPL.';
        
                if (!isset($ADODB_COUNTRECS)) $ADODB_COUNTRECS = true; 
        }
        
        
        //==============================================================================================        
        // CHANGE NOTHING BELOW UNLESS YOU ARE DESIGNING ADODB
        //==============================================================================================        
        
        ADODB_Setup();

        //==============================================================================================        
        // CLASS ADOFieldObject
        //==============================================================================================        
        class ADOFieldObject { 
                var $name = '';
                var $max_length=0;
                var $type="";
/*
                // additional fields by dannym... (danny_milo@yahoo.com)
                var $not_null = false; 
                // actually, this has already been built-in in the postgres, fbsql AND mysql module? ^-^
                // so we can as well make not_null standard (leaving it at "false" does not harm anyways)

                var $has_default = false; // this one I have done only in mysql and postgres for now ... 
                        // others to come (dannym)
                var $default_value; // default, if any, and supported. Check has_default first.
*/
        }
        

        
        function ADODB_TransMonitor($dbms, $fn, $errno, $errmsg, $p1, $p2, &$thisConnection)
        {
                //print "Errorno ($fn errno=$errno m=$errmsg) ";
                $thisConnection->_transOK = false;
                if ($thisConnection->_oldRaiseFn) {
                        $fn = $thisConnection->_oldRaiseFn;
                        $fn($dbms, $fn, $errno, $errmsg, $p1, $p2,$thisConnection);
                }
        }
        
        //==============================================================================================        
        // CLASS ADOConnection
        //==============================================================================================        
        
        class ADOConnection {
        //
        // PUBLIC VARS 
        //
        var $dataProvider = 'native';
        var $databaseType = '';         
        var $database = '';                     
        var $host = '';                         
        var $user = '';                         
        var $password = '';             
        var $debug = false;             
        var $maxblobsize = 262144;      
        var $concat_operator = '+'; 
        var $substr = 'substr';         
        var $length = 'length';         
        var $random = 'rand()';         
        var $upperCase = 'upper';               
        var $fmtDate = "'Y-m-d'";       
        var $fmtTimeStamp = "'Y-m-d, h:i:s A'"; 
        var $true = '1';                        
        var $false = '0';                       
        var $replaceQuote = "\\'";      
        var $nameQuote = '"';           
        var $charSet=false;             
        var $metaDatabasesSQL = '';
        var $metaTablesSQL = '';
        var $uniqueOrderBy = false; 
        var $emptyDate = '&nbsp;';
        var $emptyTimeStamp = '&nbsp;';
        var $lastInsID = false;
        //--
        var $hasInsertID = false;               
        var $hasAffectedRows = false;   
        var $hasTop = false;                    
        var $hasLimit = false;                  
        var $readOnly = false;                  
        var $hasMoveFirst = false;  
        var $hasGenID = false;          
        var $hasTransactions = true; 
        //--
        var $genID = 0;                         
        var $raiseErrorFn = false;      
        var $isoDates = false; 
        var $cacheSecs = 3600; 

        // memcache
        var $memCache = false; 
        var $memCacheHost; 
        var $memCachePort = 11211; 
        var $memCacheCompress = false; 

        var $sysDate = false; 
        var $sysTimeStamp = false; 
        var $arrayClass = 'ADORecordSet_array'; 
        
        var $noNullStrings = false; 
        var $numCacheHits = 0; 
        var $numCacheMisses = 0;
        var $pageExecuteCountRows = true;
        var $uniqueSort = false; 
        var $leftOuter = false; 
        var $rightOuter = false; 
        var $ansiOuter = false; 
        var $autoRollback = false; // autoRollback on PConnect().
        var $poorAffectedRows = false; // affectedRows not working or unreliable
        
        var $fnExecute = false;
        var $fnCacheExecute = false;
        var $blobEncodeType = false; // false=not required, 'I'=encode to integer, 'C'=encode to char
        var $rsPrefix = "ADORecordSet_";
        
        var $autoCommit = true;         
        var $transOff = 0;                      
        var $transCnt = 0;                      
        
        var $fetchMode=false;
        
        var $null2null = 'null'; // in autoexecute/getinsertsql/getupdatesql, this value will be converted to a null
         //
         // PRIVATE VARS
         //
        var $_oldRaiseFn =  false;
        var $_transOK = null;
        var $_connectionID      = false;        
        var $_errorMsg = false;         

        var $_errorCode = false;        
        var $_queryID = false;          
        
        var $_isPersistentConnection = false;   
        var $_bindInputArray = false; 
        var $_evalAll = false;
        var $_affected = false;
        var $_logsql = false;
        var $_transmode = ''; // transaction mode
        

        
        function ADOConnection()                        
        {
                die('Virtual Class -- cannot instantiate');
        }
        
        function Version()
        {
        global $ADODB_vers;
        
                return (float) substr($ADODB_vers,1);
        }
        
        function ServerInfo()
        {
                return array('description' => '', 'version' => '');
        }
        
        function IsConnected()
        {
        return !empty($this->_connectionID);
        }
        
        function _findvers($str)
        {
                if (preg_match('/([0-9]+\.([0-9\.])+)/',$str, $arr)) return $arr[1];
                else return '';
        }
        
        function outp($msg,$newline=true)
        {
        global $ADODB_FLUSH,$ADODB_OUTP;
        
                if (defined('ADODB_OUTP')) {
                        $fn = ADODB_OUTP;
                        $fn($msg,$newline);
                        return;
                } else if (isset($ADODB_OUTP)) {
                        $fn = $ADODB_OUTP;
                        $fn($msg,$newline);
                        return;
                }
                
                if ($newline) $msg .= "<br>\n";
                
                if (isset($_SERVER['HTTP_USER_AGENT']) || !$newline) echo $msg;
                else echo strip_tags($msg);
        
                
                if (!empty($ADODB_FLUSH) && ob_get_length() !== false) flush(); //  do not flush if output buffering enabled - useless - thx to Jesse Mullan 
                
        }
        
        function Time()
        {
                $rs =& $this->_Execute("select $this->sysTimeStamp");
                if ($rs && !$rs->EOF) return $this->UnixTimeStamp(reset($rs->fields));
                
                return false;
        }
        
        function Connect($argHostname = "", $argUsername = "", $argPassword = "", $argDatabaseName = "", $forceNew = false) 
        {
                if ($argHostname != "") $this->host = $argHostname;
                if ($argUsername != "") $this->user = $argUsername;
                if ($argPassword != "") $this->password = $argPassword; // not stored for security reasons
                if ($argDatabaseName != "") $this->database = $argDatabaseName;         
                
                $this->_isPersistentConnection = false; 
                if ($forceNew) {
                        if ($rez=$this->_nconnect($this->host, $this->user, $this->password, $this->database)) return true;
                } else {
                         if ($rez=$this->_connect($this->host, $this->user, $this->password, $this->database)) return true;
                }
                if (isset($rez)) {
                        $err = $this->ErrorMsg();
                        if (empty($err)) $err = "Connection error to server '$argHostname' with user '$argUsername'";
                        $ret = false;
                } else {
                        $err = "Missing extension for ".$this->dataProvider;
                        $ret = 0;
                }
                if ($fn = $this->raiseErrorFn) 
                        $fn($this->databaseType,'CONNECT',$this->ErrorNo(),$err,$this->host,$this->database,$this);
                
                
                $this->_connectionID = false;
                if ($this->debug) ADOConnection::outp( $this->host.': '.$err);
                return $ret;
        }       
        
        function _nconnect($argHostname, $argUsername, $argPassword, $argDatabaseName)
        {
                return $this->_connect($argHostname, $argUsername, $argPassword, $argDatabaseName);
        }
        
        
        function NConnect($argHostname = "", $argUsername = "", $argPassword = "", $argDatabaseName = "") 
        {
                return $this->Connect($argHostname, $argUsername, $argPassword, $argDatabaseName, true);
        }
        
        function PConnect($argHostname = "", $argUsername = "", $argPassword = "", $argDatabaseName = "")
        {
                if (defined('ADODB_NEVER_PERSIST')) 
                        return $this->Connect($argHostname,$argUsername,$argPassword,$argDatabaseName);
                
                if ($argHostname != "") $this->host = $argHostname;
                if ($argUsername != "") $this->user = $argUsername;
                if ($argPassword != "") $this->password = $argPassword;
                if ($argDatabaseName != "") $this->database = $argDatabaseName;         
                        
                $this->_isPersistentConnection = true;  
                if ($rez = $this->_pconnect($this->host, $this->user, $this->password, $this->database)) return true;
                if (isset($rez)) {
                        $err = $this->ErrorMsg();
                        if (empty($err)) $err = "Connection error to server '$argHostname' with user '$argUsername'";
                        $ret = false;
                } else {
                        $err = "Missing extension for ".$this->dataProvider;
                        $ret = 0;
                }
                if ($fn = $this->raiseErrorFn) {
                        $fn($this->databaseType,'PCONNECT',$this->ErrorNo(),$err,$this->host,$this->database,$this);
                }
                
                $this->_connectionID = false;
                if ($this->debug) ADOConnection::outp( $this->host.': '.$err);
                return $ret;
        }

        // Format date column in sql string given an input format that understands Y M D
        function SQLDate($fmt, $col=false)
        {       
                if (!$col) $col = $this->sysDate;
                return $col; // child class implement
        }
        
        function Prepare($sql)
        {
                return $sql;
        }
        
        function PrepareSP($sql,$param=true)
        {
                return $this->Prepare($sql,$param);
        }
        
        function Quote($s)
        {
                return $this->qstr($s,false);
        }
        
        function QMagic($s)
        {
                return $this->qstr($s,get_magic_quotes_gpc());
        }

        function q(&$s)
        {
                #if (!empty($this->qNull)) if ($s == 'null') return $s;
                $s = $this->qstr($s,false);
        }
        
        function ErrorNative()
        {
                return $this->ErrorNo();
        }

        
        function nextId($seq_name)
        {
                return $this->GenID($seq_name);
        }

        function RowLock($table,$where)
        {
                return false;
        }
        
        function CommitLock($table)
        {
                return $this->CommitTrans();
        }
        
        function RollbackLock($table)
        {
                return $this->RollbackTrans();
        }
        
        function SetFetchMode($mode)
        {       
                $old = $this->fetchMode;
                $this->fetchMode = $mode;
                
                if ($old === false) {
                global $ADODB_FETCH_MODE;
                        return $ADODB_FETCH_MODE;
                }
                return $old;
        }
        

        function &Query($sql, $inputarr=false)
        {
                $rs = &$this->Execute($sql, $inputarr);
                if (!$rs && defined('ADODB_PEAR')) return ADODB_PEAR_Error();
                return $rs;
        }

        
        function &LimitQuery($sql, $offset, $count, $params=false)
        {
                $rs = &$this->SelectLimit($sql, $count, $offset, $params); 
                if (!$rs && defined('ADODB_PEAR')) return ADODB_PEAR_Error();
                return $rs;
        }

        
        function Disconnect()
        {
                return $this->Close();
        }
        
        /*
                 Returns placeholder for parameter, eg.
                 $DB->Param('a')
                 
                 will return ':a' for Oracle, and '?' for most other databases...
                 
                 For databases that require positioned params, eg $1, $2, $3 for postgresql,
                        pass in Param(false) before setting the first parameter.
        */
        function Param($name,$type='C')
        {
                return '?';
        }
        
        /*
                InParameter and OutParameter are self-documenting versions of Parameter().
        */
        function InParameter(&$stmt,&$var,$name,$maxLen=4000,$type=false)
        {
                return $this->Parameter($stmt,$var,$name,false,$maxLen,$type);
        }
        
        /*
        */
        function OutParameter(&$stmt,&$var,$name,$maxLen=4000,$type=false)
        {
                return $this->Parameter($stmt,$var,$name,true,$maxLen,$type);
        
        }

        
        /* 
        Usage in oracle
                $stmt = $db->Prepare('select * from table where id =:myid and group=:group');
                $db->Parameter($stmt,$id,'myid');
                $db->Parameter($stmt,$group,'group',64);
                $db->Execute();
                
                @param $stmt Statement returned by Prepare() or PrepareSP().
                @param $var PHP variable to bind to
                @param $name Name of stored procedure variable name to bind to.
                @param [$isOutput] Indicates direction of parameter 0/false=IN  1=OUT  2= IN/OUT. This is ignored in oci8.
                @param [$maxLen] Holds an maximum length of the variable.
                @param [$type] The data type of $var. Legal values depend on driver.

        */
        function Parameter(&$stmt,&$var,$name,$isOutput=false,$maxLen=4000,$type=false)
        {
                return false;
        }
        
        
        function IgnoreErrors($saveErrs=false)
        {
                if (!$saveErrs) {
                        $saveErrs = array($this->raiseErrorFn,$this->_transOK);
                        $this->raiseErrorFn = false;
                        return $saveErrs;
                } else {
                        $this->raiseErrorFn = $saveErrs[0];
                        $this->_transOK = $saveErrs[1];
                }
        }
        
        function StartTrans($errfn = 'ADODB_TransMonitor')
        {
                if ($this->transOff > 0) {
                        $this->transOff += 1;
                        return;
                }
                
                $this->_oldRaiseFn = $this->raiseErrorFn;
                $this->raiseErrorFn = $errfn;
                $this->_transOK = true;
                
                if ($this->debug && $this->transCnt > 0) ADOConnection::outp("Bad Transaction: StartTrans called within BeginTrans");
                $this->BeginTrans();
                $this->transOff = 1;
        }
        
        
        function CompleteTrans($autoComplete = true)
        {
                if ($this->transOff > 1) {
                        $this->transOff -= 1;
                        return true;
                }
                $this->raiseErrorFn = $this->_oldRaiseFn;
                
                $this->transOff = 0;
                if ($this->_transOK && $autoComplete) {
                        if (!$this->CommitTrans()) {
                                $this->_transOK = false;
                                if ($this->debug) ADOConnection::outp("Smart Commit failed");
                        } else
                                if ($this->debug) ADOConnection::outp("Smart Commit occurred");
                } else {
                        $this->_transOK = false;
                        $this->RollbackTrans();
                        if ($this->debug) ADOCOnnection::outp("Smart Rollback occurred");
                }
                
                return $this->_transOK;
        }
        
        /*
                At the end of a StartTrans/CompleteTrans block, perform a rollback.
        */
        function FailTrans()
        {
                if ($this->debug) 
                        if ($this->transOff == 0) {
                                ADOConnection::outp("FailTrans outside StartTrans/CompleteTrans");
                        } else {
                                ADOConnection::outp("FailTrans was called");
                                adodb_backtrace();
                        }
                $this->_transOK = false;
        }
        
        function HasFailedTrans()
        {
                if ($this->transOff > 0) return $this->_transOK == false;
                return false;
        }
        
        function &Execute($sql,$inputarr=false) 
        {
                if ($this->fnExecute) {
                        $fn = $this->fnExecute;
                        $ret =& $fn($this,$sql,$inputarr);
                        if (isset($ret)) return $ret;
                }
                if ($inputarr) {
                        if (!is_array($inputarr)) $inputarr = array($inputarr);
                        
                        $element0 = reset($inputarr);
                        # is_object check because oci8 descriptors can be passed in
                        $array_2d = is_array($element0) && !is_object(reset($element0));
                        //remove extra memory copy of input -mikefedyk
                        unset($element0);
                        
                        if (!is_array($sql) && !$this->_bindInputArray) {
                                $sqlarr = explode('?',$sql);
                                        
                                if (!$array_2d) $inputarr = array($inputarr);
                                foreach($inputarr as $arr) {
                                        $sql = ''; $i = 0;
                                        //Use each() instead of foreach to reduce memory usage -mikefedyk
                                        while(list(, $v) = each($arr)) {
                                                $sql .= $sqlarr[$i];
                                                // from Ron Baldwin <ron.baldwin#sourceprose.com>
                                                // Only quote string types      
                                                $typ = gettype($v);
                                                if ($typ == 'string')
                                                        //New memory copy of input created here -mikefedyk
                                                        $sql .= $this->qstr($v);
                                                else if ($typ == 'double')
                                                        $sql .= str_replace(',','.',$v); // locales fix so 1.1 does not get converted to 1,1
                                                else if ($typ == 'boolean')
                                                        $sql .= $v ? $this->true : $this->false;
                                                else if ($typ == 'object') {
                                                        if (method_exists($v, '__toString')) $sql .= $this->qstr($v->__toString());
                                                        else $sql .= $this->qstr((string) $v);
                                                } else if ($v === null)
                                                        $sql .= 'NULL';
                                                else
                                                        $sql .= $v;
                                                $i += 1;
                                        }
                                        if (isset($sqlarr[$i])) {
                                                $sql .= $sqlarr[$i];
                                                if ($i+1 != sizeof($sqlarr)) ADOConnection::outp( "Input Array does not match ?: ".htmlspecialchars($sql));
                                        } else if ($i != sizeof($sqlarr))       
                                                ADOConnection::outp( "Input array does not match ?: ".htmlspecialchars($sql));
                
                                        $ret =& $this->_Execute($sql);
                                        if (!$ret) return $ret;
                                }       
                        } else {
                                if ($array_2d) {
                                        if (is_string($sql))
                                                $stmt = $this->Prepare($sql);
                                        else
                                                $stmt = $sql;
                                                
                                        foreach($inputarr as $arr) {
                                                $ret =& $this->_Execute($stmt,$arr);
                                                if (!$ret) return $ret;
                                        }
                                } else {
                                        $ret =& $this->_Execute($sql,$inputarr);
                                }
                        }
                } else {
                        $ret =& $this->_Execute($sql,false);
                }

                return $ret;
        }
        
        
        function &_Execute($sql,$inputarr=false)
        {
                if ($this->debug) {
                        global $ADODB_INCLUDED_LIB;
                        if (empty($ADODB_INCLUDED_LIB)) include(ADODB_DIR.'/adodb-lib.inc.php');
                        $this->_queryID = _adodb_debug_execute($this, $sql,$inputarr);
                } else {
                        $this->_queryID = @$this->_query($sql,$inputarr);
                }
                
                /************************
                // OK, query executed
                *************************/

                if ($this->_queryID === false) { // error handling if query fails
                        if ($this->debug == 99) adodb_backtrace(true,5);        
                        $fn = $this->raiseErrorFn;
                        if ($fn) {
                                $fn($this->databaseType,'EXECUTE',$this->ErrorNo(),$this->ErrorMsg(),$sql,$inputarr,$this);
                        } 
                        $false = false;
                        return $false;
                } 
                
                if ($this->_queryID === true) { // return simplified recordset for inserts/updates/deletes with lower overhead
                        $rs = new ADORecordSet_empty();
                        return $rs;
                }
                
                // return real recordset from select statement
                $rsclass = $this->rsPrefix.$this->databaseType;
                $rs = new $rsclass($this->_queryID,$this->fetchMode);
                $rs->connection = &$this; // Pablo suggestion
                $rs->Init();
                if (is_array($sql)) $rs->sql = $sql[0];
                else $rs->sql = $sql;
                if ($rs->_numOfRows <= 0) {
                global $ADODB_COUNTRECS;
                        if ($ADODB_COUNTRECS) {
                                if (!$rs->EOF) { 
                                        $rs = &$this->_rs2rs($rs,-1,-1,!is_array($sql));
                                        $rs->_queryID = $this->_queryID;
                                } else
                                        $rs->_numOfRows = 0;
                        }
                }
                return $rs;
        }

        function CreateSequence($seqname='adodbseq',$startID=1)
        {
                if (empty($this->_genSeqSQL)) return false;
                return $this->Execute(sprintf($this->_genSeqSQL,$seqname,$startID));
        }

        function DropSequence($seqname='adodbseq')
        {
                if (empty($this->_dropSeqSQL)) return false;
                return $this->Execute(sprintf($this->_dropSeqSQL,$seqname));
        }

        function GenID($seqname='adodbseq',$startID=1)
        {
                if (!$this->hasGenID) {
                        return 0; // formerly returns false pre 1.60
                }
                
                $getnext = sprintf($this->_genIDSQL,$seqname);
                
                $holdtransOK = $this->_transOK;
                
                $save_handler = $this->raiseErrorFn;
                $this->raiseErrorFn = '';
                @($rs = $this->Execute($getnext));
                $this->raiseErrorFn = $save_handler;
                
                if (!$rs) {
                        $this->_transOK = $holdtransOK; //if the status was ok before reset
                        $createseq = $this->Execute(sprintf($this->_genSeqSQL,$seqname,$startID));
                        $rs = $this->Execute($getnext);
                }
                if ($rs && !$rs->EOF) $this->genID = reset($rs->fields);
                else $this->genID = 0; // false
        
                if ($rs) $rs->Close();

                return $this->genID;
        }       

        function Insert_ID($table='',$column='')
        {
                if ($this->_logsql && $this->lastInsID) return $this->lastInsID;
                if ($this->hasInsertID) return $this->_insertid($table,$column);
                if ($this->debug) {
                        ADOConnection::outp( '<p>Insert_ID error</p>');
                        adodb_backtrace();
                }
                return false;
        }


        function PO_Insert_ID($table="", $id="") 
        {
           if ($this->hasInsertID){
                   return $this->Insert_ID($table,$id);
           } else {
                   return $this->GetOne("SELECT MAX($id) FROM $table");
           }
        }

        function Affected_Rows()
        {
                if ($this->hasAffectedRows) {
                        if ($this->fnExecute === 'adodb_log_sql') {
                                if ($this->_logsql && $this->_affected !== false) return $this->_affected;
                        }
                        $val = $this->_affectedrows();
                        return ($val < 0) ? false : $val;
                }
                                  
                if ($this->debug) ADOConnection::outp( '<p>Affected_Rows error</p>',false);
                return false;
        }
        
        
        function ErrorMsg()
        {
                if ($this->_errorMsg) return '!! '.strtoupper($this->dataProvider.' '.$this->databaseType).': '.$this->_errorMsg;
                else return '';
        }
        
        
        function ErrorNo() 
        {
                return ($this->_errorMsg) ? -1 : 0;
        }
        
        function MetaError($err=false)
        {
                include_once(ADODB_DIR."/adodb-error.inc.php");
                if ($err === false) $err = $this->ErrorNo();
                return adodb_error($this->dataProvider,$this->databaseType,$err);
        }
        
        function MetaErrorMsg($errno)
        {
                include_once(ADODB_DIR."/adodb-error.inc.php");
                return adodb_errormsg($errno);
        }
        
        function MetaPrimaryKeys($table, $owner=false)
        {
        // owner not used in base class - see oci8
                $p = array();
                $objs =& $this->MetaColumns($table);
                if ($objs) {
                        foreach($objs as $v) {
                                if (!empty($v->primary_key))
                                        $p[] = $v->name;
                        }
                }
                if (sizeof($p)) return $p;
                if (function_exists('ADODB_VIEW_PRIMARYKEYS'))
                        return ADODB_VIEW_PRIMARYKEYS($this->databaseType, $this->database, $table, $owner);
                return false;
        }
        
        function MetaForeignKeys($table, $owner=false, $upper=false)
        {
                return false;
        }
        function SelectDB($dbName) 
        {return false;}
        
        
        function &SelectLimit($sql,$nrows=-1,$offset=-1, $inputarr=false,$secs2cache=0)
        {
                if ($this->hasTop && $nrows > 0) {
                // suggested by Reinhard Balling. Access requires top after distinct 
                 // Informix requires first before distinct - F Riosa
                        $ismssql = (strpos($this->databaseType,'mssql') !== false);
                        if ($ismssql) $isaccess = false;
                        else $isaccess = (strpos($this->databaseType,'access') !== false);
                        
                        if ($offset <=  0) {
                                
                                        // access includes ties in result
                                        if ($isaccess) {
                                                $sql = preg_replace(
                                                '/(^\s*select\s+(distinctrow|distinct)?)/i','\\1 '.$this->hasTop.' '.((integer)$nrows).' ',$sql);

                                                if ($secs2cache != 0) {
                                                        $ret =& $this->CacheExecute($secs2cache, $sql,$inputarr);
                                                } else {
                                                        $ret =& $this->Execute($sql,$inputarr);
                                                }
                                                return $ret; // PHP5 fix
                                        } else if ($ismssql){
                                                $sql = preg_replace(
                                                '/(^\s*select\s+(distinctrow|distinct)?)/i','\\1 '.$this->hasTop.' '.((integer)$nrows).' ',$sql);
                                        } else {
                                                $sql = preg_replace(
                                                '/(^\s*select\s)/i','\\1 '.$this->hasTop.' '.((integer)$nrows).' ',$sql);
                                        }
                        } else {
                                $nn = $nrows + $offset;
                                if ($isaccess || $ismssql) {
                                        $sql = preg_replace(
                                        '/(^\s*select\s+(distinctrow|distinct)?)/i','\\1 '.$this->hasTop.' '.$nn.' ',$sql);
                                } else {
                                        $sql = preg_replace(
                                        '/(^\s*select\s)/i','\\1 '.$this->hasTop.' '.$nn.' ',$sql);
                                }
                        }
                }
                
                // if $offset>0, we want to skip rows, and $ADODB_COUNTRECS is set, we buffer  rows
                // 0 to offset-1 which will be discarded anyway. So we disable $ADODB_COUNTRECS.
                global $ADODB_COUNTRECS;
                
                $savec = $ADODB_COUNTRECS;
                $ADODB_COUNTRECS = false;
                        
                if ($offset>0){
                        if ($secs2cache != 0) $rs = &$this->CacheExecute($secs2cache,$sql,$inputarr);
                        else $rs = &$this->Execute($sql,$inputarr);
                } else {
                        if ($secs2cache != 0) $rs = &$this->CacheExecute($secs2cache,$sql,$inputarr);
                        else $rs = &$this->Execute($sql,$inputarr);
                }
                $ADODB_COUNTRECS = $savec;
                if ($rs && !$rs->EOF) {
                        $rs =& $this->_rs2rs($rs,$nrows,$offset);
                }
                //print_r($rs);
                return $rs;
        }
        
        function &SerializableRS(&$rs)
        {
                $rs2 =& $this->_rs2rs($rs);
                $ignore = false;
                $rs2->connection =& $ignore;
                
                return $rs2;
        }
        
        function &_rs2rs(&$rs,$nrows=-1,$offset=-1,$close=true)
        {
                if (! $rs) {
                        $false = false;
                        return $false;
                }
                $dbtype = $rs->databaseType;
                if (!$dbtype) {
                        $rs = &$rs;  // required to prevent crashing in 4.2.1, but does not happen in 4.3.1 -- why ?
                        return $rs;
                }
                if (($dbtype == 'array' || $dbtype == 'csv') && $nrows == -1 && $offset == -1) {
                        $rs->MoveFirst();
                        $rs = &$rs; // required to prevent crashing in 4.2.1, but does not happen in 4.3.1-- why ?
                        return $rs;
                }
                $flds = array();
                for ($i=0, $max=$rs->FieldCount(); $i < $max; $i++) {
                        $flds[] = $rs->FetchField($i);
                }

                $arr =& $rs->GetArrayLimit($nrows,$offset);
                //print_r($arr);
                if ($close) $rs->Close();
                
                $arrayClass = $this->arrayClass;
                
                $rs2 = new $arrayClass();
                $rs2->connection = &$this;
                $rs2->sql = $rs->sql;
                $rs2->dataProvider = $this->dataProvider;
                $rs2->InitArrayFields($arr,$flds);
                $rs2->fetchMode = isset($rs->adodbFetchMode) ? $rs->adodbFetchMode : $rs->fetchMode;
                return $rs2;
        }
        
        /*
        * Return all rows. Compat with PEAR DB
        */
        function &GetAll($sql, $inputarr=false)
        {
                $arr =& $this->GetArray($sql,$inputarr);
                return $arr;
        }
        
        function &GetAssoc($sql, $inputarr=false,$force_array = false, $first2cols = false)
        {
                $rs =& $this->Execute($sql, $inputarr);
                if (!$rs) {
                        $false = false;
                        return $false;
                }
                $arr =& $rs->GetAssoc($force_array,$first2cols);
                return $arr;
        }
        
        function &CacheGetAssoc($secs2cache, $sql=false, $inputarr=false,$force_array = false, $first2cols = false)
        {
                if (!is_numeric($secs2cache)) {
                        $first2cols = $force_array;
                        $force_array = $inputarr;
                }
                $rs =& $this->CacheExecute($secs2cache, $sql, $inputarr);
                if (!$rs) {
                        $false =