Merge "exception: Improve formatting of fatal error log messages"
[lhc/web/wiklou.git] / tests / phpunit / includes / libs / rdbms / database / DatabaseSQLTest.php
1 <?php
2
3 use Wikimedia\Rdbms\LikeMatch;
4 use Wikimedia\Rdbms\Database;
5
6 /**
7 * Test the parts of the Database abstract class that deal
8 * with creating SQL text.
9 */
10 class DatabaseSQLTest extends PHPUnit\Framework\TestCase {
11
12 use MediaWikiCoversValidator;
13
14 /** @var DatabaseTestHelper|Database */
15 private $database;
16
17 protected function setUp() {
18 parent::setUp();
19 $this->database = new DatabaseTestHelper( __CLASS__, [ 'cliMode' => true ] );
20 }
21
22 protected function assertLastSql( $sqlText ) {
23 $this->assertEquals(
24 $sqlText,
25 $this->database->getLastSqls()
26 );
27 }
28
29 protected function assertLastSqlDb( $sqlText, DatabaseTestHelper $db ) {
30 $this->assertEquals( $sqlText, $db->getLastSqls() );
31 }
32
33 /**
34 * @dataProvider provideSelect
35 * @covers Wikimedia\Rdbms\Database::select
36 * @covers Wikimedia\Rdbms\Database::selectSQLText
37 * @covers Wikimedia\Rdbms\Database::tableNamesWithIndexClauseOrJOIN
38 * @covers Wikimedia\Rdbms\Database::useIndexClause
39 * @covers Wikimedia\Rdbms\Database::ignoreIndexClause
40 * @covers Wikimedia\Rdbms\Database::makeSelectOptions
41 * @covers Wikimedia\Rdbms\Database::makeOrderBy
42 * @covers Wikimedia\Rdbms\Database::makeGroupByWithHaving
43 */
44 public function testSelect( $sql, $sqlText ) {
45 $this->database->select(
46 $sql['tables'],
47 $sql['fields'],
48 isset( $sql['conds'] ) ? $sql['conds'] : [],
49 __METHOD__,
50 isset( $sql['options'] ) ? $sql['options'] : [],
51 isset( $sql['join_conds'] ) ? $sql['join_conds'] : []
52 );
53 $this->assertLastSql( $sqlText );
54 }
55
56 public static function provideSelect() {
57 return [
58 [
59 [
60 'tables' => 'table',
61 'fields' => [ 'field', 'alias' => 'field2' ],
62 'conds' => [ 'alias' => 'text' ],
63 ],
64 "SELECT field,field2 AS alias " .
65 "FROM table " .
66 "WHERE alias = 'text'"
67 ],
68 [
69 [
70 'tables' => 'table',
71 'fields' => [ 'field', 'alias' => 'field2' ],
72 'conds' => 'alias = \'text\'',
73 ],
74 "SELECT field,field2 AS alias " .
75 "FROM table " .
76 "WHERE alias = 'text'"
77 ],
78 [
79 [
80 'tables' => 'table',
81 'fields' => [ 'field', 'alias' => 'field2' ],
82 'conds' => [],
83 ],
84 "SELECT field,field2 AS alias " .
85 "FROM table"
86 ],
87 [
88 [
89 'tables' => 'table',
90 'fields' => [ 'field', 'alias' => 'field2' ],
91 'conds' => '',
92 ],
93 "SELECT field,field2 AS alias " .
94 "FROM table"
95 ],
96 [
97 [
98 'tables' => 'table',
99 'fields' => [ 'field', 'alias' => 'field2' ],
100 'conds' => '0', // T188314
101 ],
102 "SELECT field,field2 AS alias " .
103 "FROM table " .
104 "WHERE 0"
105 ],
106 [
107 [
108 // 'tables' with space prepended indicates pre-escaped table name
109 'tables' => ' table LEFT JOIN table2',
110 'fields' => [ 'field' ],
111 'conds' => [ 'field' => 'text' ],
112 ],
113 "SELECT field FROM table LEFT JOIN table2 WHERE field = 'text'"
114 ],
115 [
116 [
117 // Empty 'tables' is allowed
118 'tables' => '',
119 'fields' => [ 'SPECIAL_QUERY()' ],
120 ],
121 "SELECT SPECIAL_QUERY()"
122 ],
123 [
124 [
125 'tables' => 'table',
126 'fields' => [ 'field', 'alias' => 'field2' ],
127 'conds' => [ 'alias' => 'text' ],
128 'options' => [ 'LIMIT' => 1, 'ORDER BY' => 'field' ],
129 ],
130 "SELECT field,field2 AS alias " .
131 "FROM table " .
132 "WHERE alias = 'text' " .
133 "ORDER BY field " .
134 "LIMIT 1"
135 ],
136 [
137 [
138 'tables' => [ 'table', 't2' => 'table2' ],
139 'fields' => [ 'tid', 'field', 'alias' => 'field2', 't2.id' ],
140 'conds' => [ 'alias' => 'text' ],
141 'options' => [ 'LIMIT' => 1, 'ORDER BY' => 'field' ],
142 'join_conds' => [ 't2' => [
143 'LEFT JOIN', 'tid = t2.id'
144 ] ],
145 ],
146 "SELECT tid,field,field2 AS alias,t2.id " .
147 "FROM table LEFT JOIN table2 t2 ON ((tid = t2.id)) " .
148 "WHERE alias = 'text' " .
149 "ORDER BY field " .
150 "LIMIT 1"
151 ],
152 [
153 [
154 'tables' => [ 'table', 't2' => 'table2' ],
155 'fields' => [ 'tid', 'field', 'alias' => 'field2', 't2.id' ],
156 'conds' => [ 'alias' => 'text' ],
157 'options' => [ 'LIMIT' => 1, 'GROUP BY' => 'field', 'HAVING' => 'COUNT(*) > 1' ],
158 'join_conds' => [ 't2' => [
159 'LEFT JOIN', 'tid = t2.id'
160 ] ],
161 ],
162 "SELECT tid,field,field2 AS alias,t2.id " .
163 "FROM table LEFT JOIN table2 t2 ON ((tid = t2.id)) " .
164 "WHERE alias = 'text' " .
165 "GROUP BY field HAVING COUNT(*) > 1 " .
166 "LIMIT 1"
167 ],
168 [
169 [
170 'tables' => [ 'table', 't2' => 'table2' ],
171 'fields' => [ 'tid', 'field', 'alias' => 'field2', 't2.id' ],
172 'conds' => [ 'alias' => 'text' ],
173 'options' => [
174 'LIMIT' => 1,
175 'GROUP BY' => [ 'field', 'field2' ],
176 'HAVING' => [ 'COUNT(*) > 1', 'field' => 1 ]
177 ],
178 'join_conds' => [ 't2' => [
179 'LEFT JOIN', 'tid = t2.id'
180 ] ],
181 ],
182 "SELECT tid,field,field2 AS alias,t2.id " .
183 "FROM table LEFT JOIN table2 t2 ON ((tid = t2.id)) " .
184 "WHERE alias = 'text' " .
185 "GROUP BY field,field2 HAVING (COUNT(*) > 1) AND field = '1' " .
186 "LIMIT 1"
187 ],
188 [
189 [
190 'tables' => [ 'table' ],
191 'fields' => [ 'alias' => 'field' ],
192 'conds' => [ 'alias' => [ 1, 2, 3, 4 ] ],
193 ],
194 "SELECT field AS alias " .
195 "FROM table " .
196 "WHERE alias IN ('1','2','3','4')"
197 ],
198 [
199 [
200 'tables' => 'table',
201 'fields' => [ 'field' ],
202 'options' => [ 'USE INDEX' => [ 'table' => 'X' ] ],
203 ],
204 // No-op by default
205 "SELECT field FROM table"
206 ],
207 [
208 [
209 'tables' => 'table',
210 'fields' => [ 'field' ],
211 'options' => [ 'IGNORE INDEX' => [ 'table' => 'X' ] ],
212 ],
213 // No-op by default
214 "SELECT field FROM table"
215 ],
216 [
217 [
218 'tables' => 'table',
219 'fields' => [ 'field' ],
220 'options' => [ 'DISTINCT', 'LOCK IN SHARE MODE' ],
221 ],
222 "SELECT DISTINCT field FROM table LOCK IN SHARE MODE"
223 ],
224 [
225 [
226 'tables' => 'table',
227 'fields' => [ 'field' ],
228 'options' => [ 'EXPLAIN' => true ],
229 ],
230 'EXPLAIN SELECT field FROM table'
231 ],
232 [
233 [
234 'tables' => 'table',
235 'fields' => [ 'field' ],
236 'options' => [ 'FOR UPDATE' ],
237 ],
238 "SELECT field FROM table FOR UPDATE"
239 ],
240 ];
241 }
242
243 /**
244 * @covers Wikimedia\Rdbms\Subquery
245 * @dataProvider provideSelectRowCount
246 * @param $sql
247 * @param $sqlText
248 */
249 public function testSelectRowCount( $sql, $sqlText ) {
250 $this->database->selectRowCount(
251 $sql['tables'],
252 $sql['field'],
253 isset( $sql['conds'] ) ? $sql['conds'] : [],
254 __METHOD__,
255 isset( $sql['options'] ) ? $sql['options'] : [],
256 isset( $sql['join_conds'] ) ? $sql['join_conds'] : []
257 );
258 $this->assertLastSql( $sqlText );
259 }
260
261 public static function provideSelectRowCount() {
262 return [
263 [
264 [
265 'tables' => 'table',
266 'field' => [ '*' ],
267 'conds' => [ 'field' => 'text' ],
268 ],
269 "SELECT COUNT(*) AS rowcount FROM " .
270 "(SELECT 1 FROM table WHERE field = 'text' ) tmp_count"
271 ],
272 [
273 [
274 'tables' => 'table',
275 'field' => [ 'column' ],
276 'conds' => [ 'field' => 'text' ],
277 ],
278 "SELECT COUNT(*) AS rowcount FROM " .
279 "(SELECT 1 FROM table WHERE field = 'text' AND (column IS NOT NULL) ) tmp_count"
280 ],
281 [
282 [
283 'tables' => 'table',
284 'field' => [ 'alias' => 'column' ],
285 'conds' => [ 'field' => 'text' ],
286 ],
287 "SELECT COUNT(*) AS rowcount FROM " .
288 "(SELECT 1 FROM table WHERE field = 'text' AND (column IS NOT NULL) ) tmp_count"
289 ],
290 [
291 [
292 'tables' => 'table',
293 'field' => [ 'alias' => 'column' ],
294 'conds' => '',
295 ],
296 "SELECT COUNT(*) AS rowcount FROM " .
297 "(SELECT 1 FROM table WHERE (column IS NOT NULL) ) tmp_count"
298 ],
299 [
300 [
301 'tables' => 'table',
302 'field' => [ 'alias' => 'column' ],
303 'conds' => false,
304 ],
305 "SELECT COUNT(*) AS rowcount FROM " .
306 "(SELECT 1 FROM table WHERE (column IS NOT NULL) ) tmp_count"
307 ],
308 [
309 [
310 'tables' => 'table',
311 'field' => [ 'alias' => 'column' ],
312 'conds' => null,
313 ],
314 "SELECT COUNT(*) AS rowcount FROM " .
315 "(SELECT 1 FROM table WHERE (column IS NOT NULL) ) tmp_count"
316 ],
317 [
318 [
319 'tables' => 'table',
320 'field' => [ 'alias' => 'column' ],
321 'conds' => '1',
322 ],
323 "SELECT COUNT(*) AS rowcount FROM " .
324 "(SELECT 1 FROM table WHERE (1) AND (column IS NOT NULL) ) tmp_count"
325 ],
326 [
327 [
328 'tables' => 'table',
329 'field' => [ 'alias' => 'column' ],
330 'conds' => '0',
331 ],
332 "SELECT COUNT(*) AS rowcount FROM " .
333 "(SELECT 1 FROM table WHERE (0) AND (column IS NOT NULL) ) tmp_count"
334 ],
335 ];
336 }
337
338 /**
339 * @dataProvider provideUpdate
340 * @covers Wikimedia\Rdbms\Database::update
341 * @covers Wikimedia\Rdbms\Database::makeUpdateOptions
342 * @covers Wikimedia\Rdbms\Database::makeUpdateOptionsArray
343 */
344 public function testUpdate( $sql, $sqlText ) {
345 $this->database->update(
346 $sql['table'],
347 $sql['values'],
348 $sql['conds'],
349 __METHOD__,
350 isset( $sql['options'] ) ? $sql['options'] : []
351 );
352 $this->assertLastSql( $sqlText );
353 }
354
355 public static function provideUpdate() {
356 return [
357 [
358 [
359 'table' => 'table',
360 'values' => [ 'field' => 'text', 'field2' => 'text2' ],
361 'conds' => [ 'alias' => 'text' ],
362 ],
363 "UPDATE table " .
364 "SET field = 'text'" .
365 ",field2 = 'text2' " .
366 "WHERE alias = 'text'"
367 ],
368 [
369 [
370 'table' => 'table',
371 'values' => [ 'field = other', 'field2' => 'text2' ],
372 'conds' => [ 'id' => '1' ],
373 ],
374 "UPDATE table " .
375 "SET field = other" .
376 ",field2 = 'text2' " .
377 "WHERE id = '1'"
378 ],
379 [
380 [
381 'table' => 'table',
382 'values' => [ 'field = other', 'field2' => 'text2' ],
383 'conds' => '*',
384 ],
385 "UPDATE table " .
386 "SET field = other" .
387 ",field2 = 'text2'"
388 ],
389 ];
390 }
391
392 /**
393 * @dataProvider provideDelete
394 * @covers Wikimedia\Rdbms\Database::delete
395 */
396 public function testDelete( $sql, $sqlText ) {
397 $this->database->delete(
398 $sql['table'],
399 $sql['conds'],
400 __METHOD__
401 );
402 $this->assertLastSql( $sqlText );
403 }
404
405 public static function provideDelete() {
406 return [
407 [
408 [
409 'table' => 'table',
410 'conds' => [ 'alias' => 'text' ],
411 ],
412 "DELETE FROM table " .
413 "WHERE alias = 'text'"
414 ],
415 [
416 [
417 'table' => 'table',
418 'conds' => '*',
419 ],
420 "DELETE FROM table"
421 ],
422 ];
423 }
424
425 /**
426 * @dataProvider provideUpsert
427 * @covers Wikimedia\Rdbms\Database::upsert
428 */
429 public function testUpsert( $sql, $sqlText ) {
430 $this->database->upsert(
431 $sql['table'],
432 $sql['rows'],
433 $sql['uniqueIndexes'],
434 $sql['set'],
435 __METHOD__
436 );
437 $this->assertLastSql( $sqlText );
438 }
439
440 public static function provideUpsert() {
441 return [
442 [
443 [
444 'table' => 'upsert_table',
445 'rows' => [ 'field' => 'text', 'field2' => 'text2' ],
446 'uniqueIndexes' => [ 'field' ],
447 'set' => [ 'field' => 'set' ],
448 ],
449 "BEGIN; " .
450 "UPDATE upsert_table " .
451 "SET field = 'set' " .
452 "WHERE ((field = 'text')); " .
453 "INSERT IGNORE INTO upsert_table " .
454 "(field,field2) " .
455 "VALUES ('text','text2'); " .
456 "COMMIT"
457 ],
458 ];
459 }
460
461 /**
462 * @dataProvider provideDeleteJoin
463 * @covers Wikimedia\Rdbms\Database::deleteJoin
464 */
465 public function testDeleteJoin( $sql, $sqlText ) {
466 $this->database->deleteJoin(
467 $sql['delTable'],
468 $sql['joinTable'],
469 $sql['delVar'],
470 $sql['joinVar'],
471 $sql['conds'],
472 __METHOD__
473 );
474 $this->assertLastSql( $sqlText );
475 }
476
477 public static function provideDeleteJoin() {
478 return [
479 [
480 [
481 'delTable' => 'table',
482 'joinTable' => 'table_join',
483 'delVar' => 'field',
484 'joinVar' => 'field_join',
485 'conds' => [ 'alias' => 'text' ],
486 ],
487 "DELETE FROM table " .
488 "WHERE field IN (" .
489 "SELECT field_join FROM table_join WHERE alias = 'text'" .
490 ")"
491 ],
492 [
493 [
494 'delTable' => 'table',
495 'joinTable' => 'table_join',
496 'delVar' => 'field',
497 'joinVar' => 'field_join',
498 'conds' => '*',
499 ],
500 "DELETE FROM table " .
501 "WHERE field IN (" .
502 "SELECT field_join FROM table_join " .
503 ")"
504 ],
505 ];
506 }
507
508 /**
509 * @dataProvider provideInsert
510 * @covers Wikimedia\Rdbms\Database::insert
511 * @covers Wikimedia\Rdbms\Database::makeInsertOptions
512 */
513 public function testInsert( $sql, $sqlText ) {
514 $this->database->insert(
515 $sql['table'],
516 $sql['rows'],
517 __METHOD__,
518 isset( $sql['options'] ) ? $sql['options'] : []
519 );
520 $this->assertLastSql( $sqlText );
521 }
522
523 public static function provideInsert() {
524 return [
525 [
526 [
527 'table' => 'table',
528 'rows' => [ 'field' => 'text', 'field2' => 2 ],
529 ],
530 "INSERT INTO table " .
531 "(field,field2) " .
532 "VALUES ('text','2')"
533 ],
534 [
535 [
536 'table' => 'table',
537 'rows' => [ 'field' => 'text', 'field2' => 2 ],
538 'options' => 'IGNORE',
539 ],
540 "INSERT IGNORE INTO table " .
541 "(field,field2) " .
542 "VALUES ('text','2')"
543 ],
544 [
545 [
546 'table' => 'table',
547 'rows' => [
548 [ 'field' => 'text', 'field2' => 2 ],
549 [ 'field' => 'multi', 'field2' => 3 ],
550 ],
551 'options' => 'IGNORE',
552 ],
553 "INSERT IGNORE INTO table " .
554 "(field,field2) " .
555 "VALUES " .
556 "('text','2')," .
557 "('multi','3')"
558 ],
559 ];
560 }
561
562 /**
563 * @dataProvider provideInsertSelect
564 * @covers Wikimedia\Rdbms\Database::insertSelect
565 * @covers Wikimedia\Rdbms\Database::nativeInsertSelect
566 */
567 public function testInsertSelect( $sql, $sqlTextNative, $sqlSelect, $sqlInsert ) {
568 $this->database->insertSelect(
569 $sql['destTable'],
570 $sql['srcTable'],
571 $sql['varMap'],
572 $sql['conds'],
573 __METHOD__,
574 isset( $sql['insertOptions'] ) ? $sql['insertOptions'] : [],
575 isset( $sql['selectOptions'] ) ? $sql['selectOptions'] : [],
576 isset( $sql['selectJoinConds'] ) ? $sql['selectJoinConds'] : []
577 );
578 $this->assertLastSql( $sqlTextNative );
579
580 $dbWeb = new DatabaseTestHelper( __CLASS__, [ 'cliMode' => false ] );
581 $dbWeb->forceNextResult( [
582 array_flip( array_keys( $sql['varMap'] ) )
583 ] );
584 $dbWeb->insertSelect(
585 $sql['destTable'],
586 $sql['srcTable'],
587 $sql['varMap'],
588 $sql['conds'],
589 __METHOD__,
590 isset( $sql['insertOptions'] ) ? $sql['insertOptions'] : [],
591 isset( $sql['selectOptions'] ) ? $sql['selectOptions'] : [],
592 isset( $sql['selectJoinConds'] ) ? $sql['selectJoinConds'] : []
593 );
594 $this->assertLastSqlDb( implode( '; ', [ $sqlSelect, 'BEGIN', $sqlInsert, 'COMMIT' ] ), $dbWeb );
595 }
596
597 public static function provideInsertSelect() {
598 return [
599 [
600 [
601 'destTable' => 'insert_table',
602 'srcTable' => 'select_table',
603 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
604 'conds' => '*',
605 ],
606 "INSERT INTO insert_table " .
607 "(field_insert,field) " .
608 "SELECT field_select,field2 " .
609 "FROM select_table WHERE *",
610 "SELECT field_select AS field_insert,field2 AS field " .
611 "FROM select_table WHERE * FOR UPDATE",
612 "INSERT INTO insert_table (field_insert,field) VALUES ('0','1')"
613 ],
614 [
615 [
616 'destTable' => 'insert_table',
617 'srcTable' => 'select_table',
618 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
619 'conds' => [ 'field' => 2 ],
620 ],
621 "INSERT INTO insert_table " .
622 "(field_insert,field) " .
623 "SELECT field_select,field2 " .
624 "FROM select_table " .
625 "WHERE field = '2'",
626 "SELECT field_select AS field_insert,field2 AS field FROM " .
627 "select_table WHERE field = '2' FOR UPDATE",
628 "INSERT INTO insert_table (field_insert,field) VALUES ('0','1')"
629 ],
630 [
631 [
632 'destTable' => 'insert_table',
633 'srcTable' => 'select_table',
634 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
635 'conds' => [ 'field' => 2 ],
636 'insertOptions' => 'IGNORE',
637 'selectOptions' => [ 'ORDER BY' => 'field' ],
638 ],
639 "INSERT IGNORE INTO insert_table " .
640 "(field_insert,field) " .
641 "SELECT field_select,field2 " .
642 "FROM select_table " .
643 "WHERE field = '2' " .
644 "ORDER BY field",
645 "SELECT field_select AS field_insert,field2 AS field " .
646 "FROM select_table WHERE field = '2' ORDER BY field FOR UPDATE",
647 "INSERT IGNORE INTO insert_table (field_insert,field) VALUES ('0','1')"
648 ],
649 [
650 [
651 'destTable' => 'insert_table',
652 'srcTable' => [ 'select_table1', 'select_table2' ],
653 'varMap' => [ 'field_insert' => 'field_select', 'field' => 'field2' ],
654 'conds' => [ 'field' => 2 ],
655 'insertOptions' => [ 'NO_AUTO_COLUMNS' ],
656 'selectOptions' => [ 'ORDER BY' => 'field', 'FORCE INDEX' => [ 'select_table1' => 'index1' ] ],
657 'selectJoinConds' => [
658 'select_table2' => [ 'LEFT JOIN', [ 'select_table1.foo = select_table2.bar' ] ],
659 ],
660 ],
661 "INSERT INTO insert_table " .
662 "(field_insert,field) " .
663 "SELECT field_select,field2 " .
664 "FROM select_table1 LEFT JOIN select_table2 ON ((select_table1.foo = select_table2.bar)) " .
665 "WHERE field = '2' " .
666 "ORDER BY field",
667 "SELECT field_select AS field_insert,field2 AS field " .
668 "FROM select_table1 LEFT JOIN select_table2 ON ((select_table1.foo = select_table2.bar)) " .
669 "WHERE field = '2' ORDER BY field FOR UPDATE",
670 "INSERT INTO insert_table (field_insert,field) VALUES ('0','1')"
671 ],
672 ];
673 }
674
675 public function testInsertSelectBatching() {
676 $dbWeb = new DatabaseTestHelper( __CLASS__, [ 'cliMode' => false ] );
677 $rows = [];
678 for ( $i = 0; $i <= 25000; $i++ ) {
679 $rows[] = [ 'field' => $i ];
680 }
681 $dbWeb->forceNextResult( $rows );
682 $dbWeb->insertSelect(
683 'insert_table',
684 'select_table',
685 [ 'field' => 'field2' ],
686 '*',
687 __METHOD__
688 );
689 $this->assertLastSqlDb( implode( '; ', [
690 'SELECT field2 AS field FROM select_table WHERE * FOR UPDATE',
691 'BEGIN',
692 "INSERT INTO insert_table (field) VALUES ('" . implode( "'),('", range( 0, 9999 ) ) . "')",
693 "INSERT INTO insert_table (field) VALUES ('" . implode( "'),('", range( 10000, 19999 ) ) . "')",
694 "INSERT INTO insert_table (field) VALUES ('" . implode( "'),('", range( 20000, 25000 ) ) . "')",
695 'COMMIT'
696 ] ), $dbWeb );
697 }
698
699 /**
700 * @dataProvider provideReplace
701 * @covers Wikimedia\Rdbms\Database::replace
702 */
703 public function testReplace( $sql, $sqlText ) {
704 $this->database->replace(
705 $sql['table'],
706 $sql['uniqueIndexes'],
707 $sql['rows'],
708 __METHOD__
709 );
710 $this->assertLastSql( $sqlText );
711 }
712
713 public static function provideReplace() {
714 return [
715 [
716 [
717 'table' => 'replace_table',
718 'uniqueIndexes' => [ 'field' ],
719 'rows' => [ 'field' => 'text', 'field2' => 'text2' ],
720 ],
721 "BEGIN; DELETE FROM replace_table " .
722 "WHERE (field = 'text'); " .
723 "INSERT INTO replace_table " .
724 "(field,field2) " .
725 "VALUES ('text','text2'); COMMIT"
726 ],
727 [
728 [
729 'table' => 'module_deps',
730 'uniqueIndexes' => [ [ 'md_module', 'md_skin' ] ],
731 'rows' => [
732 'md_module' => 'module',
733 'md_skin' => 'skin',
734 'md_deps' => 'deps',
735 ],
736 ],
737 "BEGIN; DELETE FROM module_deps " .
738 "WHERE (md_module = 'module' AND md_skin = 'skin'); " .
739 "INSERT INTO module_deps " .
740 "(md_module,md_skin,md_deps) " .
741 "VALUES ('module','skin','deps'); COMMIT"
742 ],
743 [
744 [
745 'table' => 'module_deps',
746 'uniqueIndexes' => [ [ 'md_module', 'md_skin' ] ],
747 'rows' => [
748 [
749 'md_module' => 'module',
750 'md_skin' => 'skin',
751 'md_deps' => 'deps',
752 ], [
753 'md_module' => 'module2',
754 'md_skin' => 'skin2',
755 'md_deps' => 'deps2',
756 ],
757 ],
758 ],
759 "BEGIN; DELETE FROM module_deps " .
760 "WHERE (md_module = 'module' AND md_skin = 'skin'); " .
761 "INSERT INTO module_deps " .
762 "(md_module,md_skin,md_deps) " .
763 "VALUES ('module','skin','deps'); " .
764 "DELETE FROM module_deps " .
765 "WHERE (md_module = 'module2' AND md_skin = 'skin2'); " .
766 "INSERT INTO module_deps " .
767 "(md_module,md_skin,md_deps) " .
768 "VALUES ('module2','skin2','deps2'); COMMIT"
769 ],
770 [
771 [
772 'table' => 'module_deps',
773 'uniqueIndexes' => [ 'md_module', 'md_skin' ],
774 'rows' => [
775 [
776 'md_module' => 'module',
777 'md_skin' => 'skin',
778 'md_deps' => 'deps',
779 ], [
780 'md_module' => 'module2',
781 'md_skin' => 'skin2',
782 'md_deps' => 'deps2',
783 ],
784 ],
785 ],
786 "BEGIN; DELETE FROM module_deps " .
787 "WHERE (md_module = 'module') OR (md_skin = 'skin'); " .
788 "INSERT INTO module_deps " .
789 "(md_module,md_skin,md_deps) " .
790 "VALUES ('module','skin','deps'); " .
791 "DELETE FROM module_deps " .
792 "WHERE (md_module = 'module2') OR (md_skin = 'skin2'); " .
793 "INSERT INTO module_deps " .
794 "(md_module,md_skin,md_deps) " .
795 "VALUES ('module2','skin2','deps2'); COMMIT"
796 ],
797 [
798 [
799 'table' => 'module_deps',
800 'uniqueIndexes' => [],
801 'rows' => [
802 'md_module' => 'module',
803 'md_skin' => 'skin',
804 'md_deps' => 'deps',
805 ],
806 ],
807 "BEGIN; INSERT INTO module_deps " .
808 "(md_module,md_skin,md_deps) " .
809 "VALUES ('module','skin','deps'); COMMIT"
810 ],
811 ];
812 }
813
814 /**
815 * @dataProvider provideNativeReplace
816 * @covers Wikimedia\Rdbms\Database::nativeReplace
817 */
818 public function testNativeReplace( $sql, $sqlText ) {
819 $this->database->nativeReplace(
820 $sql['table'],
821 $sql['rows'],
822 __METHOD__
823 );
824 $this->assertLastSql( $sqlText );
825 }
826
827 public static function provideNativeReplace() {
828 return [
829 [
830 [
831 'table' => 'replace_table',
832 'rows' => [ 'field' => 'text', 'field2' => 'text2' ],
833 ],
834 "REPLACE INTO replace_table " .
835 "(field,field2) " .
836 "VALUES ('text','text2')"
837 ],
838 ];
839 }
840
841 /**
842 * @dataProvider provideConditional
843 * @covers Wikimedia\Rdbms\Database::conditional
844 */
845 public function testConditional( $sql, $sqlText ) {
846 $this->assertEquals( trim( $this->database->conditional(
847 $sql['conds'],
848 $sql['true'],
849 $sql['false']
850 ) ), $sqlText );
851 }
852
853 public static function provideConditional() {
854 return [
855 [
856 [
857 'conds' => [ 'field' => 'text' ],
858 'true' => 1,
859 'false' => 'NULL',
860 ],
861 "(CASE WHEN field = 'text' THEN 1 ELSE NULL END)"
862 ],
863 [
864 [
865 'conds' => [ 'field' => 'text', 'field2' => 'anothertext' ],
866 'true' => 1,
867 'false' => 'NULL',
868 ],
869 "(CASE WHEN field = 'text' AND field2 = 'anothertext' THEN 1 ELSE NULL END)"
870 ],
871 [
872 [
873 'conds' => 'field=1',
874 'true' => 1,
875 'false' => 'NULL',
876 ],
877 "(CASE WHEN field=1 THEN 1 ELSE NULL END)"
878 ],
879 ];
880 }
881
882 /**
883 * @dataProvider provideBuildConcat
884 * @covers Wikimedia\Rdbms\Database::buildConcat
885 */
886 public function testBuildConcat( $stringList, $sqlText ) {
887 $this->assertEquals( trim( $this->database->buildConcat(
888 $stringList
889 ) ), $sqlText );
890 }
891
892 public static function provideBuildConcat() {
893 return [
894 [
895 [ 'field', 'field2' ],
896 "CONCAT(field,field2)"
897 ],
898 [
899 [ "'test'", 'field2' ],
900 "CONCAT('test',field2)"
901 ],
902 ];
903 }
904
905 /**
906 * @dataProvider provideBuildLike
907 * @covers Wikimedia\Rdbms\Database::buildLike
908 * @covers Wikimedia\Rdbms\Database::escapeLikeInternal
909 */
910 public function testBuildLike( $array, $sqlText ) {
911 $this->assertEquals( trim( $this->database->buildLike(
912 $array
913 ) ), $sqlText );
914 }
915
916 public static function provideBuildLike() {
917 return [
918 [
919 'text',
920 "LIKE 'text' ESCAPE '`'"
921 ],
922 [
923 [ 'text', new LikeMatch( '%' ) ],
924 "LIKE 'text%' ESCAPE '`'"
925 ],
926 [
927 [ 'text', new LikeMatch( '%' ), 'text2' ],
928 "LIKE 'text%text2' ESCAPE '`'"
929 ],
930 [
931 [ 'text', new LikeMatch( '_' ) ],
932 "LIKE 'text_' ESCAPE '`'"
933 ],
934 [
935 'more_text',
936 "LIKE 'more`_text' ESCAPE '`'"
937 ],
938 [
939 [ 'C:\\Windows\\', new LikeMatch( '%' ) ],
940 "LIKE 'C:\\Windows\\%' ESCAPE '`'"
941 ],
942 [
943 [ 'accent`_test`', new LikeMatch( '%' ) ],
944 "LIKE 'accent```_test``%' ESCAPE '`'"
945 ],
946 ];
947 }
948
949 /**
950 * @dataProvider provideUnionQueries
951 * @covers Wikimedia\Rdbms\Database::unionQueries
952 */
953 public function testUnionQueries( $sql, $sqlText ) {
954 $this->assertEquals( trim( $this->database->unionQueries(
955 $sql['sqls'],
956 $sql['all']
957 ) ), $sqlText );
958 }
959
960 public static function provideUnionQueries() {
961 return [
962 [
963 [
964 'sqls' => [ 'RAW SQL', 'RAW2SQL' ],
965 'all' => true,
966 ],
967 "(RAW SQL) UNION ALL (RAW2SQL)"
968 ],
969 [
970 [
971 'sqls' => [ 'RAW SQL', 'RAW2SQL' ],
972 'all' => false,
973 ],
974 "(RAW SQL) UNION (RAW2SQL)"
975 ],
976 [
977 [
978 'sqls' => [ 'RAW SQL', 'RAW2SQL', 'RAW3SQL' ],
979 'all' => false,
980 ],
981 "(RAW SQL) UNION (RAW2SQL) UNION (RAW3SQL)"
982 ],
983 ];
984 }
985
986 /**
987 * @dataProvider provideUnionConditionPermutations
988 * @covers Wikimedia\Rdbms\Database::unionConditionPermutations
989 */
990 public function testUnionConditionPermutations( $params, $expect ) {
991 if ( isset( $params['unionSupportsOrderAndLimit'] ) ) {
992 $this->database->setUnionSupportsOrderAndLimit( $params['unionSupportsOrderAndLimit'] );
993 }
994
995 $sql = trim( $this->database->unionConditionPermutations(
996 $params['table'],
997 $params['vars'],
998 $params['permute_conds'],
999 isset( $params['extra_conds'] ) ? $params['extra_conds'] : '',
1000 'FNAME',
1001 isset( $params['options'] ) ? $params['options'] : [],
1002 isset( $params['join_conds'] ) ? $params['join_conds'] : []
1003 ) );
1004 $this->assertEquals( $expect, $sql );
1005 }
1006
1007 public static function provideUnionConditionPermutations() {
1008 // phpcs:disable Generic.Files.LineLength
1009 return [
1010 [
1011 [
1012 'table' => [ 'table1', 'table2' ],
1013 'vars' => [ 'field1', 'alias' => 'field2' ],
1014 'permute_conds' => [
1015 'field3' => [ 1, 2, 3 ],
1016 'duplicates' => [ 4, 5, 4 ],
1017 'empty' => [],
1018 'single' => [ 0 ],
1019 ],
1020 'extra_conds' => 'table2.bar > 23',
1021 'options' => [
1022 'ORDER BY' => [ 'field1', 'alias' ],
1023 'INNER ORDER BY' => [ 'field1', 'field2' ],
1024 'LIMIT' => 100,
1025 ],
1026 'join_conds' => [
1027 'table2' => [ 'JOIN', 'table1.foo_id = table2.foo_id' ],
1028 ],
1029 ],
1030 "(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 " .
1031 "(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 " .
1032 "(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 " .
1033 "(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 " .
1034 "(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 " .
1035 "(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 ) " .
1036 "ORDER BY field1,alias LIMIT 100"
1037 ],
1038 [
1039 [
1040 'table' => 'foo',
1041 'vars' => [ 'foo_id' ],
1042 'permute_conds' => [
1043 'bar' => [ 1, 2, 3 ],
1044 ],
1045 'extra_conds' => [ 'baz' => null ],
1046 'options' => [
1047 'NOTALL',
1048 'ORDER BY' => [ 'foo_id' ],
1049 'LIMIT' => 25,
1050 ],
1051 ],
1052 "(SELECT foo_id FROM foo WHERE bar = '1' AND baz IS NULL ORDER BY foo_id LIMIT 25 ) UNION " .
1053 "(SELECT foo_id FROM foo WHERE bar = '2' AND baz IS NULL ORDER BY foo_id LIMIT 25 ) UNION " .
1054 "(SELECT foo_id FROM foo WHERE bar = '3' AND baz IS NULL ORDER BY foo_id LIMIT 25 ) " .
1055 "ORDER BY foo_id LIMIT 25"
1056 ],
1057 [
1058 [
1059 'table' => 'foo',
1060 'vars' => [ 'foo_id' ],
1061 'permute_conds' => [
1062 'bar' => [ 1, 2, 3 ],
1063 ],
1064 'extra_conds' => [ 'baz' => null ],
1065 'options' => [
1066 'NOTALL' => true,
1067 'ORDER BY' => [ 'foo_id' ],
1068 'LIMIT' => 25,
1069 ],
1070 'unionSupportsOrderAndLimit' => false,
1071 ],
1072 "(SELECT foo_id FROM foo WHERE bar = '1' AND baz IS NULL ) UNION " .
1073 "(SELECT foo_id FROM foo WHERE bar = '2' AND baz IS NULL ) UNION " .
1074 "(SELECT foo_id FROM foo WHERE bar = '3' AND baz IS NULL ) " .
1075 "ORDER BY foo_id LIMIT 25"
1076 ],
1077 [
1078 [
1079 'table' => 'foo',
1080 'vars' => [ 'foo_id' ],
1081 'permute_conds' => [],
1082 'extra_conds' => [ 'baz' => null ],
1083 'options' => [
1084 'ORDER BY' => [ 'foo_id' ],
1085 'LIMIT' => 25,
1086 ],
1087 ],
1088 "SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY foo_id LIMIT 25"
1089 ],
1090 [
1091 [
1092 'table' => 'foo',
1093 'vars' => [ 'foo_id' ],
1094 'permute_conds' => [
1095 'bar' => [],
1096 ],
1097 'extra_conds' => [ 'baz' => null ],
1098 'options' => [
1099 'ORDER BY' => [ 'foo_id' ],
1100 'LIMIT' => 25,
1101 ],
1102 ],
1103 "SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY foo_id LIMIT 25"
1104 ],
1105 [
1106 [
1107 'table' => 'foo',
1108 'vars' => [ 'foo_id' ],
1109 'permute_conds' => [
1110 'bar' => [ 1 ],
1111 ],
1112 'options' => [
1113 'ORDER BY' => [ 'foo_id' ],
1114 'LIMIT' => 25,
1115 'OFFSET' => 150,
1116 ],
1117 ],
1118 "SELECT foo_id FROM foo WHERE bar = '1' ORDER BY foo_id LIMIT 150,25"
1119 ],
1120 [
1121 [
1122 'table' => 'foo',
1123 'vars' => [ 'foo_id' ],
1124 'permute_conds' => [],
1125 'extra_conds' => [ 'baz' => null ],
1126 'options' => [
1127 'ORDER BY' => [ 'foo_id' ],
1128 'LIMIT' => 25,
1129 'OFFSET' => 150,
1130 'INNER ORDER BY' => [ 'bar_id' ],
1131 ],
1132 ],
1133 "(SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY bar_id LIMIT 175 ) ORDER BY foo_id LIMIT 150,25"
1134 ],
1135 [
1136 [
1137 'table' => 'foo',
1138 'vars' => [ 'foo_id' ],
1139 'permute_conds' => [],
1140 'extra_conds' => [ 'baz' => null ],
1141 'options' => [
1142 'ORDER BY' => [ 'foo_id' ],
1143 'LIMIT' => 25,
1144 'OFFSET' => 150,
1145 'INNER ORDER BY' => [ 'bar_id' ],
1146 ],
1147 'unionSupportsOrderAndLimit' => false,
1148 ],
1149 "SELECT foo_id FROM foo WHERE baz IS NULL ORDER BY foo_id LIMIT 150,25"
1150 ],
1151 ];
1152 // phpcs:enable
1153 }
1154
1155 /**
1156 * @covers Wikimedia\Rdbms\Database::commit
1157 * @covers Wikimedia\Rdbms\Database::doCommit
1158 */
1159 public function testTransactionCommit() {
1160 $this->database->begin( __METHOD__ );
1161 $this->database->commit( __METHOD__ );
1162 $this->assertLastSql( 'BEGIN; COMMIT' );
1163 }
1164
1165 /**
1166 * @covers Wikimedia\Rdbms\Database::rollback
1167 * @covers Wikimedia\Rdbms\Database::doRollback
1168 */
1169 public function testTransactionRollback() {
1170 $this->database->begin( __METHOD__ );
1171 $this->database->rollback( __METHOD__ );
1172 $this->assertLastSql( 'BEGIN; ROLLBACK' );
1173 }
1174
1175 /**
1176 * @covers Wikimedia\Rdbms\Database::dropTable
1177 */
1178 public function testDropTable() {
1179 $this->database->setExistingTables( [ 'table' ] );
1180 $this->database->dropTable( 'table', __METHOD__ );
1181 $this->assertLastSql( 'DROP TABLE table CASCADE' );
1182 }
1183
1184 /**
1185 * @covers Wikimedia\Rdbms\Database::dropTable
1186 */
1187 public function testDropNonExistingTable() {
1188 $this->assertFalse(
1189 $this->database->dropTable( 'non_existing', __METHOD__ )
1190 );
1191 }
1192
1193 /**
1194 * @dataProvider provideMakeList
1195 * @covers Wikimedia\Rdbms\Database::makeList
1196 */
1197 public function testMakeList( $list, $mode, $sqlText ) {
1198 $this->assertEquals( trim( $this->database->makeList(
1199 $list, $mode
1200 ) ), $sqlText );
1201 }
1202
1203 public static function provideMakeList() {
1204 return [
1205 [
1206 [ 'value', 'value2' ],
1207 LIST_COMMA,
1208 "'value','value2'"
1209 ],
1210 [
1211 [ 'field', 'field2' ],
1212 LIST_NAMES,
1213 "field,field2"
1214 ],
1215 [
1216 [ 'field' => 'value', 'field2' => 'value2' ],
1217 LIST_AND,
1218 "field = 'value' AND field2 = 'value2'"
1219 ],
1220 [
1221 [ 'field' => null, "field2 != 'value2'" ],
1222 LIST_AND,
1223 "field IS NULL AND (field2 != 'value2')"
1224 ],
1225 [
1226 [ 'field' => [ 'value', null, 'value2' ], 'field2' => 'value2' ],
1227 LIST_AND,
1228 "(field IN ('value','value2') OR field IS NULL) AND field2 = 'value2'"
1229 ],
1230 [
1231 [ 'field' => [ null ], 'field2' => null ],
1232 LIST_AND,
1233 "field IS NULL AND field2 IS NULL"
1234 ],
1235 [
1236 [ 'field' => 'value', 'field2' => 'value2' ],
1237 LIST_OR,
1238 "field = 'value' OR field2 = 'value2'"
1239 ],
1240 [
1241 [ 'field' => 'value', 'field2' => null ],
1242 LIST_OR,
1243 "field = 'value' OR field2 IS NULL"
1244 ],
1245 [
1246 [ 'field' => [ 'value', 'value2' ], 'field2' => [ 'value' ] ],
1247 LIST_OR,
1248 "field IN ('value','value2') OR field2 = 'value'"
1249 ],
1250 [
1251 [ 'field' => [ null, 'value', null, 'value2' ], "field2 != 'value2'" ],
1252 LIST_OR,
1253 "(field IN ('value','value2') OR field IS NULL) OR (field2 != 'value2')"
1254 ],
1255 [
1256 [ 'field' => 'value', 'field2' => 'value2' ],
1257 LIST_SET,
1258 "field = 'value',field2 = 'value2'"
1259 ],
1260 [
1261 [ 'field' => 'value', 'field2' => null ],
1262 LIST_SET,
1263 "field = 'value',field2 = NULL"
1264 ],
1265 [
1266 [ 'field' => 'value', "field2 != 'value2'" ],
1267 LIST_SET,
1268 "field = 'value',field2 != 'value2'"
1269 ],
1270 ];
1271 }
1272
1273 /**
1274 * @covers Wikimedia\Rdbms\Database::registerTempTableOperation
1275 */
1276 public function testSessionTempTables() {
1277 $temp1 = $this->database->tableName( 'tmp_table_1' );
1278 $temp2 = $this->database->tableName( 'tmp_table_2' );
1279 $temp3 = $this->database->tableName( 'tmp_table_3' );
1280
1281 $this->database->query( "CREATE TEMPORARY TABLE $temp1 LIKE orig_tbl", __METHOD__ );
1282 $this->database->query( "CREATE TEMPORARY TABLE $temp2 LIKE orig_tbl", __METHOD__ );
1283 $this->database->query( "CREATE TEMPORARY TABLE $temp3 LIKE orig_tbl", __METHOD__ );
1284
1285 $this->assertTrue( $this->database->tableExists( "tmp_table_1", __METHOD__ ) );
1286 $this->assertTrue( $this->database->tableExists( "tmp_table_2", __METHOD__ ) );
1287 $this->assertTrue( $this->database->tableExists( "tmp_table_3", __METHOD__ ) );
1288
1289 $this->database->dropTable( 'tmp_table_1', __METHOD__ );
1290 $this->database->dropTable( 'tmp_table_2', __METHOD__ );
1291 $this->database->dropTable( 'tmp_table_3', __METHOD__ );
1292
1293 $this->assertFalse( $this->database->tableExists( "tmp_table_1", __METHOD__ ) );
1294 $this->assertFalse( $this->database->tableExists( "tmp_table_2", __METHOD__ ) );
1295 $this->assertFalse( $this->database->tableExists( "tmp_table_3", __METHOD__ ) );
1296
1297 $this->database->query( "CREATE TEMPORARY TABLE tmp_table_1 LIKE orig_tbl", __METHOD__ );
1298 $this->database->query( "CREATE TEMPORARY TABLE 'tmp_table_2' LIKE orig_tbl", __METHOD__ );
1299 $this->database->query( "CREATE TEMPORARY TABLE `tmp_table_3` LIKE orig_tbl", __METHOD__ );
1300
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__ ) );
1304
1305 $this->database->query( "DROP TEMPORARY TABLE tmp_table_1 LIKE orig_tbl", __METHOD__ );
1306 $this->database->query( "DROP TEMPORARY TABLE 'tmp_table_2' LIKE orig_tbl", __METHOD__ );
1307 $this->database->query( "DROP TABLE `tmp_table_3` LIKE orig_tbl", __METHOD__ );
1308
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__ ) );
1312 }
1313
1314 public function provideBuildSubstring() {
1315 yield [ 'someField', 1, 2, 'SUBSTRING(someField FROM 1 FOR 2)' ];
1316 yield [ 'someField', 1, null, 'SUBSTRING(someField FROM 1)' ];
1317 }
1318
1319 /**
1320 * @covers Wikimedia\Rdbms\Database::buildSubstring
1321 * @dataProvider provideBuildSubstring
1322 */
1323 public function testBuildSubstring( $input, $start, $length, $expected ) {
1324 $output = $this->database->buildSubstring( $input, $start, $length );
1325 $this->assertSame( $expected, $output );
1326 }
1327
1328 public function provideBuildSubstring_invalidParams() {
1329 yield [ -1, 1 ];
1330 yield [ 1, -1 ];
1331 yield [ 1, 'foo' ];
1332 yield [ 'foo', 1 ];
1333 yield [ null, 1 ];
1334 yield [ 0, 1 ];
1335 }
1336
1337 /**
1338 * @covers Wikimedia\Rdbms\Database::buildSubstring
1339 * @covers Wikimedia\Rdbms\Database::assertBuildSubstringParams
1340 * @dataProvider provideBuildSubstring_invalidParams
1341 */
1342 public function testBuildSubstring_invalidParams( $start, $length ) {
1343 $this->setExpectedException( InvalidArgumentException::class );
1344 $this->database->buildSubstring( 'foo', $start, $length );
1345 }
1346
1347 /**
1348 * @covers \Wikimedia\Rdbms\Database::buildIntegerCast
1349 */
1350 public function testBuildIntegerCast() {
1351 $output = $this->database->buildIntegerCast( 'fieldName' );
1352 $this->assertSame( 'CAST( fieldName AS INTEGER )', $output );
1353 }
1354
1355 }