* @copyright © 2013 Wikimedia Foundation Inc.
*/
-use Wikimedia\AtEase\AtEase;
use Wikimedia\Rdbms\IDatabase;
use Wikimedia\Rdbms\IMaintainableDatabase;
use Wikimedia\Rdbms\LBFactory;
use Wikimedia\Rdbms\ChronologyProtector;
use Wikimedia\Rdbms\MySQLMasterPos;
use Wikimedia\Rdbms\DatabaseDomain;
+use Wikimedia\Rdbms\LoadMonitorNull;
/**
* @group Database
$this->assertSame( $factory->getLocalDomainID(), $factory->resolveDomainID( false ) );
$factory->shutdown();
- $lb->closeAll();
}
public function testLBFactorySimpleServers() {
'cluster master set' );
$factory->shutdown();
- $lb->closeAll();
}
public function testLBFactoryMultiConns() {
};
$factory = $this->newLBFactoryMultiLBs();
- $this->assertEquals( 0, $countLBsFunc( $factory ) );
+ $this->assertSame( 0, $countLBsFunc( $factory ) );
$dbw = $factory->getMainLB()->getConnection( DB_MASTER );
$this->assertEquals( 1, $countLBsFunc( $factory ) );
// Test that LoadBalancer instances made during pre-commit callbacks in do not
$called = 0;
$factory = $this->newLBFactoryMultiLBs();
- $this->assertEquals( 0, $countLBsFunc( $factory ) );
+ $this->assertSame( 0, $countLBsFunc( $factory ) );
$dbw = $factory->getMainLB()->getConnection( DB_MASTER );
$this->assertEquals( 1, $countLBsFunc( $factory ) );
// Test that LoadBalancer instances made during pre-commit callbacks in do not
unset( $db );
/** @var IMaintainableDatabase $db */
- $db = $lb->getConnection( DB_MASTER, [], $lb::DOMAIN_ANY );
+ $db = $lb->getConnection( DB_MASTER, [], '' );
- $this->assertEquals(
+ $this->assertSame(
'',
$db->getDomainId(),
'Null domain ID handle used'
);
- $this->assertEquals(
- '',
+ $this->assertNull(
$db->getDBname(),
'Null domain ID handle used'
);
- $this->assertEquals(
+ $this->assertSame(
'',
$db->tablePrefix(),
'Main domain ID handle used; prefix is empty though'
);
$lb = $factory->getMainLB();
/** @var IMaintainableDatabase $db */
- $db = $lb->getConnection( DB_MASTER, [], $lb::DOMAIN_ANY );
+ $db = $lb->getConnection( DB_MASTER, [], '' );
- $this->assertEquals( '', $db->getDomainID(), "Null domain used" );
+ $this->assertSame( '', $db->getDomainID(), "Null domain used" );
$this->assertEquals(
$this->quoteTable( $db, 'page' ),
);
$lb = $factory->getMainLB();
/** @var IDatabase $db */
- $db = $lb->getConnection( DB_MASTER, [], $lb::DOMAIN_ANY );
+ $db = $lb->getConnection( DB_MASTER, [], '' );
- AtEase::suppressWarnings();
+ \Wikimedia\suppressWarnings();
try {
- $this->assertFalse( $db->selectDomain( 'garbagedb' ) );
+ $this->assertFalse( $db->selectDB( 'garbage-db' ) );
$this->fail( "No error thrown." );
} catch ( \Wikimedia\Rdbms\DBQueryError $e ) {
- $this->assertRegExp( '/[\'"]garbagedb[\'"]/', $e->getMessage() );
+ $this->assertRegExp( '/[\'"]garbage-db[\'"]/', $e->getMessage() );
}
- AtEase::restoreWarnings();
+ \Wikimedia\restoreWarnings();
}
/**
);
$lb = $factory->getMainLB();
- if ( !$factory->getMainLB()->getServerAttributes( 0 )[Database::ATTR_DB_IS_FILE] ) {
- $this->markTestSkipped( "Not applicable per ATTR_DB_IS_FILE" );
+ if ( !$lb->getConnection( DB_MASTER )->databasesAreIndependent() ) {
+ $this->markTestSkipped( "Not applicable per databasesAreIndependent()" );
}
/** @var IDatabase $db */
- $this->assertNotNull( $lb->getConnection( DB_MASTER, [], $lb::DOMAIN_ANY ) );
+ $lb->getConnection( DB_MASTER, [], '' );
}
/**
}
$db = $lb->getConnection( DB_MASTER );
- $db->selectDomain( 'garbage-db' );
+ $db->selectDB( 'garbage-db' );
}
/**
$lb->forEachOpenConnection( function () use ( &$n ) {
++$n;
} );
- $this->assertEquals( 0, $n, "Connections closed" );
+ $this->assertSame( 0, $n, "Connections closed" );
$conn2 = $lb->getConnectionRef( DB_MASTER );
$this->assertEquals(