ForeignDBViaLBRepo.php

Go to the documentation of this file.

<?php
use MediaWiki\MediaWikiServices;
use Wikimedia\Rdbms\IConnectionProvider;
 
class ForeignDBViaLBRepo extends LocalRepo implements IForeignRepoWithDB {
    protected $fileFactory = [ ForeignDBFile::class, 'newFromTitle' ];
 
    protected $fileFromRowFactory = [ ForeignDBFile::class, 'newFromRow' ];
 
    public function __construct( $info ) {
        parent::__construct( $info );
        '@phan-var array $info';
        $this->dbDomain = $info['wiki'];
        $this->hasAccessibleSharedCache = $info['hasSharedCache'];
    }
 
    public function getPrimaryDB() {
        return $this->getDbProvider()->getPrimaryDatabase( $this->dbDomain );
    }
 
    public function getReplicaDB() {
        return $this->getDbProvider()->getReplicaDatabase( $this->dbDomain );
    }
 
    protected function getDBFactory() {
        return function ( $index ) {
            if ( $index == DB_PRIMARY ) {
                return $this->getDbProvider()->getPrimaryDatabase( $this->dbDomain );
            } else {
                return $this->getDbProvider()->getReplicaDatabase( $this->dbDomain );
            }
        };
    }
 
    protected function getDbProvider(): IConnectionProvider {
        return MediaWikiServices::getInstance()->getDBLoadBalancerFactory();
    }
 
    protected function assertWritableRepo() {
        // @phan-suppress-previous-line PhanPluginNeverReturnMethod
        throw new MWException( static::class . ': write operations are not supported.' );
    }
 
    public function getInfo() {
        return FileRepo::getInfo();
    }
}