3 use Wikimedia\Rdbms\IDatabase
;
4 use Wikimedia\Rdbms\LikeMatch
;
5 use Wikimedia\Rdbms\Database
;
6 use Wikimedia\TestingAccessWrapper
;
7 use Wikimedia\Rdbms\DBTransactionStateError
;
8 use Wikimedia\Rdbms\DBUnexpectedError
;
9 use Wikimedia\Rdbms\DBTransactionError
;
12 * Test the parts of the Database abstract class that deal
13 * with creating SQL text.
15 class DatabaseSQLTest
extends PHPUnit\Framework\TestCase
{
17 use MediaWikiCoversValidator
;
18 use PHPUnit4And6Compat
;
20 /** @var DatabaseTestHelper|Database */
23 protected function setUp() {
25 $this->database
= new DatabaseTestHelper( __CLASS__
, [ 'cliMode' => true ] );
28 protected function assertLastSql( $sqlText ) {
31 $this->database
->getLastSqls()
35 protected function assertLastSqlDb( $sqlText, DatabaseTestHelper
$db ) {
36 $this->assertEquals( $sqlText, $db->getLastSqls() );
40 * @dataProvider provideSelect
41 * @covers Wikimedia\Rdbms\Database::select
42 * @covers Wikimedia\Rdbms\Database::selectSQLText
43 * @covers Wikimedia\Rdbms\Database::tableNamesWithIndexClauseOrJOIN
44 * @covers Wikimedia\Rdbms\Database::useIndexClause
45 * @covers Wikimedia\Rdbms\Database::ignoreIndexClause
46 * @covers Wikimedia\Rdbms\Database::makeSelectOptions
47 * @covers Wikimedia\Rdbms\Database::makeOrderBy
48 * @covers Wikimedia\Rdbms\Database::makeGroupByWithHaving
49 * @covers Wikimedia\Rdbms\Database::selectFieldsOrOptionsAggregate
50 * @covers Wikimedia\Rdbms\Database::selectOptionsIncludeLocking
52 public function testSelect( $sql, $sqlText ) {
53 $this->database
->select(
56 isset( $sql['conds'] ) ?
$sql['conds'] : [],
58 isset( $sql['options'] ) ?
$sql['options'] : [],
59 isset( $sql['join_conds'] ) ?
$sql['join_conds'] : []
61 $this->assertLastSql( $sqlText );
64 public static function provideSelect() {
69 'fields' => [ 'field', 'alias' => 'field2' ],
70 'conds' => [ 'alias' => 'text' ],
72 "SELECT field,field2 AS alias " .
74 "WHERE alias = 'text'"
79 'fields' => [ 'field', 'alias' => 'field2' ],
80 'conds' => 'alias = \'text\'',
82 "SELECT field,field2 AS alias " .
84 "WHERE alias = 'text'"
89 'fields' => [ 'field', 'alias' => 'field2' ],
92 "SELECT field,field2 AS alias " .
98 'fields' => [ 'field', 'alias' => 'field2' ],
101 "SELECT field,field2 AS alias " .
107 'fields' => [ 'field', 'alias' => 'field2' ],
108 'conds' => '0', // T188314
110 "SELECT field,field2 AS alias " .
116 // 'tables' with space prepended indicates pre-escaped table name
117 'tables' => ' table LEFT JOIN table2',
118 'fields' => [ 'field' ],
119 'conds' => [ 'field' => 'text' ],
121 "SELECT field FROM table LEFT JOIN table2 WHERE field = 'text'"
125 // Empty 'tables' is allowed
127 'fields' => [ 'SPECIAL_QUERY()' ],
129 "SELECT SPECIAL_QUERY()"
134 'fields' => [ 'field', 'alias' => 'field2' ],
135 'conds' => [ 'alias' => 'text' ],
136 'options' => [ 'LIMIT' => 1, 'ORDER BY' => 'field' ],
138 "SELECT field,field2 AS alias " .
140 "WHERE alias = 'text' " .
146 'tables' => [ 'table', 't2' => 'table2' ],
147 'fields' => [ 'tid', 'field', 'alias' => 'field2', 't2.id' ],
148 'conds' => [ 'alias' => 'text' ],
149 'options' => [ 'LIMIT' => 1, 'ORDER BY' => 'field' ],
150 'join_conds' => [ 't2' => [
151 'LEFT JOIN', 'tid = t2.id'
154 "SELECT tid,field,field2 AS alias,t2.id " .
155 "FROM table LEFT JOIN table2 t2 ON ((tid = t2.id)) " .
156 "WHERE alias = 'text' " .
162 'tables' => [ 'table', 't2' => 'table2' ],
163 'fields' => [ 'tid', 'field', 'alias' => 'field2', 't2.id' ],
164 'conds' => [ 'alias' => 'text' ],
165 'options' => [ 'LIMIT' => 1, 'GROUP BY' => 'field', 'HAVING' => 'COUNT(*) > 1' ],
166 'join_conds' => [ 't2' => [
167 'LEFT JOIN', 'tid = t2.id'
170 "SELECT tid,field,field2 AS alias,t2.id " .
171 "FROM table LEFT JOIN table2 t2 ON ((tid = t2.id)) " .
172 "WHERE alias = 'text' " .
173 "GROUP BY field HAVING COUNT(*) > 1 " .
178 'tables' => [ 'table', 't2' => 'table2' ],
179 'fields' => [ 'tid', 'field', 'alias' => 'field2', 't2.id' ],
180 'conds' => [ 'alias' => 'text' ],
183 'GROUP BY' => [ 'field', 'field2' ],
184 'HAVING' => [ 'COUNT(*) > 1', 'field' => 1 ]
186 'join_conds' => [ 't2' => [
187 'LEFT JOIN', 'tid = t2.id'
190 "SELECT tid,field,field2 AS alias,t2.id " .
191 "FROM table LEFT JOIN table2 t2 ON ((tid = t2.id)) " .
192 "WHERE alias = 'text' " .
193 "GROUP BY field,field2 HAVING (COUNT(*) > 1) AND field = '1' " .
198 'tables' => [ 'table' ],
199 'fields' => [ 'alias' => 'field' ],
200 'conds' => [ 'alias' => [ 1, 2, 3, 4 ] ],
202 "SELECT field AS alias " .
204 "WHERE alias IN ('1','2','3','4')"
209 'fields' => [ 'field' ],
210 'options' => [ 'USE INDEX' => [ 'table' => 'X' ] ],
213 "SELECT field FROM table"
218 'fields' => [ 'field' ],
219 'options' => [ 'IGNORE INDEX' => [ 'table' => 'X' ] ],
222 "SELECT field FROM table"
227 'fields' => [ 'field' ],
228 'options' => [ 'DISTINCT' ],
230 "SELECT DISTINCT field FROM table"
235 'fields' => [ 'field' ],
236 'options' => [ 'LOCK IN SHARE MODE' ],
238 "SELECT field FROM table LOCK IN SHARE MODE"
243 'fields' => [ 'field' ],
244 'options' => [ 'EXPLAIN' => true ],
246 'EXPLAIN SELECT field FROM table'
251 'fields' => [ 'field' ],
252 'options' => [ 'FOR UPDATE' ],
254 "SELECT field FROM table FOR UPDATE"
260 * @covers Wikimedia\Rdbms\Subquery
261 * @dataProvider provideSelectRowCount
265 public function testSelectRowCount( $sql, $sqlText ) {
266 $this->database
->selectRowCount(
269 isset( $sql['conds'] ) ?
$sql['conds'] : [],
271 isset( $sql['options'] ) ?
$sql['options'] : [],
272 isset( $sql['join_conds'] ) ?
$sql['join_conds'] : []
274 $this->assertLastSql( $sqlText );
277 public static function provideSelectRowCount() {
283 'conds' => [ 'field' => 'text' ],
285 "SELECT COUNT(*) AS rowcount FROM " .
286 "(SELECT 1 FROM table WHERE field = 'text' ) tmp_count"
291 'field' => [ 'column' ],
292 'conds' => [ 'field' => 'text' ],
294 "SELECT COUNT(*) AS rowcount FROM " .
295 "(SELECT 1 FROM table WHERE field = 'text' AND (column IS NOT NULL) ) tmp_count"
300 'field' => [ 'alias' => 'column' ],
301 'conds' => [ 'field' => 'text' ],
303 "SELECT COUNT(*) AS rowcount FROM " .
304 "(SELECT 1 FROM table WHERE field = 'text' AND (column IS NOT NULL) ) tmp_count"
309 'field' => [ 'alias' => 'column' ],
312 "SELECT COUNT(*) AS rowcount FROM " .
313 "(SELECT 1 FROM table WHERE (column IS NOT NULL) ) tmp_count"
318 'field' => [ 'alias' => 'column' ],
321 "SELECT COUNT(*) AS rowcount FROM " .
322 "(SELECT 1 FROM table WHERE (column IS NOT NULL) ) tmp_count"
327 'field' => [ 'alias' => 'column' ],
330 "SELECT COUNT(*) AS rowcount FROM " .
331 "(SELECT 1 FROM table WHERE (column IS NOT NULL) ) tmp_count"
336 'field' => [ 'alias' => 'column' ],
339 "SELECT COUNT(*) AS rowcount FROM " .
340 "(SELECT 1 FROM table WHERE (1) AND (column IS NOT NULL) ) tmp_count"
345 'field' => [ 'alias' => 'column' ],
348 "SELECT COUNT(*) AS rowcount FROM " .
349 "(SELECT 1 FROM table WHERE (0) AND (column IS NOT NULL) ) tmp_count"
355 * @dataProvider provideUpdate
356 * @covers Wikimedia\Rdbms\Database::update
357 * @covers Wikimedia\Rdbms\Database::makeUpdateOptions
358 * @covers Wikimedia\Rdbms\Database::makeUpdateOptionsArray
360 public function testUpdate( $sql, $sqlText ) {
361 $this->database
->update(
366 isset( $sql['options'] ) ?
$sql['options'] : []
368 $this->assertLastSql( $sqlText );
371 public static function provideUpdate() {
376 'values' => [ 'field' => 'text', 'field2' => 'text2' ],
377 'conds' => [ 'alias' => 'text' ],
380 "SET field = 'text'" .
381 ",field2 = 'text2' " .
382 "WHERE alias = 'text'"
387 'values' => [ 'field = other', 'field2' => 'text2' ],
388 'conds' => [ 'id' => '1' ],
391 "SET field = other" .
392 ",field2 = 'text2' " .
398 'values' => [ 'field = other', 'field2' => 'text2' ],
402 "SET field = other" .
409 * @dataProvider provideDelete
410 * @covers Wikimedia\Rdbms\Database::delete
412 public function testDelete( $sql, $sqlText ) {
413 $this->database
->delete(
418 $this->assertLastSql( $sqlText );
421 public static function provideDelete() {
426 'conds' => [ 'alias' => 'text' ],
428 "DELETE FROM table " .
429 "WHERE alias = 'text'"
442 * @dataProvider provideUpsert
443 * @covers Wikimedia\Rdbms\Database::upsert
445 public function testUpsert( $sql, $sqlText ) {
446 $this->database
->upsert(
449 $sql['uniqueIndexes'],
453 $this->assertLastSql( $sqlText );
456 public static function provideUpsert() {
460 'table' => 'upsert_table',
461 'rows' => [ 'field' => 'text', 'field2' => 'text2' ],
462 'uniqueIndexes' => [ 'field' ],
463 'set' => [ 'field' => 'set' ],
466 "UPDATE upsert_table " .
467 "SET field = 'set' " .
468 "WHERE ((field = 'text')); " .
469 "INSERT IGNORE INTO upsert_table " .
471 "VALUES ('text','text2'); " .
478 * @dataProvider provideDeleteJoin
479 * @covers Wikimedia\Rdbms\Database::deleteJoin
481 public function testDeleteJoin( $sql, $sqlText ) {
482 $this->database
->deleteJoin(
490 $this->assertLastSql( $sqlText );
493 public static function provideDeleteJoin() {
497 'delTable' => 'table',
498 'joinTable' => 'table_join',
500 'joinVar' => 'field_join',
501 'conds' => [ 'alias' => 'text' ],
503 "DELETE FROM table " .
505 "SELECT field_join FROM table_join WHERE alias = 'text'" .
510 'delTable' => 'table',
511 'joinTable' => 'table_join',
513 'joinVar' => 'field_join',
516 "DELETE FROM table " .
518 "SELECT field_join FROM table_join " .
525 * @dataProvider provideInsert
526 * @covers Wikimedia\Rdbms\Database::insert
527 * @covers Wikimedia\Rdbms\Database::makeInsertOptions
529 public function testInsert( $sql, $sqlText ) {
530 $this->database
->insert(
534 isset( $sql['options'] ) ?
$sql['options'] : []
536 $this->assertLastSql( $sqlText );
539 public static function provideInsert() {
544 'rows' => [ 'field' => 'text', 'field2' => 2 ],
546 "INSERT INTO table " .
548 "VALUES ('text','2')"
553 'rows' => [ 'field' => 'text', 'field2' => 2 ],
554 'options' => 'IGNORE',
556 "INSERT IGNORE INTO table " .
558 "VALUES ('text','2')"
564 [ 'field' => 'text', 'field2' => 2 ],
565 [ 'field' => 'multi', 'field2' => 3 ],
567 'options' => 'IGNORE',
569 "INSERT IGNORE INTO table " .
579 * @dataProvider provideInsertSelect
580 * @covers Wikimedia\Rdbms\Database::insertSelect
581 * @covers Wikimedia\Rdbms\Database::nativeInsertSelect
583 public function testInsertSelect( $sql, $sqlTextNative, $sqlSelect, $sqlInsert ) {
584 $this->database
->insertSelect(
590 isset( $sql['insertOptions'] ) ?
$sql['insertOptions'] : [],
591 isset( $sql['selectOptions'] ) ?
$sql['selectOptions'] : [],
592 isset( $sql['selectJoinConds'] ) ?
$sql['selectJoinConds'] : []
594 $this->assertLastSql( $sqlTextNative );
596 $dbWeb = new DatabaseTestHelper( __CLASS__
, [ 'cliMode' => false ] );
597 $dbWeb->forceNextResult( [
598 array_flip( array_keys( $sql['varMap'] ) )
600 $dbWeb->insertSelect(
606 isset( $sql['insertOptions'] ) ?
$sql['insertOptions'] : [],
607 isset( $sql['selectOptions'] ) ?
$sql['selectOptions'] : [],
608 isset( $sql['selectJoinConds'] ) ?
$sql['selectJoinConds'] : []
610 $this->assertLastSqlDb( implode( '; ', [ $sqlSelect, 'BEGIN', $sqlInsert, 'COMMIT' ] ), $dbWeb );
613 public static function provideInsertSelect() {
617 'destTable' => 'insert_table',
618 'srcTable' => 'select_table',
619 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
622 "INSERT INTO insert_table " .
623 "(field_insert,field) " .
624 "SELECT field_select,field2 " .
625 "FROM select_table WHERE *",
626 "SELECT field_select AS field_insert,field2 AS field " .
627 "FROM select_table WHERE * FOR UPDATE",
628 "INSERT INTO insert_table (field_insert,field) VALUES ('0','1')"
632 'destTable' => 'insert_table',
633 'srcTable' => 'select_table',
634 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
635 'conds' => [ 'field' => 2 ],
637 "INSERT INTO insert_table " .
638 "(field_insert,field) " .
639 "SELECT field_select,field2 " .
640 "FROM select_table " .
642 "SELECT field_select AS field_insert,field2 AS field FROM " .
643 "select_table WHERE field = '2' FOR UPDATE",
644 "INSERT INTO insert_table (field_insert,field) VALUES ('0','1')"
648 'destTable' => 'insert_table',
649 'srcTable' => 'select_table',
650 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
651 'conds' => [ 'field' => 2 ],
652 'insertOptions' => 'IGNORE',
653 'selectOptions' => [ 'ORDER BY' => 'field' ],
655 "INSERT IGNORE INTO insert_table " .
656 "(field_insert,field) " .
657 "SELECT field_select,field2 " .
658 "FROM select_table " .
659 "WHERE field = '2' " .
661 "SELECT field_select AS field_insert,field2 AS field " .
662 "FROM select_table WHERE field = '2' ORDER BY field FOR UPDATE",
663 "INSERT IGNORE INTO insert_table (field_insert,field) VALUES ('0','1')"
667 'destTable' => 'insert_table',
668 'srcTable' => [ 'select_table1', 'select_table2' ],
669 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
670 'conds' => [ 'field' => 2 ],
671 'insertOptions' => [ 'NO_AUTO_COLUMNS' ],
672 'selectOptions' => [ 'ORDER BY' => 'field', 'FORCE INDEX' => [ 'select_table1' => 'index1' ] ],
673 'selectJoinConds' => [
674 'select_table2' => [ 'LEFT JOIN', [ 'select_table1.foo = select_table2.bar' ] ],
677 "INSERT INTO insert_table " .
678 "(field_insert,field) " .
679 "SELECT field_select,field2 " .
680 "FROM select_table1 LEFT JOIN select_table2 ON ((select_table1.foo = select_table2.bar)) " .
681 "WHERE field = '2' " .
683 "SELECT field_select AS field_insert,field2 AS field " .
684 "FROM select_table1 LEFT JOIN select_table2 ON ((select_table1.foo = select_table2.bar)) " .
685 "WHERE field = '2' ORDER BY field FOR UPDATE",
686 "INSERT INTO insert_table (field_insert,field) VALUES ('0','1')"
691 public function testInsertSelectBatching() {
692 $dbWeb = new DatabaseTestHelper( __CLASS__
, [ 'cliMode' => false ] );
694 for ( $i = 0; $i <= 25000; $i++
) {
695 $rows[] = [ 'field' => $i ];
697 $dbWeb->forceNextResult( $rows );
698 $dbWeb->insertSelect(
701 [ 'field' => 'field2' ],
705 $this->assertLastSqlDb( implode( '; ', [
706 'SELECT field2 AS field FROM select_table WHERE * FOR UPDATE',
708 "INSERT INTO insert_table (field) VALUES ('" . implode( "'),('", range( 0, 9999 ) ) . "')",
709 "INSERT INTO insert_table (field) VALUES ('" . implode( "'),('", range( 10000, 19999 ) ) . "')",
710 "INSERT INTO insert_table (field) VALUES ('" . implode( "'),('", range( 20000, 25000 ) ) . "')",
716 * @dataProvider provideReplace
717 * @covers Wikimedia\Rdbms\Database::replace
719 public function testReplace( $sql, $sqlText ) {
720 $this->database
->replace(
722 $sql['uniqueIndexes'],
726 $this->assertLastSql( $sqlText );
729 public static function provideReplace() {
733 'table' => 'replace_table',
734 'uniqueIndexes' => [ 'field' ],
735 'rows' => [ 'field' => 'text', 'field2' => 'text2' ],
737 "BEGIN; DELETE FROM replace_table " .
738 "WHERE (field = 'text'); " .
739 "INSERT INTO replace_table " .
741 "VALUES ('text','text2'); COMMIT"
745 'table' => 'module_deps',
746 'uniqueIndexes' => [ [ 'md_module', 'md_skin' ] ],
748 'md_module' => 'module',
753 "BEGIN; DELETE FROM module_deps " .
754 "WHERE (md_module = 'module' AND md_skin = 'skin'); " .
755 "INSERT INTO module_deps " .
756 "(md_module,md_skin,md_deps) " .
757 "VALUES ('module','skin','deps'); COMMIT"
761 'table' => 'module_deps',
762 'uniqueIndexes' => [ [ 'md_module', 'md_skin' ] ],
765 'md_module' => 'module',
769 'md_module' => 'module2',
770 'md_skin' => 'skin2',
771 'md_deps' => 'deps2',
775 "BEGIN; DELETE FROM module_deps " .
776 "WHERE (md_module = 'module' AND md_skin = 'skin'); " .
777 "INSERT INTO module_deps " .
778 "(md_module,md_skin,md_deps) " .
779 "VALUES ('module','skin','deps'); " .
780 "DELETE FROM module_deps " .
781 "WHERE (md_module = 'module2' AND md_skin = 'skin2'); " .
782 "INSERT INTO module_deps " .
783 "(md_module,md_skin,md_deps) " .
784 "VALUES ('module2','skin2','deps2'); COMMIT"
788 'table' => 'module_deps',
789 'uniqueIndexes' => [ 'md_module', 'md_skin' ],
792 'md_module' => 'module',
796 'md_module' => 'module2',
797 'md_skin' => 'skin2',
798 'md_deps' => 'deps2',
802 "BEGIN; DELETE FROM module_deps " .
803 "WHERE (md_module = 'module') OR (md_skin = 'skin'); " .
804 "INSERT INTO module_deps " .
805 "(md_module,md_skin,md_deps) " .
806 "VALUES ('module','skin','deps'); " .
807 "DELETE FROM module_deps " .
808 "WHERE (md_module = 'module2') OR (md_skin = 'skin2'); " .
809 "INSERT INTO module_deps " .
810 "(md_module,md_skin,md_deps) " .
811 "VALUES ('module2','skin2','deps2'); COMMIT"
815 'table' => 'module_deps',
816 'uniqueIndexes' => [],
818 'md_module' => 'module',
823 "BEGIN; INSERT INTO module_deps " .
824 "(md_module,md_skin,md_deps) " .
825 "VALUES ('module','skin','deps'); COMMIT"
831 * @dataProvider provideNativeReplace
832 * @covers Wikimedia\Rdbms\Database::nativeReplace
834 public function testNativeReplace( $sql, $sqlText ) {
835 $this->database
->nativeReplace(
840 $this->assertLastSql( $sqlText );
843 public static function provideNativeReplace() {
847 'table' => 'replace_table',
848 'rows' => [ 'field' => 'text', 'field2' => 'text2' ],
850 "REPLACE INTO replace_table " .
852 "VALUES ('text','text2')"
858 * @dataProvider provideConditional
859 * @covers Wikimedia\Rdbms\Database::conditional
861 public function testConditional( $sql, $sqlText ) {
862 $this->assertEquals( trim( $this->database
->conditional(
869 public static function provideConditional() {
873 'conds' => [ 'field' => 'text' ],
877 "(CASE WHEN field = 'text' THEN 1 ELSE NULL END)"
881 'conds' => [ 'field' => 'text', 'field2' => 'anothertext' ],
885 "(CASE WHEN field = 'text' AND field2 = 'anothertext' THEN 1 ELSE NULL END)"
889 'conds' => 'field=1',
893 "(CASE WHEN field=1 THEN 1 ELSE NULL END)"
899 * @dataProvider provideBuildConcat
900 * @covers Wikimedia\Rdbms\Database::buildConcat
902 public function testBuildConcat( $stringList, $sqlText ) {
903 $this->assertEquals( trim( $this->database
->buildConcat(
908 public static function provideBuildConcat() {
911 [ 'field', 'field2' ],
912 "CONCAT(field,field2)"
915 [ "'test'", 'field2' ],
916 "CONCAT('test',field2)"
922 * @dataProvider provideBuildLike
923 * @covers Wikimedia\Rdbms\Database::buildLike
924 * @covers Wikimedia\Rdbms\Database::escapeLikeInternal
926 public function testBuildLike( $array, $sqlText ) {
927 $this->assertEquals( trim( $this->database
->buildLike(
932 public static function provideBuildLike() {
936 "LIKE 'text' ESCAPE '`'"
939 [ 'text', new LikeMatch( '%' ) ],
940 "LIKE 'text%' ESCAPE '`'"
943 [ 'text', new LikeMatch( '%' ), 'text2' ],
944 "LIKE 'text%text2' ESCAPE '`'"
947 [ 'text', new LikeMatch( '_' ) ],
948 "LIKE 'text_' ESCAPE '`'"
952 "LIKE 'more`_text' ESCAPE '`'"
955 [ 'C:\\Windows\\', new LikeMatch( '%' ) ],
956 "LIKE 'C:\\Windows\\%' ESCAPE '`'"
959 [ 'accent`_test`', new LikeMatch( '%' ) ],
960 "LIKE 'accent```_test``%' ESCAPE '`'"
966 * @dataProvider provideUnionQueries
967 * @covers Wikimedia\Rdbms\Database::unionQueries
969 public function testUnionQueries( $sql, $sqlText ) {
970 $this->assertEquals( trim( $this->database
->unionQueries(
976 public static function provideUnionQueries() {
980 'sqls' => [ 'RAW SQL', 'RAW2SQL' ],
983 "(RAW SQL) UNION ALL (RAW2SQL)"
987 'sqls' => [ 'RAW SQL', 'RAW2SQL' ],
990 "(RAW SQL) UNION (RAW2SQL)"
994 'sqls' => [ 'RAW SQL', 'RAW2SQL', 'RAW3SQL' ],
997 "(RAW SQL) UNION (RAW2SQL) UNION (RAW3SQL)"
1003 * @dataProvider provideUnionConditionPermutations
1004 * @covers Wikimedia\Rdbms\Database::unionConditionPermutations
1006 public function testUnionConditionPermutations( $params, $expect ) {
1007 if ( isset( $params['unionSupportsOrderAndLimit'] ) ) {
1008 $this->database
->setUnionSupportsOrderAndLimit( $params['unionSupportsOrderAndLimit'] );
1011 $sql = trim( $this->database
->unionConditionPermutations(
1014 $params['permute_conds'],
1015 isset( $params['extra_conds'] ) ?
$params['extra_conds'] : '',
1017 isset( $params['options'] ) ?
$params['options'] : [],
1018 isset( $params['join_conds'] ) ?
$params['join_conds'] : []
1020 $this->assertEquals( $expect, $sql );
1023 public static function provideUnionConditionPermutations() {
1024 // phpcs:disable Generic.Files.LineLength
1028 'table' => [ 'table1', 'table2' ],
1029 'vars' => [ 'field1', 'alias' => 'field2' ],
1030 'permute_conds' => [
1031 'field3' => [ 1, 2, 3 ],
1032 'duplicates' => [ 4, 5, 4 ],
1036 'extra_conds' => 'table2.bar > 23',
1038 'ORDER BY' => [ 'field1', 'alias' ],
1039 'INNER ORDER BY' => [ 'field1', 'field2' ],
1043 'table2' => [ 'JOIN', 'table1.foo_id = table2.foo_id' ],
1046 "(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 " .
1047 "(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 " .
1048 "(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 " .
1049 "(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 " .
1050 "(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 " .
1051 "(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 ) " .
1052 "ORDER BY field1,alias LIMIT 100"
1057 'vars' => [ 'foo_id' ],
1058 'permute_conds' => [
1059 'bar' => [ 1, 2, 3 ],
1061 'extra_conds' => [ 'baz' => null ],
1064 'ORDER BY' => [ 'foo_id' ],
1068 "(SELECT foo_id FROM foo WHERE bar = '1' AND baz IS NULL ORDER BY foo_id LIMIT 25 ) UNION " .
1069 "(SELECT foo_id FROM foo WHERE bar = '2' AND baz IS NULL ORDER BY foo_id LIMIT 25 ) UNION " .
1070 "(SELECT foo_id FROM foo WHERE bar = '3' AND baz IS NULL ORDER BY foo_id LIMIT 25 ) " .
1071 "ORDER BY foo_id LIMIT 25"
1076 'vars' => [ 'foo_id' ],
1077 'permute_conds' => [
1078 'bar' => [ 1, 2, 3 ],
1080 'extra_conds' => [ 'baz' => null ],
1083 'ORDER BY' => [ 'foo_id' ],
1086 'unionSupportsOrderAndLimit' => false,
1088 "(SELECT foo_id FROM foo WHERE bar = '1' AND baz IS NULL ) UNION " .
1089 "(SELECT foo_id FROM foo WHERE bar = '2' AND baz IS NULL ) UNION " .
1090 "(SELECT foo_id FROM foo WHERE bar = '3' AND baz IS NULL ) " .
1091 "ORDER BY foo_id LIMIT 25"
1096 'vars' => [ 'foo_id' ],
1097 'permute_conds' => [],
1098 'extra_conds' => [ 'baz' => null ],
1100 'ORDER BY' => [ 'foo_id' ],
1104 "SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY foo_id LIMIT 25"
1109 'vars' => [ 'foo_id' ],
1110 'permute_conds' => [
1113 'extra_conds' => [ 'baz' => null ],
1115 'ORDER BY' => [ 'foo_id' ],
1119 "SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY foo_id LIMIT 25"
1124 'vars' => [ 'foo_id' ],
1125 'permute_conds' => [
1129 'ORDER BY' => [ 'foo_id' ],
1134 "SELECT foo_id FROM foo WHERE bar = '1' ORDER BY foo_id LIMIT 150,25"
1139 'vars' => [ 'foo_id' ],
1140 'permute_conds' => [],
1141 'extra_conds' => [ 'baz' => null ],
1143 'ORDER BY' => [ 'foo_id' ],
1146 'INNER ORDER BY' => [ 'bar_id' ],
1149 "(SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY bar_id LIMIT 175 ) ORDER BY foo_id LIMIT 150,25"
1154 'vars' => [ 'foo_id' ],
1155 'permute_conds' => [],
1156 'extra_conds' => [ 'baz' => null ],
1158 'ORDER BY' => [ 'foo_id' ],
1161 'INNER ORDER BY' => [ 'bar_id' ],
1163 'unionSupportsOrderAndLimit' => false,
1165 "SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY foo_id LIMIT 150,25"
1172 * @covers Wikimedia\Rdbms\Database::commit
1173 * @covers Wikimedia\Rdbms\Database::doCommit
1175 public function testTransactionCommit() {
1176 $this->database
->begin( __METHOD__
);
1177 $this->database
->commit( __METHOD__
);
1178 $this->assertLastSql( 'BEGIN; COMMIT' );
1182 * @covers Wikimedia\Rdbms\Database::rollback
1183 * @covers Wikimedia\Rdbms\Database::doRollback
1185 public function testTransactionRollback() {
1186 $this->database
->begin( __METHOD__
);
1187 $this->database
->rollback( __METHOD__
);
1188 $this->assertLastSql( 'BEGIN; ROLLBACK' );
1192 * @covers Wikimedia\Rdbms\Database::dropTable
1194 public function testDropTable() {
1195 $this->database
->setExistingTables( [ 'table' ] );
1196 $this->database
->dropTable( 'table', __METHOD__
);
1197 $this->assertLastSql( 'DROP TABLE table CASCADE' );
1201 * @covers Wikimedia\Rdbms\Database::dropTable
1203 public function testDropNonExistingTable() {
1205 $this->database
->dropTable( 'non_existing', __METHOD__
)
1210 * @dataProvider provideMakeList
1211 * @covers Wikimedia\Rdbms\Database::makeList
1213 public function testMakeList( $list, $mode, $sqlText ) {
1214 $this->assertEquals( trim( $this->database
->makeList(
1219 public static function provideMakeList() {
1222 [ 'value', 'value2' ],
1227 [ 'field', 'field2' ],
1232 [ 'field' => 'value', 'field2' => 'value2' ],
1234 "field = 'value' AND field2 = 'value2'"
1237 [ 'field' => null, "field2 != 'value2'" ],
1239 "field IS NULL AND (field2 != 'value2')"
1242 [ 'field' => [ 'value', null, 'value2' ], 'field2' => 'value2' ],
1244 "(field IN ('value','value2') OR field IS NULL) AND field2 = 'value2'"
1247 [ 'field' => [ null ], 'field2' => null ],
1249 "field IS NULL AND field2 IS NULL"
1252 [ 'field' => 'value', 'field2' => 'value2' ],
1254 "field = 'value' OR field2 = 'value2'"
1257 [ 'field' => 'value', 'field2' => null ],
1259 "field = 'value' OR field2 IS NULL"
1262 [ 'field' => [ 'value', 'value2' ], 'field2' => [ 'value' ] ],
1264 "field IN ('value','value2') OR field2 = 'value'"
1267 [ 'field' => [ null, 'value', null, 'value2' ], "field2 != 'value2'" ],
1269 "(field IN ('value','value2') OR field IS NULL) OR (field2 != 'value2')"
1272 [ 'field' => 'value', 'field2' => 'value2' ],
1274 "field = 'value',field2 = 'value2'"
1277 [ 'field' => 'value', 'field2' => null ],
1279 "field = 'value',field2 = NULL"
1282 [ 'field' => 'value', "field2 != 'value2'" ],
1284 "field = 'value',field2 != 'value2'"
1290 * @covers Wikimedia\Rdbms\Database::registerTempTableOperation
1292 public function testSessionTempTables() {
1293 $temp1 = $this->database
->tableName( 'tmp_table_1' );
1294 $temp2 = $this->database
->tableName( 'tmp_table_2' );
1295 $temp3 = $this->database
->tableName( 'tmp_table_3' );
1297 $this->database
->query( "CREATE TEMPORARY TABLE $temp1 LIKE orig_tbl", __METHOD__
);
1298 $this->database
->query( "CREATE TEMPORARY TABLE $temp2 LIKE orig_tbl", __METHOD__
);
1299 $this->database
->query( "CREATE TEMPORARY TABLE $temp3 LIKE orig_tbl", __METHOD__
);
1301 $this->assertTrue( $this->database
->tableExists( "tmp_table_1", __METHOD__
) );
1302 $this->assertTrue( $this->database
->tableExists( "tmp_table_2", __METHOD__
) );
1303 $this->assertTrue( $this->database
->tableExists( "tmp_table_3", __METHOD__
) );
1305 $this->database
->dropTable( 'tmp_table_1', __METHOD__
);
1306 $this->database
->dropTable( 'tmp_table_2', __METHOD__
);
1307 $this->database
->dropTable( 'tmp_table_3', __METHOD__
);
1309 $this->assertFalse( $this->database
->tableExists( "tmp_table_1", __METHOD__
) );
1310 $this->assertFalse( $this->database
->tableExists( "tmp_table_2", __METHOD__
) );
1311 $this->assertFalse( $this->database
->tableExists( "tmp_table_3", __METHOD__
) );
1313 $this->database
->query( "CREATE TEMPORARY TABLE tmp_table_1 LIKE orig_tbl", __METHOD__
);
1314 $this->database
->query( "CREATE TEMPORARY TABLE 'tmp_table_2' LIKE orig_tbl", __METHOD__
);
1315 $this->database
->query( "CREATE TEMPORARY TABLE `tmp_table_3` LIKE orig_tbl", __METHOD__
);
1317 $this->assertTrue( $this->database
->tableExists( "tmp_table_1", __METHOD__
) );
1318 $this->assertTrue( $this->database
->tableExists( "tmp_table_2", __METHOD__
) );
1319 $this->assertTrue( $this->database
->tableExists( "tmp_table_3", __METHOD__
) );
1321 $this->database
->query( "DROP TEMPORARY TABLE tmp_table_1 LIKE orig_tbl", __METHOD__
);
1322 $this->database
->query( "DROP TEMPORARY TABLE 'tmp_table_2' LIKE orig_tbl", __METHOD__
);
1323 $this->database
->query( "DROP TABLE `tmp_table_3` LIKE orig_tbl", __METHOD__
);
1325 $this->assertFalse( $this->database
->tableExists( "tmp_table_1", __METHOD__
) );
1326 $this->assertFalse( $this->database
->tableExists( "tmp_table_2", __METHOD__
) );
1327 $this->assertFalse( $this->database
->tableExists( "tmp_table_3", __METHOD__
) );
1330 public function provideBuildSubstring() {
1331 yield
[ 'someField', 1, 2, 'SUBSTRING(someField FROM 1 FOR 2)' ];
1332 yield
[ 'someField', 1, null, 'SUBSTRING(someField FROM 1)' ];
1336 * @covers Wikimedia\Rdbms\Database::buildSubstring
1337 * @dataProvider provideBuildSubstring
1339 public function testBuildSubstring( $input, $start, $length, $expected ) {
1340 $output = $this->database
->buildSubstring( $input, $start, $length );
1341 $this->assertSame( $expected, $output );
1344 public function provideBuildSubstring_invalidParams() {
1354 * @covers Wikimedia\Rdbms\Database::buildSubstring
1355 * @covers Wikimedia\Rdbms\Database::assertBuildSubstringParams
1356 * @dataProvider provideBuildSubstring_invalidParams
1358 public function testBuildSubstring_invalidParams( $start, $length ) {
1359 $this->setExpectedException( InvalidArgumentException
::class );
1360 $this->database
->buildSubstring( 'foo', $start, $length );
1364 * @covers \Wikimedia\Rdbms\Database::buildIntegerCast
1366 public function testBuildIntegerCast() {
1367 $output = $this->database
->buildIntegerCast( 'fieldName' );
1368 $this->assertSame( 'CAST( fieldName AS INTEGER )', $output );
1372 * @covers \Wikimedia\Rdbms\Database::doSavepoint
1373 * @covers \Wikimedia\Rdbms\Database::doReleaseSavepoint
1374 * @covers \Wikimedia\Rdbms\Database::doRollbackToSavepoint
1375 * @covers \Wikimedia\Rdbms\Database::startAtomic
1376 * @covers \Wikimedia\Rdbms\Database::endAtomic
1377 * @covers \Wikimedia\Rdbms\Database::cancelAtomic
1378 * @covers \Wikimedia\Rdbms\Database::doAtomicSection
1380 public function testAtomicSections() {
1381 $this->database
->startAtomic( __METHOD__
);
1382 $this->database
->endAtomic( __METHOD__
);
1383 $this->assertLastSql( 'BEGIN; COMMIT' );
1385 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1386 $this->database
->cancelAtomic( __METHOD__
);
1387 $this->assertLastSql( 'BEGIN; ROLLBACK' );
1389 $this->database
->begin( __METHOD__
);
1390 $this->database
->startAtomic( __METHOD__
);
1391 $this->database
->endAtomic( __METHOD__
);
1392 $this->database
->commit( __METHOD__
);
1393 $this->assertLastSql( 'BEGIN; COMMIT' );
1395 $this->database
->begin( __METHOD__
);
1396 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1397 $this->database
->endAtomic( __METHOD__
);
1398 $this->database
->commit( __METHOD__
);
1399 // phpcs:ignore Generic.Files.LineLength
1400 $this->assertLastSql( 'BEGIN; SAVEPOINT wikimedia_rdbms_atomic1; RELEASE SAVEPOINT wikimedia_rdbms_atomic1; COMMIT' );
1402 $this->database
->begin( __METHOD__
);
1403 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1404 $this->database
->cancelAtomic( __METHOD__
);
1405 $this->database
->commit( __METHOD__
);
1406 // phpcs:ignore Generic.Files.LineLength
1407 $this->assertLastSql( 'BEGIN; SAVEPOINT wikimedia_rdbms_atomic1; ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1; COMMIT' );
1409 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1410 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1411 $this->database
->cancelAtomic( __METHOD__
);
1412 $this->database
->endAtomic( __METHOD__
);
1413 // phpcs:ignore Generic.Files.LineLength
1414 $this->assertLastSql( 'BEGIN; SAVEPOINT wikimedia_rdbms_atomic1; ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1; COMMIT' );
1416 $noOpCallack = function () {
1419 $this->database
->doAtomicSection( __METHOD__
, $noOpCallack, IDatabase
::ATOMIC_CANCELABLE
);
1420 $this->assertLastSql( 'BEGIN; COMMIT' );
1422 $this->database
->doAtomicSection( __METHOD__
, $noOpCallack );
1423 $this->assertLastSql( 'BEGIN; COMMIT' );
1425 $this->database
->begin( __METHOD__
);
1426 $this->database
->doAtomicSection( __METHOD__
, $noOpCallack, IDatabase
::ATOMIC_CANCELABLE
);
1427 $this->database
->rollback( __METHOD__
);
1428 // phpcs:ignore Generic.Files.LineLength
1429 $this->assertLastSql( 'BEGIN; SAVEPOINT wikimedia_rdbms_atomic1; RELEASE SAVEPOINT wikimedia_rdbms_atomic1; ROLLBACK' );
1431 $fname = __METHOD__
;
1434 IDatabase
::TRIGGER_COMMIT
=> 'tCommit',
1435 IDatabase
::TRIGGER_ROLLBACK
=> 'tRollback'
1437 $pcCallback = function ( IDatabase
$db ) use ( $fname ) {
1438 $this->database
->query( "SELECT 0", $fname );
1440 $callback1 = function ( $trigger = '-' ) use ( $fname, $triggerMap ) {
1441 $this->database
->query( "SELECT 1, {$triggerMap[$trigger]} AS t", $fname );
1443 $callback2 = function ( $trigger = '-' ) use ( $fname, $triggerMap ) {
1444 $this->database
->query( "SELECT 2, {$triggerMap[$trigger]} AS t", $fname );
1446 $callback3 = function ( $trigger = '-' ) use ( $fname, $triggerMap ) {
1447 $this->database
->query( "SELECT 3, {$triggerMap[$trigger]} AS t", $fname );
1450 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1451 $this->database
->onTransactionPreCommitOrIdle( $pcCallback, __METHOD__
);
1452 $this->database
->cancelAtomic( __METHOD__
);
1453 $this->assertLastSql( 'BEGIN; ROLLBACK' );
1455 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1456 $this->database
->onTransactionCommitOrIdle( $callback1, __METHOD__
);
1457 $this->database
->cancelAtomic( __METHOD__
);
1458 $this->assertLastSql( 'BEGIN; ROLLBACK' );
1460 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1461 $this->database
->onTransactionResolution( $callback1, __METHOD__
);
1462 $this->database
->cancelAtomic( __METHOD__
);
1463 $this->assertLastSql( 'BEGIN; ROLLBACK; SELECT 1, tRollback AS t' );
1465 $this->database
->startAtomic( __METHOD__
. '_outer' );
1466 $this->database
->onTransactionPreCommitOrIdle( $pcCallback, __METHOD__
);
1467 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1468 $this->database
->onTransactionPreCommitOrIdle( $pcCallback, __METHOD__
);
1469 $this->database
->cancelAtomic( __METHOD__
);
1470 $this->database
->onTransactionPreCommitOrIdle( $pcCallback, __METHOD__
);
1471 $this->database
->endAtomic( __METHOD__
. '_outer' );
1472 $this->assertLastSql( implode( "; ", [
1474 'SAVEPOINT wikimedia_rdbms_atomic1',
1475 'ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1',
1481 $this->database
->startAtomic( __METHOD__
. '_outer' );
1482 $this->database
->onTransactionCommitOrIdle( $callback1, __METHOD__
);
1483 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1484 $this->database
->onTransactionCommitOrIdle( $callback2, __METHOD__
);
1485 $this->database
->cancelAtomic( __METHOD__
);
1486 $this->database
->onTransactionCommitOrIdle( $callback3, __METHOD__
);
1487 $this->database
->endAtomic( __METHOD__
. '_outer' );
1488 $this->assertLastSql( implode( "; ", [
1490 'SAVEPOINT wikimedia_rdbms_atomic1',
1491 'ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1',
1493 'SELECT 1, tCommit AS t',
1494 'SELECT 3, tCommit AS t'
1497 $this->database
->startAtomic( __METHOD__
. '_outer' );
1498 $this->database
->onTransactionResolution( $callback1, __METHOD__
);
1499 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1500 $this->database
->onTransactionResolution( $callback2, __METHOD__
);
1501 $this->database
->cancelAtomic( __METHOD__
);
1502 $this->database
->onTransactionResolution( $callback3, __METHOD__
);
1503 $this->database
->endAtomic( __METHOD__
. '_outer' );
1504 $this->assertLastSql( implode( "; ", [
1506 'SAVEPOINT wikimedia_rdbms_atomic1',
1507 'ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1',
1509 'SELECT 1, tCommit AS t',
1510 'SELECT 2, tRollback AS t',
1511 'SELECT 3, tCommit AS t'
1514 $makeCallback = function ( $id ) use ( $fname, $triggerMap ) {
1515 return function ( $trigger = '-' ) use ( $id, $fname, $triggerMap ) {
1516 $this->database
->query( "SELECT $id, {$triggerMap[$trigger]} AS t", $fname );
1520 $this->database
->startAtomic( __METHOD__
. '_outer' );
1521 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1522 $this->database
->onTransactionResolution( $makeCallback( 1 ), __METHOD__
);
1523 $this->database
->cancelAtomic( __METHOD__
);
1524 $this->database
->endAtomic( __METHOD__
. '_outer' );
1525 $this->assertLastSql( implode( "; ", [
1527 'SAVEPOINT wikimedia_rdbms_atomic1',
1528 'ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1',
1530 'SELECT 1, tRollback AS t'
1533 $this->database
->startAtomic( __METHOD__
. '_level1', IDatabase
::ATOMIC_CANCELABLE
);
1534 $this->database
->onTransactionResolution( $makeCallback( 1 ), __METHOD__
);
1535 $this->database
->startAtomic( __METHOD__
. '_level2' );
1536 $this->database
->startAtomic( __METHOD__
. '_level3', IDatabase
::ATOMIC_CANCELABLE
);
1537 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1538 $this->database
->onTransactionResolution( $makeCallback( 2 ), __METHOD__
);
1539 $this->database
->endAtomic( __METHOD__
);
1540 $this->database
->onTransactionResolution( $makeCallback( 3 ), __METHOD__
);
1541 $this->database
->cancelAtomic( __METHOD__
. '_level3' );
1542 $this->database
->endAtomic( __METHOD__
. '_level2' );
1543 $this->database
->onTransactionResolution( $makeCallback( 4 ), __METHOD__
);
1544 $this->database
->endAtomic( __METHOD__
. '_level1' );
1545 $this->assertLastSql( implode( "; ", [
1547 'SAVEPOINT wikimedia_rdbms_atomic1',
1548 'SAVEPOINT wikimedia_rdbms_atomic2',
1549 'RELEASE SAVEPOINT wikimedia_rdbms_atomic2',
1550 'ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1',
1551 'COMMIT; SELECT 1, tCommit AS t',
1552 'SELECT 2, tRollback AS t',
1553 'SELECT 3, tRollback AS t',
1554 'SELECT 4, tCommit AS t'
1559 * @covers \Wikimedia\Rdbms\Database::doSavepoint
1560 * @covers \Wikimedia\Rdbms\Database::doReleaseSavepoint
1561 * @covers \Wikimedia\Rdbms\Database::doRollbackToSavepoint
1562 * @covers \Wikimedia\Rdbms\Database::startAtomic
1563 * @covers \Wikimedia\Rdbms\Database::endAtomic
1564 * @covers \Wikimedia\Rdbms\Database::cancelAtomic
1565 * @covers \Wikimedia\Rdbms\Database::doAtomicSection
1567 public function testAtomicSectionsRecovery() {
1568 $this->database
->begin( __METHOD__
);
1570 $this->database
->doAtomicSection(
1573 $this->database
->startAtomic( 'inner_func1' );
1574 $this->database
->startAtomic( 'inner_func2' );
1576 throw new RuntimeException( 'Test exception' );
1578 IDatabase
::ATOMIC_CANCELABLE
1580 $this->fail( 'Expected exception not thrown' );
1581 } catch ( RuntimeException
$ex ) {
1582 $this->assertSame( 'Test exception', $ex->getMessage() );
1584 $this->database
->commit( __METHOD__
);
1585 // phpcs:ignore Generic.Files.LineLength
1586 $this->assertLastSql( 'BEGIN; SAVEPOINT wikimedia_rdbms_atomic1; ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1; COMMIT' );
1588 $this->database
->begin( __METHOD__
);
1590 $this->database
->doAtomicSection(
1593 throw new RuntimeException( 'Test exception' );
1596 $this->fail( 'Test exception not thrown' );
1597 } catch ( RuntimeException
$ex ) {
1598 $this->assertSame( 'Test exception', $ex->getMessage() );
1601 $this->database
->commit( __METHOD__
);
1602 $this->fail( 'Test exception not thrown' );
1603 } catch ( DBTransactionError
$ex ) {
1605 'Cannot execute query from ' . __METHOD__
. ' while transaction status is ERROR.',
1609 $this->database
->rollback( __METHOD__
);
1610 $this->assertLastSql( 'BEGIN; ROLLBACK' );
1614 * @covers \Wikimedia\Rdbms\Database::doSavepoint
1615 * @covers \Wikimedia\Rdbms\Database::doReleaseSavepoint
1616 * @covers \Wikimedia\Rdbms\Database::doRollbackToSavepoint
1617 * @covers \Wikimedia\Rdbms\Database::startAtomic
1618 * @covers \Wikimedia\Rdbms\Database::endAtomic
1619 * @covers \Wikimedia\Rdbms\Database::cancelAtomic
1620 * @covers \Wikimedia\Rdbms\Database::doAtomicSection
1622 public function testAtomicSectionsCallbackCancellation() {
1623 $fname = __METHOD__
;
1624 $callback1Called = null;
1625 $callback1 = function ( $trigger = '-' ) use ( $fname, &$callback1Called ) {
1626 $callback1Called = $trigger;
1627 $this->database
->query( "SELECT 1", $fname );
1629 $callback2Called = null;
1630 $callback2 = function ( $trigger = '-' ) use ( $fname, &$callback2Called ) {
1631 $callback2Called = $trigger;
1632 $this->database
->query( "SELECT 2", $fname );
1634 $callback3Called = null;
1635 $callback3 = function ( $trigger = '-' ) use ( $fname, &$callback3Called ) {
1636 $callback3Called = $trigger;
1637 $this->database
->query( "SELECT 3", $fname );
1640 $this->database
->startAtomic( __METHOD__
. '_outer' );
1641 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1642 $this->database
->startAtomic( __METHOD__
. '_inner' );
1643 $this->database
->onTransactionCommitOrIdle( $callback1, __METHOD__
);
1644 $this->database
->onTransactionPreCommitOrIdle( $callback2, __METHOD__
);
1645 $this->database
->onTransactionResolution( $callback3, __METHOD__
);
1646 $this->database
->endAtomic( __METHOD__
. '_inner' );
1647 $this->database
->cancelAtomic( __METHOD__
);
1648 $this->database
->endAtomic( __METHOD__
. '_outer' );
1649 $this->assertNull( $callback1Called );
1650 $this->assertNull( $callback2Called );
1651 $this->assertEquals( IDatabase
::TRIGGER_ROLLBACK
, $callback3Called );
1652 // phpcs:ignore Generic.Files.LineLength
1653 $this->assertLastSql( 'BEGIN; SAVEPOINT wikimedia_rdbms_atomic1; ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1; COMMIT; SELECT 3' );
1655 $callback1Called = null;
1656 $callback2Called = null;
1657 $callback3Called = null;
1658 $this->database
->startAtomic( __METHOD__
. '_outer' );
1659 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1660 $this->database
->startAtomic( __METHOD__
. '_inner', IDatabase
::ATOMIC_CANCELABLE
);
1661 $this->database
->onTransactionCommitOrIdle( $callback1, __METHOD__
);
1662 $this->database
->onTransactionPreCommitOrIdle( $callback2, __METHOD__
);
1663 $this->database
->onTransactionResolution( $callback3, __METHOD__
);
1664 $this->database
->endAtomic( __METHOD__
. '_inner' );
1665 $this->database
->cancelAtomic( __METHOD__
);
1666 $this->database
->endAtomic( __METHOD__
. '_outer' );
1667 $this->assertNull( $callback1Called );
1668 $this->assertNull( $callback2Called );
1669 $this->assertEquals( IDatabase
::TRIGGER_ROLLBACK
, $callback3Called );
1670 // phpcs:ignore Generic.Files.LineLength
1671 $this->assertLastSql( 'BEGIN; SAVEPOINT wikimedia_rdbms_atomic1; SAVEPOINT wikimedia_rdbms_atomic2; RELEASE SAVEPOINT wikimedia_rdbms_atomic2; ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1; COMMIT; SELECT 3' );
1673 $callback1Called = null;
1674 $callback2Called = null;
1675 $callback3Called = null;
1676 $this->database
->startAtomic( __METHOD__
. '_outer' );
1677 $atomicId = $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1678 $this->database
->startAtomic( __METHOD__
. '_inner' );
1679 $this->database
->onTransactionCommitOrIdle( $callback1, __METHOD__
);
1680 $this->database
->onTransactionPreCommitOrIdle( $callback2, __METHOD__
);
1681 $this->database
->onTransactionResolution( $callback3, __METHOD__
);
1682 $this->database
->cancelAtomic( __METHOD__
, $atomicId );
1683 $this->database
->endAtomic( __METHOD__
. '_outer' );
1684 $this->assertNull( $callback1Called );
1685 $this->assertNull( $callback2Called );
1686 $this->assertEquals( IDatabase
::TRIGGER_ROLLBACK
, $callback3Called );
1688 $callback1Called = null;
1689 $callback2Called = null;
1690 $callback3Called = null;
1691 $this->database
->startAtomic( __METHOD__
. '_outer' );
1692 $atomicId = $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1693 $this->database
->startAtomic( __METHOD__
. '_inner' );
1694 $this->database
->onTransactionCommitOrIdle( $callback1, __METHOD__
);
1695 $this->database
->onTransactionPreCommitOrIdle( $callback2, __METHOD__
);
1696 $this->database
->onTransactionResolution( $callback3, __METHOD__
);
1698 $this->database
->cancelAtomic( __METHOD__
. '_X', $atomicId );
1699 } catch ( DBUnexpectedError
$e ) {
1702 "Invalid atomic section ended (got {$m}_X but expected {$m}).",
1706 $this->database
->cancelAtomic( __METHOD__
);
1707 $this->database
->endAtomic( __METHOD__
. '_outer' );
1708 $this->assertNull( $callback1Called );
1709 $this->assertNull( $callback2Called );
1710 $this->assertEquals( IDatabase
::TRIGGER_ROLLBACK
, $callback3Called );
1712 $this->database
->startAtomic( __METHOD__
. '_outer' );
1713 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1714 $this->database
->startAtomic( __METHOD__
. '_inner' );
1715 $this->database
->onTransactionCommitOrIdle( $callback1, __METHOD__
);
1716 $this->database
->onTransactionPreCommitOrIdle( $callback2, __METHOD__
);
1717 $this->database
->onTransactionResolution( $callback3, __METHOD__
);
1718 $this->database
->cancelAtomic( __METHOD__
. '_inner' );
1719 $this->database
->cancelAtomic( __METHOD__
);
1720 $this->database
->endAtomic( __METHOD__
. '_outer' );
1721 $this->assertNull( $callback1Called );
1722 $this->assertNull( $callback2Called );
1723 $this->assertEquals( IDatabase
::TRIGGER_ROLLBACK
, $callback3Called );
1725 $wrapper = TestingAccessWrapper
::newFromObject( $this->database
);
1726 $callback1Called = null;
1727 $callback2Called = null;
1728 $callback3Called = null;
1729 $this->database
->startAtomic( __METHOD__
. '_outer' );
1730 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1731 $this->database
->startAtomic( __METHOD__
. '_inner' );
1732 $this->database
->onTransactionCommitOrIdle( $callback1, __METHOD__
);
1733 $this->database
->onTransactionPreCommitOrIdle( $callback2, __METHOD__
);
1734 $this->database
->onTransactionResolution( $callback3, __METHOD__
);
1735 $wrapper->trxStatus
= Database
::STATUS_TRX_ERROR
;
1736 $this->database
->cancelAtomic( __METHOD__
. '_inner' );
1737 $this->database
->cancelAtomic( __METHOD__
);
1738 $this->database
->endAtomic( __METHOD__
. '_outer' );
1739 $this->assertNull( $callback1Called );
1740 $this->assertNull( $callback2Called );
1741 $this->assertEquals( IDatabase
::TRIGGER_ROLLBACK
, $callback3Called );
1745 * @covers \Wikimedia\Rdbms\Database::doSavepoint
1746 * @covers \Wikimedia\Rdbms\Database::doReleaseSavepoint
1747 * @covers \Wikimedia\Rdbms\Database::doRollbackToSavepoint
1748 * @covers \Wikimedia\Rdbms\Database::startAtomic
1749 * @covers \Wikimedia\Rdbms\Database::endAtomic
1750 * @covers \Wikimedia\Rdbms\Database::cancelAtomic
1751 * @covers \Wikimedia\Rdbms\Database::doAtomicSection
1753 public function testAtomicSectionsTrxRound() {
1754 $this->database
->setFlag( IDatabase
::DBO_TRX
);
1755 $this->database
->startAtomic( __METHOD__
, IDatabase
::ATOMIC_CANCELABLE
);
1756 $this->database
->query( 'SELECT 1', __METHOD__
);
1757 $this->database
->endAtomic( __METHOD__
);
1758 $this->database
->commit( __METHOD__
, IDatabase
::FLUSHING_ALL_PEERS
);
1759 // phpcs:ignore Generic.Files.LineLength
1760 $this->assertLastSql( 'BEGIN; SAVEPOINT wikimedia_rdbms_atomic1; SELECT 1; RELEASE SAVEPOINT wikimedia_rdbms_atomic1; COMMIT' );
1763 public static function provideAtomicSectionMethodsForErrors() {
1771 * @dataProvider provideAtomicSectionMethodsForErrors
1772 * @covers \Wikimedia\Rdbms\Database::endAtomic
1773 * @covers \Wikimedia\Rdbms\Database::cancelAtomic
1775 public function testNoAtomicSection( $method ) {
1777 $this->database
->$method( __METHOD__
);
1778 $this->fail( 'Expected exception not thrown' );
1779 } catch ( DBUnexpectedError
$ex ) {
1781 'No atomic section is open (got ' . __METHOD__
. ').',
1788 * @dataProvider provideAtomicSectionMethodsForErrors
1789 * @covers \Wikimedia\Rdbms\Database::endAtomic
1790 * @covers \Wikimedia\Rdbms\Database::cancelAtomic
1792 public function testInvalidAtomicSectionEnded( $method ) {
1793 $this->database
->startAtomic( __METHOD__
. 'X' );
1795 $this->database
->$method( __METHOD__
);
1796 $this->fail( 'Expected exception not thrown' );
1797 } catch ( DBUnexpectedError
$ex ) {
1799 'Invalid atomic section ended (got ' . __METHOD__
. ' but expected ' .
1800 __METHOD__
. 'X' . ').',
1807 * @covers \Wikimedia\Rdbms\Database::cancelAtomic
1809 public function testUncancellableAtomicSection() {
1810 $this->database
->startAtomic( __METHOD__
);
1812 $this->database
->cancelAtomic( __METHOD__
);
1813 $this->database
->select( 'test', '1', [], __METHOD__
);
1814 $this->fail( 'Expected exception not thrown' );
1815 } catch ( DBTransactionError
$ex ) {
1817 'Cannot execute query from ' . __METHOD__
. ' while transaction status is ERROR.',
1824 * @expectedException \Wikimedia\Rdbms\DBTransactionStateError
1826 public function testTransactionErrorState1() {
1827 $wrapper = TestingAccessWrapper
::newFromObject( $this->database
);
1829 $this->database
->begin( __METHOD__
);
1830 $wrapper->trxStatus
= Database
::STATUS_TRX_ERROR
;
1831 $this->database
->delete( 'x', [ 'field' => 3 ], __METHOD__
);
1832 $this->database
->commit( __METHOD__
);
1836 * @covers \Wikimedia\Rdbms\Database::query
1838 public function testTransactionErrorState2() {
1839 $wrapper = TestingAccessWrapper
::newFromObject( $this->database
);
1841 $this->database
->startAtomic( __METHOD__
);
1842 $wrapper->trxStatus
= Database
::STATUS_TRX_ERROR
;
1843 $this->database
->rollback( __METHOD__
);
1844 $this->assertEquals( 0, $this->database
->trxLevel() );
1845 $this->assertEquals( Database
::STATUS_TRX_NONE
, $wrapper->trxStatus() );
1846 $this->assertLastSql( 'BEGIN; ROLLBACK' );
1848 $this->database
->startAtomic( __METHOD__
);
1849 $this->assertEquals( Database
::STATUS_TRX_OK
, $wrapper->trxStatus() );
1850 $this->database
->delete( 'x', [ 'field' => 1 ], __METHOD__
);
1851 $this->database
->endAtomic( __METHOD__
);
1852 $this->assertEquals( Database
::STATUS_TRX_NONE
, $wrapper->trxStatus() );
1853 $this->assertLastSql( 'BEGIN; DELETE FROM x WHERE field = \'1\'; COMMIT' );
1854 $this->assertEquals( 0, $this->database
->trxLevel(), 'Use after rollback()' );
1856 $this->database
->begin( __METHOD__
);
1857 $this->database
->startAtomic( __METHOD__
, Database
::ATOMIC_CANCELABLE
);
1858 $this->database
->update( 'y', [ 'a' => 1 ], [ 'field' => 1 ], __METHOD__
);
1859 $wrapper->trxStatus
= Database
::STATUS_TRX_ERROR
;
1860 $this->database
->cancelAtomic( __METHOD__
);
1861 $this->assertEquals( Database
::STATUS_TRX_OK
, $wrapper->trxStatus() );
1862 $this->database
->startAtomic( __METHOD__
);
1863 $this->database
->delete( 'y', [ 'field' => 1 ], __METHOD__
);
1864 $this->database
->endAtomic( __METHOD__
);
1865 $this->database
->commit( __METHOD__
);
1866 // phpcs:ignore Generic.Files.LineLength
1867 $this->assertLastSql( 'BEGIN; SAVEPOINT wikimedia_rdbms_atomic1; UPDATE y SET a = \'1\' WHERE field = \'1\'; ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1; DELETE FROM y WHERE field = \'1\'; COMMIT' );
1868 $this->assertEquals( 0, $this->database
->trxLevel(), 'Use after rollback()' );
1871 $this->database
->startAtomic( __METHOD__
);
1872 $this->assertEquals( Database
::STATUS_TRX_OK
, $wrapper->trxStatus() );
1873 $this->database
->delete( 'x', [ 'field' => 3 ], __METHOD__
);
1874 $this->database
->endAtomic( __METHOD__
);
1875 $this->assertEquals( Database
::STATUS_TRX_NONE
, $wrapper->trxStatus() );
1876 $this->assertLastSql( 'BEGIN; DELETE FROM x WHERE field = \'3\'; COMMIT' );
1877 $this->assertEquals( 0, $this->database
->trxLevel() );
1881 * @covers \Wikimedia\Rdbms\Database::query
1883 public function testImplicitTransactionRollback() {
1884 $doError = function () {
1885 $this->database
->forceNextQueryError( 666, 'Evilness' );
1887 $this->database
->delete( 'error', '1', __CLASS__
. '::SomeCaller' );
1888 $this->fail( 'Expected exception not thrown' );
1889 } catch ( DBError
$e ) {
1890 $this->assertSame( 666, $e->errno
);
1894 $this->database
->setFlag( Database
::DBO_TRX
);
1896 // Implicit transaction gets silently rolled back
1897 $this->database
->begin( __METHOD__
, Database
::TRANSACTION_INTERNAL
);
1898 call_user_func( $doError );
1899 $this->database
->delete( 'x', [ 'field' => 1 ], __METHOD__
);
1900 $this->database
->commit( __METHOD__
, Database
::FLUSHING_INTERNAL
);
1902 $this->assertLastSql( 'BEGIN; DELETE FROM error WHERE 1; ROLLBACK; BEGIN; DELETE FROM x WHERE field = \'1\'; COMMIT' );
1904 // ... unless there were prior writes
1905 $this->database
->begin( __METHOD__
, Database
::TRANSACTION_INTERNAL
);
1906 $this->database
->delete( 'x', [ 'field' => 1 ], __METHOD__
);
1907 call_user_func( $doError );
1909 $this->database
->delete( 'x', [ 'field' => 1 ], __METHOD__
);
1910 $this->fail( 'Expected exception not thrown' );
1911 } catch ( DBTransactionStateError
$e ) {
1913 $this->database
->rollback( __METHOD__
, Database
::FLUSHING_INTERNAL
);
1915 $this->assertLastSql( 'BEGIN; DELETE FROM x WHERE field = \'1\'; DELETE FROM error WHERE 1; ROLLBACK' );
1919 * @covers \Wikimedia\Rdbms\Database::query
1921 public function testTransactionStatementRollbackIgnoring() {
1922 $wrapper = TestingAccessWrapper
::newFromObject( $this->database
);
1924 $wrapper->deprecationLogger
= function ( $msg ) use ( &$warning ) {
1928 $doError = function () {
1929 $this->database
->forceNextQueryError( 666, 'Evilness', [
1930 'wasKnownStatementRollbackError' => true,
1933 $this->database
->delete( 'error', '1', __CLASS__
. '::SomeCaller' );
1934 $this->fail( 'Expected exception not thrown' );
1935 } catch ( DBError
$e ) {
1936 $this->assertSame( 666, $e->errno
);
1939 $expectWarning = 'Caller from ' . __METHOD__
.
1940 ' ignored an error originally raised from ' . __CLASS__
. '::SomeCaller: [666] Evilness';
1942 // Rollback doesn't raise a warning
1944 $this->database
->startAtomic( __METHOD__
);
1945 call_user_func( $doError );
1946 $this->database
->rollback( __METHOD__
);
1947 $this->database
->delete( 'x', [ 'field' => 1 ], __METHOD__
);
1948 $this->assertSame( [], $warning );
1950 $this->assertLastSql( 'BEGIN; DELETE FROM error WHERE 1; ROLLBACK; DELETE FROM x WHERE field = \'1\'' );
1952 // cancelAtomic() doesn't raise a warning
1954 $this->database
->begin( __METHOD__
);
1955 $this->database
->startAtomic( __METHOD__
, Database
::ATOMIC_CANCELABLE
);
1956 call_user_func( $doError );
1957 $this->database
->cancelAtomic( __METHOD__
);
1958 $this->database
->delete( 'x', [ 'field' => 1 ], __METHOD__
);
1959 $this->database
->commit( __METHOD__
);
1960 $this->assertSame( [], $warning );
1962 $this->assertLastSql( 'BEGIN; SAVEPOINT wikimedia_rdbms_atomic1; DELETE FROM error WHERE 1; ROLLBACK TO SAVEPOINT wikimedia_rdbms_atomic1; DELETE FROM x WHERE field = \'1\'; COMMIT' );
1964 // Commit does raise a warning
1966 $this->database
->begin( __METHOD__
);
1967 call_user_func( $doError );
1968 $this->database
->commit( __METHOD__
);
1969 $this->assertSame( [ $expectWarning ], $warning );
1970 $this->assertLastSql( 'BEGIN; DELETE FROM error WHERE 1; COMMIT' );
1972 // Deprecation only gets raised once
1974 $this->database
->begin( __METHOD__
);
1975 call_user_func( $doError );
1976 $this->database
->delete( 'x', [ 'field' => 1 ], __METHOD__
);
1977 $this->database
->commit( __METHOD__
);
1978 $this->assertSame( [ $expectWarning ], $warning );
1980 $this->assertLastSql( 'BEGIN; DELETE FROM error WHERE 1; DELETE FROM x WHERE field = \'1\'; COMMIT' );
1984 * @covers \Wikimedia\Rdbms\Database::close
1986 public function testPrematureClose1() {
1987 $fname = __METHOD__
;
1988 $this->database
->begin( __METHOD__
);
1989 $this->database
->onTransactionCommitOrIdle( function () use ( $fname ) {
1990 $this->database
->query( 'SELECT 1', $fname );
1992 $this->database
->delete( 'x', [ 'field' => 3 ], __METHOD__
);
1993 $this->database
->close();
1995 $this->assertFalse( $this->database
->isOpen() );
1996 $this->assertLastSql( 'BEGIN; DELETE FROM x WHERE field = \'3\'; COMMIT; SELECT 1' );
1997 $this->assertEquals( 0, $this->database
->trxLevel() );
2001 * @covers \Wikimedia\Rdbms\Database::close
2003 public function testPrematureClose2() {
2005 $fname = __METHOD__
;
2006 $this->database
->startAtomic( __METHOD__
);
2007 $this->database
->onTransactionCommitOrIdle( function () use ( $fname ) {
2008 $this->database
->query( 'SELECT 1', $fname );
2010 $this->database
->delete( 'x', [ 'field' => 3 ], __METHOD__
);
2011 $this->database
->close();
2012 $this->fail( 'Expected exception not thrown' );
2013 } catch ( DBUnexpectedError
$ex ) {
2015 'Wikimedia\Rdbms\Database::close: atomic sections ' .
2016 'DatabaseSQLTest::testPrematureClose2 are still open.',
2021 $this->assertFalse( $this->database
->isOpen() );
2022 $this->assertLastSql( 'BEGIN; DELETE FROM x WHERE field = \'3\'; ROLLBACK' );
2023 $this->assertEquals( 0, $this->database
->trxLevel() );
2027 * @covers \Wikimedia\Rdbms\Database::close
2029 public function testPrematureClose3() {
2031 $this->database
->setFlag( IDatabase
::DBO_TRX
);
2032 $this->database
->delete( 'x', [ 'field' => 3 ], __METHOD__
);
2033 $this->assertEquals( 1, $this->database
->trxLevel() );
2034 $this->database
->close();
2035 $this->fail( 'Expected exception not thrown' );
2036 } catch ( DBUnexpectedError
$ex ) {
2038 'Wikimedia\Rdbms\Database::close: ' .
2039 'mass commit/rollback of peer transaction required (DBO_TRX set).',
2044 $this->assertFalse( $this->database
->isOpen() );
2045 $this->assertLastSql( 'BEGIN; DELETE FROM x WHERE field = \'3\'; ROLLBACK' );
2046 $this->assertEquals( 0, $this->database
->trxLevel() );
2050 * @covers \Wikimedia\Rdbms\Database::close
2052 public function testPrematureClose4() {
2053 $this->database
->setFlag( IDatabase
::DBO_TRX
);
2054 $this->database
->query( 'SELECT 1', __METHOD__
);
2055 $this->assertEquals( 1, $this->database
->trxLevel() );
2056 $this->database
->close();
2057 $this->database
->clearFlag( IDatabase
::DBO_TRX
);
2059 $this->assertFalse( $this->database
->isOpen() );
2060 $this->assertLastSql( 'BEGIN; SELECT 1; COMMIT' );
2061 $this->assertEquals( 0, $this->database
->trxLevel() );