ForeignDBViaLBRepo.php

Go to the documentation of this file.

<?php
use MediaWiki\MediaWikiServices;
use Wikimedia\Rdbms\IDatabase;
use Wikimedia\Rdbms\ILoadBalancer;
 
class ForeignDBViaLBRepo extends LocalRepo {
    protected $wiki;
 
    protected $fileFactory = [ ForeignDBFile::class, 'newFromTitle' ];
 
    protected $fileFromRowFactory = [ ForeignDBFile::class, 'newFromRow' ];
 
    protected $hasSharedCache;
 
    function __construct( $info ) {
        parent::__construct( $info );
        '@phan-var array $info';
        $this->wiki = $info['wiki'];
        $this->hasSharedCache = $info['hasSharedCache'];
    }
 
    function getMasterDB() {
        return $this->getDBLoadBalancer()->getConnectionRef( DB_MASTER, [], $this->wiki );
    }
 
    function getReplicaDB() {
        return $this->getDBLoadBalancer()->getConnectionRef( DB_REPLICA, [], $this->wiki );
    }
 
    protected function getDBFactory() {
        return function ( $index ) {
            return $this->getDBLoadBalancer()->getConnectionRef( $index, [], $this->wiki );
        };
    }
 
    protected function getDBLoadBalancer() {
        $lbFactory = MediaWikiServices::getInstance()->getDBLoadBalancerFactory();
 
        return $lbFactory->getMainLB( $this->wiki );
    }
 
    function hasSharedCache() {
        return $this->hasSharedCache;
    }
 
    function getSharedCacheKey( ...$args ) {
        if ( $this->hasSharedCache() ) {
            array_unshift( $args, $this->wiki );
 
            return implode( ':', $args );
        } else {
            return false;
        }
    }
 
    protected function assertWritableRepo() {
        throw new MWException( static::class . ': write operations are not supported.' );
    }
 
    public function getInfo() {
        return FileRepo::getInfo();
    }
}