NetworkedDatabaseCreator.php

Go to the documentation of this file.

<?php
 
namespace MediaWiki\Installer;
 
use MediaWiki\Installer\Task\ITaskContext;
use MediaWiki\Status\Status;
use Wikimedia\Rdbms\DatabaseDomain;
use Wikimedia\Rdbms\IDatabase;
use Wikimedia\Rdbms\ILoadBalancer;
 
abstract class NetworkedDatabaseCreator extends DatabaseCreator {
    public function existsLocally( $database ) {
        $connStatus = $this->context->getConnection( ITaskContext::CONN_CREATE_DATABASE );
        if ( !$connStatus->isOK() ) {
            return false;
        }
        return $this->existsInConnection( $connStatus->getDB(), $database );
    }
 
    public function existsInLoadBalancer( ILoadBalancer $loadBalancer, $database ) {
        $conn = $loadBalancer->getConnection( DB_PRIMARY, [], DatabaseDomain::newUnspecified()->getId() );
        return $this->existsInConnection( $conn, $database );
    }
 
    public function createLocally( $database ): Status {
        $connStatus = $this->context->getConnection( ITaskContext::CONN_CREATE_DATABASE );
        if ( !$connStatus->isOK() ) {
            return $connStatus;
        }
        $conn = $connStatus->getDB();
        return $this->createInConnection( $conn, $database );
    }
 
    public function createInLoadBalancer( ILoadBalancer $loadBalancer, $database ): Status {
        $conn = $loadBalancer->getConnection( DB_PRIMARY, [], DatabaseDomain::newUnspecified()->getId() );
        return $this->createInConnection( $conn, $database );
    }
 
    abstract protected function existsInConnection( IDatabase $conn, $database );
 
    abstract protected function createInConnection( IDatabase $conn, $database ): Status;
}