DBAccessObjectUtils.php

Go to the documentation of this file.

<?php
namespace Wikimedia\Rdbms;
 
use InvalidArgumentException;
 
class DBAccessObjectUtils implements IDBAccessObject {
    public static function hasFlags( $bitfield, $flags ) {
        return ( $bitfield & $flags ) == $flags;
    }
 
    public static function getDBOptions( $bitfield ) {
        wfDeprecated( __METHOD__, '1.43' );
        if ( self::hasFlags( $bitfield, IDBAccessObject::READ_LATEST_IMMUTABLE ) ) {
            $index = DB_REPLICA; // override READ_LATEST if set
        } elseif ( self::hasFlags( $bitfield, IDBAccessObject::READ_LATEST ) ) {
            $index = DB_PRIMARY;
        } else {
            $index = DB_REPLICA;
        }
 
        $lockingOptions = [];
        if ( self::hasFlags( $bitfield, IDBAccessObject::READ_EXCLUSIVE ) ) {
            $lockingOptions[] = 'FOR UPDATE';
        } elseif ( self::hasFlags( $bitfield, IDBAccessObject::READ_LOCKING ) ) {
            $lockingOptions[] = 'LOCK IN SHARE MODE';
        }
 
        return [ $index, $lockingOptions ];
    }
 
    public static function getDBFromIndex( IConnectionProvider $dbProvider, int $index ): IReadableDatabase {
        wfDeprecated( __METHOD__, '1.42' );
        if ( $index === DB_PRIMARY ) {
            return $dbProvider->getPrimaryDatabase();
        } elseif ( $index === DB_REPLICA ) {
            return $dbProvider->getReplicaDatabase();
        } else {
            throw new InvalidArgumentException( '$index must be either DB_REPLICA or DB_PRIMARY' );
        }
    }
 
    public static function getDBFromRecency( IConnectionProvider $dbProvider, int $recency ): IReadableDatabase {
        if ( self::hasFlags( $recency, IDBAccessObject::READ_LATEST ) ) {
            return $dbProvider->getPrimaryDatabase();
        }
        return $dbProvider->getReplicaDatabase();
    }
}
 
class_alias( DBAccessObjectUtils::class, 'DBAccessObjectUtils' );