use MediaWiki\MediaWikiServices;
use Wikimedia\Rdbms\LoadBalancer;
-use Wikimedia\Rdbms\IDatabase;
+use Wikimedia\Rdbms\IMaintainableDatabase;
/**
* @ingroup Dump
/**
* The dependency-injected database to use.
*
- * @var IDatabase|null
+ * @var IMaintainableDatabase|null
*
* @see self::setDB
*/
$dbr = $this->forcedDb;
if ( $this->forcedDb === null ) {
- $dbr = wfGetDB( DB_REPLICA );
+ $dbr = $this->getDB( DB_REPLICA );
}
$this->maxCount = $dbr->selectField( $table, "MAX($field)", '', __METHOD__ );
$this->startTime = microtime( true );
* @todo Fixme: the --server parameter is currently not respected, as it
* doesn't seem terribly easy to ask the load balancer for a particular
* connection by name.
- * @return IDatabase
+ * @return IMaintainableDatabase
*/
function backupDb() {
if ( $this->forcedDb !== null ) {
$lbFactory = MediaWikiServices::getInstance()->getDBLoadBalancerFactory();
$this->lb = $lbFactory->newMainLB();
- $db = $this->lb->getConnection( DB_REPLICA, 'dump' );
+ $db = $this->lb->getMaintenanceConnectionRef( DB_REPLICA, 'dump' );
// Discourage the server from disconnecting us if it takes a long time
// to read out the big ol' batch query.
* Force the dump to use the provided database connection for database
* operations, wherever possible.
*
- * @param IDatabase|null $db (Optional) the database connection to use. If null, resort to
- * use the globally provided ways to get database connections.
+ * @param IMaintainableDatabase $db The database connection to use
*/
- function setDB( IDatabase $db = null ) {
+ function setDB( IMaintainableDatabase $db ) {
parent::setDB( $db );
$this->forcedDb = $db;
}
$pageRatePart = '-';
$revRatePart = '-';
}
+
+ $dbDomain = WikiMap::getCurrentWikiDbDomain()->getId();
$this->progress( sprintf(
"%s: %s (ID %d) %d pages (%0.1f|%0.1f/sec all|curr), "
. "%d revs (%0.1f|%0.1f/sec all|curr), ETA %s [max %d]",
- $now, wfWikiID(), $this->ID, $this->pageCount, $pageRate,
+ $now, $dbDomain, $this->ID, $this->pageCount, $pageRate,
$pageRatePart, $this->revCount, $revRate, $revRatePart, $etats,
$this->maxCount
) );