X-Git-Url: http://git.heureux-cyclage.org/?a=blobdiff_plain;f=includes%2FWatchedItemStore.php;h=9a74401a4304ca214f2100eadc806f78174b1fdb;hb=63ce63820e3dbf1d68df0b64ef31ace389c6bef8;hp=a13609bf5dccbd8ca33afeac444863cba749eee9;hpb=fe79bc528b0e054aa630bd4fcfcdd4a9804892da;p=lhc%2Fweb%2Fwiklou.git diff --git a/includes/WatchedItemStore.php b/includes/WatchedItemStore.php index a13609bf5d..9a74401a43 100644 --- a/includes/WatchedItemStore.php +++ b/includes/WatchedItemStore.php @@ -190,13 +190,13 @@ class WatchedItemStore implements StatsdAwareInterface { } /** - * @param int $slaveOrMaster DB_MASTER or DB_SLAVE + * @param int $dbIndex DB_MASTER or DB_REPLICA * * @return DatabaseBase * @throws MWException */ - private function getConnection( $slaveOrMaster ) { - return $this->loadBalancer->getConnection( $slaveOrMaster, [ 'watchlist' ] ); + private function getConnection( $dbIndex ) { + return $this->loadBalancer->getConnection( $dbIndex, [ 'watchlist' ] ); } /** @@ -217,7 +217,7 @@ class WatchedItemStore implements StatsdAwareInterface { * @return int */ public function countWatchedItems( User $user ) { - $dbr = $this->getConnection( DB_SLAVE ); + $dbr = $this->getConnection( DB_REPLICA ); $return = (int)$dbr->selectField( 'watchlist', 'COUNT(*)', @@ -237,7 +237,7 @@ class WatchedItemStore implements StatsdAwareInterface { * @return int */ public function countWatchers( LinkTarget $target ) { - $dbr = $this->getConnection( DB_SLAVE ); + $dbr = $this->getConnection( DB_REPLICA ); $return = (int)$dbr->selectField( 'watchlist', 'COUNT(*)', @@ -263,7 +263,7 @@ class WatchedItemStore implements StatsdAwareInterface { * @throws MWException */ public function countVisitingWatchers( LinkTarget $target, $threshold ) { - $dbr = $this->getConnection( DB_SLAVE ); + $dbr = $this->getConnection( DB_REPLICA ); $visitingWatchers = (int)$dbr->selectField( 'watchlist', 'COUNT(*)', @@ -293,7 +293,7 @@ class WatchedItemStore implements StatsdAwareInterface { public function countWatchersMultiple( array $targets, array $options = [] ) { $dbOptions = [ 'GROUP BY' => [ 'wl_namespace', 'wl_title' ] ]; - $dbr = $this->getConnection( DB_SLAVE ); + $dbr = $this->getConnection( DB_REPLICA ); if ( array_key_exists( 'minimumWatchers', $options ) ) { $dbOptions['HAVING'] = 'COUNT(*) >= ' . (int)$options['minimumWatchers']; @@ -341,7 +341,7 @@ class WatchedItemStore implements StatsdAwareInterface { array $targetsWithVisitThresholds, $minimumWatchers = null ) { - $dbr = $this->getConnection( DB_SLAVE ); + $dbr = $this->getConnection( DB_REPLICA ); $conds = $this->getVisitingWatchersCondition( $dbr, $targetsWithVisitThresholds ); @@ -452,7 +452,7 @@ class WatchedItemStore implements StatsdAwareInterface { return false; } - $dbr = $this->getConnection( DB_SLAVE ); + $dbr = $this->getConnection( DB_REPLICA ); $row = $dbr->selectRow( 'watchlist', 'wl_notificationtimestamp', @@ -499,7 +499,7 @@ class WatchedItemStore implements StatsdAwareInterface { "wl_title {$options['sort']}" ]; } - $db = $this->getConnection( $options['forWrite'] ? DB_MASTER : DB_SLAVE ); + $db = $this->getConnection( $options['forWrite'] ? DB_MASTER : DB_REPLICA ); $res = $db->select( 'watchlist', @@ -569,7 +569,7 @@ class WatchedItemStore implements StatsdAwareInterface { return $timestamps; } - $dbr = $this->getConnection( DB_SLAVE ); + $dbr = $this->getConnection( DB_REPLICA ); $lb = new LinkBatch( $targetsToLoad ); $res = $dbr->select( @@ -885,7 +885,7 @@ class WatchedItemStore implements StatsdAwareInterface { $queryOptions['LIMIT'] = $unreadLimit; } - $dbr = $this->getConnection( DB_SLAVE ); + $dbr = $this->getConnection( DB_REPLICA ); $rowCount = $dbr->selectRowCount( 'watchlist', '1',