Page MenuHomeWickedGov Phorge
Files F4094964

DatabaseMessageIndex.php
No OneTemporary
Actions

Size
2 KB
Referenced Files
None
Subscribers
None

DatabaseMessageIndex.php
View Options

<?php
declare ( strict_types = 1 );
namespace MediaWiki\Extension\Translate\MessageLoading;
use MediaWiki\MediaWikiServices;
use Wikimedia\Rdbms\ILoadBalancer;
/**
* Storage on the database itself.
*
* This is likely to be the slowest backend. However, it scales okay
* and provides random access. It also doesn't need any special setup,
* the database table is added with update.php together with other tables,
* which is the reason this is the default backend. It also works well
* on multi-server setup without needing for shared file storage.
*/
class DatabaseMessageIndex extends MessageIndexStore {
private ?array $index = null;
private ILoadBalancer $loadBalancer;
public function __construct() {
$this->loadBalancer = MediaWikiServices::getInstance()->getDBLoadBalancer();
}
public function retrieve( bool $readLatest = false ): array {
if ( $this->index !== null && !$readLatest ) {
return $this->index;
}
$dbr = $this->loadBalancer->getConnection( $readLatest ? DB_PRIMARY : DB_REPLICA );
$res = $dbr->newSelectQueryBuilder()
->select( '*' )
->from( 'translate_messageindex' )
->caller( __METHOD__ )
->fetchResultSet();
$this->index = [];
foreach ( $res as $row ) {
$this->index[$row->tmi_key] = $this->unserialize( $row->tmi_value );
}
return $this->index;
}
/** @inheritDoc */
public function get( string $key ) {
$dbr = $this->loadBalancer->getConnection( DB_REPLICA );
$value = $dbr->newSelectQueryBuilder()
->select( 'tmi_value' )
->from( 'translate_messageindex' )
->where( [ 'tmi_key' => $key ] )
->caller( __METHOD__ )
->fetchField();
return is_string( $value ) ? $this->unserialize( $value ) : null;
}
public function store( array $array, array $diff ): void {
$updates = [];
foreach ( [ $diff['add'], $diff['mod'] ] as $changes ) {
foreach ( $changes as $key => $data ) {
[ , $new ] = $data;
$updates[] = [
'tmi_key' => $key,
'tmi_value' => $this->serialize( $new ),
];
}
}
$deletions = array_keys( $diff['del'] );
$dbw = $this->loadBalancer->getConnection( DB_PRIMARY );
$dbw->startAtomic( __METHOD__ );
if ( $updates !== [] ) {
$dbw->newReplaceQueryBuilder()
->replaceInto( 'translate_messageindex' )
->uniqueIndexFields( [ 'tmi_key' ] )
->rows( $updates )
->caller( __METHOD__ )
->execute();
}
if ( $deletions !== [] ) {
$dbw->newDeleteQueryBuilder()
->deleteFrom( 'translate_messageindex' )
->where( [ 'tmi_key' => $deletions ] )
->caller( __METHOD__ )
->execute();
}
$dbw->endAtomic( __METHOD__ );
$this->index = $array;
}
}

File Metadata

Mime Type
text/x-php
Expires
Tue, Aug 18, 13:35 (4 w, 22 h ago)
Storage Engine
local-disk
Storage Format
Raw Data
Storage Handle
a0/a6/8695bf0c929858f30b5201545c9b
Default Alt Text
DatabaseMessageIndex.php (2 KB)

Event Timeline