-
Notifications
You must be signed in to change notification settings - Fork 159
Expand file tree
/
Copy pathDBDiffComprehensiveTest.php
More file actions
155 lines (129 loc) · 4.57 KB
/
DBDiffComprehensiveTest.php
File metadata and controls
155 lines (129 loc) · 4.57 KB
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
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
<?php
require_once __DIR__ . '/AbstractComprehensiveTest.php';
/**
* MySQL implementation of the comprehensive test suite.
* All test methods live in AbstractComprehensiveTest.
*/
class DBDiffComprehensiveTest extends AbstractComprehensiveTest
{
// MySQL connection details
private $host;
private $port = 3306;
private $user = 'root';
private $pass = 'rootpass';
private $db;
private $mysqlMajorVersion;
protected function connectAndBootstrap(): void
{
$this->host = getenv('DB_HOST') ?: ($_ENV['DB_HOST'] ?? ($_SERVER['DB_HOST'] ?? 'db'));
$this->db1 = 'dbdiff_test1';
$this->db2 = 'dbdiff_test2';
$this->db = $this->connectWithRetry(
"mysql:host={$this->host};port={$this->port}",
$this->user,
$this->pass
);
$version = $this->db->getAttribute(PDO::ATTR_SERVER_VERSION);
$this->mysqlMajorVersion = (int) explode('.', $version)[0];
$this->db->exec("DROP DATABASE IF EXISTS `{$this->db1}`;");
$this->db->exec("DROP DATABASE IF EXISTS `{$this->db2}`;");
$this->db->exec("CREATE DATABASE `{$this->db1}`;");
$this->db->exec("CREATE DATABASE `{$this->db2}`;");
}
protected function getVersionSuffix(): string
{
$engine = getenv('DBDIFF_ENGINE') ?: null;
if ($engine) {
return $engine;
}
return (string) $this->mysqlMajorVersion;
}
protected function loadFixture(string $fixtureName): void
{
$db1File = "tests/fixtures/{$fixtureName}/db1.sql";
$db2File = "tests/fixtures/{$fixtureName}/db2.sql";
if (!file_exists($db1File) || !file_exists($db2File)) {
$this->fail("Fixture files not found for: $fixtureName");
}
$this->db->exec("USE `{$this->db1}`");
$this->db->exec(file_get_contents($db1File));
$this->db->exec("USE `{$this->db2}`");
$this->db->exec(file_get_contents($db2File));
}
protected function driverArgs(): array
{
return ["--server1={$this->user}:{$this->pass}@{$this->host}:{$this->port}"];
}
protected function dbInputArg(): string
{
return "server1.{$this->db1}:server1.{$this->db2}";
}
protected function tableInputArg(string $table): ?string
{
return "server1.{$this->db1}.{$table}:server1.{$this->db2}.{$table}";
}
protected function getServerConfig(): array
{
return [
'user' => $this->user,
'password' => $this->pass,
'host' => $this->host,
'port' => $this->port,
];
}
protected function tearDownDatabases(): void
{
if ($this->db) {
$this->db->exec("DROP DATABASE IF EXISTS `{$this->db1}`;");
$this->db->exec("DROP DATABASE IF EXISTS `{$this->db2}`;");
}
}
// ── Dolt-specific skips ──────────────────────────────────────────────
// Dolt's strict SQL engine rejects cross-database data diff queries
// involving datetime columns with empty-string defaults. These tests
// use the basic_schema_data fixture whose `posts.published_at` column
// triggers this. Schema-only and legacy E2E data diffs work fine.
private function skipOnDolt(): void
{
if (getenv('DBDIFF_ENGINE') === 'dolt') {
$this->markTestSkipped('Dolt: cross-database data diff with datetime columns not yet supported');
}
}
public function testDataOnlyDiff(): void
{
$this->skipOnDolt();
parent::testDataOnlyDiff();
}
public function testTemplateOutput(): void
{
$this->skipOnDolt();
parent::testTemplateOutput();
}
public function testUpOnlyOutput(): void
{
$this->skipOnDolt();
parent::testUpOnlyOutput();
}
public function testDownOnlyOutput(): void
{
$this->skipOnDolt();
parent::testDownOnlyOutput();
}
public function testConfigFileUsage(): void
{
$this->skipOnDolt();
parent::testConfigFileUsage();
}
public function testConfigFileWithCliOverride(): void
{
$this->skipOnDolt();
parent::testConfigFileWithCliOverride();
}
public function testProgrammableObjectsDiff(): void
{
if (getenv('DBDIFF_ENGINE') === 'dolt') {
$this->markTestSkipped('Dolt: stored procedure/trigger multi-statement fixture loading not supported');
}
parent::testProgrammableObjectsDiff();
}
}