ForeignDBRepo.php

Go to the documentation of this file.

<?php
class ForeignDBRepo extends LocalRepo {
    # Settings
    var $dbType, $dbServer, $dbUser, $dbPassword, $dbName, $dbFlags,
        $tablePrefix, $hasSharedCache;

    # Other stuff
    var $dbConn;
    var $fileFactory = array( 'ForeignDBFile', 'newFromTitle' );
    var $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.' );
    }
}