ForeignDBViaLBRepo.php

Go to the documentation of this file.

<?php
class ForeignDBViaLBRepo extends LocalRepo {
    protected $wiki;

    protected $dbName;

    protected $tablePrefix;

    protected $fileFactory = [ 'ForeignDBFile', 'newFromTitle' ];

    protected $fileFromRowFactory = [ 'ForeignDBFile', 'newFromRow' ];

    protected $hasSharedCache;

    function __construct( $info ) {
        parent::__construct( $info );
        $this->wiki = $info['wiki'];
        list( $this->dbName, $this->tablePrefix ) = wfSplitWikiID( $this->wiki );
        $this->hasSharedCache = $info['hasSharedCache'];
    }

    function getMasterDB() {
        return wfGetLB( $this->wiki )->getConnectionRef( DB_MASTER, [], $this->wiki );
    }

    function getSlaveDB() {
        return wfGetLB( $this->wiki )->getConnectionRef( DB_REPLICA, [], $this->wiki );
    }

    protected function getDBFactory() {
        return function( $index ) {
            return wfGetLB( $this->wiki )->getConnectionRef( $index, [], $this->wiki );
        };
    }

    function hasSharedCache() {
        return $this->hasSharedCache;
    }

    function getSharedCacheKey( /*...*/ ) {
        if ( $this->hasSharedCache() ) {
            $args = func_get_args();
            array_unshift( $args, $this->wiki );

            return implode( ':', $args );
        } else {
            return false;
        }
    }

    protected function assertWritableRepo() {
        throw new MWException( get_class( $this ) . ': write operations are not supported.' );
    }

    public function getInfo() {
        return FileRepo::getInfo();
    }
}