catalog->useMinimalCatalog(); } public function test_it_fixes_json_columns() { $initial = $this->getAffectedColumnDefinitions(); // artificial corruption of the default DB $corrupted = []; foreach (self::AFFECTED_COLUMNS as $index => $col) { $this->corruptJsonColumn($initial[$index], ...$col); $corrupted[$index] = $this->getColumnDefinition(...$col); $this->assertOnlyCommentChanged($initial[$index], $corrupted[$index], '(DC2Type:json_array)', ...$col); } // after applying the migration, everything should be back to normal $this->reExecuteMigration(self::MIGRATION_LABEL); $this->assertEquals($initial, $this->getAffectedColumnDefinitions()); } /** * Creates a json column comment so we can fix it later * This avoids managing a "corrupted" DB dump just for this test */ private function corruptJsonColumn(array $definition, string $table, string $column) { $isNullable = ('YES' === $definition['IS_NULLABLE']); $sql = <<getConnection()->executeStatement(sprintf( $sql, $table, $column, $isNullable ? 'DEFAULT NULL' : 'NOT NULL', )); } /** * Make sure that we don't modify more than expected (ie: the comment) */ private function assertOnlyCommentChanged(array $before, array $after, string $expected, string $table, string $column) { $diff = array_diff_assoc($after, $before); $data = print_r([ 'table' => $table, 'column' => $column, 'before' => $before, 'after' => $after, 'diff' => $diff, ], true); $this->assertCount(1, $diff, $data); $this->assertEquals('COLUMN_COMMENT', array_keys($diff)[0], $data); $this->assertEquals($expected, $after['COLUMN_COMMENT'], $data); } private function getAffectedColumnDefinitions(): array { return array_map(fn ($col) => $this->getColumnDefinition(...$col), self::AFFECTED_COLUMNS); } private function getColumnDefinition(string $table, string $column): array { $sql = <<getConnection() ->executeQuery($sql, [ 'table_name' => $table, 'column_name' => $column, ]) ->fetchAssociative(); } private function getConnection(): Connection { return $this->get('database_connection'); } }