SessionConsistentConnectionManager.php

Go to the documentation of this file.

<?php
 
namespace Wikimedia\Rdbms;
 
class SessionConsistentConnectionManager extends ConnectionManager {
 
    private $forceWriteConnection = false;
 
    public function prepareForUpdates() {
        $this->forceWriteConnection = true;
    }
 
    public function getReadConnection( array $groups = null ) {
        if ( $this->forceWriteConnection ) {
            return parent::getWriteConnection();
        }
 
        return parent::getReadConnection( $groups );
    }
 
    public function getWriteConnection() {
        $this->prepareForUpdates();
        return parent::getWriteConnection();
    }
 
    public function getReadConnectionRef( array $groups = null ) {
        if ( $this->forceWriteConnection ) {
            return parent::getWriteConnectionRef();
        }
 
        return parent::getReadConnectionRef( $groups );
    }
 
    public function getWriteConnectionRef() {
        $this->prepareForUpdates();
        return parent::getWriteConnectionRef();
    }
 
}