1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
<?php
namespace MediaWiki\Tests\Maintenance;
use MwSql;
/**
* @covers \MwSql
* @group Database
* @author Dreamy Jazz
*/
class MwSqlTest extends MaintenanceBaseTestCase {
protected function getMaintenanceClass() {
return MwSql::class;
}
public function testExecuteForSelectQueryProvidedViaQueryOption() {
// Add a testing row to the updatelog table, which we will use the maintenance script to read back.
$this->getDb()->newInsertQueryBuilder()
->insertInto( 'updatelog' )
->row( [ 'ul_key' => 'testing', 'ul_value' => 'testing-value-12345' ] )
->caller( __METHOD__ )
->execute();
// Output JSON to make it easier to assert that the script worked.
$this->maintenance->setOption( 'json', 1 );
// Specify the query using the 'query' option to avoid needing to write to STDIN.
$this->maintenance->setOption(
'query',
$this->newSelectQueryBuilder()
->field( 'ul_value' )
->from( 'updatelog' )
->where( [ 'ul_key' => 'testing' ] )
->caller( __METHOD__ )
->getSQL()
);
$this->maintenance->execute();
$this->assertArrayEquals(
[ [ 'ul_value' => 'testing-value-12345' ] ],
json_decode( $this->getActualOutputForAssertion(), true ),
true,
true,
'JSON output was not as expected.'
);
}
public function testExecuteForSelectQueryProvidedViaSQLFile() {
// Add a testing row to the updatelog table, which we will use the maintenance script to read back.
$this->getDb()->newInsertQueryBuilder()
->insertInto( 'updatelog' )
->row( [ 'ul_key' => 'testing', 'ul_value' => 'testing-value-12345' ] )
->caller( __METHOD__ )
->execute();
// Output JSON to make it easier to assert that the script worked.
$this->maintenance->setOption( 'json', 1 );
// Specify the query using the 'query' option to avoid needing to write to STDIN.
$file = $this->getNewTempFile();
file_put_contents(
$file,
$this->newSelectQueryBuilder()
->field( 'ul_value' )
->from( 'updatelog' )
->where( [ 'ul_key' => 'testing' ] )
->caller( __METHOD__ )
->getSQL()
);
$this->maintenance->setArg( 0, $file );
$this->maintenance->execute();
$this->assertArrayEquals(
[ [ 'ul_value' => 'testing-value-12345' ] ],
json_decode( $this->getActualOutputForAssertion(), true ),
true,
true,
'JSON output was not as expected.'
);
}
public function testExecuteForUnconfiguredReplicaDB() {
$this->expectCallToFatalError();
$this->expectOutputRegex( '/No replica DB server.*abceftest/' );
// Specify the query using the 'query' option with a query that should fail.
$this->maintenance->setOption(
'query',
$this->newSelectQueryBuilder()
->field( 'abcdef' )
->from( 'updatelog' )
->where( [ 'ul_key' => 'testing' ] )
->caller( __METHOD__ )
->getSQL()
);
$this->maintenance->setOption( 'replicadb', 'abceftest' );
$this->maintenance->execute();
}
}
|
