Search moodle.org's
Developer Documentation

See Release Notes

  • Bug fixes for general core bugs in 3.10.x will end 8 November 2021 (12 months).
  • Bug fixes for security issues in 3.10.x will end 9 May 2022 (18 months).
  • PHP version: minimum PHP 7.2.0 Note: minimum PHP version has increased since Moodle 3.8. PHP 7.3.x and 7.4.x are supported too.
<?php
< /* < @version v5.20.16 12-Jan-2020 < @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 8. < < This is the preferred driver for MySQL connections, and supports both transactional < and non-transactional table types. You can use this as a drop-in replacement for both < the mysql and mysqlt drivers. As of ADOdb Version 5.20.0, all other native MySQL drivers < are deprecated < < Requires mysql client. Works on Windows and Unix. < < 21 October 2003: MySQLi extension implementation by Arjen de Rijke (a.de.rijke@xs4all.nl) < Based on adodb 3.40
> /** > * MySQL improved driver (mysqli) > * > * This is the preferred driver for MySQL connections. It supports both > * transactional and non-transactional table types. You can use this as a > * drop-in replacement for both the mysql and mysqlt drivers. > * As of ADOdb Version 5.20.0, all other native MySQL drivers are deprecated. > * > * 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_DIR')) { > die(); > }
if (! defined("_ADODB_MYSQLI_LAYER")) { define("_ADODB_MYSQLI_LAYER", 1 ); // PHP5 compat... if (! defined("MYSQLI_BINARY_FLAG")) define("MYSQLI_BINARY_FLAG", 128); if (!defined('MYSQLI_READ_DEFAULT_GROUP')) define('MYSQLI_READ_DEFAULT_GROUP',1);
< // disable adodb extension - currently incompatible. < global $ADODB_EXTENSION; $ADODB_EXTENSION = false; <
> /** > * Class ADODB_mysqli > */
class ADODB_mysqli extends ADOConnection { var $databaseType = 'mysqli'; var $dataProvider = 'mysql'; var $hasInsertID = true; var $hasAffectedRows = true; var $metaTablesSQL = "SELECT TABLE_NAME, CASE WHEN TABLE_TYPE = 'VIEW' THEN 'V' ELSE 'T' END FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA="; var $metaColumnsSQL = "SHOW COLUMNS FROM `%s`"; var $fmtTimeStamp = "'Y-m-d H:i:s'"; var $hasLimit = true; var $hasMoveFirst = true; var $hasGenID = true; var $isoDates = true; // accepts dates in ISO format var $sysDate = 'CURDATE()'; var $sysTimeStamp = 'NOW()'; var $hasTransactions = true; var $forceNewConnect = false; var $poorAffectedRows = true; var $clientFlags = 0; var $substr = "substring"; var $port = 3306; //Default to 3306 to fix HHVM bug var $socket = ''; //Default to empty string to fix HHVM bug var $_bindInputArray = false; var $nameQuote = '`'; /// string to use to quote identifiers and names var $optionFlags = array(array(MYSQLI_READ_DEFAULT_GROUP,0)); var $arrayClass = 'ADORecordSet_array_mysqli'; var $multiQuery = false;
> var $ssl_key = null; > var $ssl_cert = null; function __construct() > var $ssl_ca = null; { > var $ssl_capath = null; // if(!extension_loaded("mysqli")) > var $ssl_cipher = null; //trigger_error("You must have the mysqli extension installed.", E_USER_ERROR); > } > /** > * Tells the insert_id method how to obtain the last value, depending on whether function SetTransactionMode( $transaction_mode ) > * we are using a stored procedure or not { > */ $this->_transmode = $transaction_mode; > private $usePreparedStatement = false; if (empty($transaction_mode)) { > private $useLastInsertStatement = false;
< function __construct()
> /** > * @var bool True if the last executed statement is a SELECT {@see _query()} > */ > private $isSelectStatement = false; > > /** > * ADODB_mysqli constructor. > */ > public function __construct()
< // if(!extension_loaded("mysqli")) < //trigger_error("You must have the mysqli extension installed.", E_USER_ERROR);
> parent::__construct(); > > // Forcing error reporting mode to OFF, which is no longer the default > // starting with PHP 8.1 (see #755) > mysqli_report(MYSQLI_REPORT_OFF);
if (!stristr($transaction_mode,'isolation')) $transaction_mode = 'ISOLATION LEVEL '.$transaction_mode;
> $this->Execute("SET SESSION TRANSACTION ".$transaction_mode); > /** } > * Sets the isolation level of a transaction. > * // returns true or false > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:settransactionmode // To add: parameter int $port, > * // parameter string $socket > * @param string $transaction_mode The transaction mode to set. function _connect($argHostname = NULL, > * $argUsername = NULL, > * @return void $argPassword = NULL, > */
< $this->Execute('SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ');
> $this->execute('SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ');
< $this->Execute("SET SESSION TRANSACTION ".$transaction_mode);
> $this->execute("SET SESSION TRANSACTION ".$transaction_mode); > } > > /** > * Adds a parameter to the connection string. > * > * Parameter must be one of the the constants listed in mysqli_options(). > * @see https://www.php.net/manual/en/mysqli.options.php > * > * @param int $parameter The parameter to set > * @param string $value The value of the parameter > * > * @example, for mssqlnative driver ('CharacterSet','UTF-8') > * @return bool > */ > public function setConnectionParameter($parameter, $value) { > if(!is_numeric($parameter)) { > $this->outp_throw("Invalid connection parameter '$parameter'", __METHOD__); > return false; > } > $this->connectionParameters[$parameter] = $value; > return true;
< // returns true or false < // To add: parameter int $port, < // parameter string $socket < function _connect($argHostname = NULL, < $argUsername = NULL, < $argPassword = NULL, < $argDatabasename = NULL, $persist=false)
> /** > * Connect to a database. > * > * @todo add: parameter int $port, parameter string $socket > * > * @param string|null $argHostname (Optional) The host to connect to. > * @param string|null $argUsername (Optional) The username to connect as. > * @param string|null $argPassword (Optional) The password to connect with. > * @param string|null $argDatabasename (Optional) The name of the database to start in when connected. > * @param bool $persist (Optional) Whether or not to use a persistent connection. > * > * @return bool|null True if connected successfully, false if connection failed, or null if the mysqli extension > * isn't currently loaded. > */ > function _connect($argHostname = null, > $argUsername = null, > $argPassword = null, > $argDatabasename = null, > $persist = false)
if ($this->debug) {
< ADOConnection::outp("mysqli_init() failed : " . $this->ErrorMsg());
> ADOConnection::outp("mysqli_init() failed : " . $this->errorMsg());
} return false; } /* I suggest a simple fix which would enable adodb and mysqli driver to read connection options from the standard mysql configuration file /etc/my.cnf - "Bastien Duclaux" <bduclaux#yahoo.com> */
> $this->optionFlags = array();
foreach($this->optionFlags as $arr) { mysqli_options($this->_connectionID,$arr[0],$arr[1]); }
< //http ://php.net/manual/en/mysqli.persistconns.php < if ($persist && PHP_VERSION > 5.2 && strncmp($argHostname,'p:',2) != 0) $argHostname = 'p:'.$argHostname;
> // Now merge in the standard connection parameters setting > foreach ($this->connectionParameters as $parameter => $value) { > // Make sure parameter is numeric before calling mysqli_options() > // that to avoid Warning (or TypeError exception on PHP 8). > if (!is_numeric($parameter) > || !mysqli_options($this->_connectionID, $parameter, $value) > ) { > $this->outp_throw("Invalid connection parameter '$parameter'", __METHOD__); > } > } > > //https://php.net/manual/en/mysqli.persistconns.php > if ($persist && strncmp($argHostname,'p:',2) != 0) { > $argHostname = 'p:' . $argHostname; > } > > // SSL Connections for MySQLI > if ($this->ssl_key || $this->ssl_cert || $this->ssl_ca || $this->ssl_capath || $this->ssl_cipher) { > mysqli_ssl_set($this->_connectionID, $this->ssl_key, $this->ssl_cert, $this->ssl_ca, $this->ssl_capath, $this->ssl_cipher); > }
#if (!empty($this->port)) $argHostname .= ":".$this->port; $ok = @mysqli_real_connect($this->_connectionID, $argHostname, $argUsername, $argPassword, $argDatabasename, # PHP7 compat: port must be int. Use default port if cast yields zero (int)$this->port != 0 ? (int)$this->port : 3306, $this->socket, $this->clientFlags); if ($ok) {
< if ($argDatabasename) return $this->SelectDB($argDatabasename);
> if ($argDatabasename) return $this->selectDB($argDatabasename);
return true; } else { if ($this->debug) {
< ADOConnection::outp("Could not connect : " . $this->ErrorMsg());
> ADOConnection::outp("Could not connect : " . $this->errorMsg());
} $this->_connectionID = null; return false; } }
< // returns true or false < // How to force a persistent connection
> /** > * Connect to a database with a persistent connection. > * > * @param string|null $argHostname The host to connect to. > * @param string|null $argUsername The username to connect as. > * @param string|null $argPassword The password to connect with. > * @param string|null $argDatabasename The name of the database to start in when connected. > * > * @return bool|null True if connected successfully, false if connection failed, or null if the mysqli extension > * isn't currently loaded. > */
function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename) { return $this->_connect($argHostname, $argUsername, $argPassword, $argDatabasename, true); }
< // When is this used? Close old connection first? < // In _connect(), check $this->forceNewConnect?
> /** > * Connect to a database, whilst setting $this->forceNewConnect to true. > * > * When is this used? Close old connection first? > * In _connect(), check $this->forceNewConnect? > * > * @param string|null $argHostname The host to connect to. > * @param string|null $argUsername The username to connect as. > * @param string|null $argPassword The password to connect with. > * @param string|null $argDatabasename The name of the database to start in when connected. > * > * @return bool|null True if connected successfully, false if connection failed, or null if the mysqli extension > * isn't currently loaded. > */
function _nconnect($argHostname, $argUsername, $argPassword, $argDatabasename) { $this->forceNewConnect = true; return $this->_connect($argHostname, $argUsername, $argPassword, $argDatabasename); }
> /** function IfNull( $field, $ifNull ) > * Replaces a null value with a specified replacement. { > * return " IFNULL($field, $ifNull) "; // if MySQL > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:ifnull } > * > * @param mixed $field The field in the table to check. // do not use $ADODB_COUNTRECS > * @param mixed $ifNull The value to replace the null value with if it is found. function GetOne($sql,$inputarr=false) > * { > * @return string global $ADODB_GETONE_EOF; > */
< return " IFNULL($field, $ifNull) "; // if MySQL
> return " IFNULL($field, $ifNull) ";
< // do not use $ADODB_COUNTRECS
> /** > * Retrieves the first column of the first matching row of an executed SQL statement. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:getone > * > * @param string $sql The SQL to execute. > * @param bool|array $inputarr (Optional) An array containing any required SQL parameters, or false if none needed. > * > * @return bool|array|null > */
< $rs = $this->Execute($sql,$inputarr);
> $rs = $this->execute($sql,$inputarr);
if ($rs) { if ($rs->EOF) $ret = $ADODB_GETONE_EOF; else $ret = reset($rs->fields);
< $rs->Close();
> $rs->close();
} return $ret; }
> /** function ServerInfo() > * Get information about the current MySQL server. { > * $arr['description'] = $this->GetOne("select version()"); > * @return array $arr['version'] = ADOConnection::_findvers($arr['description']); > */
< $arr['description'] = $this->GetOne("select version()");
> $arr['description'] = $this->getOne("select version()");
}
<
> /** > * Begins a granular transaction. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:begintrans > * > * @return bool Always returns true. > */
function BeginTrans() { if ($this->transOff) return true; $this->transCnt += 1;
< //$this->Execute('SET AUTOCOMMIT=0');
> //$this->execute('SET AUTOCOMMIT=0');
mysqli_autocommit($this->_connectionID, false);
< $this->Execute('BEGIN');
> $this->execute('BEGIN');
return true; }
> /** function CommitTrans($ok=true) > * Commits a granular transaction. { > * if ($this->transOff) return true; > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:committrans if (!$ok) return $this->RollbackTrans(); > * > * @param bool $ok (Optional) If false, will rollback the transaction instead. if ($this->transCnt) $this->transCnt -= 1; > * $this->Execute('COMMIT'); > * @return bool Always returns true. > */
< if (!$ok) return $this->RollbackTrans();
> if (!$ok) return $this->rollbackTrans();
< $this->Execute('COMMIT');
> $this->execute('COMMIT');
< //$this->Execute('SET AUTOCOMMIT=1');
> //$this->execute('SET AUTOCOMMIT=1');
}
> /** function RollbackTrans() > * Rollback a smart transaction. { > * if ($this->transOff) return true; > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:rollbacktrans if ($this->transCnt) $this->transCnt -= 1; > * $this->Execute('ROLLBACK'); > * @return bool Always returns true. //$this->Execute('SET AUTOCOMMIT=1'); > */
< $this->Execute('ROLLBACK'); < //$this->Execute('SET AUTOCOMMIT=1');
> $this->execute('ROLLBACK'); > //$this->execute('SET AUTOCOMMIT=1');
}
> /** function RowLock($tables,$where='',$col='1 as adodbignore') > * Lock a table row for a duration of a transaction. { > * if ($this->transCnt==0) $this->BeginTrans(); > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:rowlock if ($where) $where = ' where '.$where; > * $rs = $this->Execute("select $col from $tables $where for update"); > * @param string $tables The table(s) to lock rows for. return !empty($rs); > * @param string $where (Optional) The WHERE clause to use to determine which rows to lock. } > * @param string $col (Optional) The columns to select. > * /** > * @return bool True if the locking SQL statement executed successfully, otherwise false. * Quotes a string to be sent to the database > */
< if ($this->transCnt==0) $this->BeginTrans();
> if ($this->transCnt==0) $this->beginTrans();
< $rs = $this->Execute("select $col from $tables $where for update");
> $rs = $this->execute("select $col from $tables $where for update");
< * Quotes a string to be sent to the database < * When there is no active connection,
> * Appropriately quotes strings with ' characters for insertion into the database. > * > * Relies on mysqli_real_escape_string() > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:qstr > *
< * @param boolean $magic_quotes If false, use mysqli_real_escape_string() < * if you are quoting a string extracted from a POST/GET variable, < * then pass get_magic_quotes_gpc() as the second parameter. This will < * ensure that the variable is not quoted twice, once by qstr() and < * once by the magic_quotes_gpc. < * Eg. $s = $db->qstr(_GET['name'],get_magic_quotes_gpc());
> * @param bool $magic_quotes This param is not used since 5.21.0. > * It remains for backwards compatibility. > *
< function qstr($s, $magic_quotes = false)
> function qStr($s, $magic_quotes=false)
{
< if (is_null($s)) return 'NULL'; < if (!$magic_quotes) {
> if (is_null($s)) { > return 'NULL'; > } >
// mysqli_real_escape_string() throws a warning when the given // connection is invalid
< if (PHP_VERSION >= 5 && $this->_connectionID) {
> if ($this->_connectionID) {
return "'" . mysqli_real_escape_string($this->_connectionID, $s) . "'"; } if ($this->replaceQuote[0] == '\\') {
< $s = adodb_str_replace(array('\\',"\0"), array('\\\\',"\\\0") ,$s);
> $s = str_replace(array('\\', "\0"), array('\\\\', "\\\0") ,$s);
} return "'" . str_replace("'", $this->replaceQuote, $s) . "'"; }
< // undo magic quotes for " < $s = str_replace('\\"','"',$s); < return "'$s'"; < }
< function _insertid()
> /** > * Return the AUTO_INCREMENT id of the last row that has been inserted or updated in a table. > * > * @inheritDoc > */ > protected function _insertID($table = '', $column = '')
{
> // mysqli_insert_id does not return the last_insert_id if called after $result = @mysqli_insert_id($this->_connectionID); > // execution of a stored procedure so we execute this instead. if ($result == -1) { > if ($this->useLastInsertStatement) if ($this->debug) ADOConnection::outp("mysqli_insert_id() failed : " . $this->ErrorMsg()); > $result = ADOConnection::getOne('SELECT LAST_INSERT_ID()'); } > else
return $result;
>
< if ($this->debug) ADOConnection::outp("mysqli_insert_id() failed : " . $this->ErrorMsg());
> if ($this->debug) > ADOConnection::outp("mysqli_insert_id() failed : " . $this->errorMsg());
> // reset prepared statement flags // Only works for INSERT, UPDATE and DELETE query's > $this->usePreparedStatement = false; function _affectedrows() > $this->useLastInsertStatement = false;
< // Only works for INSERT, UPDATE and DELETE query's
> /** > * Returns how many rows were effected by the most recently executed SQL statement. > * Only works for INSERT, UPDATE and DELETE queries. > * > * @return int The number of rows affected. > */
$result = @mysqli_affected_rows($this->_connectionID);
> if ($this->isSelectStatement) { if ($result == -1) { > // Affected rows works fine against selects, returning if ($this->debug) ADOConnection::outp("mysqli_affected_rows() failed : " . $this->ErrorMsg()); > // the rowcount, but ADOdb does not do that. } > return false; return $result; > } } >
< if ($this->debug) ADOConnection::outp("mysqli_affected_rows() failed : " . $this->ErrorMsg());
> if ($this->debug) ADOConnection::outp("mysqli_affected_rows() failed : " . $this->errorMsg());
< // See http://www.mysql.com/doc/M/i/Miscellaneous_functions.html
// Reference on Last_Insert_ID on the recommended way to simulate sequences var $_genIDSQL = "update %s set id=LAST_INSERT_ID(id+1);"; var $_genSeqSQL = "create table if not exists %s (id int not null)"; var $_genSeqCountSQL = "select count(*) from %s"; var $_genSeq2SQL = "insert into %s values (%s)"; var $_dropSeqSQL = "drop table if exists %s";
> /** function CreateSequence($seqname='adodbseq',$startID=1) > * Creates a sequence in the database. { > * if (empty($this->_genSeqSQL)) return false; > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:createsequence $u = strtoupper($seqname); > * > * @param string $seqname The sequence name. $ok = $this->Execute(sprintf($this->_genSeqSQL,$seqname)); > * @param int $startID The start id. if (!$ok) return false; > * return $this->Execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1)); > * @return ADORecordSet|bool A record set if executed successfully, otherwise false. } > */
< $u = strtoupper($seqname);
< $ok = $this->Execute(sprintf($this->_genSeqSQL,$seqname));
> $ok = $this->execute(sprintf($this->_genSeqSQL,$seqname));
< return $this->Execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1));
> return $this->execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1));
// post-nuke sets hasGenID to false
> /** if (!$this->hasGenID) return false; > * A portable method of creating sequence numbers. > * $getnext = sprintf($this->_genIDSQL,$seqname); > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:genid $holdtransOK = $this->_transOK; // save the current status > * $rs = @$this->Execute($getnext); > * @param string $seqname (Optional) The name of the sequence to use. if (!$rs) { > * @param int $startID (Optional) The point to start at in the sequence. if ($holdtransOK) $this->_transOK = true; //if the status was ok before reset > * $u = strtoupper($seqname); > * @return bool|int|string $this->Execute(sprintf($this->_genSeqSQL,$seqname)); > */
< $rs = @$this->Execute($getnext);
> $rs = @$this->execute($getnext);
< $u = strtoupper($seqname); < $this->Execute(sprintf($this->_genSeqSQL,$seqname)); < $cnt = $this->GetOne(sprintf($this->_genSeqCountSQL,$seqname)); < if (!$cnt) $this->Execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1)); < $rs = $this->Execute($getnext);
> $this->execute(sprintf($this->_genSeqSQL,$seqname)); > $cnt = $this->getOne(sprintf($this->_genSeqCountSQL,$seqname)); > if (!$cnt) $this->execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1)); > $rs = $this->execute($getnext);
$this->genID = mysqli_insert_id($this->_connectionID);
< $rs->Close();
> if ($this->genID == 0) { > $getnext = "select LAST_INSERT_ID() from " . $seqname; > $rs = $this->execute($getnext); > $this->genID = (int)$rs->fields[0]; > } > $rs->close();
} else $this->genID = 0; return $this->genID; }
> /** function MetaDatabases() > * Return a list of all visible databases except the 'mysql' database. { > * $query = "SHOW DATABASES"; > * @return array|false An array of database names, or false if the query failed. $ret = $this->Execute($query); > */
< $ret = $this->Execute($query);
> $ret = $this->execute($query);
$arr = array(); while (!$ret->EOF){
< $db = $ret->Fields('Database');
> $db = $ret->fields('Database');
if ($db != 'mysql') $arr[] = $db;
< $ret->MoveNext();
> $ret->moveNext();
} return $arr; } return $ret; }
< < function MetaIndexes ($table, $primary = FALSE, $owner = false)
> /** > * Get a list of indexes on the specified table. > * > * @param string $table The name of the table to get indexes for. > * @param bool $primary (Optional) Whether or not to include the primary key. > * @param bool $owner (Optional) Unused. > * > * @return array|bool An array of the indexes, or false if the query to get the indexes failed. > */ > function MetaIndexes($table, $primary = false, $owner = false)
{ // save old fetch mode global $ADODB_FETCH_MODE; $false = false; $save = $ADODB_FETCH_MODE; $ADODB_FETCH_MODE = ADODB_FETCH_NUM; if ($this->fetchMode !== FALSE) {
< $savem = $this->SetFetchMode(FALSE);
> $savem = $this->setFetchMode(FALSE);
} // get index details
< $rs = $this->Execute(sprintf('SHOW INDEXES FROM %s',$table));
> $rs = $this->execute(sprintf('SHOW INDEXES FROM %s',$table));
// restore fetchmode if (isset($savem)) {
< $this->SetFetchMode($savem);
> $this->setFetchMode($savem);
} $ADODB_FETCH_MODE = $save; if (!is_object($rs)) { return $false; } $indexes = array (); // parse index data into array
< while ($row = $rs->FetchRow()) {
> while ($row = $rs->fetchRow()) {
if ($primary == FALSE AND $row[2] == 'PRIMARY') { continue; } if (!isset($indexes[$row[2]])) { $indexes[$row[2]] = array( 'unique' => ($row[1] == 0), 'columns' => array() ); } $indexes[$row[2]]['columns'][$row[3] - 1] = $row[4]; } // sort columns by order in the index foreach ( array_keys ($indexes) as $index ) { ksort ($indexes[$index]['columns']); } return $indexes; }
< < // Format date column in sql string given an input format that understands Y M D
> /** > * Returns a portably-formatted date string from a timestamp database column. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:sqldate > * > * @param string $fmt The date format to use. > * @param string|bool $col (Optional) The table column to date format, or if false, use NOW(). > * > * @return bool|string The SQL DATE_FORMAT() string, or false if the provided date format was empty. > */
function SQLDate($fmt, $col=false) { if (!$col) $col = $this->sysTimeStamp; $s = 'DATE_FORMAT('.$col.",'"; $concat = false; $len = strlen($fmt); for ($i=0; $i < $len; $i++) { $ch = $fmt[$i]; switch($ch) { case 'Y': case 'y': $s .= '%Y'; break; case 'Q': case 'q': $s .= "'),Quarter($col)"; if ($len > $i+1) $s .= ",DATE_FORMAT($col,'"; else $s .= ",('"; $concat = true; break; case 'M': $s .= '%b'; break; case 'm': $s .= '%m'; break; case 'D': case 'd': $s .= '%d'; break; case 'H': $s .= '%H'; break; case 'h': $s .= '%I'; break; case 'i': $s .= '%i'; break; case 's': $s .= '%s'; break; case 'a': case 'A': $s .= '%p'; break; case 'w': $s .= '%w'; break; case 'l': $s .= '%W'; break; default: if ($ch == '\\') { $i++; $ch = substr($fmt,$i,1); } $s .= $ch; break; } } $s.="')"; if ($concat) $s = "CONCAT($s)"; return $s; }
< // returns concatenated string < // much easier to run "mysqld --ansi" or "mysqld --sql-mode=PIPES_AS_CONCAT" and use || operator
> /** > * Returns a database-specific concatenation of strings. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:concat > * > * @return string > */
function Concat() {
< $s = "";
$arr = func_get_args(); // suggestion by andrew005@mnogo.ru $s = implode(',',$arr); if (strlen($s) > 0) return "CONCAT($s)"; else return ''; }
< // dayFraction is a day in floating point
> /** > * Creates a portable date offset field, for use in SQL statements. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:offsetdate > * > * @param float $dayFraction A day in floating point > * @param string|bool $date (Optional) The date to offset. If false, uses CURDATE() > * > * @return string > */
function OffsetDate($dayFraction,$date=false) { if (!$date) $date = $this->sysDate; $fraction = $dayFraction * 24 * 3600; return $date . ' + INTERVAL ' . $fraction.' SECOND'; // return "from_unixtime(unix_timestamp($date)+$fraction)"; }
> /** function MetaProcedures($NamePattern = false, $catalog = null, $schemaPattern = null) > * Returns information about stored procedures and stored functions. { > * // save old fetch mode > * @param string|bool $NamePattern (Optional) Only look for procedures/functions with a name matching this pattern. global $ADODB_FETCH_MODE; > * @param null $catalog (Optional) Unused. > * @param null $schemaPattern (Optional) Unused. $false = false; > * $save = $ADODB_FETCH_MODE; > * @return array $ADODB_FETCH_MODE = ADODB_FETCH_NUM; > */
< $false = false;
if ($this->fetchMode !== FALSE) {
< $savem = $this->SetFetchMode(FALSE);
> $savem = $this->setFetchMode(FALSE);
} $procedures = array (); // get index details $likepattern = ''; if ($NamePattern) { $likepattern = " LIKE '".$NamePattern."'"; }
< $rs = $this->Execute('SHOW PROCEDURE STATUS'.$likepattern);
> $rs = $this->execute('SHOW PROCEDURE STATUS'.$likepattern);
if (is_object($rs)) { // parse index data into array
< while ($row = $rs->FetchRow()) {
> while ($row = $rs->fetchRow()) {
$procedures[$row[1]] = array( 'type' => 'PROCEDURE', 'catalog' => '', 'schema' => '', 'remarks' => $row[7], ); } }
< $rs = $this->Execute('SHOW FUNCTION STATUS'.$likepattern);
> $rs = $this->execute('SHOW FUNCTION STATUS'.$likepattern);
if (is_object($rs)) { // parse index data into array
< while ($row = $rs->FetchRow()) {
> while ($row = $rs->fetchRow()) {
$procedures[$row[1]] = array( 'type' => 'FUNCTION', 'catalog' => '', 'schema' => '', 'remarks' => $row[7] ); } } // restore fetchmode if (isset($savem)) {
< $this->SetFetchMode($savem);
> $this->setFetchMode($savem);
} $ADODB_FETCH_MODE = $save; return $procedures; } /** * Retrieves a list of tables based on given criteria *
< * @param string $ttype Table type = 'TABLE', 'VIEW' or false=both (default) < * @param string $showSchema schema name, false = current schema (default) < * @param string $mask filters the table by name
> * @param string|bool $ttype (Optional) Table type = 'TABLE', 'VIEW' or false=both (default) > * @param string|bool $showSchema (Optional) schema name, false = current schema (default) > * @param string|bool $mask (Optional) filters the table by name
* * @return array list of tables */ function MetaTables($ttype=false,$showSchema=false,$mask=false) { $save = $this->metaTablesSQL; if ($showSchema && is_string($showSchema)) { $this->metaTablesSQL .= $this->qstr($showSchema); } else { $this->metaTablesSQL .= "schema()"; } if ($mask) { $mask = $this->qstr($mask); $this->metaTablesSQL .= " AND table_name LIKE $mask"; }
< $ret = ADOConnection::MetaTables($ttype,$showSchema);
> $ret = ADOConnection::metaTables($ttype,$showSchema);
$this->metaTablesSQL = $save; return $ret; }
< // "Innox - Juan Carlos Gonzalez" <jgonzalez#innox.com.mx> < function MetaForeignKeys( $table, $owner = FALSE, $upper = FALSE, $associative = FALSE )
> /** > * Return information about a table's foreign keys. > * > * @param string $table The name of the table to get the foreign keys for. > * @param string|bool $owner (Optional) The database the table belongs to, or false to assume the current db. > * @param string|bool $upper (Optional) Force uppercase table name on returned array keys. > * @param bool $associative (Optional) Whether to return an associate or numeric array. > * > * @return array|bool An array of foreign keys, or false no foreign keys could be found. > */ > function MetaForeignKeys($table, $owner = false, $upper = false, $associative = false)
{
>
global $ADODB_FETCH_MODE;
< if ($ADODB_FETCH_MODE == ADODB_FETCH_ASSOC || $this->fetchMode == ADODB_FETCH_ASSOC) $associative = true;
> if ($ADODB_FETCH_MODE == ADODB_FETCH_ASSOC > || $this->fetchMode == ADODB_FETCH_ASSOC) > $associative = true; > > $savem = $ADODB_FETCH_MODE; > $this->setFetchMode(ADODB_FETCH_ASSOC);
if ( !empty($owner) ) { $table = "$owner.$table"; }
>
$a_create_table = $this->getRow(sprintf('SHOW CREATE TABLE %s', $table));
< if ($associative) {
> > $this->setFetchMode($savem); >
$create_sql = isset($a_create_table["Create Table"]) ? $a_create_table["Create Table"] : $a_create_table["Create View"];
< } else $create_sql = $a_create_table[1];
$matches = array(); if (!preg_match_all("/FOREIGN KEY \(`(.*?)`\) REFERENCES `(.*?)` \(`(.*?)`\)/", $create_sql, $matches)) return false; $foreign_keys = array(); $num_keys = count($matches[0]); for ( $i = 0; $i < $num_keys; $i ++ ) { $my_field = explode('`, `', $matches[1][$i]); $ref_table = $matches[2][$i]; $ref_field = explode('`, `', $matches[3][$i]); if ( $upper ) { $ref_table = strtoupper($ref_table); } // see https://sourceforge.net/p/adodb/bugs/100/ if (!isset($foreign_keys[$ref_table])) { $foreign_keys[$ref_table] = array(); } $num_fields = count($my_field); for ( $j = 0; $j < $num_fields; $j ++ ) { if ( $associative ) { $foreign_keys[$ref_table][$ref_field[$j]] = $my_field[$j]; } else { $foreign_keys[$ref_table][] = "{$my_field[$j]}={$ref_field[$j]}"; } } } return $foreign_keys; }
> /** function MetaColumns($table, $normalize=true) > * Return an array of information about a table's columns. { > * $false = false; > * @param string $table The name of the table to get the column info for. if (!$this->metaColumnsSQL) > * @param bool $normalize (Optional) Unused. return $false; > * > * @return ADOFieldObject[]|bool An array of info for each column, or false if it could not determine the info. global $ADODB_FETCH_MODE; > */
$save = $ADODB_FETCH_MODE; $ADODB_FETCH_MODE = ADODB_FETCH_NUM; if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
> /* $rs = $this->Execute(sprintf($this->metaColumnsSQL,$table)); > * Return assoc array where key is column name, value is column type if (isset($savem)) $this->SetFetchMode($savem); > * [1] => int unsigned $ADODB_FETCH_MODE = $save; > */ if (!is_object($rs)) > return $false; > $SQL = "SELECT column_name, column_type > FROM information_schema.columns $retarr = array(); > WHERE table_schema='{$this->databaseName}' while (!$rs->EOF) { > AND table_name='$table'"; $fld = new ADOFieldObject(); > $fld->name = $rs->fields[0]; > $schemaArray = $this->getAssoc($SQL); $type = $rs->fields[1]; > $schemaArray = array_change_key_case($schemaArray,CASE_LOWER); >
// split type into type(length):
> /* $fld->scale = null; > * Type from information_schema returns if (preg_match("/^(.+)\((\d+),(\d+)/", $type, $query_array)) { > * the same format in V8 mysql as V5 $fld->type = $query_array[1]; > */ $fld->max_length = is_numeric($query_array[2]) ? $query_array[2] : -1; > $type = $schemaArray[strtolower($fld->name)]; $fld->scale = is_numeric($query_array[3]) ? $query_array[3] : -1; >
} elseif (preg_match("/^(.+)\((\d+)/", $type, $query_array)) { $fld->type = $query_array[1]; $fld->max_length = is_numeric($query_array[2]) ? $query_array[2] : -1; } elseif (preg_match("/^(enum)\((.*)\)$/i", $type, $query_array)) { $fld->type = $query_array[1]; $arr = explode(",",$query_array[2]); $fld->enums = $arr; $zlen = max(array_map("strlen",$arr)) - 2; // PHP >= 4.0.6 $fld->max_length = ($zlen > 0) ? $zlen : 1; } else { $fld->type = $type; $fld->max_length = -1; }
>
$fld->not_null = ($rs->fields[2] != 'YES'); $fld->primary_key = ($rs->fields[3] == 'PRI'); $fld->auto_increment = (strpos($rs->fields[5], 'auto_increment') !== false); $fld->binary = (strpos($type,'blob') !== false); $fld->unsigned = (strpos($type,'unsigned') !== false); $fld->zerofill = (strpos($type,'zerofill') !== false); if (!$fld->binary) { $d = $rs->fields[4]; if ($d != '' && $d != 'NULL') { $fld->has_default = true; $fld->default_value = $d; } else { $fld->has_default = false; } } if ($save == ADODB_FETCH_NUM) { $retarr[] = $fld; } else { $retarr[strtoupper($fld->name)] = $fld; }
< $rs->MoveNext();
> $rs->moveNext();
}
< $rs->Close();
> $rs->close();
return $retarr; }
< // returns true or false
> /** > * Select which database to connect to. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:selectdb > * > * @param string $dbName The name of the database to select. > * > * @return bool True if the database was selected successfully, otherwise false. > */
function SelectDB($dbName) { // $this->_connectionID = $this->mysqli_resolve_link($this->_connectionID); $this->database = $dbName; $this->databaseName = $dbName; # obsolete, retained for compat with older adodb versions if ($this->_connectionID) { $result = @mysqli_select_db($this->_connectionID, $dbName); if (!$result) {
< ADOConnection::outp("Select of database " . $dbName . " failed. " . $this->ErrorMsg());
> ADOConnection::outp("Select of database " . $dbName . " failed. " . $this->errorMsg());
} return $result; } return false; }
< // parameters use PostgreSQL convention, not MySQL
> /** > * Executes a provided SQL statement and returns a handle to the result, with the ability to supply a starting > * offset and record count. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:selectlimit > * > * @param string $sql The SQL to execute. > * @param int $nrows (Optional) The limit for the number of records you want returned. By default, all results. > * @param int $offset (Optional) The offset to use when selecting the results. By default, no offset. > * @param array|bool $inputarr (Optional) Any parameter values required by the SQL statement, or false if none. > * @param int $secs (Optional) If greater than 0, perform a cached execute. By default, normal execution. > * > * @return ADORecordSet|false The query results, or false if the query failed to execute. > */
function SelectLimit($sql, $nrows = -1, $offset = -1, $inputarr = false, $secs = 0) { $nrows = (int) $nrows; $offset = (int) $offset; $offsetStr = ($offset >= 0) ? "$offset," : ''; if ($nrows < 0) $nrows = '18446744073709551615'; if ($secs)
< $rs = $this->CacheExecute($secs, $sql . " LIMIT $offsetStr$nrows" , $inputarr );
> $rs = $this->cacheExecute($secs, $sql . " LIMIT $offsetStr$nrows" , $inputarr );
else
< $rs = $this->Execute($sql . " LIMIT $offsetStr$nrows" , $inputarr );
> $rs = $this->execute($sql . " LIMIT $offsetStr$nrows" , $inputarr );
return $rs; }
<
> /** > * Prepares an SQL statement and returns a handle to use. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:prepare > * @todo update this function to handle prepared statements correctly > * > * @param string $sql The SQL to prepare. > * > * @return string The original SQL that was provided. > */
function Prepare($sql) {
> /* return $sql; > * Flag the insert_id method to use the correct retrieval method $stmt = $this->_connectionID->prepare($sql); > */ if (!$stmt) { > $this->usePreparedStatement = true; echo $this->ErrorMsg(); > return $sql; > /* } > * Prepared statements are not yet handled correctly return array($sql,$stmt); > */
< echo $this->ErrorMsg();
> echo $this->errorMsg();
< < // returns queryID or false
> /** > * Return the query id. > * > * @param string|array $sql > * @param array $inputarr > * > * @return bool|mysqli_result > */
function _query($sql, $inputarr) { global $ADODB_COUNTRECS; // Move to the next recordset, or return false if there is none. In a stored proc // call, mysqli_next_result returns true for the last "recordset", but mysqli_store_result // returns false. I think this is because the last "recordset" is actually just the // return value of the stored proc (ie the number of rows affected). // Commented out for reasons of performance. You should retrieve every recordset yourself. // if (!mysqli_next_result($this->connection->_connectionID)) return false; if (is_array($sql)) { // Prepare() not supported because mysqli_stmt_execute does not return a recordset, but // returns as bound variables. $stmt = $sql[1]; $a = ''; foreach($inputarr as $k => $v) { if (is_string($v)) $a .= 's'; else if (is_integer($v)) $a .= 'i'; else $a .= 'd'; }
> /* $fnarr = array_merge( array($stmt,$a) , $inputarr); > * set prepared statement flags $ret = call_user_func_array('mysqli_stmt_bind_param',$fnarr); > */ $ret = mysqli_stmt_execute($stmt); > if ($this->usePreparedStatement) return $ret; > $this->useLastInsertStatement = true; } >
< $ret = call_user_func_array('mysqli_stmt_bind_param',$fnarr);
> call_user_func_array('mysqli_stmt_bind_param',$fnarr);
/*
> else if (!$mysql_res = mysqli_query($this->_connectionID, $sql, ($ADODB_COUNTRECS) ? MYSQLI_STORE_RESULT : MYSQLI_USE_RESULT)) { > { if ($this->debug) ADOConnection::outp("Query: " . $sql . " failed. " . $this->ErrorMsg()); > /* return false; > * reset prepared statement flags, in case we set them } > * previously and didn't use them > */ return $mysql_res; > $this->usePreparedStatement = false; */ > $this->useLastInsertStatement = false; > }
< if ($this->debug) ADOConnection::outp("Query: " . $sql . " failed. " . $this->ErrorMsg());
> if ($this->debug) ADOConnection::outp("Query: " . $sql . " failed. " . $this->errorMsg());
$rs = mysqli_multi_query($this->_connectionID, $sql.';'); if ($rs) { $rs = ($ADODB_COUNTRECS) ? @mysqli_store_result( $this->_connectionID ) : @mysqli_use_result( $this->_connectionID ); return $rs ? $rs : true; // mysqli_more_results( $this->_connectionID ) } } else { $rs = mysqli_query($this->_connectionID, $sql, $ADODB_COUNTRECS ? MYSQLI_STORE_RESULT : MYSQLI_USE_RESULT);
< < if ($rs) return $rs;
> if ($rs) { > $this->isSelectStatement = is_object($rs); > return $rs; > }
} if($this->debug)
< ADOConnection::outp("Query: " . $sql . " failed. " . $this->ErrorMsg());
> ADOConnection::outp("Query: " . $sql . " failed. " . $this->errorMsg());
return false; }
< /* Returns: the last error message from previous database operation */
> /** > * Returns a database specific error message. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:errormsg > * > * @return string The last error message. > */
function ErrorMsg() { if (empty($this->_connectionID)) $this->_errorMsg = @mysqli_connect_error(); else $this->_errorMsg = @mysqli_error($this->_connectionID); return $this->_errorMsg; }
< /* Returns: the last error number from previous database operation */
> /** > * Returns the last error number from previous database operation. > * > * @return int The last error number. > */
function ErrorNo() { if (empty($this->_connectionID)) return @mysqli_connect_errno(); else return @mysqli_errno($this->_connectionID); }
< // returns true or false
> /** > * Close the database connection. > * > * @return void > */
function _close() {
< @mysqli_close($this->_connectionID);
> if($this->_connectionID) { > mysqli_close($this->_connectionID); > }
$this->_connectionID = false; }
< /* < * Maximum size of C field
> /** > * Returns the largest length of data that can be inserted into a character field. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:charmax > * > * @return int
*/ function CharMax() { return 255; }
< /* < * Maximum size of X field
> /** > * Returns the largest length of data that can be inserted into a text field. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:textmax > * > * @return int
*/ function TextMax() { return 4294967295; }
< < // 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 UTF8 database and server it on-site as latin1 etc. < // GetCharSet - get the name of the character set the client is using now < // Under Windows, the functions should work with MySQL 4.1.11 and above, the set of charsets supported < // depends on compile flags of mysql distribution < < function GetCharSet()
> function getCharSet()
{
< //we will use ADO's builtin property charSet < if (!method_exists($this->_connectionID,'character_set_name'))
> if (!$this->_connectionID || !method_exists($this->_connectionID,'character_set_name')) {
return false;
< < $this->charSet = @$this->_connectionID->character_set_name(); < if (!$this->charSet) { < return false; < } else { < return $this->charSet;
}
> } > $this->charSet = $this->_connectionID->character_set_name(); > return $this->charSet ?: false;
< // SetCharSet - switch the client encoding < function SetCharSet($charset_name)
> function setCharSet($charset)
{
< if (!method_exists($this->_connectionID,'set_charset')) {
> if (!$this->_connectionID || !method_exists($this->_connectionID,'set_charset')) {
return false; }
< if ($this->charSet !== $charset_name) { < $if = @$this->_connectionID->set_charset($charset_name); < return ($if === true & $this->GetCharSet() == $charset_name); < } else { < return true;
> if ($this->charSet !== $charset) { > if (!$this->_connectionID->set_charset($charset)) { > return false;
}
> $this->getCharSet();
}
<
> return true;
}
< /*-------------------------------------------------------------------------------------- < Class Name: Recordset < --------------------------------------------------------------------------------------*/
> }
> /** class ADORecordSet_mysqli extends ADORecordSet{ > * Class ADORecordSet_mysqli > */
var $databaseType = "mysqli"; var $canSeek = true; function __construct($queryID, $mode = false) { if ($mode === false) { global $ADODB_FETCH_MODE; $mode = $ADODB_FETCH_MODE; } switch ($mode) { case ADODB_FETCH_NUM: $this->fetchMode = MYSQLI_NUM; break; case ADODB_FETCH_ASSOC: $this->fetchMode = MYSQLI_ASSOC; break; case ADODB_FETCH_DEFAULT: case ADODB_FETCH_BOTH: default: $this->fetchMode = MYSQLI_BOTH; break; } $this->adodbFetchMode = $mode; parent::__construct($queryID); } function _initrs() { global $ADODB_COUNTRECS; $this->_numOfRows = $ADODB_COUNTRECS ? @mysqli_num_rows($this->_queryID) : -1; $this->_numOfFields = @mysqli_num_fields($this->_queryID); } /* 1 = MYSQLI_NOT_NULL_FLAG 2 = MYSQLI_PRI_KEY_FLAG 4 = MYSQLI_UNIQUE_KEY_FLAG 8 = MYSQLI_MULTIPLE_KEY_FLAG 16 = MYSQLI_BLOB_FLAG 32 = MYSQLI_UNSIGNED_FLAG 64 = MYSQLI_ZEROFILL_FLAG 128 = MYSQLI_BINARY_FLAG 256 = MYSQLI_ENUM_FLAG 512 = MYSQLI_AUTO_INCREMENT_FLAG 1024 = MYSQLI_TIMESTAMP_FLAG 2048 = MYSQLI_SET_FLAG 32768 = MYSQLI_NUM_FLAG 16384 = MYSQLI_PART_KEY_FLAG 32768 = MYSQLI_GROUP_FLAG 65536 = MYSQLI_UNIQUE_FLAG 131072 = MYSQLI_BINCMP_FLAG */
> /** function FetchField($fieldOffset = -1) > * Returns raw, database specific information about a field. { > * $fieldnr = $fieldOffset; > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:recordset:fetchfield if ($fieldOffset != -1) { > * $fieldOffset = @mysqli_field_seek($this->_queryID, $fieldnr); > * @param int $fieldOffset (Optional) The field number to get information for. } > * $o = @mysqli_fetch_field($this->_queryID); > * @return ADOFieldObject|bool if (!$o) return false; > */
//Fix for HHVM if ( !isset($o->flags) ) { $o->flags = 0; } /* Properties of an ADOFieldObject as set by MetaColumns */ $o->primary_key = $o->flags & MYSQLI_PRI_KEY_FLAG; $o->not_null = $o->flags & MYSQLI_NOT_NULL_FLAG; $o->auto_increment = $o->flags & MYSQLI_AUTO_INCREMENT_FLAG; $o->binary = $o->flags & MYSQLI_BINARY_FLAG; // $o->blob = $o->flags & MYSQLI_BLOB_FLAG; /* not returned by MetaColumns */ $o->unsigned = $o->flags & MYSQLI_UNSIGNED_FLAG;
< return $o;
> /* > * Trivial method to cast class to ADOfieldObject > */ > $a = new ADOFieldObject; > foreach (get_object_vars($o) as $key => $name) > $a->$key = $name; > return $a;
}
> /** function GetRowAssoc($upper = ADODB_ASSOC_CASE) > * Reads a row in associative mode if the recordset fetch mode is numeric. { > * Using this function when the fetch mode is set to ADODB_FETCH_ASSOC may produce unpredictable results. if ($this->fetchMode == MYSQLI_ASSOC && $upper == ADODB_ASSOC_CASE_LOWER) { > * return $this->fields; > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:getrowassoc } > * $row = ADORecordSet::GetRowAssoc($upper); > * @param int $upper Indicates whether the keys of the recordset should be upper case or lower case. return $row; > * } > * @return array|bool > */
< $row = ADORecordSet::GetRowAssoc($upper);
> $row = ADORecordSet::getRowAssoc($upper);
< /* Use associative array to get fields array */
> /** > * Returns a single field in a single row of the current recordset. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:recordset:fields > * > * @param string $colname The name of the field to retrieve. > * > * @return mixed > */
{ if ($this->fetchMode != MYSQLI_NUM) { return @$this->fields[$colname]; } if (!$this->bind) { $this->bind = array(); for ($i = 0; $i < $this->_numOfFields; $i++) {
< $o = $this->FetchField($i);
> $o = $this->fetchField($i);
$this->bind[strtoupper($o->name)] = $i; } } return $this->fields[$this->bind[strtoupper($colname)]]; }
> /** function _seek($row) > * Adjusts the result pointer to an arbitrary row in the result. { > * if ($this->_numOfRows == 0 || $row < 0) { > * @param int $row The row to seek to. return false; > * } > * @return bool False if the recordset contains no rows, otherwise true. > */
mysqli_data_seek($this->_queryID, $row); $this->EOF = false; return true; }
<
> /** > * In databases that allow accessing of recordsets, retrieves the next set. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:recordset:nextrecordset > * > * @return bool > */
function NextRecordSet() { global $ADODB_COUNTRECS; mysqli_free_result($this->_queryID); $this->_queryID = -1; // Move to the next recordset, or return false if there is none. In a stored proc // call, mysqli_next_result returns true for the last "recordset", but mysqli_store_result // returns false. I think this is because the last "recordset" is actually just the // return value of the stored proc (ie the number of rows affected). if(!mysqli_next_result($this->connection->_connectionID)) { return false; }
>
// CD: There is no $this->_connectionID variable, at least in the ADO version I'm using $this->_queryID = ($ADODB_COUNTRECS) ? @mysqli_store_result( $this->connection->_connectionID ) : @mysqli_use_result( $this->connection->_connectionID );
>
if(!$this->_queryID) { return false; }
>
$this->_inited = false; $this->bind = false; $this->_currentRow = -1;
< $this->Init();
> $this->init();
return true; }
< // 10% speedup to move MoveNext to child class < // This is the only implementation that works now (23-10-2003). < // Other functions return no or the wrong results.
> /** > * Moves the cursor to the next record of the recordset from the current position. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:movenext > * > * @return bool False if there are no more records to move on to, otherwise true. > */
function MoveNext() { if ($this->EOF) return false; $this->_currentRow++; $this->fields = @mysqli_fetch_array($this->_queryID,$this->fetchMode); if (is_array($this->fields)) { $this->_updatefields(); return true; } $this->EOF = true; return false; }
> /** function _fetch() > * Attempt to fetch a result row using the current fetch mode and return whether or not this was successful. { > * $this->fields = mysqli_fetch_array($this->_queryID,$this->fetchMode); > * @return bool True if row was fetched successfully, otherwise false. $this->_updatefields(); > */
return is_array($this->fields); }
> /** function _close() > * Frees the memory associated with a result. { > * //if results are attached to this pointer from Stored Proceedure calls, the next standard query will die 2014 > * @return void //only a problem with persistant connections > */
< //if results are attached to this pointer from Stored Proceedure calls, the next standard query will die 2014 < //only a problem with persistant connections
> //if results are attached to this pointer from Stored Procedure calls, the next standard query will die 2014 > //only a problem with persistent connections
while(mysqli_more_results($this->connection->_connectionID)){ mysqli_next_result($this->connection->_connectionID); } } if($this->_queryID instanceof mysqli_result) { mysqli_free_result($this->_queryID); } $this->_queryID = false; } /* 0 = MYSQLI_TYPE_DECIMAL 1 = MYSQLI_TYPE_CHAR 1 = MYSQLI_TYPE_TINY 2 = MYSQLI_TYPE_SHORT 3 = MYSQLI_TYPE_LONG 4 = MYSQLI_TYPE_FLOAT 5 = MYSQLI_TYPE_DOUBLE 6 = MYSQLI_TYPE_NULL 7 = MYSQLI_TYPE_TIMESTAMP 8 = MYSQLI_TYPE_LONGLONG 9 = MYSQLI_TYPE_INT24 10 = MYSQLI_TYPE_DATE 11 = MYSQLI_TYPE_TIME 12 = MYSQLI_TYPE_DATETIME 13 = MYSQLI_TYPE_YEAR 14 = MYSQLI_TYPE_NEWDATE 247 = MYSQLI_TYPE_ENUM 248 = MYSQLI_TYPE_SET 249 = MYSQLI_TYPE_TINY_BLOB 250 = MYSQLI_TYPE_MEDIUM_BLOB 251 = MYSQLI_TYPE_LONG_BLOB 252 = MYSQLI_TYPE_BLOB 253 = MYSQLI_TYPE_VAR_STRING 254 = MYSQLI_TYPE_STRING 255 = MYSQLI_TYPE_GEOMETRY */
> /** function MetaType($t, $len = -1, $fieldobj = false) > * Get the MetaType character for a given field type. { > * if (is_object($t)) { > * @param string|object $t The type to get the MetaType character for. $fieldobj = $t; > * @param int $len (Optional) Redundant. Will always be set to -1. $t = $fieldobj->type; > * @param bool|object $fieldobj (Optional) $len = $fieldobj->max_length; > * } > * @return string The MetaType > */
<
$len = -1; // mysql max_length is not accurate switch (strtoupper($t)) { case 'STRING': case 'CHAR': case 'VARCHAR': case 'TINYBLOB': case 'TINYTEXT': case 'ENUM': case 'SET': case MYSQLI_TYPE_TINY_BLOB :
< #case MYSQLI_TYPE_CHAR :
> // case MYSQLI_TYPE_CHAR :
case MYSQLI_TYPE_STRING : case MYSQLI_TYPE_ENUM : case MYSQLI_TYPE_SET : case 253 :
< if ($len <= $this->blobSize) return 'C';
> if ($len <= $this->blobSize) { > return 'C'; > }
case 'TEXT': case 'LONGTEXT': case 'MEDIUMTEXT': return 'X'; // php_mysql extension always returns 'blob' even if 'text' // so we have to check whether binary... case 'IMAGE': case 'LONGBLOB': case 'BLOB': case 'MEDIUMBLOB': case MYSQLI_TYPE_BLOB : case MYSQLI_TYPE_LONG_BLOB : case MYSQLI_TYPE_MEDIUM_BLOB : return !empty($fieldobj->binary) ? 'B' : 'X'; case 'YEAR': case 'DATE': case MYSQLI_TYPE_DATE : case MYSQLI_TYPE_YEAR : return 'D'; case 'TIME': case 'DATETIME': case 'TIMESTAMP': case MYSQLI_TYPE_DATETIME : case MYSQLI_TYPE_NEWDATE : case MYSQLI_TYPE_TIME : case MYSQLI_TYPE_TIMESTAMP : return 'T'; case 'INT': case 'INTEGER': case 'BIGINT': case 'TINYINT': case 'MEDIUMINT': case 'SMALLINT': case MYSQLI_TYPE_INT24 : case MYSQLI_TYPE_LONG : case MYSQLI_TYPE_LONGLONG : case MYSQLI_TYPE_SHORT : case MYSQLI_TYPE_TINY :
< if (!empty($fieldobj->primary_key)) return 'R';
> if (!empty($fieldobj->primary_key)) { > return 'R'; > }
return 'I'; // Added floating-point types
< // Maybe not necessery.
> // Maybe not necessary.
case 'FLOAT': case 'DOUBLE': // case 'DOUBLE PRECISION': case 'DECIMAL': case 'DEC': case 'FIXED': default: //if (!is_numeric($t)) echo "<p>--- Error in type matching $t -----</p>"; return 'N'; }
< } // function
> }
} // rs class
< } < < class ADORecordSet_array_mysqli extends ADORecordSet_array { < < function __construct($id=-1,$mode=false)
> /** > * Class ADORecordSet_array_mysqli > */ > class ADORecordSet_array_mysqli extends ADORecordSet_array
{
< parent::__construct($id,$mode); < } <
> /** > * Get the MetaType character for a given field type. > * > * @param string|object $t The type to get the MetaType character for. > * @param int $len (Optional) Redundant. Will always be set to -1. > * @param bool|object $fieldobj (Optional) > * > * @return string The MetaType > */
function MetaType($t, $len = -1, $fieldobj = false) { if (is_object($t)) { $fieldobj = $t; $t = $fieldobj->type; $len = $fieldobj->max_length; }
<
$len = -1; // mysql max_length is not accurate switch (strtoupper($t)) { case 'STRING': case 'CHAR': case 'VARCHAR': case 'TINYBLOB': case 'TINYTEXT': case 'ENUM': case 'SET': case MYSQLI_TYPE_TINY_BLOB :
< #case MYSQLI_TYPE_CHAR :
> // case MYSQLI_TYPE_CHAR :
case MYSQLI_TYPE_STRING : case MYSQLI_TYPE_ENUM : case MYSQLI_TYPE_SET : case 253 :
< if ($len <= $this->blobSize) return 'C';
> if ($len <= $this->blobSize) { > return 'C'; > }
case 'TEXT': case 'LONGTEXT': case 'MEDIUMTEXT': return 'X'; // php_mysql extension always returns 'blob' even if 'text' // so we have to check whether binary... case 'IMAGE': case 'LONGBLOB': case 'BLOB': case 'MEDIUMBLOB': case MYSQLI_TYPE_BLOB : case MYSQLI_TYPE_LONG_BLOB : case MYSQLI_TYPE_MEDIUM_BLOB :
<
return !empty($fieldobj->binary) ? 'B' : 'X';
>
case 'YEAR': case 'DATE': case MYSQLI_TYPE_DATE : case MYSQLI_TYPE_YEAR :
<
return 'D'; case 'TIME': case 'DATETIME': case 'TIMESTAMP': case MYSQLI_TYPE_DATETIME : case MYSQLI_TYPE_NEWDATE : case MYSQLI_TYPE_TIME : case MYSQLI_TYPE_TIMESTAMP :
<
return 'T'; case 'INT': case 'INTEGER': case 'BIGINT': case 'TINYINT': case 'MEDIUMINT': case 'SMALLINT': case MYSQLI_TYPE_INT24 : case MYSQLI_TYPE_LONG : case MYSQLI_TYPE_LONGLONG : case MYSQLI_TYPE_SHORT : case MYSQLI_TYPE_TINY :
< < if (!empty($fieldobj->primary_key)) return 'R'; <
> if (!empty($fieldobj->primary_key)) { > return 'R'; > }
return 'I';
<
// Added floating-point types
< // Maybe not necessery.
> // Maybe not necessary.
case 'FLOAT': case 'DOUBLE': // case 'DOUBLE PRECISION': case 'DECIMAL': case 'DEC': case 'FIXED': default: //if (!is_numeric($t)) echo "<p>--- Error in type matching $t -----</p>"; return 'N'; }
< } // function <
}
> } > > } // if defined _ADODB_MYSQLI_LAYER