ConnectionManager.php

Go to the documentation of this file.

<?php
 
namespace Wikimedia\Rdbms;
 
use InvalidArgumentException;
 
class ConnectionManager {
 
    private $loadBalancer;
 
    private $domain;
 
    private $groups = [];
 
    public function __construct( LoadBalancer $loadBalancer, $domain = false, array $groups = [] ) {
        if ( !is_string( $domain ) && $domain !== false ) {
            throw new InvalidArgumentException( '$dbName must be a string, or false.' );
        }
 
        $this->loadBalancer = $loadBalancer;
        $this->domain = $domain;
        $this->groups = $groups;
    }
 
    private function getConnection( $i, array $groups = null ) {
        $groups = $groups === null ? $this->groups : $groups;
        return $this->loadBalancer->getConnection( $i, $groups, $this->domain );
    }
 
    private function getConnectionRef( $i, array $groups = null ) {
        $groups = $groups === null ? $this->groups : $groups;
        return $this->loadBalancer->getConnectionRef( $i, $groups, $this->domain );
    }
 
    public function getWriteConnection() {
        return $this->getConnection( DB_MASTER );
    }
 
    public function getReadConnection( array $groups = null ) {
        $groups = $groups === null ? $this->groups : $groups;
        return $this->getConnection( DB_REPLICA, $groups );
    }
 
    public function releaseConnection( IDatabase $db ) {
        $this->loadBalancer->reuseConnection( $db );
    }
 
    public function getWriteConnectionRef() {
        return $this->getConnectionRef( DB_MASTER );
    }
 
    public function getReadConnectionRef( array $groups = null ) {
        $groups = $groups === null ? $this->groups : $groups;
        return $this->getConnectionRef( DB_REPLICA, $groups );
    }
 
}