connection = $this->get('database_connection'); } public function test_it_adds_product_mapping_column(): void { $this->removeColumn('akeneo_catalog', 'product_mapping'); $this->reExecuteMigration(self::MIGRATION_LABEL); $this->assertTrue($this->hasColumn('akeneo_catalog', 'product_mapping')); } private function removeColumn(string $table, string $column): void { if (!$this->hasColumn($table, $column)) { return; } $this->connection->executeQuery( <<assertFalse($this->hasColumn($table, $column)); } private function hasColumn(string $table, string $column): bool { $rows = $this->connection->fetchAllAssociative( <<= 1; } }