3 use Wikimedia\Rdbms\Database
;
4 use Wikimedia\Rdbms\IDatabase
;
5 use Wikimedia\Rdbms\DatabaseDomain
;
6 use Wikimedia\Rdbms\DatabaseMysqli
;
7 use Wikimedia\Rdbms\LBFactorySingle
;
8 use Wikimedia\Rdbms\TransactionProfiler
;
9 use Wikimedia\TestingAccessWrapper
;
10 use Wikimedia\Rdbms\DatabaseSqlite
;
11 use Wikimedia\Rdbms\DatabasePostgres
;
12 use Wikimedia\Rdbms\DatabaseMssql
;
13 use Wikimedia\Rdbms\DBUnexpectedError
;
15 class DatabaseTest
extends PHPUnit\Framework\TestCase
{
16 /** @var DatabaseTestHelper */
19 use MediaWikiCoversValidator
;
21 protected function setUp() {
22 $this->db
= new DatabaseTestHelper( __CLASS__
. '::' . $this->getName() );
26 * @dataProvider provideAddQuotes
27 * @covers Wikimedia\Rdbms\Database::factory
29 public function testFactory() {
30 $m = Database
::NEW_UNCONNECTED
; // no-connect mode
31 $p = [ 'host' => 'localhost', 'user' => 'me', 'password' => 'myself', 'dbname' => 'i' ];
33 $this->assertInstanceOf( DatabaseMysqli
::class, Database
::factory( 'mysqli', $p, $m ) );
34 $this->assertInstanceOf( DatabaseMysqli
::class, Database
::factory( 'MySqli', $p, $m ) );
35 $this->assertInstanceOf( DatabaseMysqli
::class, Database
::factory( 'MySQLi', $p, $m ) );
36 $this->assertInstanceOf( DatabasePostgres
::class, Database
::factory( 'postgres', $p, $m ) );
37 $this->assertInstanceOf( DatabasePostgres
::class, Database
::factory( 'Postgres', $p, $m ) );
39 $x = $p +
[ 'port' => 10000, 'UseWindowsAuth' => false ];
40 $this->assertInstanceOf( DatabaseMssql
::class, Database
::factory( 'mssql', $x, $m ) );
42 $x = $p +
[ 'dbFilePath' => 'some/file.sqlite' ];
43 $this->assertInstanceOf( DatabaseSqlite
::class, Database
::factory( 'sqlite', $x, $m ) );
44 $x = $p +
[ 'dbDirectory' => 'some/file' ];
45 $this->assertInstanceOf( DatabaseSqlite
::class, Database
::factory( 'sqlite', $x, $m ) );
48 public static function provideAddQuotes() {
52 [ 1234.5678, "'1234.5678'" ],
53 [ 'string', "'string'" ],
54 [ 'string\'s cause trouble', "'string\'s cause trouble'" ],
59 * @dataProvider provideAddQuotes
60 * @covers Wikimedia\Rdbms\Database::addQuotes
62 public function testAddQuotes( $input, $expected ) {
63 $this->assertEquals( $expected, $this->db
->addQuotes( $input ) );
66 public static function provideTableName() {
67 // Formatting is mostly ignored since addIdentifierQuotes is abstract.
68 // For testing of addIdentifierQuotes, see actual Database subclas tests.
84 [ 'dbname' => 'sharedb', 'schema' => null, 'prefix' => '' ],
90 [ 'dbname' => 'sharedb', 'schema' => null, 'prefix' => '' ],
93 'sharedb.sh_tablename',
96 [ 'dbname' => 'sharedb', 'schema' => null, 'prefix' => 'sh_' ],
98 'shared-prefix-raw' => [
99 'sharedb.sh_tablename',
102 [ 'dbname' => 'sharedb', 'schema' => null, 'prefix' => 'sh_' ],
105 'databasename.tablename',
106 'databasename.tablename',
110 'databasename.tablename',
111 'databasename.tablename',
118 * @dataProvider provideTableName
119 * @covers Wikimedia\Rdbms\Database::tableName
121 public function testTableName( $expected, $table, $format, array $alias = null ) {
123 $this->db
->setTableAliases( [ $table => $alias ] );
127 $this->db
->tableName( $table, $format ?
: 'quoted' )
131 public function provideTableNamesWithIndexClauseOrJOIN() {
133 'one-element array' => [
134 [ 'table' ], [], 'table '
137 [ 'table1', 'table2' ], [], 'table1,table2 '
140 [ 'table1', 'table2' ],
141 [ 'table2' => [ 'LEFT JOIN', 't1_id = t2_id' ] ],
142 'table1 LEFT JOIN table2 ON ((t1_id = t2_id))'
144 'real join with multiple conditionals' => [
145 [ 'table1', 'table2' ],
146 [ 'table2' => [ 'LEFT JOIN', [ 't1_id = t2_id', 't2_x = \'X\'' ] ] ],
147 'table1 LEFT JOIN table2 ON ((t1_id = t2_id) AND (t2_x = \'X\'))'
149 'join with parenthesized group' => [
150 [ 'table1', 'n' => [ 'table2', 'table3' ] ],
152 'table3' => [ 'JOIN', 't2_id = t3_id' ],
153 'n' => [ 'LEFT JOIN', 't1_id = t2_id' ],
155 'table1 LEFT JOIN (table2 JOIN table3 ON ((t2_id = t3_id))) ON ((t1_id = t2_id))'
157 'join with degenerate parenthesized group' => [
158 [ 'table1', 'n' => [ 't2' => 'table2' ] ],
160 'n' => [ 'LEFT JOIN', 't1_id = t2_id' ],
162 'table1 LEFT JOIN table2 t2 ON ((t1_id = t2_id))'
168 * @dataProvider provideTableNamesWithIndexClauseOrJOIN
169 * @covers Wikimedia\Rdbms\Database::tableNamesWithIndexClauseOrJOIN
171 public function testTableNamesWithIndexClauseOrJOIN( $tables, $join_conds, $expect ) {
172 $clause = TestingAccessWrapper
::newFromObject( $this->db
)
173 ->tableNamesWithIndexClauseOrJOIN( $tables, [], [], $join_conds );
174 $this->assertSame( $expect, $clause );
178 * @covers Wikimedia\Rdbms\Database::onTransactionCommitOrIdle
179 * @covers Wikimedia\Rdbms\Database::runOnTransactionIdleCallbacks
181 public function testTransactionIdle() {
184 $db->clearFlag( DBO_TRX
);
187 $callback = function ( $trigger, IDatabase
$db ) use ( &$flagSet, &$called ) {
189 $flagSet = $db->getFlag( DBO_TRX
);
192 $db->onTransactionCommitOrIdle( $callback, __METHOD__
);
193 $this->assertTrue( $called, 'Callback reached' );
194 $this->assertFalse( $flagSet, 'DBO_TRX off in callback' );
195 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX still default' );
199 $db->startAtomic( __METHOD__
);
200 $db->onTransactionCommitOrIdle( $callback, __METHOD__
);
201 $this->assertFalse( $called, 'Callback not reached during TRX' );
202 $db->endAtomic( __METHOD__
);
204 $this->assertTrue( $called, 'Callback reached after COMMIT' );
205 $this->assertFalse( $flagSet, 'DBO_TRX off in callback' );
206 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX restored to default' );
208 $db->clearFlag( DBO_TRX
);
209 $db->onTransactionCommitOrIdle(
210 function ( $trigger, IDatabase
$db ) {
211 $db->setFlag( DBO_TRX
);
215 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX restored to default' );
219 * @covers Wikimedia\Rdbms\Database::onTransactionCommitOrIdle
220 * @covers Wikimedia\Rdbms\Database::runOnTransactionIdleCallbacks
222 public function testTransactionIdle_TRX() {
223 $db = $this->getMockDB( [ 'isOpen', 'ping', 'getDBname' ] );
224 $db->method( 'isOpen' )->willReturn( true );
225 $db->method( 'ping' )->willReturn( true );
226 $db->method( 'getDBname' )->willReturn( '' );
227 $db->setFlag( DBO_TRX
);
229 $lbFactory = LBFactorySingle
::newFromConnection( $db );
230 // Ask for the connection so that LB sets internal state
231 // about this connection being the master connection
232 $lb = $lbFactory->getMainLB();
233 $conn = $lb->openConnection( $lb->getWriterIndex() );
234 $this->assertSame( $db, $conn, 'Same DB instance' );
235 $this->assertTrue( $db->getFlag( DBO_TRX
), 'DBO_TRX is set' );
239 $callback = function () use ( $db, &$flagSet, &$called ) {
241 $flagSet = $db->getFlag( DBO_TRX
);
244 $db->onTransactionCommitOrIdle( $callback, __METHOD__
);
245 $this->assertTrue( $called, 'Called when idle if DBO_TRX is set' );
246 $this->assertFalse( $flagSet, 'DBO_TRX off in callback' );
247 $this->assertTrue( $db->getFlag( DBO_TRX
), 'DBO_TRX still default' );
250 $lbFactory->beginMasterChanges( __METHOD__
);
251 $db->onTransactionCommitOrIdle( $callback, __METHOD__
);
252 $this->assertFalse( $called, 'Not called when lb-transaction is active' );
254 $lbFactory->commitMasterChanges( __METHOD__
);
255 $this->assertTrue( $called, 'Called when lb-transaction is committed' );
258 $lbFactory->beginMasterChanges( __METHOD__
);
259 $db->onTransactionCommitOrIdle( $callback, __METHOD__
);
260 $this->assertFalse( $called, 'Not called when lb-transaction is active' );
262 $lbFactory->rollbackMasterChanges( __METHOD__
);
263 $this->assertFalse( $called, 'Not called when lb-transaction is rolled back' );
265 $lbFactory->commitMasterChanges( __METHOD__
);
266 $this->assertFalse( $called, 'Not called in next round commit' );
268 $db->setFlag( DBO_TRX
);
270 $db->onTransactionCommitOrIdle( function () {
271 throw new RuntimeException( 'test' );
273 $this->fail( "Exception not thrown" );
274 } catch ( RuntimeException
$e ) {
275 $this->assertTrue( $db->getFlag( DBO_TRX
) );
280 * @covers Wikimedia\Rdbms\Database::onTransactionPreCommitOrIdle
281 * @covers Wikimedia\Rdbms\Database::runOnTransactionPreCommitCallbacks
283 public function testTransactionPreCommitOrIdle() {
284 $db = $this->getMockDB( [ 'isOpen' ] );
285 $db->method( 'isOpen' )->willReturn( true );
286 $db->clearFlag( DBO_TRX
);
288 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX is not set' );
291 $db->onTransactionPreCommitOrIdle(
292 function ( IDatabase
$db ) use ( &$called ) {
297 $this->assertTrue( $called, 'Called when idle' );
299 $db->begin( __METHOD__
);
301 $db->onTransactionPreCommitOrIdle(
302 function ( IDatabase
$db ) use ( &$called ) {
307 $this->assertFalse( $called, 'Not called when transaction is active' );
308 $db->commit( __METHOD__
);
309 $this->assertTrue( $called, 'Called when transaction is committed' );
313 * @covers Wikimedia\Rdbms\Database::onTransactionPreCommitOrIdle
314 * @covers Wikimedia\Rdbms\Database::runOnTransactionPreCommitCallbacks
316 public function testTransactionPreCommitOrIdle_TRX() {
317 $db = $this->getMockDB( [ 'isOpen', 'ping', 'getDBname' ] );
318 $db->method( 'isOpen' )->willReturn( true );
319 $db->method( 'ping' )->willReturn( true );
320 $db->method( 'getDBname' )->willReturn( 'unittest' );
321 $db->setFlag( DBO_TRX
);
323 $lbFactory = LBFactorySingle
::newFromConnection( $db );
324 // Ask for the connection so that LB sets internal state
325 // about this connection being the master connection
326 $lb = $lbFactory->getMainLB();
327 $conn = $lb->openConnection( $lb->getWriterIndex() );
328 $this->assertSame( $db, $conn, 'Same DB instance' );
330 $this->assertFalse( $lb->hasMasterChanges() );
331 $this->assertTrue( $db->getFlag( DBO_TRX
), 'DBO_TRX is set' );
333 $callback = function ( IDatabase
$db ) use ( &$called ) {
336 $db->onTransactionPreCommitOrIdle( $callback, __METHOD__
);
337 $this->assertTrue( $called, 'Called when idle if DBO_TRX is set' );
339 $lbFactory->commitMasterChanges();
340 $this->assertFalse( $called );
343 $lbFactory->beginMasterChanges( __METHOD__
);
344 $db->onTransactionPreCommitOrIdle( $callback, __METHOD__
);
345 $this->assertFalse( $called, 'Not called when lb-transaction is active' );
346 $lbFactory->commitMasterChanges( __METHOD__
);
347 $this->assertTrue( $called, 'Called when lb-transaction is committed' );
350 $lbFactory->beginMasterChanges( __METHOD__
);
351 $db->onTransactionPreCommitOrIdle( $callback, __METHOD__
);
352 $this->assertFalse( $called, 'Not called when lb-transaction is active' );
354 $lbFactory->rollbackMasterChanges( __METHOD__
);
355 $this->assertFalse( $called, 'Not called when lb-transaction is rolled back' );
357 $lbFactory->commitMasterChanges( __METHOD__
);
358 $this->assertFalse( $called, 'Not called in next round commit' );
362 * @covers Wikimedia\Rdbms\Database::onTransactionResolution
363 * @covers Wikimedia\Rdbms\Database::runOnTransactionIdleCallbacks
365 public function testTransactionResolution() {
368 $db->clearFlag( DBO_TRX
);
369 $db->begin( __METHOD__
);
371 $db->onTransactionResolution( function ( $trigger, IDatabase
$db ) use ( &$called ) {
373 $db->setFlag( DBO_TRX
);
375 $db->commit( __METHOD__
);
376 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX restored to default' );
377 $this->assertTrue( $called, 'Callback reached' );
379 $db->clearFlag( DBO_TRX
);
380 $db->begin( __METHOD__
);
382 $db->onTransactionResolution( function ( $trigger, IDatabase
$db ) use ( &$called ) {
384 $db->setFlag( DBO_TRX
);
386 $db->rollback( __METHOD__
);
387 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX restored to default' );
388 $this->assertTrue( $called, 'Callback reached' );
392 * @covers Wikimedia\Rdbms\Database::setTransactionListener
394 public function testTransactionListener() {
397 $db->setTransactionListener( 'ping', function () use ( $db, &$called ) {
402 $db->begin( __METHOD__
);
403 $db->commit( __METHOD__
);
404 $this->assertTrue( $called, 'Callback reached' );
407 $db->begin( __METHOD__
);
408 $db->commit( __METHOD__
);
409 $this->assertTrue( $called, 'Callback still reached' );
412 $db->begin( __METHOD__
);
413 $db->rollback( __METHOD__
);
414 $this->assertTrue( $called, 'Callback reached' );
416 $db->setTransactionListener( 'ping', null );
418 $db->begin( __METHOD__
);
419 $db->commit( __METHOD__
);
420 $this->assertFalse( $called, 'Callback not reached' );
424 * Use this mock instead of DatabaseTestHelper for cases where
425 * DatabaseTestHelper is too inflexibile due to mocking too much
426 * or being too restrictive about fname matching (e.g. for tests
427 * that assert behaviour when the name is a mismatch, we need to
428 * catch the error here instead of there).
432 private function getMockDB( $methods = [] ) {
433 static $abstractMethods = [
434 'fetchAffectedRowCount',
438 'fetchObject', 'fetchRow',
439 'fieldInfo', 'fieldName',
440 'getSoftwareLink', 'getServerVersion',
444 'lastError', 'lastErrno',
445 'numFields', 'numRows',
450 $db = $this->getMockBuilder( Database
::class )
451 ->disableOriginalConstructor()
452 ->setMethods( array_values( array_unique( array_merge(
457 $wdb = TestingAccessWrapper
::newFromObject( $db );
458 $wdb->trxProfiler
= new TransactionProfiler();
459 $wdb->connLogger
= new \Psr\Log\
NullLogger();
460 $wdb->queryLogger
= new \Psr\Log\
NullLogger();
461 $wdb->currentDomain
= DatabaseDomain
::newUnspecified();
466 * @covers Wikimedia\Rdbms\Database::flushSnapshot
468 public function testFlushSnapshot() {
469 $db = $this->getMockDB( [ 'isOpen' ] );
470 $db->method( 'isOpen' )->willReturn( true );
472 $db->flushSnapshot( __METHOD__
); // ok
473 $db->flushSnapshot( __METHOD__
); // ok
475 $db->setFlag( DBO_TRX
, $db::REMEMBER_PRIOR
);
476 $db->query( 'SELECT 1', __METHOD__
);
477 $this->assertTrue( (bool)$db->trxLevel(), "Transaction started." );
478 $db->flushSnapshot( __METHOD__
); // ok
479 $db->restoreFlags( $db::RESTORE_PRIOR
);
481 $this->assertFalse( (bool)$db->trxLevel(), "Transaction cleared." );
485 * @covers Wikimedia\Rdbms\Database::getScopedLockAndFlush
486 * @covers Wikimedia\Rdbms\Database::lock
487 * @covers Wikimedia\Rdbms\Database::unlock
488 * @covers Wikimedia\Rdbms\Database::lockIsFree
490 public function testGetScopedLock() {
491 $db = $this->getMockDB( [ 'isOpen', 'getDBname' ] );
492 $db->method( 'isOpen' )->willReturn( true );
493 $db->method( 'getDBname' )->willReturn( 'unittest' );
495 $this->assertEquals( 0, $db->trxLevel() );
496 $this->assertEquals( true, $db->lockIsFree( 'x', __METHOD__
) );
497 $this->assertEquals( true, $db->lock( 'x', __METHOD__
) );
498 $this->assertEquals( false, $db->lockIsFree( 'x', __METHOD__
) );
499 $this->assertEquals( true, $db->unlock( 'x', __METHOD__
) );
500 $this->assertEquals( true, $db->lockIsFree( 'x', __METHOD__
) );
501 $this->assertEquals( 0, $db->trxLevel() );
503 $db->setFlag( DBO_TRX
);
504 $this->assertEquals( true, $db->lockIsFree( 'x', __METHOD__
) );
505 $this->assertEquals( true, $db->lock( 'x', __METHOD__
) );
506 $this->assertEquals( false, $db->lockIsFree( 'x', __METHOD__
) );
507 $this->assertEquals( true, $db->unlock( 'x', __METHOD__
) );
508 $this->assertEquals( true, $db->lockIsFree( 'x', __METHOD__
) );
509 $db->clearFlag( DBO_TRX
);
511 // Pending writes with DBO_TRX
512 $this->assertEquals( 0, $db->trxLevel() );
513 $this->assertTrue( $db->lockIsFree( 'meow', __METHOD__
) );
514 $db->setFlag( DBO_TRX
);
515 $db->query( "DELETE FROM test WHERE t = 1" ); // trigger DBO_TRX transaction before lock
517 $lock = $db->getScopedLockAndFlush( 'meow', __METHOD__
, 1 );
518 $this->fail( "Exception not reached" );
519 } catch ( DBUnexpectedError
$e ) {
520 $this->assertEquals( 1, $db->trxLevel(), "Transaction not committed." );
521 $this->assertTrue( $db->lockIsFree( 'meow', __METHOD__
), 'Lock not acquired' );
523 $db->rollback( __METHOD__
, IDatabase
::FLUSHING_ALL_PEERS
);
524 // Pending writes without DBO_TRX
525 $db->clearFlag( DBO_TRX
);
526 $this->assertEquals( 0, $db->trxLevel() );
527 $this->assertTrue( $db->lockIsFree( 'meow2', __METHOD__
) );
528 $db->begin( __METHOD__
);
529 $db->query( "DELETE FROM test WHERE t = 1" ); // trigger DBO_TRX transaction before lock
531 $lock = $db->getScopedLockAndFlush( 'meow2', __METHOD__
, 1 );
532 $this->fail( "Exception not reached" );
533 } catch ( DBUnexpectedError
$e ) {
534 $this->assertEquals( 1, $db->trxLevel(), "Transaction not committed." );
535 $this->assertTrue( $db->lockIsFree( 'meow2', __METHOD__
), 'Lock not acquired' );
537 $db->rollback( __METHOD__
);
538 // No pending writes, with DBO_TRX
539 $db->setFlag( DBO_TRX
);
540 $this->assertEquals( 0, $db->trxLevel() );
541 $this->assertTrue( $db->lockIsFree( 'wuff', __METHOD__
) );
542 $db->query( "SELECT 1", __METHOD__
);
543 $this->assertEquals( 1, $db->trxLevel() );
544 $lock = $db->getScopedLockAndFlush( 'wuff', __METHOD__
, 1 );
545 $this->assertEquals( 0, $db->trxLevel() );
546 $this->assertFalse( $db->lockIsFree( 'wuff', __METHOD__
), 'Lock already acquired' );
547 $db->rollback( __METHOD__
, IDatabase
::FLUSHING_ALL_PEERS
);
548 // No pending writes, without DBO_TRX
549 $db->clearFlag( DBO_TRX
);
550 $this->assertEquals( 0, $db->trxLevel() );
551 $this->assertTrue( $db->lockIsFree( 'wuff2', __METHOD__
) );
552 $db->begin( __METHOD__
);
554 $lock = $db->getScopedLockAndFlush( 'wuff2', __METHOD__
, 1 );
555 $this->fail( "Exception not reached" );
556 } catch ( DBUnexpectedError
$e ) {
557 $this->assertEquals( 1, $db->trxLevel(), "Transaction not committed." );
558 $this->assertFalse( $db->lockIsFree( 'wuff2', __METHOD__
), 'Lock not acquired' );
560 $db->rollback( __METHOD__
);
564 * @covers Wikimedia\Rdbms\Database::getFlag
565 * @covers Wikimedia\Rdbms\Database::setFlag
566 * @covers Wikimedia\Rdbms\Database::restoreFlags
568 public function testFlagSetting() {
570 $origTrx = $db->getFlag( DBO_TRX
);
571 $origSsl = $db->getFlag( DBO_SSL
);
574 ?
$db->clearFlag( DBO_TRX
, $db::REMEMBER_PRIOR
)
575 : $db->setFlag( DBO_TRX
, $db::REMEMBER_PRIOR
);
576 $this->assertEquals( !$origTrx, $db->getFlag( DBO_TRX
) );
579 ?
$db->clearFlag( DBO_SSL
, $db::REMEMBER_PRIOR
)
580 : $db->setFlag( DBO_SSL
, $db::REMEMBER_PRIOR
);
581 $this->assertEquals( !$origSsl, $db->getFlag( DBO_SSL
) );
583 $db->restoreFlags( $db::RESTORE_INITIAL
);
584 $this->assertEquals( $origTrx, $db->getFlag( DBO_TRX
) );
585 $this->assertEquals( $origSsl, $db->getFlag( DBO_SSL
) );
588 ?
$db->clearFlag( DBO_TRX
, $db::REMEMBER_PRIOR
)
589 : $db->setFlag( DBO_TRX
, $db::REMEMBER_PRIOR
);
591 ?
$db->clearFlag( DBO_SSL
, $db::REMEMBER_PRIOR
)
592 : $db->setFlag( DBO_SSL
, $db::REMEMBER_PRIOR
);
595 $this->assertEquals( $origSsl, $db->getFlag( DBO_SSL
) );
596 $this->assertEquals( !$origTrx, $db->getFlag( DBO_TRX
) );
599 $this->assertEquals( $origSsl, $db->getFlag( DBO_SSL
) );
600 $this->assertEquals( $origTrx, $db->getFlag( DBO_TRX
) );
604 * @expectedException UnexpectedValueException
605 * @covers Wikimedia\Rdbms\Database::setFlag
607 public function testDBOIgnoreSet() {
608 $db = $this->getMockBuilder( DatabaseMysqli
::class )
609 ->disableOriginalConstructor()
613 $db->setFlag( Database
::DBO_IGNORE
);
617 * @expectedException UnexpectedValueException
618 * @covers Wikimedia\Rdbms\Database::clearFlag
620 public function testDBOIgnoreClear() {
621 $db = $this->getMockBuilder( DatabaseMysqli
::class )
622 ->disableOriginalConstructor()
626 $db->clearFlag( Database
::DBO_IGNORE
);
630 * @covers Wikimedia\Rdbms\Database::tablePrefix
631 * @covers Wikimedia\Rdbms\Database::dbSchema
633 public function testSchemaAndPrefixMutators() {
634 $ud = DatabaseDomain
::newUnspecified();
636 $this->assertEquals( $ud->getId(), $this->db
->getDomainID() );
638 $old = $this->db
->tablePrefix();
639 $oldDomain = $this->db
->getDomainId();
640 $this->assertInternalType( 'string', $old, 'Prefix is string' );
641 $this->assertSame( $old, $this->db
->tablePrefix(), "Prefix unchanged" );
642 $this->assertSame( $old, $this->db
->tablePrefix( 'xxx_' ) );
643 $this->assertSame( 'xxx_', $this->db
->tablePrefix(), "Prefix set" );
644 $this->db
->tablePrefix( $old );
645 $this->assertNotEquals( 'xxx_', $this->db
->tablePrefix() );
646 $this->assertSame( $oldDomain, $this->db
->getDomainId() );
648 $old = $this->db
->dbSchema();
649 $oldDomain = $this->db
->getDomainId();
650 $this->assertInternalType( 'string', $old, 'Schema is string' );
651 $this->assertSame( $old, $this->db
->dbSchema(), "Schema unchanged" );
653 $this->db
->selectDB( 'y' );
654 $this->assertSame( $old, $this->db
->dbSchema( 'xxx' ) );
655 $this->assertSame( 'xxx', $this->db
->dbSchema(), "Schema set" );
656 $this->db
->dbSchema( $old );
657 $this->assertNotEquals( 'xxx', $this->db
->dbSchema() );
658 $this->assertSame( "y", $this->db
->getDomainId() );
662 * @covers Wikimedia\Rdbms\Database::tablePrefix
663 * @covers Wikimedia\Rdbms\Database::dbSchema
664 * @expectedException DBUnexpectedError
666 public function testSchemaWithNoDB() {
667 $ud = DatabaseDomain
::newUnspecified();
669 $this->assertEquals( $ud->getId(), $this->db
->getDomainID() );
670 $this->assertSame( '', $this->db
->dbSchema() );
672 $this->db
->dbSchema( 'xxx' );
676 * @covers Wikimedia\Rdbms\Database::selectDomain
678 public function testSelectDomain() {
679 $oldDomain = $this->db
->getDomainId();
680 $oldDatabase = $this->db
->getDBname();
681 $oldSchema = $this->db
->dbSchema();
682 $oldPrefix = $this->db
->tablePrefix();
684 $this->db
->selectDomain( 'testselectdb-xxx_' );
685 $this->assertSame( 'testselectdb', $this->db
->getDBname() );
686 $this->assertSame( '', $this->db
->dbSchema() );
687 $this->assertSame( 'xxx_', $this->db
->tablePrefix() );
689 $this->db
->selectDomain( $oldDomain );
690 $this->assertSame( $oldDatabase, $this->db
->getDBname() );
691 $this->assertSame( $oldSchema, $this->db
->dbSchema() );
692 $this->assertSame( $oldPrefix, $this->db
->tablePrefix() );
693 $this->assertSame( $oldDomain, $this->db
->getDomainId() );
695 $this->db
->selectDomain( 'testselectdb-schema-xxx_' );
696 $this->assertSame( 'testselectdb', $this->db
->getDBname() );
697 $this->assertSame( 'schema', $this->db
->dbSchema() );
698 $this->assertSame( 'xxx_', $this->db
->tablePrefix() );
700 $this->db
->selectDomain( $oldDomain );
701 $this->assertSame( $oldDatabase, $this->db
->getDBname() );
702 $this->assertSame( $oldSchema, $this->db
->dbSchema() );
703 $this->assertSame( $oldPrefix, $this->db
->tablePrefix() );
704 $this->assertSame( $oldDomain, $this->db
->getDomainId() );