Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://doc.wikimedia.org/mediawiki-core/master/php/DatabaseMySQL_8php_source.html below:

MediaWiki: includes/libs/rdbms/database/DatabaseMySQL.php Source File

use Wikimedia\AtEase\AtEase;

use Wikimedia\IPUtils;

$sessionLastAutoRowId;

( [

,

,

,

,

] as $name ) {

( isset( $params[$var] ) ) {

$this->$var = $params[$var];

$this->utf8Mode = !empty( $params[

] );

parent::__construct( $params );

$params[

],

$params[

],

$params[

] ??

,

$params[

] ?? [],

!empty( $params[

] )

( $server, $user, $password, $db, $schema, $tablePrefix ) {

$this->

( __METHOD__ );

( $schema !==

) {

$this->conn = $this->mysqlConnect( $server, $user, $password, $db );

}

( RuntimeException $e ) {

( !$this->conn ) {

( $db !==

) ? $db :

,

( !$this->

->getFlag( self::DBO_GAUGE ) ) {

$set[] =

;

( !is_int( $val ) && !is_float( $val ) ) {

$set[] = $this->

->addIdentifierQuotes( $var ) .

. $val;

$sql =

. implode(

, $set );

( $qs->res ===

) {

}

( RuntimeException $e ) {

__CLASS__ .

( $database ===

) {

( $database !== $this->

() ) {

$query =

( $sql, self::QUERY_CHANGE_TRX,

);

$qs = $this->

( $query, __METHOD__, self::QUERY_CHANGE_TRX );

( $qs->res ===

) {

$this->

->setCurrentDomain( $domain );

$error = $this->mysqlError( $this->conn );

$error = $this->mysqlError();

$error = $this->mysqlError() ?: $this->lastConnectError;

$row = $this->replicationReporter->getReplicationSafetyInfo( $this, $fname );

( $row->binlog_format ===

) {

( isset( $selectOptions[

] ) ) {

in_array(

, $insertOptions ) ||

(

)$row->innodb_autoinc_lock_mode === 0

( $this->conn && $this->conn->warning_count ) {

$warnings = $this->conn->get_warnings();

$done = $warnings ===

;

( in_array( $warnings->errno, [

. $warnings->message,

$done = !$warnings->next();

$conds = $this->

->normalizeConditions( $conds, $fname );

$column = $this->

->extractSingleFieldFromList( $var );

( is_string( $column ) && !in_array( $column, [

,

] ) ) {

$conds[] =

;

$options[

] =

;

$res = $this->

( $tables, $var, $conds, $fname, $options, $join_conds );

( $res ===

) {

( !$res->numRows() ) {

( $res as $plan ) {

$rows *= $plan->rows > 0 ? $plan->rows : 1;

[ $db, $pt ] = $this->platform->getDatabaseAndTableIdentifier( $table );

( isset( $this->sessionTempTables[$db][$pt] ) ) {

(

)$this->newSelectQueryBuilder()

->from(

)

=> $db,

. $this->tableName( $table ) .

,

self::QUERY_SILENCE_ERRORS | self::QUERY_IGNORE_DBO_TRX | self::QUERY_CHANGE_NONE,

$res = $this->query( $query, __METHOD__ );

;

$res->getInternalFieldInfo( $field );

( $table, $index, $fname = __METHOD__ ) {

. $this->tableName( $table ),

self::QUERY_IGNORE_DBO_TRX | self::QUERY_CHANGE_NONE,

$res = $this->query( $query, $fname );

( $res as $row ) {

( $row->Key_name === $index ) {

[

=> !$row->Non_unique ];

$this->mysqlRealEscapeString( $s );

$flags = self::QUERY_IGNORE_DBO_TRX | self::QUERY_CHANGE_NONE;

$query =

(

, $flags,

);

$res = $this->query( $query, __METHOD__ );

$row = $res->fetchObject();

$row && $row->Value && $row->Value !==

;

[ $variant ] = $this->getMySqlServerVariant();

( $variant ===

) {

;

;

getMySqlServerVariant() {

$version = $this->getServerVersion();

$parts = explode(

, $version, 2 );

$suffix = $parts[1] ??

;

( str_contains( $suffix,

) || str_contains( $suffix,

) ) {

$vendor =

;

[ $vendor, $number ];

$version = $this->conn->server_info;

str_starts_with( $version,

) &&

( str_contains( $version,

) || str_contains( $version,

) )

$version = substr( $version, strlen(

) );

$sqlAssignments = [];

( isset( $options[

] ) ) {

$encTimeout = (int)$options[

];

$sqlAssignments[] =

;

$sqlAssignments[] =

;

( isset( $options[

] ) ) {

$maxLength = (int)$options[

];

$sqlAssignments[] =

;

( $sqlAssignments ) {

. implode(

, $sqlAssignments ),

self::QUERY_CHANGE_TRX | self::QUERY_CHANGE_NONE,

$this->query( $query, __METHOD__ );

( preg_match(

, $newLine, $m ) ) {

$this->delimiter = $m[1];

parent::streamStatementEnd( $sql, $newLine );

$query =

( $this->platform->lockIsFreeSQLText( $lockName ), self::QUERY_CHANGE_LOCKS,

);

$res = $this->query( $query, $method );

$row = $res->fetchObject();

( $row->unlocked == 1 );

(

$lockName,

$method,

$timeout ) {

$query =

( $this->platform->lockSQLText( $lockName, $timeout ), self::QUERY_CHANGE_LOCKS,

);

$res = $this->query( $query, $method );

$row = $res->fetchObject();

( $row->acquired !==

) ? (float)$row->acquired :

;

(

$lockName,

$method ) {

$query =

( $this->platform->unlockSQLText( $lockName ), self::QUERY_CHANGE_LOCKS,

);

$res = $this->query( $query, $method );

$row = $res->fetchObject();

( $row->released == 1 );

$releaseLockFields = [];

( $this->sessionNamedLocks as $name => $info ) {

$encName = $this->addQuotes( $this->platform->makeLockName( $name ) );

$releaseLockFields[] =

;

( $releaseLockFields ) {

$sql =

. implode(

, $releaseLockFields );

$flags = self::QUERY_CHANGE_LOCKS | self::QUERY_NO_RETRY;

$query =

( $sql, $flags,

);

$qs = $this->executeQuery( $query, __METHOD__, $flags );

( $qs->res ===

) {

$this->reportQueryError( $qs->message, $qs->code, $sql, $fname,

);

( $table, array $rows, $uniqueKeys, array $set, $fname = __METHOD__ ) {

$identityKey = $this->platform->normalizeUpsertParams( $uniqueKeys, $rows );

$this->platform->assertValidUpsertSetArray( $set, $identityKey, $rows );

$encTable = $this->tableName( $table );

[ $sqlColumns, $sqlTuples ] = $this->platform->makeInsertLists( $rows );

$sqlColumnAssignments = $this->makeList( $set, self::LIST_SET );

.

.

;

$query =

( $sql, self::QUERY_CHANGE_ROWS,

, $table );

$this->query( $query, $fname );

$this->lastQueryAffectedRows = min( $this->lastQueryAffectedRows, count( $rows ) );

( $table, $uniqueKeys, $rows, $fname = __METHOD__ ) {

$this->platform->normalizeUpsertParams( $uniqueKeys, $rows );

$encTable = $this->tableName( $table );

[ $sqlColumns, $sqlTuples ] = $this->platform->makeInsertLists( $rows );

$sql =

;

$query =

( $sql, self::QUERY_CHANGE_ROWS,

, $table );

$this->query( $query, $fname );

$this->lastQueryAffectedRows = min( $this->lastQueryAffectedRows, count( $rows ) );

in_array( $errno, [ 2013, 2006, 2003, 1927, 1053 ],

);

in_array( $errno, [ 3024, 2062, 1969, 1028 ],

);

[ 3024, 1969, 1022, 1062, 1216, 1217, 1137, 1146, 1051, 1054 ],

$oldName, $newName, $temporary =

, $fname = __METHOD__

$tmp = $temporary ?

:

;

$newNameQuoted = $this->addIdentifierQuotes( $newName );

$oldNameQuoted = $this->addIdentifierQuotes( $oldName );

,

self::QUERY_PSEUDO_PERMANENT | self::QUERY_CHANGE_SCHEMA,

$temporary ?

:

,

$this->query( $query, $fname );

( $prefix =

, $fname = __METHOD__ ) {

$qb = $this->newSelectQueryBuilder()

->select(

)

->from(

)

=> $this->currentDomain->getDatabase(),

=>

( $prefix !==

&& $prefix !==

) {

$qb->andWhere( $this->expr(

$qb->fetchFieldValues();

$sql = parent::selectSQLText( $tables, $vars, $conds, $fname, $options, $join_conds );

$timeoutMsec = intval( $options[

] ?? 0 );

( $timeoutMsec > 0 ) {

[ $vendor, $number ] = $this->getMySqlServerVariant();

( $vendor ===

&& version_compare( $number,

,

) ) {

$timeoutSec = $timeoutMsec / 1000;

$sql =

;

} elseif ( $vendor ===

&& version_compare( $number,

,

) ) {

,

$conn = $this->getBindingHandle();

AtEase::suppressWarnings();

$res = $conn->query( $sql );

AtEase::restoreWarnings();

$insertId = (int)$conn->insert_id;

$this->lastQueryInsertId = $insertId;

$this->sessionLastAutoRowId = $insertId ?: $this->sessionLastAutoRowId;

$conn->affected_rows,

mysqlConnect( $server, $user, $password, $db ) {

( !function_exists(

) ) {

$this->newExceptionAfterConnectError(

mysqli_report( MYSQLI_REPORT_OFF );

$hostAndPort = IPUtils::splitHostAndPort( $server );

( $hostAndPort ) {

$realServer = $hostAndPort[0];

( $hostAndPort[1] ) {

$port = $hostAndPort[1];

} elseif ( substr_count( $server,

) == 1 ) {

[ $realServer, $socket ] = explode(

, $server, 2 );

$realServer = $server;

$mysqli = mysqli_init();

$flags = MYSQLI_CLIENT_FOUND_ROWS;

$flags |= MYSQLI_CLIENT_SSL;

( $this->getFlag( self::DBO_COMPRESS ) ) {

$flags |= MYSQLI_CLIENT_COMPRESS;

( $this->getFlag( self::DBO_PERSISTENT ) ) {

$realServer =

. $realServer;

( $this->utf8Mode ) {

$mysqli->options( MYSQLI_SET_CHARSET_NAME,

);

$mysqli->options( MYSQLI_SET_CHARSET_NAME,

);

$mysqli->options( MYSQLI_OPT_CONNECT_TIMEOUT, $this->connectTimeout ?: 3 );

( $this->receiveTimeout ) {

$mysqli->options( MYSQLI_OPT_READ_TIMEOUT, $this->receiveTimeout );

$ok = $mysqli->real_connect( $realServer, $user, $password, $db, $port, $socket, $flags );

$ok ? $mysqli :

;

( $this->conn instanceof mysqli ) ? mysqli_close( $this->conn ) :

;

$this->sessionLastAutoRowId;

$this->sessionLastAutoRowId = 0;

( $this->lastEmulatedInsertId ===

) {

$conn = $this->getBindingHandle();

$this->lastEmulatedInsertId = (int)$conn->insert_id;

$this->lastEmulatedInsertId;

( $this->conn instanceof mysqli ) {

$this->conn->errno;

mysqli_connect_errno();

mysqlError( $conn =

) {

( $conn ===

) {

(

)mysqli_connect_error();

mysqlRealEscapeString( $s ): string {

$conn = $this->getBindingHandle();

$conn->real_escape_string( (

)$s );

Class to handle database/schema/prefix specifications for IDatabase.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4