3 use Wikimedia\Rdbms\LikeMatch
;
6 * Test the parts of the Database abstract class that deal
7 * with creating SQL text.
9 class DatabaseSQLTest
extends PHPUnit_Framework_TestCase
{
10 /** @var DatabaseTestHelper */
13 protected function setUp() {
15 $this->database
= new DatabaseTestHelper( __CLASS__
, [ 'cliMode' => true ] );
18 protected function assertLastSql( $sqlText ) {
21 $this->database
->getLastSqls()
25 protected function assertLastSqlDb( $sqlText, DatabaseTestHelper
$db ) {
26 $this->assertEquals( $sqlText, $db->getLastSqls() );
30 * @dataProvider provideSelect
31 * @covers Wikimedia\Rdbms\Database::select
32 * @covers Wikimedia\Rdbms\Database::selectSQLText
33 * @covers Wikimedia\Rdbms\Database::tableNamesWithIndexClauseOrJOIN
34 * @covers Wikimedia\Rdbms\Database::makeSelectOptions
35 * @covers Wikimedia\Rdbms\Database::makeOrderBy
36 * @covers Wikimedia\Rdbms\Database::makeGroupByWithHaving
38 public function testSelect( $sql, $sqlText ) {
39 $this->database
->select(
42 isset( $sql['conds'] ) ?
$sql['conds'] : [],
44 isset( $sql['options'] ) ?
$sql['options'] : [],
45 isset( $sql['join_conds'] ) ?
$sql['join_conds'] : []
47 $this->assertLastSql( $sqlText );
50 public static function provideSelect() {
55 'fields' => [ 'field', 'alias' => 'field2' ],
56 'conds' => [ 'alias' => 'text' ],
58 "SELECT field,field2 AS alias " .
60 "WHERE alias = 'text'"
65 'fields' => [ 'field', 'alias' => 'field2' ],
66 'conds' => [ 'alias' => 'text' ],
67 'options' => [ 'LIMIT' => 1, 'ORDER BY' => 'field' ],
69 "SELECT field,field2 AS alias " .
71 "WHERE alias = 'text' " .
77 'tables' => [ 'table', 't2' => 'table2' ],
78 'fields' => [ 'tid', 'field', 'alias' => 'field2', 't2.id' ],
79 'conds' => [ 'alias' => 'text' ],
80 'options' => [ 'LIMIT' => 1, 'ORDER BY' => 'field' ],
81 'join_conds' => [ 't2' => [
82 'LEFT JOIN', 'tid = t2.id'
85 "SELECT tid,field,field2 AS alias,t2.id " .
86 "FROM table LEFT JOIN table2 t2 ON ((tid = t2.id)) " .
87 "WHERE alias = 'text' " .
93 'tables' => [ 'table', 't2' => 'table2' ],
94 'fields' => [ 'tid', 'field', 'alias' => 'field2', 't2.id' ],
95 'conds' => [ 'alias' => 'text' ],
96 'options' => [ 'LIMIT' => 1, 'GROUP BY' => 'field', 'HAVING' => 'COUNT(*) > 1' ],
97 'join_conds' => [ 't2' => [
98 'LEFT JOIN', 'tid = t2.id'
101 "SELECT tid,field,field2 AS alias,t2.id " .
102 "FROM table LEFT JOIN table2 t2 ON ((tid = t2.id)) " .
103 "WHERE alias = 'text' " .
104 "GROUP BY field HAVING COUNT(*) > 1 " .
109 'tables' => [ 'table', 't2' => 'table2' ],
110 'fields' => [ 'tid', 'field', 'alias' => 'field2', 't2.id' ],
111 'conds' => [ 'alias' => 'text' ],
114 'GROUP BY' => [ 'field', 'field2' ],
115 'HAVING' => [ 'COUNT(*) > 1', 'field' => 1 ]
117 'join_conds' => [ 't2' => [
118 'LEFT JOIN', 'tid = t2.id'
121 "SELECT tid,field,field2 AS alias,t2.id " .
122 "FROM table LEFT JOIN table2 t2 ON ((tid = t2.id)) " .
123 "WHERE alias = 'text' " .
124 "GROUP BY field,field2 HAVING (COUNT(*) > 1) AND field = '1' " .
129 'tables' => [ 'table' ],
130 'fields' => [ 'alias' => 'field' ],
131 'conds' => [ 'alias' => [ 1, 2, 3, 4 ] ],
133 "SELECT field AS alias " .
135 "WHERE alias IN ('1','2','3','4')"
141 * @dataProvider provideUpdate
142 * @covers Wikimedia\Rdbms\Database::update
143 * @covers Wikimedia\Rdbms\Database::makeUpdateOptions
144 * @covers Wikimedia\Rdbms\Database::makeUpdateOptionsArray
146 public function testUpdate( $sql, $sqlText ) {
147 $this->database
->update(
152 isset( $sql['options'] ) ?
$sql['options'] : []
154 $this->assertLastSql( $sqlText );
157 public static function provideUpdate() {
162 'values' => [ 'field' => 'text', 'field2' => 'text2' ],
163 'conds' => [ 'alias' => 'text' ],
166 "SET field = 'text'" .
167 ",field2 = 'text2' " .
168 "WHERE alias = 'text'"
173 'values' => [ 'field = other', 'field2' => 'text2' ],
174 'conds' => [ 'id' => '1' ],
177 "SET field = other" .
178 ",field2 = 'text2' " .
184 'values' => [ 'field = other', 'field2' => 'text2' ],
188 "SET field = other" .
195 * @dataProvider provideDelete
196 * @covers Wikimedia\Rdbms\Database::delete
198 public function testDelete( $sql, $sqlText ) {
199 $this->database
->delete(
204 $this->assertLastSql( $sqlText );
207 public static function provideDelete() {
212 'conds' => [ 'alias' => 'text' ],
214 "DELETE FROM table " .
215 "WHERE alias = 'text'"
228 * @dataProvider provideUpsert
229 * @covers Wikimedia\Rdbms\Database::upsert
231 public function testUpsert( $sql, $sqlText ) {
232 $this->database
->upsert(
235 $sql['uniqueIndexes'],
239 $this->assertLastSql( $sqlText );
242 public static function provideUpsert() {
246 'table' => 'upsert_table',
247 'rows' => [ 'field' => 'text', 'field2' => 'text2' ],
248 'uniqueIndexes' => [ 'field' ],
249 'set' => [ 'field' => 'set' ],
252 "UPDATE upsert_table " .
253 "SET field = 'set' " .
254 "WHERE ((field = 'text')); " .
255 "INSERT IGNORE INTO upsert_table " .
257 "VALUES ('text','text2'); " .
264 * @dataProvider provideDeleteJoin
265 * @covers Wikimedia\Rdbms\Database::deleteJoin
267 public function testDeleteJoin( $sql, $sqlText ) {
268 $this->database
->deleteJoin(
276 $this->assertLastSql( $sqlText );
279 public static function provideDeleteJoin() {
283 'delTable' => 'table',
284 'joinTable' => 'table_join',
286 'joinVar' => 'field_join',
287 'conds' => [ 'alias' => 'text' ],
289 "DELETE FROM table " .
291 "SELECT field_join FROM table_join WHERE alias = 'text'" .
296 'delTable' => 'table',
297 'joinTable' => 'table_join',
299 'joinVar' => 'field_join',
302 "DELETE FROM table " .
304 "SELECT field_join FROM table_join " .
311 * @dataProvider provideInsert
312 * @covers Wikimedia\Rdbms\Database::insert
313 * @covers Wikimedia\Rdbms\Database::makeInsertOptions
315 public function testInsert( $sql, $sqlText ) {
316 $this->database
->insert(
320 isset( $sql['options'] ) ?
$sql['options'] : []
322 $this->assertLastSql( $sqlText );
325 public static function provideInsert() {
330 'rows' => [ 'field' => 'text', 'field2' => 2 ],
332 "INSERT INTO table " .
334 "VALUES ('text','2')"
339 'rows' => [ 'field' => 'text', 'field2' => 2 ],
340 'options' => 'IGNORE',
342 "INSERT IGNORE INTO table " .
344 "VALUES ('text','2')"
350 [ 'field' => 'text', 'field2' => 2 ],
351 [ 'field' => 'multi', 'field2' => 3 ],
353 'options' => 'IGNORE',
355 "INSERT IGNORE INTO table " .
365 * @dataProvider provideInsertSelect
366 * @covers Wikimedia\Rdbms\Database::insertSelect
367 * @covers Wikimedia\Rdbms\Database::nativeInsertSelect
369 public function testInsertSelect( $sql, $sqlTextNative, $sqlSelect, $sqlInsert ) {
370 $this->database
->insertSelect(
376 isset( $sql['insertOptions'] ) ?
$sql['insertOptions'] : [],
377 isset( $sql['selectOptions'] ) ?
$sql['selectOptions'] : [],
378 isset( $sql['selectJoinConds'] ) ?
$sql['selectJoinConds'] : []
380 $this->assertLastSql( $sqlTextNative );
382 $dbWeb = new DatabaseTestHelper( __CLASS__
, [ 'cliMode' => false ] );
383 $dbWeb->forceNextResult( [
384 array_flip( array_keys( $sql['varMap'] ) )
386 $dbWeb->insertSelect(
392 isset( $sql['insertOptions'] ) ?
$sql['insertOptions'] : [],
393 isset( $sql['selectOptions'] ) ?
$sql['selectOptions'] : [],
394 isset( $sql['selectJoinConds'] ) ?
$sql['selectJoinConds'] : []
396 $this->assertLastSqlDb( implode( '; ', [ $sqlSelect, $sqlInsert ] ), $dbWeb );
399 public static function provideInsertSelect() {
403 'destTable' => 'insert_table',
404 'srcTable' => 'select_table',
405 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
408 "INSERT INTO insert_table " .
409 "(field_insert,field) " .
410 "SELECT field_select,field2 " .
411 "FROM select_table WHERE *",
412 "SELECT field_select AS field_insert,field2 AS field " .
413 "FROM select_table WHERE * FOR UPDATE",
414 "INSERT INTO insert_table (field_insert,field) VALUES ('0','1')"
418 'destTable' => 'insert_table',
419 'srcTable' => 'select_table',
420 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
421 'conds' => [ 'field' => 2 ],
423 "INSERT INTO insert_table " .
424 "(field_insert,field) " .
425 "SELECT field_select,field2 " .
426 "FROM select_table " .
428 "SELECT field_select AS field_insert,field2 AS field FROM " .
429 "select_table WHERE field = '2' FOR UPDATE",
430 "INSERT INTO insert_table (field_insert,field) VALUES ('0','1')"
434 'destTable' => 'insert_table',
435 'srcTable' => 'select_table',
436 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
437 'conds' => [ 'field' => 2 ],
438 'insertOptions' => 'IGNORE',
439 'selectOptions' => [ 'ORDER BY' => 'field' ],
441 "INSERT IGNORE INTO insert_table " .
442 "(field_insert,field) " .
443 "SELECT field_select,field2 " .
444 "FROM select_table " .
445 "WHERE field = '2' " .
447 "SELECT field_select AS field_insert,field2 AS field " .
448 "FROM select_table WHERE field = '2' ORDER BY field FOR UPDATE",
449 "INSERT IGNORE INTO insert_table (field_insert,field) VALUES ('0','1')"
453 'destTable' => 'insert_table',
454 'srcTable' => [ 'select_table1', 'select_table2' ],
455 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
456 'conds' => [ 'field' => 2 ],
457 'selectOptions' => [ 'ORDER BY' => 'field', 'FORCE INDEX' => [ 'select_table1' => 'index1' ] ],
458 'selectJoinConds' => [
459 'select_table2' => [ 'LEFT JOIN', [ 'select_table1.foo = select_table2.bar' ] ],
462 "INSERT INTO insert_table " .
463 "(field_insert,field) " .
464 "SELECT field_select,field2 " .
465 "FROM select_table1 LEFT JOIN select_table2 ON ((select_table1.foo = select_table2.bar)) " .
466 "WHERE field = '2' " .
468 "SELECT field_select AS field_insert,field2 AS field " .
469 "FROM select_table1 LEFT JOIN select_table2 ON ((select_table1.foo = select_table2.bar)) " .
470 "WHERE field = '2' ORDER BY field FOR UPDATE",
471 "INSERT INTO insert_table (field_insert,field) VALUES ('0','1')"
477 * @dataProvider provideReplace
478 * @covers Wikimedia\Rdbms\Database::replace
480 public function testReplace( $sql, $sqlText ) {
481 $this->database
->replace(
483 $sql['uniqueIndexes'],
487 $this->assertLastSql( $sqlText );
490 public static function provideReplace() {
494 'table' => 'replace_table',
495 'uniqueIndexes' => [ 'field' ],
496 'rows' => [ 'field' => 'text', 'field2' => 'text2' ],
498 "DELETE FROM replace_table " .
499 "WHERE ( field='text' ); " .
500 "INSERT INTO replace_table " .
502 "VALUES ('text','text2')"
506 'table' => 'module_deps',
507 'uniqueIndexes' => [ [ 'md_module', 'md_skin' ] ],
509 'md_module' => 'module',
514 "DELETE FROM module_deps " .
515 "WHERE ( md_module='module' AND md_skin='skin' ); " .
516 "INSERT INTO module_deps " .
517 "(md_module,md_skin,md_deps) " .
518 "VALUES ('module','skin','deps')"
522 'table' => 'module_deps',
523 'uniqueIndexes' => [ [ 'md_module', 'md_skin' ] ],
526 'md_module' => 'module',
530 'md_module' => 'module2',
531 'md_skin' => 'skin2',
532 'md_deps' => 'deps2',
536 "DELETE FROM module_deps " .
537 "WHERE ( md_module='module' AND md_skin='skin' ); " .
538 "INSERT INTO module_deps " .
539 "(md_module,md_skin,md_deps) " .
540 "VALUES ('module','skin','deps'); " .
541 "DELETE FROM module_deps " .
542 "WHERE ( md_module='module2' AND md_skin='skin2' ); " .
543 "INSERT INTO module_deps " .
544 "(md_module,md_skin,md_deps) " .
545 "VALUES ('module2','skin2','deps2')"
549 'table' => 'module_deps',
550 'uniqueIndexes' => [ 'md_module', 'md_skin' ],
553 'md_module' => 'module',
557 'md_module' => 'module2',
558 'md_skin' => 'skin2',
559 'md_deps' => 'deps2',
563 "DELETE FROM module_deps " .
564 "WHERE ( md_module='module' ) OR ( md_skin='skin' ); " .
565 "INSERT INTO module_deps " .
566 "(md_module,md_skin,md_deps) " .
567 "VALUES ('module','skin','deps'); " .
568 "DELETE FROM module_deps " .
569 "WHERE ( md_module='module2' ) OR ( md_skin='skin2' ); " .
570 "INSERT INTO module_deps " .
571 "(md_module,md_skin,md_deps) " .
572 "VALUES ('module2','skin2','deps2')"
576 'table' => 'module_deps',
577 'uniqueIndexes' => [],
579 'md_module' => 'module',
584 "INSERT INTO module_deps " .
585 "(md_module,md_skin,md_deps) " .
586 "VALUES ('module','skin','deps')"
592 * @dataProvider provideNativeReplace
593 * @covers Wikimedia\Rdbms\Database::nativeReplace
595 public function testNativeReplace( $sql, $sqlText ) {
596 $this->database
->nativeReplace(
601 $this->assertLastSql( $sqlText );
604 public static function provideNativeReplace() {
608 'table' => 'replace_table',
609 'rows' => [ 'field' => 'text', 'field2' => 'text2' ],
611 "REPLACE INTO replace_table " .
613 "VALUES ('text','text2')"
619 * @dataProvider provideConditional
620 * @covers Wikimedia\Rdbms\Database::conditional
622 public function testConditional( $sql, $sqlText ) {
623 $this->assertEquals( trim( $this->database
->conditional(
630 public static function provideConditional() {
634 'conds' => [ 'field' => 'text' ],
638 "(CASE WHEN field = 'text' THEN 1 ELSE NULL END)"
642 'conds' => [ 'field' => 'text', 'field2' => 'anothertext' ],
646 "(CASE WHEN field = 'text' AND field2 = 'anothertext' THEN 1 ELSE NULL END)"
650 'conds' => 'field=1',
654 "(CASE WHEN field=1 THEN 1 ELSE NULL END)"
660 * @dataProvider provideBuildConcat
661 * @covers Wikimedia\Rdbms\Database::buildConcat
663 public function testBuildConcat( $stringList, $sqlText ) {
664 $this->assertEquals( trim( $this->database
->buildConcat(
669 public static function provideBuildConcat() {
672 [ 'field', 'field2' ],
673 "CONCAT(field,field2)"
676 [ "'test'", 'field2' ],
677 "CONCAT('test',field2)"
683 * @dataProvider provideBuildLike
684 * @covers Wikimedia\Rdbms\Database::buildLike
685 * @covers Wikimedia\Rdbms\Database::escapeLikeInternal
687 public function testBuildLike( $array, $sqlText ) {
688 $this->assertEquals( trim( $this->database
->buildLike(
693 public static function provideBuildLike() {
697 "LIKE 'text' ESCAPE '`'"
700 [ 'text', new LikeMatch( '%' ) ],
701 "LIKE 'text%' ESCAPE '`'"
704 [ 'text', new LikeMatch( '%' ), 'text2' ],
705 "LIKE 'text%text2' ESCAPE '`'"
708 [ 'text', new LikeMatch( '_' ) ],
709 "LIKE 'text_' ESCAPE '`'"
713 "LIKE 'more`_text' ESCAPE '`'"
716 [ 'C:\\Windows\\', new LikeMatch( '%' ) ],
717 "LIKE 'C:\\Windows\\%' ESCAPE '`'"
720 [ 'accent`_test`', new LikeMatch( '%' ) ],
721 "LIKE 'accent```_test``%' ESCAPE '`'"
727 * @dataProvider provideUnionQueries
728 * @covers Wikimedia\Rdbms\Database::unionQueries
730 public function testUnionQueries( $sql, $sqlText ) {
731 $this->assertEquals( trim( $this->database
->unionQueries(
737 public static function provideUnionQueries() {
741 'sqls' => [ 'RAW SQL', 'RAW2SQL' ],
744 "(RAW SQL) UNION ALL (RAW2SQL)"
748 'sqls' => [ 'RAW SQL', 'RAW2SQL' ],
751 "(RAW SQL) UNION (RAW2SQL)"
755 'sqls' => [ 'RAW SQL', 'RAW2SQL', 'RAW3SQL' ],
758 "(RAW SQL) UNION (RAW2SQL) UNION (RAW3SQL)"
764 * @dataProvider provideUnionConditionPermutations
765 * @covers Wikimedia\Rdbms\Database::unionConditionPermutations
767 public function testUnionConditionPermutations( $params, $expect ) {
768 if ( isset( $params['unionSupportsOrderAndLimit'] ) ) {
769 $this->database
->setUnionSupportsOrderAndLimit( $params['unionSupportsOrderAndLimit'] );
772 $sql = trim( $this->database
->unionConditionPermutations(
775 $params['permute_conds'],
776 isset( $params['extra_conds'] ) ?
$params['extra_conds'] : '',
778 isset( $params['options'] ) ?
$params['options'] : [],
779 isset( $params['join_conds'] ) ?
$params['join_conds'] : []
781 $this->assertEquals( $expect, $sql );
784 public static function provideUnionConditionPermutations() {
786 // @codingStandardsIgnoreStart Generic.Files.LineLength.TooLong
789 'table' => [ 'table1', 'table2' ],
790 'vars' => [ 'field1', 'alias' => 'field2' ],
792 'field3' => [ 1, 2, 3 ],
793 'duplicates' => [ 4, 5, 4 ],
797 'extra_conds' => 'table2.bar > 23',
799 'ORDER BY' => [ 'field1', 'alias' ],
800 'INNER ORDER BY' => [ 'field1', 'field2' ],
804 'table2' => [ 'JOIN', 'table1.foo_id = table2.foo_id' ],
807 "(SELECT field1,field2 AS alias FROM table1 JOIN table2 ON ((table1.foo_id = table2.foo_id)) WHERE field3 = '1' AND duplicates = '4' AND single = '0' AND (table2.bar > 23) ORDER BY field1,field2 LIMIT 100 ) UNION ALL " .
808 "(SELECT field1,field2 AS alias FROM table1 JOIN table2 ON ((table1.foo_id = table2.foo_id)) WHERE field3 = '1' AND duplicates = '5' AND single = '0' AND (table2.bar > 23) ORDER BY field1,field2 LIMIT 100 ) UNION ALL " .
809 "(SELECT field1,field2 AS alias FROM table1 JOIN table2 ON ((table1.foo_id = table2.foo_id)) WHERE field3 = '2' AND duplicates = '4' AND single = '0' AND (table2.bar > 23) ORDER BY field1,field2 LIMIT 100 ) UNION ALL " .
810 "(SELECT field1,field2 AS alias FROM table1 JOIN table2 ON ((table1.foo_id = table2.foo_id)) WHERE field3 = '2' AND duplicates = '5' AND single = '0' AND (table2.bar > 23) ORDER BY field1,field2 LIMIT 100 ) UNION ALL " .
811 "(SELECT field1,field2 AS alias FROM table1 JOIN table2 ON ((table1.foo_id = table2.foo_id)) WHERE field3 = '3' AND duplicates = '4' AND single = '0' AND (table2.bar > 23) ORDER BY field1,field2 LIMIT 100 ) UNION ALL " .
812 "(SELECT field1,field2 AS alias FROM table1 JOIN table2 ON ((table1.foo_id = table2.foo_id)) WHERE field3 = '3' AND duplicates = '5' AND single = '0' AND (table2.bar > 23) ORDER BY field1,field2 LIMIT 100 ) " .
813 "ORDER BY field1,alias LIMIT 100"
818 'vars' => [ 'foo_id' ],
820 'bar' => [ 1, 2, 3 ],
822 'extra_conds' => [ 'baz' => null ],
825 'ORDER BY' => [ 'foo_id' ],
829 "(SELECT foo_id FROM foo WHERE bar = '1' AND baz IS NULL ORDER BY foo_id LIMIT 25 ) UNION " .
830 "(SELECT foo_id FROM foo WHERE bar = '2' AND baz IS NULL ORDER BY foo_id LIMIT 25 ) UNION " .
831 "(SELECT foo_id FROM foo WHERE bar = '3' AND baz IS NULL ORDER BY foo_id LIMIT 25 ) " .
832 "ORDER BY foo_id LIMIT 25"
837 'vars' => [ 'foo_id' ],
839 'bar' => [ 1, 2, 3 ],
841 'extra_conds' => [ 'baz' => null ],
844 'ORDER BY' => [ 'foo_id' ],
847 'unionSupportsOrderAndLimit' => false,
849 "(SELECT foo_id FROM foo WHERE bar = '1' AND baz IS NULL ) UNION " .
850 "(SELECT foo_id FROM foo WHERE bar = '2' AND baz IS NULL ) UNION " .
851 "(SELECT foo_id FROM foo WHERE bar = '3' AND baz IS NULL ) " .
852 "ORDER BY foo_id LIMIT 25"
857 'vars' => [ 'foo_id' ],
858 'permute_conds' => [],
859 'extra_conds' => [ 'baz' => null ],
861 'ORDER BY' => [ 'foo_id' ],
865 "SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY foo_id LIMIT 25"
870 'vars' => [ 'foo_id' ],
874 'extra_conds' => [ 'baz' => null ],
876 'ORDER BY' => [ 'foo_id' ],
880 "SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY foo_id LIMIT 25"
885 'vars' => [ 'foo_id' ],
890 'ORDER BY' => [ 'foo_id' ],
895 "SELECT foo_id FROM foo WHERE bar = '1' ORDER BY foo_id LIMIT 150,25"
900 'vars' => [ 'foo_id' ],
901 'permute_conds' => [],
902 'extra_conds' => [ 'baz' => null ],
904 'ORDER BY' => [ 'foo_id' ],
907 'INNER ORDER BY' => [ 'bar_id' ],
910 "(SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY bar_id LIMIT 175 ) ORDER BY foo_id LIMIT 150,25"
915 'vars' => [ 'foo_id' ],
916 'permute_conds' => [],
917 'extra_conds' => [ 'baz' => null ],
919 'ORDER BY' => [ 'foo_id' ],
922 'INNER ORDER BY' => [ 'bar_id' ],
924 'unionSupportsOrderAndLimit' => false,
926 "SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY foo_id LIMIT 150,25"
928 // @codingStandardsIgnoreEnd
933 * @covers Wikimedia\Rdbms\Database::commit
934 * @covers Wikimedia\Rdbms\Database::doCommit
936 public function testTransactionCommit() {
937 $this->database
->begin( __METHOD__
);
938 $this->database
->commit( __METHOD__
);
939 $this->assertLastSql( 'BEGIN; COMMIT' );
943 * @covers Wikimedia\Rdbms\Database::rollback
944 * @covers Wikimedia\Rdbms\Database::doRollback
946 public function testTransactionRollback() {
947 $this->database
->begin( __METHOD__
);
948 $this->database
->rollback( __METHOD__
);
949 $this->assertLastSql( 'BEGIN; ROLLBACK' );
953 * @covers Wikimedia\Rdbms\Database::dropTable
955 public function testDropTable() {
956 $this->database
->setExistingTables( [ 'table' ] );
957 $this->database
->dropTable( 'table', __METHOD__
);
958 $this->assertLastSql( 'DROP TABLE table CASCADE' );
962 * @covers Wikimedia\Rdbms\Database::dropTable
964 public function testDropNonExistingTable() {
966 $this->database
->dropTable( 'non_existing', __METHOD__
)
971 * @dataProvider provideMakeList
972 * @covers Wikimedia\Rdbms\Database::makeList
974 public function testMakeList( $list, $mode, $sqlText ) {
975 $this->assertEquals( trim( $this->database
->makeList(
980 public static function provideMakeList() {
983 [ 'value', 'value2' ],
988 [ 'field', 'field2' ],
993 [ 'field' => 'value', 'field2' => 'value2' ],
995 "field = 'value' AND field2 = 'value2'"
998 [ 'field' => null, "field2 != 'value2'" ],
1000 "field IS NULL AND (field2 != 'value2')"
1003 [ 'field' => [ 'value', null, 'value2' ], 'field2' => 'value2' ],
1005 "(field IN ('value','value2') OR field IS NULL) AND field2 = 'value2'"
1008 [ 'field' => [ null ], 'field2' => null ],
1010 "field IS NULL AND field2 IS NULL"
1013 [ 'field' => 'value', 'field2' => 'value2' ],
1015 "field = 'value' OR field2 = 'value2'"
1018 [ 'field' => 'value', 'field2' => null ],
1020 "field = 'value' OR field2 IS NULL"
1023 [ 'field' => [ 'value', 'value2' ], 'field2' => [ 'value' ] ],
1025 "field IN ('value','value2') OR field2 = 'value'"
1028 [ 'field' => [ null, 'value', null, 'value2' ], "field2 != 'value2'" ],
1030 "(field IN ('value','value2') OR field IS NULL) OR (field2 != 'value2')"
1033 [ 'field' => 'value', 'field2' => 'value2' ],
1035 "field = 'value',field2 = 'value2'"
1038 [ 'field' => 'value', 'field2' => null ],
1040 "field = 'value',field2 = NULL"
1043 [ 'field' => 'value', "field2 != 'value2'" ],
1045 "field = 'value',field2 != 'value2'"
1051 * @covers Wikimedia\Rdbms\Database::registerTempTableOperation
1053 public function testSessionTempTables() {
1054 $temp1 = $this->database
->tableName( 'tmp_table_1' );
1055 $temp2 = $this->database
->tableName( 'tmp_table_2' );
1056 $temp3 = $this->database
->tableName( 'tmp_table_3' );
1058 $this->database
->query( "CREATE TEMPORARY TABLE $temp1 LIKE orig_tbl", __METHOD__
);
1059 $this->database
->query( "CREATE TEMPORARY TABLE $temp2 LIKE orig_tbl", __METHOD__
);
1060 $this->database
->query( "CREATE TEMPORARY TABLE $temp3 LIKE orig_tbl", __METHOD__
);
1062 $this->assertTrue( $this->database
->tableExists( "tmp_table_1", __METHOD__
) );
1063 $this->assertTrue( $this->database
->tableExists( "tmp_table_2", __METHOD__
) );
1064 $this->assertTrue( $this->database
->tableExists( "tmp_table_3", __METHOD__
) );
1066 $this->database
->dropTable( 'tmp_table_1', __METHOD__
);
1067 $this->database
->dropTable( 'tmp_table_2', __METHOD__
);
1068 $this->database
->dropTable( 'tmp_table_3', __METHOD__
);
1070 $this->assertFalse( $this->database
->tableExists( "tmp_table_1", __METHOD__
) );
1071 $this->assertFalse( $this->database
->tableExists( "tmp_table_2", __METHOD__
) );
1072 $this->assertFalse( $this->database
->tableExists( "tmp_table_3", __METHOD__
) );
1074 $this->database
->query( "CREATE TEMPORARY TABLE tmp_table_1 LIKE orig_tbl", __METHOD__
);
1075 $this->database
->query( "CREATE TEMPORARY TABLE 'tmp_table_2' LIKE orig_tbl", __METHOD__
);
1076 $this->database
->query( "CREATE TEMPORARY TABLE `tmp_table_3` LIKE orig_tbl", __METHOD__
);
1078 $this->assertTrue( $this->database
->tableExists( "tmp_table_1", __METHOD__
) );
1079 $this->assertTrue( $this->database
->tableExists( "tmp_table_2", __METHOD__
) );
1080 $this->assertTrue( $this->database
->tableExists( "tmp_table_3", __METHOD__
) );
1082 $this->database
->query( "DROP TEMPORARY TABLE tmp_table_1 LIKE orig_tbl", __METHOD__
);
1083 $this->database
->query( "DROP TEMPORARY TABLE 'tmp_table_2' LIKE orig_tbl", __METHOD__
);
1084 $this->database
->query( "DROP TABLE `tmp_table_3` LIKE orig_tbl", __METHOD__
);
1086 $this->assertFalse( $this->database
->tableExists( "tmp_table_1", __METHOD__
) );
1087 $this->assertFalse( $this->database
->tableExists( "tmp_table_2", __METHOD__
) );
1088 $this->assertFalse( $this->database
->tableExists( "tmp_table_3", __METHOD__
) );