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
{
17 use MediaWikiCoversValidator
;
19 protected function setUp() {
20 $this->db
= new DatabaseTestHelper( __CLASS__
. '::' . $this->getName() );
24 * @dataProvider provideAddQuotes
25 * @covers Wikimedia\Rdbms\Database::factory
27 public function testFactory() {
28 $m = Database
::NEW_UNCONNECTED
; // no-connect mode
29 $p = [ 'host' => 'localhost', 'user' => 'me', 'password' => 'myself', 'dbname' => 'i' ];
31 $this->assertInstanceOf( DatabaseMysqli
::class, Database
::factory( 'mysqli', $p, $m ) );
32 $this->assertInstanceOf( DatabaseMysqli
::class, Database
::factory( 'MySqli', $p, $m ) );
33 $this->assertInstanceOf( DatabaseMysqli
::class, Database
::factory( 'MySQLi', $p, $m ) );
34 $this->assertInstanceOf( DatabasePostgres
::class, Database
::factory( 'postgres', $p, $m ) );
35 $this->assertInstanceOf( DatabasePostgres
::class, Database
::factory( 'Postgres', $p, $m ) );
37 $x = $p +
[ 'port' => 10000, 'UseWindowsAuth' => false ];
38 $this->assertInstanceOf( DatabaseMssql
::class, Database
::factory( 'mssql', $x, $m ) );
40 $x = $p +
[ 'dbFilePath' => 'some/file.sqlite' ];
41 $this->assertInstanceOf( DatabaseSqlite
::class, Database
::factory( 'sqlite', $x, $m ) );
42 $x = $p +
[ 'dbDirectory' => 'some/file' ];
43 $this->assertInstanceOf( DatabaseSqlite
::class, Database
::factory( 'sqlite', $x, $m ) );
46 public static function provideAddQuotes() {
50 [ 1234.5678, "'1234.5678'" ],
51 [ 'string', "'string'" ],
52 [ 'string\'s cause trouble', "'string\'s cause trouble'" ],
57 * @dataProvider provideAddQuotes
58 * @covers Wikimedia\Rdbms\Database::addQuotes
60 public function testAddQuotes( $input, $expected ) {
61 $this->assertEquals( $expected, $this->db
->addQuotes( $input ) );
64 public static function provideTableName() {
65 // Formatting is mostly ignored since addIdentifierQuotes is abstract.
66 // For testing of addIdentifierQuotes, see actual Database subclas tests.
82 [ 'dbname' => 'sharedb', 'schema' => null, 'prefix' => '' ],
88 [ 'dbname' => 'sharedb', 'schema' => null, 'prefix' => '' ],
91 'sharedb.sh_tablename',
94 [ 'dbname' => 'sharedb', 'schema' => null, 'prefix' => 'sh_' ],
96 'shared-prefix-raw' => [
97 'sharedb.sh_tablename',
100 [ 'dbname' => 'sharedb', 'schema' => null, 'prefix' => 'sh_' ],
103 'databasename.tablename',
104 'databasename.tablename',
108 'databasename.tablename',
109 'databasename.tablename',
116 * @dataProvider provideTableName
117 * @covers Wikimedia\Rdbms\Database::tableName
119 public function testTableName( $expected, $table, $format, array $alias = null ) {
121 $this->db
->setTableAliases( [ $table => $alias ] );
125 $this->db
->tableName( $table, $format ?
: 'quoted' )
129 public function provideTableNamesWithIndexClauseOrJOIN() {
131 'one-element array' => [
132 [ 'table' ], [], 'table '
135 [ 'table1', 'table2' ], [], 'table1,table2 '
138 [ 'table1', 'table2' ],
139 [ 'table2' => [ 'LEFT JOIN', 't1_id = t2_id' ] ],
140 'table1 LEFT JOIN table2 ON ((t1_id = t2_id))'
142 'real join with multiple conditionals' => [
143 [ 'table1', 'table2' ],
144 [ 'table2' => [ 'LEFT JOIN', [ 't1_id = t2_id', 't2_x = \'X\'' ] ] ],
145 'table1 LEFT JOIN table2 ON ((t1_id = t2_id) AND (t2_x = \'X\'))'
147 'join with parenthesized group' => [
148 [ 'table1', 'n' => [ 'table2', 'table3' ] ],
150 'table3' => [ 'JOIN', 't2_id = t3_id' ],
151 'n' => [ 'LEFT JOIN', 't1_id = t2_id' ],
153 'table1 LEFT JOIN (table2 JOIN table3 ON ((t2_id = t3_id))) ON ((t1_id = t2_id))'
155 'join with degenerate parenthesized group' => [
156 [ 'table1', 'n' => [ 't2' => 'table2' ] ],
158 'n' => [ 'LEFT JOIN', 't1_id = t2_id' ],
160 'table1 LEFT JOIN table2 t2 ON ((t1_id = t2_id))'
166 * @dataProvider provideTableNamesWithIndexClauseOrJOIN
167 * @covers Wikimedia\Rdbms\Database::tableNamesWithIndexClauseOrJOIN
169 public function testTableNamesWithIndexClauseOrJOIN( $tables, $join_conds, $expect ) {
170 $clause = TestingAccessWrapper
::newFromObject( $this->db
)
171 ->tableNamesWithIndexClauseOrJOIN( $tables, [], [], $join_conds );
172 $this->assertSame( $expect, $clause );
176 * @covers Wikimedia\Rdbms\Database::onTransactionCommitOrIdle
177 * @covers Wikimedia\Rdbms\Database::runOnTransactionIdleCallbacks
179 public function testTransactionIdle() {
182 $db->clearFlag( DBO_TRX
);
185 $callback = function ( $trigger, IDatabase
$db ) use ( &$flagSet, &$called ) {
187 $flagSet = $db->getFlag( DBO_TRX
);
190 $db->onTransactionCommitOrIdle( $callback, __METHOD__
);
191 $this->assertTrue( $called, 'Callback reached' );
192 $this->assertFalse( $flagSet, 'DBO_TRX off in callback' );
193 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX still default' );
197 $db->startAtomic( __METHOD__
);
198 $db->onTransactionCommitOrIdle( $callback, __METHOD__
);
199 $this->assertFalse( $called, 'Callback not reached during TRX' );
200 $db->endAtomic( __METHOD__
);
202 $this->assertTrue( $called, 'Callback reached after COMMIT' );
203 $this->assertFalse( $flagSet, 'DBO_TRX off in callback' );
204 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX restored to default' );
206 $db->clearFlag( DBO_TRX
);
207 $db->onTransactionCommitOrIdle(
208 function ( $trigger, IDatabase
$db ) {
209 $db->setFlag( DBO_TRX
);
213 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX restored to default' );
217 * @covers Wikimedia\Rdbms\Database::onTransactionCommitOrIdle
218 * @covers Wikimedia\Rdbms\Database::runOnTransactionIdleCallbacks
220 public function testTransactionIdle_TRX() {
221 $db = $this->getMockDB( [ 'isOpen', 'ping', 'getDBname' ] );
222 $db->method( 'isOpen' )->willReturn( true );
223 $db->method( 'ping' )->willReturn( true );
224 $db->method( 'getDBname' )->willReturn( '' );
225 $db->setFlag( DBO_TRX
);
227 $lbFactory = LBFactorySingle
::newFromConnection( $db );
228 // Ask for the connection so that LB sets internal state
229 // about this connection being the master connection
230 $lb = $lbFactory->getMainLB();
231 $conn = $lb->openConnection( $lb->getWriterIndex() );
232 $this->assertSame( $db, $conn, 'Same DB instance' );
233 $this->assertTrue( $db->getFlag( DBO_TRX
), 'DBO_TRX is set' );
237 $callback = function () use ( $db, &$flagSet, &$called ) {
239 $flagSet = $db->getFlag( DBO_TRX
);
242 $db->onTransactionCommitOrIdle( $callback, __METHOD__
);
243 $this->assertTrue( $called, 'Called when idle if DBO_TRX is set' );
244 $this->assertFalse( $flagSet, 'DBO_TRX off in callback' );
245 $this->assertTrue( $db->getFlag( DBO_TRX
), 'DBO_TRX still default' );
248 $lbFactory->beginMasterChanges( __METHOD__
);
249 $db->onTransactionCommitOrIdle( $callback, __METHOD__
);
250 $this->assertFalse( $called, 'Not called when lb-transaction is active' );
252 $lbFactory->commitMasterChanges( __METHOD__
);
253 $this->assertTrue( $called, 'Called when lb-transaction is committed' );
256 $lbFactory->beginMasterChanges( __METHOD__
);
257 $db->onTransactionCommitOrIdle( $callback, __METHOD__
);
258 $this->assertFalse( $called, 'Not called when lb-transaction is active' );
260 $lbFactory->rollbackMasterChanges( __METHOD__
);
261 $this->assertFalse( $called, 'Not called when lb-transaction is rolled back' );
263 $lbFactory->commitMasterChanges( __METHOD__
);
264 $this->assertFalse( $called, 'Not called in next round commit' );
266 $db->setFlag( DBO_TRX
);
268 $db->onTransactionCommitOrIdle( function () {
269 throw new RuntimeException( 'test' );
271 $this->fail( "Exception not thrown" );
272 } catch ( RuntimeException
$e ) {
273 $this->assertTrue( $db->getFlag( DBO_TRX
) );
278 * @covers Wikimedia\Rdbms\Database::onTransactionPreCommitOrIdle
279 * @covers Wikimedia\Rdbms\Database::runOnTransactionPreCommitCallbacks
281 public function testTransactionPreCommitOrIdle() {
282 $db = $this->getMockDB( [ 'isOpen' ] );
283 $db->method( 'isOpen' )->willReturn( true );
284 $db->clearFlag( DBO_TRX
);
286 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX is not set' );
289 $db->onTransactionPreCommitOrIdle(
290 function ( IDatabase
$db ) use ( &$called ) {
295 $this->assertTrue( $called, 'Called when idle' );
297 $db->begin( __METHOD__
);
299 $db->onTransactionPreCommitOrIdle(
300 function ( IDatabase
$db ) use ( &$called ) {
305 $this->assertFalse( $called, 'Not called when transaction is active' );
306 $db->commit( __METHOD__
);
307 $this->assertTrue( $called, 'Called when transaction is committed' );
311 * @covers Wikimedia\Rdbms\Database::onTransactionPreCommitOrIdle
312 * @covers Wikimedia\Rdbms\Database::runOnTransactionPreCommitCallbacks
314 public function testTransactionPreCommitOrIdle_TRX() {
315 $db = $this->getMockDB( [ 'isOpen', 'ping', 'getDBname' ] );
316 $db->method( 'isOpen' )->willReturn( true );
317 $db->method( 'ping' )->willReturn( true );
318 $db->method( 'getDBname' )->willReturn( 'unittest' );
319 $db->setFlag( DBO_TRX
);
321 $lbFactory = LBFactorySingle
::newFromConnection( $db );
322 // Ask for the connection so that LB sets internal state
323 // about this connection being the master connection
324 $lb = $lbFactory->getMainLB();
325 $conn = $lb->openConnection( $lb->getWriterIndex() );
326 $this->assertSame( $db, $conn, 'Same DB instance' );
328 $this->assertFalse( $lb->hasMasterChanges() );
329 $this->assertTrue( $db->getFlag( DBO_TRX
), 'DBO_TRX is set' );
331 $callback = function ( IDatabase
$db ) use ( &$called ) {
334 $db->onTransactionPreCommitOrIdle( $callback, __METHOD__
);
335 $this->assertTrue( $called, 'Called when idle if DBO_TRX is set' );
337 $lbFactory->commitMasterChanges();
338 $this->assertFalse( $called );
341 $lbFactory->beginMasterChanges( __METHOD__
);
342 $db->onTransactionPreCommitOrIdle( $callback, __METHOD__
);
343 $this->assertFalse( $called, 'Not called when lb-transaction is active' );
344 $lbFactory->commitMasterChanges( __METHOD__
);
345 $this->assertTrue( $called, 'Called when lb-transaction is committed' );
348 $lbFactory->beginMasterChanges( __METHOD__
);
349 $db->onTransactionPreCommitOrIdle( $callback, __METHOD__
);
350 $this->assertFalse( $called, 'Not called when lb-transaction is active' );
352 $lbFactory->rollbackMasterChanges( __METHOD__
);
353 $this->assertFalse( $called, 'Not called when lb-transaction is rolled back' );
355 $lbFactory->commitMasterChanges( __METHOD__
);
356 $this->assertFalse( $called, 'Not called in next round commit' );
360 * @covers Wikimedia\Rdbms\Database::onTransactionResolution
361 * @covers Wikimedia\Rdbms\Database::runOnTransactionIdleCallbacks
363 public function testTransactionResolution() {
366 $db->clearFlag( DBO_TRX
);
367 $db->begin( __METHOD__
);
369 $db->onTransactionResolution( function ( $trigger, IDatabase
$db ) use ( &$called ) {
371 $db->setFlag( DBO_TRX
);
373 $db->commit( __METHOD__
);
374 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX restored to default' );
375 $this->assertTrue( $called, 'Callback reached' );
377 $db->clearFlag( DBO_TRX
);
378 $db->begin( __METHOD__
);
380 $db->onTransactionResolution( function ( $trigger, IDatabase
$db ) use ( &$called ) {
382 $db->setFlag( DBO_TRX
);
384 $db->rollback( __METHOD__
);
385 $this->assertFalse( $db->getFlag( DBO_TRX
), 'DBO_TRX restored to default' );
386 $this->assertTrue( $called, 'Callback reached' );
390 * @covers Wikimedia\Rdbms\Database::setTransactionListener
392 public function testTransactionListener() {
395 $db->setTransactionListener( 'ping', function () use ( $db, &$called ) {
400 $db->begin( __METHOD__
);
401 $db->commit( __METHOD__
);
402 $this->assertTrue( $called, 'Callback reached' );
405 $db->begin( __METHOD__
);
406 $db->commit( __METHOD__
);
407 $this->assertTrue( $called, 'Callback still reached' );
410 $db->begin( __METHOD__
);
411 $db->rollback( __METHOD__
);
412 $this->assertTrue( $called, 'Callback reached' );
414 $db->setTransactionListener( 'ping', null );
416 $db->begin( __METHOD__
);
417 $db->commit( __METHOD__
);
418 $this->assertFalse( $called, 'Callback not reached' );
422 * Use this mock instead of DatabaseTestHelper for cases where
423 * DatabaseTestHelper is too inflexibile due to mocking too much
424 * or being too restrictive about fname matching (e.g. for tests
425 * that assert behaviour when the name is a mismatch, we need to
426 * catch the error here instead of there).
430 private function getMockDB( $methods = [] ) {
431 static $abstractMethods = [
432 'fetchAffectedRowCount',
436 'fetchObject', 'fetchRow',
437 'fieldInfo', 'fieldName',
438 'getSoftwareLink', 'getServerVersion',
442 'lastError', 'lastErrno',
443 'numFields', 'numRows',
448 $db = $this->getMockBuilder( Database
::class )
449 ->disableOriginalConstructor()
450 ->setMethods( array_values( array_unique( array_merge(
455 $wdb = TestingAccessWrapper
::newFromObject( $db );
456 $wdb->trxProfiler
= new TransactionProfiler();
457 $wdb->connLogger
= new \Psr\Log\
NullLogger();
458 $wdb->queryLogger
= new \Psr\Log\
NullLogger();
459 $wdb->currentDomain
= DatabaseDomain
::newUnspecified();
464 * @covers Wikimedia\Rdbms\Database::flushSnapshot
466 public function testFlushSnapshot() {
467 $db = $this->getMockDB( [ 'isOpen' ] );
468 $db->method( 'isOpen' )->willReturn( true );
470 $db->flushSnapshot( __METHOD__
); // ok
471 $db->flushSnapshot( __METHOD__
); // ok
473 $db->setFlag( DBO_TRX
, $db::REMEMBER_PRIOR
);
474 $db->query( 'SELECT 1', __METHOD__
);
475 $this->assertTrue( (bool)$db->trxLevel(), "Transaction started." );
476 $db->flushSnapshot( __METHOD__
); // ok
477 $db->restoreFlags( $db::RESTORE_PRIOR
);
479 $this->assertFalse( (bool)$db->trxLevel(), "Transaction cleared." );
483 * @covers Wikimedia\Rdbms\Database::getScopedLockAndFlush
484 * @covers Wikimedia\Rdbms\Database::lock
485 * @covers Wikimedia\Rdbms\Database::unlock
486 * @covers Wikimedia\Rdbms\Database::lockIsFree
488 public function testGetScopedLock() {
489 $db = $this->getMockDB( [ 'isOpen', 'getDBname' ] );
490 $db->method( 'isOpen' )->willReturn( true );
491 $db->method( 'getDBname' )->willReturn( 'unittest' );
493 $this->assertEquals( 0, $db->trxLevel() );
494 $this->assertEquals( true, $db->lockIsFree( 'x', __METHOD__
) );
495 $this->assertEquals( true, $db->lock( 'x', __METHOD__
) );
496 $this->assertEquals( false, $db->lockIsFree( 'x', __METHOD__
) );
497 $this->assertEquals( true, $db->unlock( 'x', __METHOD__
) );
498 $this->assertEquals( true, $db->lockIsFree( 'x', __METHOD__
) );
499 $this->assertEquals( 0, $db->trxLevel() );
501 $db->setFlag( DBO_TRX
);
502 $this->assertEquals( true, $db->lockIsFree( 'x', __METHOD__
) );
503 $this->assertEquals( true, $db->lock( 'x', __METHOD__
) );
504 $this->assertEquals( false, $db->lockIsFree( 'x', __METHOD__
) );
505 $this->assertEquals( true, $db->unlock( 'x', __METHOD__
) );
506 $this->assertEquals( true, $db->lockIsFree( 'x', __METHOD__
) );
507 $db->clearFlag( DBO_TRX
);
509 // Pending writes with DBO_TRX
510 $this->assertEquals( 0, $db->trxLevel() );
511 $this->assertTrue( $db->lockIsFree( 'meow', __METHOD__
) );
512 $db->setFlag( DBO_TRX
);
513 $db->query( "DELETE FROM test WHERE t = 1" ); // trigger DBO_TRX transaction before lock
515 $lock = $db->getScopedLockAndFlush( 'meow', __METHOD__
, 1 );
516 $this->fail( "Exception not reached" );
517 } catch ( DBUnexpectedError
$e ) {
518 $this->assertEquals( 1, $db->trxLevel(), "Transaction not committed." );
519 $this->assertTrue( $db->lockIsFree( 'meow', __METHOD__
), 'Lock not acquired' );
521 $db->rollback( __METHOD__
, IDatabase
::FLUSHING_ALL_PEERS
);
522 // Pending writes without DBO_TRX
523 $db->clearFlag( DBO_TRX
);
524 $this->assertEquals( 0, $db->trxLevel() );
525 $this->assertTrue( $db->lockIsFree( 'meow2', __METHOD__
) );
526 $db->begin( __METHOD__
);
527 $db->query( "DELETE FROM test WHERE t = 1" ); // trigger DBO_TRX transaction before lock
529 $lock = $db->getScopedLockAndFlush( 'meow2', __METHOD__
, 1 );
530 $this->fail( "Exception not reached" );
531 } catch ( DBUnexpectedError
$e ) {
532 $this->assertEquals( 1, $db->trxLevel(), "Transaction not committed." );
533 $this->assertTrue( $db->lockIsFree( 'meow2', __METHOD__
), 'Lock not acquired' );
535 $db->rollback( __METHOD__
);
536 // No pending writes, with DBO_TRX
537 $db->setFlag( DBO_TRX
);
538 $this->assertEquals( 0, $db->trxLevel() );
539 $this->assertTrue( $db->lockIsFree( 'wuff', __METHOD__
) );
540 $db->query( "SELECT 1", __METHOD__
);
541 $this->assertEquals( 1, $db->trxLevel() );
542 $lock = $db->getScopedLockAndFlush( 'wuff', __METHOD__
, 1 );
543 $this->assertEquals( 0, $db->trxLevel() );
544 $this->assertFalse( $db->lockIsFree( 'wuff', __METHOD__
), 'Lock already acquired' );
545 $db->rollback( __METHOD__
, IDatabase
::FLUSHING_ALL_PEERS
);
546 // No pending writes, without DBO_TRX
547 $db->clearFlag( DBO_TRX
);
548 $this->assertEquals( 0, $db->trxLevel() );
549 $this->assertTrue( $db->lockIsFree( 'wuff2', __METHOD__
) );
550 $db->begin( __METHOD__
);
552 $lock = $db->getScopedLockAndFlush( 'wuff2', __METHOD__
, 1 );
553 $this->fail( "Exception not reached" );
554 } catch ( DBUnexpectedError
$e ) {
555 $this->assertEquals( 1, $db->trxLevel(), "Transaction not committed." );
556 $this->assertFalse( $db->lockIsFree( 'wuff2', __METHOD__
), 'Lock not acquired' );
558 $db->rollback( __METHOD__
);
562 * @covers Wikimedia\Rdbms\Database::getFlag
563 * @covers Wikimedia\Rdbms\Database::setFlag
564 * @covers Wikimedia\Rdbms\Database::restoreFlags
566 public function testFlagSetting() {
568 $origTrx = $db->getFlag( DBO_TRX
);
569 $origSsl = $db->getFlag( DBO_SSL
);
572 ?
$db->clearFlag( DBO_TRX
, $db::REMEMBER_PRIOR
)
573 : $db->setFlag( DBO_TRX
, $db::REMEMBER_PRIOR
);
574 $this->assertEquals( !$origTrx, $db->getFlag( DBO_TRX
) );
577 ?
$db->clearFlag( DBO_SSL
, $db::REMEMBER_PRIOR
)
578 : $db->setFlag( DBO_SSL
, $db::REMEMBER_PRIOR
);
579 $this->assertEquals( !$origSsl, $db->getFlag( DBO_SSL
) );
581 $db->restoreFlags( $db::RESTORE_INITIAL
);
582 $this->assertEquals( $origTrx, $db->getFlag( DBO_TRX
) );
583 $this->assertEquals( $origSsl, $db->getFlag( DBO_SSL
) );
586 ?
$db->clearFlag( DBO_TRX
, $db::REMEMBER_PRIOR
)
587 : $db->setFlag( DBO_TRX
, $db::REMEMBER_PRIOR
);
589 ?
$db->clearFlag( DBO_SSL
, $db::REMEMBER_PRIOR
)
590 : $db->setFlag( DBO_SSL
, $db::REMEMBER_PRIOR
);
593 $this->assertEquals( $origSsl, $db->getFlag( DBO_SSL
) );
594 $this->assertEquals( !$origTrx, $db->getFlag( DBO_TRX
) );
597 $this->assertEquals( $origSsl, $db->getFlag( DBO_SSL
) );
598 $this->assertEquals( $origTrx, $db->getFlag( DBO_TRX
) );
602 * @expectedException UnexpectedValueException
603 * @covers Wikimedia\Rdbms\Database::setFlag
605 public function testDBOIgnoreSet() {
606 $db = $this->getMockBuilder( DatabaseMysqli
::class )
607 ->disableOriginalConstructor()
611 $db->setFlag( Database
::DBO_IGNORE
);
615 * @expectedException UnexpectedValueException
616 * @covers Wikimedia\Rdbms\Database::clearFlag
618 public function testDBOIgnoreClear() {
619 $db = $this->getMockBuilder( DatabaseMysqli
::class )
620 ->disableOriginalConstructor()
624 $db->clearFlag( Database
::DBO_IGNORE
);
628 * @covers Wikimedia\Rdbms\Database::tablePrefix
629 * @covers Wikimedia\Rdbms\Database::dbSchema
631 public function testSchemaAndPrefixMutators() {
632 $old = $this->db
->tablePrefix();
633 $oldDomain = $this->db
->getDomainId();
634 $this->assertInternalType( 'string', $old, 'Prefix is string' );
635 $this->assertSame( $old, $this->db
->tablePrefix(), "Prefix unchanged" );
636 $this->assertSame( $old, $this->db
->tablePrefix( 'xxx' ) );
637 $this->assertSame( 'xxx', $this->db
->tablePrefix(), "Prefix set" );
638 $this->db
->tablePrefix( $old );
639 $this->assertNotEquals( 'xxx', $this->db
->tablePrefix() );
640 $this->assertSame( $oldDomain, $this->db
->getDomainId() );
642 $old = $this->db
->dbSchema();
643 $oldDomain = $this->db
->getDomainId();
644 $this->assertInternalType( 'string', $old, 'Schema is string' );
645 $this->assertSame( $old, $this->db
->dbSchema(), "Schema unchanged" );
646 $this->assertSame( $old, $this->db
->dbSchema( 'xxx' ) );
647 $this->assertSame( 'xxx', $this->db
->dbSchema(), "Schema set" );
648 $this->db
->dbSchema( $old );
649 $this->assertNotEquals( 'xxx', $this->db
->dbSchema() );
650 $this->assertSame( $oldDomain, $this->db
->getDomainId() );
654 * @covers Wikimedia\Rdbms\Database::selectDomain
656 public function testSelectDomain() {
657 $oldDomain = $this->db
->getDomainId();
658 $oldDatabase = $this->db
->getDBname();
659 $oldSchema = $this->db
->dbSchema();
660 $oldPrefix = $this->db
->tablePrefix();
662 $this->db
->selectDomain( 'testselectdb-xxx' );
663 $this->assertSame( 'testselectdb', $this->db
->getDBname() );
664 $this->assertSame( '', $this->db
->dbSchema() );
665 $this->assertSame( 'xxx', $this->db
->tablePrefix() );
667 $this->db
->selectDomain( $oldDomain );
668 $this->assertSame( $oldDatabase, $this->db
->getDBname() );
669 $this->assertSame( $oldSchema, $this->db
->dbSchema() );
670 $this->assertSame( $oldPrefix, $this->db
->tablePrefix() );
671 $this->assertSame( $oldDomain, $this->db
->getDomainId() );
673 $this->db
->selectDomain( 'testselectdb-schema-xxx' );
674 $this->assertSame( 'testselectdb', $this->db
->getDBname() );
675 $this->assertSame( 'schema', $this->db
->dbSchema() );
676 $this->assertSame( 'xxx', $this->db
->tablePrefix() );
678 $this->db
->selectDomain( $oldDomain );
679 $this->assertSame( $oldDatabase, $this->db
->getDBname() );
680 $this->assertSame( $oldSchema, $this->db
->dbSchema() );
681 $this->assertSame( $oldPrefix, $this->db
->tablePrefix() );
682 $this->assertSame( $oldDomain, $this->db
->getDomainId() );