connection->fetchAllAssociative( << $tableName] ); return count($rows) >= 1; } protected function columnExists(string $tableName, string $columnName): bool { $rows = $this->connection->fetchAllAssociative( \strtr( << $tableName] ), ['columnName' => $columnName] ); return count($rows) >= 1; } protected function triggerExists(string $triggerName): bool { $schema = $this->connection->getDatabase(); $sql = <<connection->fetchOne($sql, ['triggerName' => $triggerName, 'schema' => $schema]); } protected function constraintExists(string $tableName, string $constraintName): bool { $sql = <<connection->executeQuery( $sql, [ 'schema' => $this->connection->getDatabase(), 'table_name' => $tableName, 'constraint_name' => $constraintName, ] )->fetchOne(); } protected function getIndexName(string $tableName, array $columnNames): ?string { $sql = <<connection->fetchAllKeyValue( $sql, [ 'schema' => $this->connection->getDatabase(), 'table_name' => $tableName, ] ); foreach ($result as $indexName => $indexColumns) { // There is a json_encode(json_decode()) because the format is not the same between PHP and mySQL. $columns = \explode(',', $indexColumns); if (\json_encode($columns) === \json_encode($columnNames)) { return $indexName; } } return null; } protected function indexExists(string $tableName, string $indexName): bool { $sql = <<connection->executeQuery( $sql, [ 'schema' => $this->connection->getDatabase(), 'table_name' => $tableName, 'index_name' => $indexName, ] )->fetchOne(); } protected function getPrimaryKey(string $tableName): array { $sql = <<connection->fetchFirstColumn($sql, [ 'schema' => $this->connection->getDatabase(), 'table_name' => $tableName ]); } }