ForeignDBRepo.php

Go to the documentation of this file.

<?php
class ForeignDBRepo extends LocalRepo {
    protected $dbType;
 
    protected $dbServer;
 
    protected $dbUser;
 
    protected $dbPassword;
 
    protected $dbName;
 
    protected $dbFlags;
 
    protected $tablePrefix;
 
    protected $hasSharedCache;
 
    # Other stuff
    protected $dbConn;
    protected $fileFactory = array( 'ForeignDBFile', 'newFromTitle' );
    protected $fileFromRowFactory = array( 'ForeignDBFile', 'newFromRow' );
 
    function __construct( $info ) {
        parent::__construct( $info );
        $this->dbType = $info['dbType'];
        $this->dbServer = $info['dbServer'];
        $this->dbUser = $info['dbUser'];
        $this->dbPassword = $info['dbPassword'];
        $this->dbName = $info['dbName'];
        $this->dbFlags = $info['dbFlags'];
        $this->tablePrefix = $info['tablePrefix'];
        $this->hasSharedCache = $info['hasSharedCache'];
    }
 
    function getMasterDB() {
        if ( !isset( $this->dbConn ) ) {
            $this->dbConn = DatabaseBase::factory( $this->dbType,
                array(
                    'host' => $this->dbServer,
                    'user' => $this->dbUser,
                    'password' => $this->dbPassword,
                    'dbname' => $this->dbName,
                    'flags' => $this->dbFlags,
                    'tablePrefix' => $this->tablePrefix,
                    'foreign' => true,
                )
            );
        }
 
        return $this->dbConn;
    }
 
    function getSlaveDB() {
        return $this->getMasterDB();
    }
 
    function hasSharedCache() {
        return $this->hasSharedCache;
    }
 
    function getSharedCacheKey( /*...*/ ) {
        if ( $this->hasSharedCache() ) {
            $args = func_get_args();
            array_unshift( $args, $this->dbName, $this->tablePrefix );
 
            return call_user_func_array( 'wfForeignMemcKey', $args );
        } else {
            return false;
        }
    }
 
    protected function assertWritableRepo() {
        throw new MWException( get_class( $this ) . ': write operations are not supported.' );
    }
 
    function getInfo() {
        return FileRepo::getInfo();
    }
}