Proyectos de Subversion Moodle

<?php

/**

 * 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_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);

/**

 * 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;

	var $ssl_ca = null;

	var $ssl_capath = null;

	var $ssl_cipher = null;

	/**

	 * Forcing emulated prepared statements.

	 *

	 * When set to true, ADODb will not execute queries using MySQLi native

	 * bound variables, and will instead use the built-in string interpolation

	 * and argument quoting from the parent class {@see ADOConnection::Execute()}.

	 *

	 * This is needed for some database engines that use mysql wire-protocol but

	 * do not support prepared statements, like

	 * {@see https://manticoresearch.com/ Manticore Search} or

	 * {@see https://clickhouse.com/ ClickHouse}.

	 *

	 * WARNING: This is a potential security risk, and strongly discouraged for code

	 * handling untrusted input {@see https://github.com/ADOdb/ADOdb/issues/1028#issuecomment-2081586024}.

	 *

	 * @var bool $doNotUseBoundVariables

	 */

	var $doNotUseBoundVariables = false;

	/** @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()

	{

		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);

	}

	/**

	 * Sets the isolation level of a transaction.

	 *

	 * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:settransactionmode

	 *

	 * @param string $transaction_mode The transaction mode to set.

	 *

	 * @return void

	 */

	function SetTransactionMode($transaction_mode)

	{

		$this->_transmode = $transaction_mode;

		if (empty($transaction_mode)) {

			$this->execute('SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ');

			return;

		}

		if (!stristr($transaction_mode,'isolation')) $transaction_mode = 'ISOLATION LEVEL '.$transaction_mode;

		$this->execute("SET SESSION TRANSACTION ".$transaction_mode);

	}

	/**

	 * Adds a parameter to the connection string, can also set connection property values.

	 *

	 * Parameter must be one of the constants listed in mysqli_options().

	 * @see https://www.php.net/manual/en/mysqli.options.php

	 *

	 * OR

	 *

	 * Parameter must be a string matching one of the following special cases.

	 * 'ssl' - SSL values e.g. ('ssl' => ['ca' => '/path/to/ca.crt.pem'])

	 * 'clientflags' - Client flags of type 'MYSQLI_CLIENT_'

	 * @see https://www.php.net/manual/en/mysqli.real-connect.php

	 * @see https://www.php.net/manual/en/mysqli.constants.php

	 * 'socket' - The socket or named pipe that should be used

	 * 'port' - The port number to attempt to connect to the MySQL server

	 *

	 * @param string|int $parameter The parameter to set

	 * @param string|int|array $value The value of the parameter

	 *

	 * @return bool

	 */

	public function setConnectionParameter($parameter, $value) {

		// Special case for setting SSL values.

		if ("ssl" === $parameter && is_array($value)) {

			if (isset($value["key"])) {

				$this->ssl_key = $value["key"];

			}

			if (isset($value["cert"])) {

				$this->ssl_cert = $value["cert"];

			}

			if (isset($value["ca"])) {

				$this->ssl_ca = $value["ca"];

			}

			if (isset($value["capath"])) {

				$this->ssl_capath = $value["capath"];

			}

			if (isset($value["cipher"])) {

				$this->ssl_cipher = $value["cipher"];

			}

			return true;

		}

		// Special case for setting the client flag(s).

		if ("clientflags" === $parameter && is_numeric($value)) {

			$this->clientFlags = $value;

			return true;

		}

		// Special case for setting the socket.

		if ("socket" === $parameter && is_string($value)) {

			$this->socket = $value;

			return true;

		}

		// Special case for setting the port.

		if ("port" === $parameter && is_numeric($value)) {

			$this->port = (int)$value;

			return true;

		}

		// Standard mysqli_options.

		if (is_numeric($parameter)) {

			return parent::setConnectionParameter($parameter, $value);

		}

		$this->outp_throw("Invalid connection parameter '$parameter'", __METHOD__);

		return 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(!extension_loaded("mysqli")) {

			return null;

		}

		// Check for a function that only exists in mysqlnd

		if (!function_exists('mysqli_stmt_get_result')) {

			// @TODO This will be treated as if the mysqli extension were not available

			// This could be misleading, so we output an additional error message.

			// We should probably throw a specific exception instead.

			$this->outp("MySQL Native Driver (msqlnd) required");

			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());

			}

			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]);

		}

		// 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);

			// Check for any SSL client flag set, NOTE: bitwise operation.

			if (!($this->clientFlags & MYSQLI_CLIENT_SSL)) {

        			ADOConnection::outp('When using certificates, set the client flag MYSQLI_CLIENT_SSL_VERIFY_SERVER_CERT or MYSQLI_CLIENT_SSL_DONT_VERIFY_SERVER_CERT');

				return false;

			}

		}

		#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);

			return true;

		} else {

			if ($this->debug) {

				ADOConnection::outp("Could not connect : "  . $this->errorMsg());

			}

			$this->_connectionID = null;

			return false;

		}

	}

	/**

	 * 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);

	}

	/**

	 * 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);

	}

	/**

	 * Replaces a null value with a specified replacement.

	 *

	 * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:ifnull

	 *

	 * @param mixed $field The field in the table to check.

	 * @param mixed $ifNull The value to replace the null value with if it is found.

	 *

	 * @return string

	 */

	function IfNull($field, $ifNull)

	{

		return " IFNULL($field, $ifNull) ";

	}

	/**

	 * 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

	 */

	function GetOne($sql, $inputarr = false)

	{

		global $ADODB_GETONE_EOF;

		$ret = false;

		$rs = $this->execute($sql,$inputarr);

		if ($rs) {

			if ($rs->EOF) $ret = $ADODB_GETONE_EOF;

			else $ret = reset($rs->fields);

			$rs->close();

		}

		return $ret;

	}

	/**

	 * Get information about the current MySQL server.

	 *

	 * @return array

	 */

	function ServerInfo()

	{

		$arr['description'] = $this->getOne("select version()");

		$arr['version'] = ADOConnection::_findvers($arr['description']);

		return $arr;

	}

	/**

	 * 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');

		mysqli_autocommit($this->_connectionID, false);

		$this->execute('BEGIN');

		return true;

	}

	/**

	 * Commits a granular transaction.

	 *

	 * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:committrans

	 *

	 * @param bool $ok (Optional) If false, will rollback the transaction instead.

	 *

	 * @return bool Always returns true.

	 */

	function CommitTrans($ok = true)

	{

		if ($this->transOff) return true;

		if (!$ok) return $this->rollbackTrans();

		if ($this->transCnt) $this->transCnt -= 1;

		$this->execute('COMMIT');

		//$this->execute('SET AUTOCOMMIT=1');

		mysqli_autocommit($this->_connectionID, true);

		return true;

	}

	/**

	 * Rollback a smart transaction.

	 *

	 * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:rollbacktrans

	 *

	 * @return bool Always returns true.

	 */

	function RollbackTrans()

	{

		if ($this->transOff) return true;

		if ($this->transCnt) $this->transCnt -= 1;

		$this->execute('ROLLBACK');

		//$this->execute('SET AUTOCOMMIT=1');

		mysqli_autocommit($this->_connectionID, true);

		return true;

	}

	/**

	 * 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 ($where) $where = ' where '.$where;

		$rs = $this->execute("select $col from $table $where for update");

		return !empty($rs);

	}

	/**

	 * 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 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)

	{

		if (is_null($s)) {

			return 'NULL';

		}

		// mysqli_real_escape_string() throws a warning when the given

		// connection is invalid

		if ($this->_connectionID) {

			return "'" . mysqli_real_escape_string($this->_connectionID, $s) . "'";

		}

		if ($this->replaceQuote[0] == '\\') {

			$s = str_replace(array('\\', "\0"), array('\\\\', "\\\0") ,$s);

		}

		return "'" . str_replace("'", $this->replaceQuote, $s) . "'";

	}

	/**

	 * 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

		// execution of a stored procedure so we execute this instead.

		if ($this->useLastInsertStatement)

			$result = ADOConnection::getOne('SELECT LAST_INSERT_ID()');

		else

			$result = @mysqli_insert_id($this->_connectionID);

		if ($result == -1) {

			if ($this->debug)

				ADOConnection::outp("mysqli_insert_id() failed : "  . $this->errorMsg());

		}

		// reset prepared statement flags

		$this->usePreparedStatement   = false;

		$this->useLastInsertStatement = false;

		return $result;

	}

	/**

	 * 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.

	 */

	function _affectedrows()

	{

		if ($this->isSelectStatement) {

			// Affected rows works fine against selects, returning

			// the rowcount, but ADOdb does not do that.

			return false;

		}

		else if ($this->statementAffectedRows >= 0)

		{

			$result = $this->statementAffectedRows;

			$this->statementAffectedRows = -1;

		}

		else

		{

			$result =  @mysqli_affected_rows($this->_connectionID);

			if ($result == -1) {

				if ($this->debug) ADOConnection::outp("mysqli_affected_rows() failed : "  . $this->errorMsg());

			}

		}

		return $result;

	}

	// 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";

	/**

	 * Creates a sequence in the database.

	 *

	 * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:createsequence

	 *

	 * @param string $seqname The sequence name.

	 * @param int $startID The start id.

	 *

	 * @return ADORecordSet|bool A record set if executed successfully, otherwise false.

	 */

	function CreateSequence($seqname = 'adodbseq', $startID = 1)

	{

		if (empty($this->_genSeqSQL)) return false;

		$ok = $this->execute(sprintf($this->_genSeqSQL,$seqname));

		if (!$ok) return false;

		return $this->execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1));

	}

	/**

	 * A portable method of creating sequence numbers.

	 *

	 * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:genid

	 *

	 * @param string $seqname (Optional) The name of the sequence to use.

	 * @param int $startID (Optional) The point to start at in the sequence.

	 *

	 * @return bool|int|string

	 */

	function GenID($seqname = 'adodbseq', $startID = 1)

	{

		// post-nuke sets hasGenID to false

		if (!$this->hasGenID) return false;

		$getnext = sprintf($this->_genIDSQL,$seqname);

		$holdtransOK = $this->_transOK; // save the current status

		$rs = @$this->execute($getnext);

		if (!$rs) {

			if ($holdtransOK) $this->_transOK = true; //if the status was ok before reset

			$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);

		}

		if ($rs) {

			$this->genID = mysqli_insert_id($this->_connectionID);

			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;

	}

	/**

	 * Return a list of all visible databases except the 'mysql' database.

	 *

	 * @return array|false An array of database names, or false if the query failed.

	 */

	function MetaDatabases()

	{

		$query = "SHOW DATABASES";

		$ret = $this->execute($query);

		if ($ret && is_object($ret)){

			$arr = array();

			while (!$ret->EOF){

				$db = $ret->fields('Database');

				if ($db != 'mysql') $arr[] = $db;

				$ret->moveNext();

			}

			return $arr;

		}

		return $ret;

	}

	/**

	 * 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;

		$save = $ADODB_FETCH_MODE;

		$ADODB_FETCH_MODE = ADODB_FETCH_NUM;

		if ($this->fetchMode !== FALSE) {

			$savem = $this->setFetchMode(FALSE);

		}

		// get index details

		$rs = $this->Execute(sprintf('SHOW INDEXES FROM `%s`',$table));

		// restore fetchmode

		if (isset($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()) {

			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;

	}

	/**

	 * 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 a database-specific concatenation of strings.

	 *

	 * @link https://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:concat

	 *

	 * @return string

	 */

	function Concat()

	{

		$arr = func_get_args();

		// suggestion by andrew005@mnogo.ru

		$s = implode(',',$arr);

		if (strlen($s) > 0) return "CONCAT($s)";

		else return '';

	}

	/**

	 * 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)";

	}

	/**

	 * 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;

		$save = $ADODB_FETCH_MODE;

		$ADODB_FETCH_MODE = ADODB_FETCH_NUM;

		if ($this->fetchMode !== FALSE) {

			$savem = $this->setFetchMode(FALSE);

		}

		$procedures = array ();

		// get index details

		$likepattern = '';

		if ($procedureNamePattern) {

			$likepattern = " LIKE '".$procedureNamePattern."'";

		}

		$rs = $this->execute('SHOW PROCEDURE STATUS'.$likepattern);

		if (is_object($rs)) {

			// parse index data into array

			while ($row = $rs->fetchRow()) {

				$procedures[$row[1]] = array(

					'type' => 'PROCEDURE',

					'catalog' => '',

					'schema' => '',

					'remarks' => $row[7],

				);

			}

		}

		$rs = $this->execute('SHOW FUNCTION STATUS'.$likepattern);

		if (is_object($rs)) {

			// parse index data into array

			while ($row = $rs->fetchRow()) {

				$procedures[$row[1]] = array(

					'type' => 'FUNCTION',

					'catalog' => '',

					'schema' => '',

					'remarks' => $row[7]

				);

			}

		}

		// restore fetchmode

		if (isset($savem)) {

				$this->setFetchMode($savem);

		}

		$ADODB_FETCH_MODE = $save;

		return $procedures;

	}

	/**

	 * Retrieves a list of tables based on given criteria

	 *

	 * @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);

		$this->metaTablesSQL = $save;

		return $ret;

	}

	/**

	 * 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;

		$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));

		$this->setFetchMode($savem);

		$create_sql = isset($a_create_table["Create Table"]) ? $a_create_table["Create Table"] : $a_create_table["Create View"];

		$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;

	}

	/**

	 * Return an array of information about a table's columns.

	 *

	 * @param string $table The name of the table to get the column info for.

	 * @param bool $normalize (Optional) Unused.

	 *

	 * @return ADOFieldObject[]|bool An array of info for each column, or false if it could not determine the info.