Search moodle.org's
Developer Documentation
Developer Documentation
- 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.
/lib/adodb/drivers/ -> adodb-mysqli.inc.php (source)
<?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;< function __construct()> /** @var mysqli Identifier for the native database connection */ > var $_connectionID = false; > > /** > * Tells the insert_id method how to obtain the last value, depending on whether > * we are using a stored procedure or not > */ > private $usePreparedStatement = false; > private $useLastInsertStatement = false; > private $usingBoundVariables = false; > private $statementAffectedRows = -1; > > /** > * @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);function SetTransactionMode( $transaction_mode )> { > /** $this->_transmode = $transaction_mode; > * Sets the isolation level of a transaction. if (empty($transaction_mode)) { > * $this->Execute('SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ'); > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:settransactionmode return; > * } > * @param string $transaction_mode The transaction mode to set. if (!stristr($transaction_mode,'isolation')) $transaction_mode = 'ISOLATION LEVEL '.$transaction_mode; > * $this->Execute("SET SESSION TRANSACTION ".$transaction_mode); > * @return void } > */< $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);< // returns true or false < // To add: parameter int $port, < // parameter string $socket < function _connect($argHostname = NULL, < $argUsername = NULL, < $argPassword = NULL, < $argDatabasename = NULL, $persist=false)> /** > * Adds a parameter to the connection string. > * > * Parameter must be one of 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 > * > * @return bool > */ > public function setConnectionParameter($parameter, $value) { > if(!is_numeric($parameter)) { > $this->outp_throw("Invalid connection parameter '$parameter'", __METHOD__); > return false; > } > return parent::setConnectionParameter($parameter, $value); > } > > /** > * 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(!extension_loaded("mysqli")) { return null; } $this->_connectionID = @mysqli_init(); if (is_null($this->_connectionID)) { // mysqli_init only fails if insufficient memory 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 $options) { > foreach ($options as $parameter => $value) { > // Make sure parameter is numeric before calling mysqli_options() > // 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); > $this->socket = MYSQLI_CLIENT_SSL; > $this->clientFlags = MYSQLI_CLIENT_SSL_DONT_VERIFY_SERVER_CERT; > }#if (!empty($this->port)) $argHostname .= ":".$this->port;> /** @noinspection PhpCastIsUnnecessaryInspection */$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? < function _nconnect($argHostname, $argUsername, $argPassword, $argDatabasename)> /** > * 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);> 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. > * > * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:rowlock > * > * @param string $table The table(s) to lock rows for. > * @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. > */ > function RowLock($table, $where = '', $col = '1 as adodbignore'){< if ($this->transCnt==0) $this->BeginTrans();> if ($this->transCnt==0) $this->beginTrans();if ($where) $where = ' where '.$where;< $rs = $this->Execute("select $col from $tables $where for update");> $rs = $this->execute("select $col from $table $where for update");return !empty($rs); } /**< * 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 string $s The string to quote< * @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. > ** @return string Quoted string */< 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()'); } > elsereturn $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; > } } > else if ($this->statementAffectedRows >= 0) > { // See http://www.mysql.com/doc/M/i/Miscellaneous_functions.html > $result = $this->statementAffectedRows; // Reference on Last_Insert_ID on the recommended way to simulate sequences > $this->statementAffectedRows = -1; var $_genIDSQL = "update %s set id=LAST_INSERT_ID(id+1);"; > } var $_genSeqSQL = "create table if not exists %s (id int not null)"; > else var $_genSeqCountSQL = "select count(*) from %s"; > {< 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> /** 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;> 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 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. > * > * @param string|bool $procedureNamePattern (Optional) Only look for procedures/functions with a name matching this pattern. > * @param null $catalog (Optional) Unused. > * @param null $schemaPattern (Optional) Unused. > * > * @return array > */ > function MetaProcedures($procedureNamePattern = false, $catalog = null, $schemaPattern = null){ // 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);} $procedures = array (); // get index details $likepattern = '';< if ($NamePattern) { < $likepattern = " LIKE '".$NamePattern."'";> if ($procedureNamePattern) { > $likepattern = " LIKE '".$procedureNamePattern."'";}< $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. > */ > public function metaForeignKeys($table, $owner = '', $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) {> > $a_create_table = $this->getRow(sprintf('SHOW CREATE TABLE `%s`', $table)); > > $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); >< $type = $rs->fields[1];> > /* > * Type from information_schema returns > * the same format in V8 mysql as V5 > */ > $type = $schemaArray[strtolower($fld->name)];$fld->scale = null; if (preg_match("/^(.+)\((\d+),(\d+)/", $type, $query_array)) { $fld->type = $query_array[1]; $fld->max_length = is_numeric($query_array[2]) ? $query_array[2] : -1; $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 $secs2cache (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)> $secs2cache = 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 );> if ($secs2cache) > $rs = $this->cacheExecute($secs2cache, $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. > * This is not used by bound parameters anymore > * > * @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();> /** > * Execute SQL // returns queryID or false > * function _query($sql, $inputarr) > * @param string $sql SQL statement to execute, or possibly an array { > * holding prepared statement ($sql[0] will hold sql text) global $ADODB_COUNTRECS; > * @param array|bool $inputarr holds the input data to bind to. // Move to the next recordset, or return false if there is none. In a stored proc > * Null elements will be set to null. // 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 ADORecordSet|bool // return value of the stored proc (ie the number of rows affected). > */ // Commented out for reasons of performance. You should retrieve every recordset yourself. > public function execute($sql, $inputarr = false) // if (!mysqli_next_result($this->connection->_connectionID)) return false; > { > if ($this->fnExecute) { if (is_array($sql)) { > $fn = $this->fnExecute; > $ret = $fn($this, $sql, $inputarr); // Prepare() not supported because mysqli_stmt_execute does not return a recordset, but > if (isset($ret)) { // returns as bound variables. > return $ret; > } $stmt = $sql[1]; > }< // returns queryID or false> if ($inputarr === false || $inputarr === []) { > return $this->_execute($sql); > } > > if (!is_array($inputarr)) { > $inputarr = array($inputarr); > } > > if (!is_array($sql)) { > // Check if we are bulkbinding. If so, $inputarr is a 2d array, > // and we make a gross assumption that all rows have the same number > // of columns of the same type, and use the elements of the first row > // to determine the MySQL bind param types. > if (is_array($inputarr[0])) { > if (!$this->bulkBind) { > $this->outp_throw( > "2D Array of values sent to execute and 'ADOdb_mysqli::bulkBind' not set", > 'Execute' > ); > return false; > } > > $bulkTypeArray = []; > foreach ($inputarr as $v) { > if (is_string($this->bulkBind)) { > $typeArray = array_merge((array)$this->bulkBind, $v); > } else { > $typeArray = $this->getBindParamWithType($v); > } > $bulkTypeArray[] = $typeArray; > } > $this->bulkBind = false; > $ret = $this->_execute($sql, $bulkTypeArray); > } else { > $typeArray = $this->getBindParamWithType($inputarr); > $ret = $this->_execute($sql, $typeArray); > } > } else { > $ret = $this->_execute($sql, $inputarr); > } > return $ret; > } > > /** > * Inserts the bind param type string at the front of the parameter array. > * > * @see https://www.php.net/manual/en/mysqli-stmt.bind-param.php > * > * @param array $inputArr > * @return array > */ > private function getBindParamWithType($inputArr): array > { > $typeString = ''; > foreach ($inputArr as $v) { > if (is_integer($v) || is_bool($v)) { > $typeString .= 'i'; > } elseif (is_float($v)) { > $typeString .= 'd'; > } elseif (is_object($v)) { > // Assume a blob > $typeString .= 'b'; > } else { > $typeString .= 's'; > } > } > > // Place the field type list at the front of the parameter array. > // This is the mysql specific format > array_unshift($inputArr, $typeString); > return $inputArr; > } > > /** > * Return the query id. > * > * @param string|array $sql > * @param array $inputarr > * > * @return bool|mysqli_result > */< foreach($inputarr as $k => $v) {> foreach($inputarr as $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); > return mysqli_stmt_execute($stmt); > } > else if (is_string($sql) && is_array($inputarr)) > { > > /* > * This is support for true prepared queries > * with bound parameters > * > * set prepared statement flags > */ > $this->usePreparedStatement = true; > $this->usingBoundVariables = true; > > $bulkBindArray = array(); > if (is_array($inputarr[0])) > { > $bulkBindArray = $inputarr; > $inputArrayCount = count($inputarr[0]) - 1; > } > else > { > $bulkBindArray[] = $inputarr; > $inputArrayCount = count($inputarr) - 1; > } > > > /* > * Prepare the statement with the placeholders, > * prepare will fail if the statement is invalid > * so we trap and error if necessary. Note that we > * are calling MySQL prepare here, not ADOdb > */ > $stmt = $this->_connectionID->prepare($sql); > if ($stmt === false) > { > $this->outp_throw( > "SQL Statement failed on preparation: " . htmlspecialchars($sql) . "'", > 'Execute' > ); > return false; > } > /* > * Make sure the number of parameters provided in the input > * array matches what the query expects. We must discount > * the first parameter which contains the data types in > * our inbound parameters > */ > $nparams = $stmt->param_count; > > if ($nparams != $inputArrayCount) > { > > $this->outp_throw( > "Input array has " . $inputArrayCount . > " params, does not match query: '" . htmlspecialchars($sql) . "'", > 'Execute' > ); > return false; > } > > foreach ($bulkBindArray as $inputarr) > { > /* > * Must pass references into call_user_func_array > */ > $paramsByReference = array(); > foreach($inputarr as $key => $value) { > /** @noinspection PhpArrayAccessCanBeReplacedWithForeachValueInspection */ > $paramsByReference[$key] = &$inputarr[$key]; > } > > /* > * Bind the params > */ > call_user_func_array(array($stmt, 'bind_param'), $paramsByReference); > > /* > * Execute > */ >< return $ret;> > /* > * Did we throw an error? > */ > if ($ret == false) > return false; > } > > // Tells affected_rows to be compliant > $this->isSelectStatement = $stmt->affected_rows == -1; > if (!$this->isSelectStatement) { > $this->statementAffectedRows = $stmt->affected_rows; > return true; > } > > // Turn the statement into a result set and return it > return $stmt->get_result(); > } > else > { > /* > * reset prepared statement flags, in case we set them > * previously and didn't use them > */ > $this->usePreparedStatement = false; > $this->useLastInsertStatement = false;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());> if ($this->debug) ADOConnection::outp("Query: " . $sql . " failed. " . $this->errorMsg());return false; } return $mysql_res; */ if ($this->multiQuery) { $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 )> return $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;> /** @var ADODB_mysqli The parent connection */ function __construct($queryID, $mode = false) > var $connection = false; { > if ($mode === false) { > /** @var mysqli_result result link identifier */ global $ADODB_FETCH_MODE; > var $_queryID; $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); < return $row;> return 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 connectionswhile(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> 245 = MYSQLI_TYPE_JSON247 = 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. > * > * @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; }> $t = strtoupper($t); > /* $len = -1; // mysql max_length is not accurate > * Add support for custom actual types. We do this switch (strtoupper($t)) { > * first, that allows us to override existing types case 'STRING': > */ case 'CHAR': > if (array_key_exists($t,$this->connection->customActualTypes)) case 'VARCHAR': > return $this->connection->customActualTypes[$t];< switch (strtoupper($t)) {> switch ($t) {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; }> $t = strtoupper($t); > $len = -1; // mysql max_length is not accurate > if (array_key_exists($t,$this->connection->customActualTypes)) switch (strtoupper($t)) { > return $this->connection->customActualTypes[$t];< switch (strtoupper($t)) {> > switch ($t) {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
