quoted generated SQL identifiers and literals

Author: grossmannmartin

src/Component/Doctrine/DatabaseSchemaFacade.php

@@ -17,12 +17,18 @@ public function __construct(
 
     public function createSchema(string $schemaName): void
     {
-        $this->em->getConnection()->executeStatement('CREATE SCHEMA ' . $schemaName);
+        $connection = $this->em->getConnection();
+        $databasePlatform = $connection->getDatabasePlatform();
+        $connection->executeStatement('CREATE SCHEMA ' . $databasePlatform->quoteSingleIdentifier($schemaName));
     }
 
     public function dropSchemaIfExists(string $schemaName): void
     {
-        $this->em->getConnection()->executeStatement('DROP SCHEMA IF EXISTS ' . $schemaName . ' CASCADE');
+        $connection = $this->em->getConnection();
+        $databasePlatform = $connection->getDatabasePlatform();
+        $connection->executeStatement(
+            'DROP SCHEMA IF EXISTS ' . $databasePlatform->quoteSingleIdentifier($schemaName) . ' CASCADE',
+        );
     }
 
     public function importDefaultSchema(): void
@@ -48,10 +54,13 @@ public function importDefaultSchema(): void
     public function dropTables(): void
     {
         $connection = $this->em->getConnection();
+        $databasePlatform = $connection->getDatabasePlatform();
         $tableNames = $connection->fetchAllAssociative('SELECT tablename FROM pg_tables WHERE schemaname = \'public\'');
 
         foreach ($tableNames as $tableName) {
-            $connection->executeStatement('DROP TABLE IF EXISTS ' . $tableName['tablename'] . ' CASCADE');
+            $connection->executeStatement(
+                'DROP TABLE IF EXISTS ' . $databasePlatform->quoteSingleIdentifier($tableName['tablename']) . ' CASCADE',
+            );
         }
     }
 }

src/Component/Domain/DomainDbFunctionsFacade.php

@@ -20,6 +20,8 @@ public function createDomainDbFunctions(): void
 
     protected function createDomainIdsByLocaleFunction(): void
     {
+        $connection = $this->em->getConnection();
+        $databasePlatform = $connection->getDatabasePlatform();
         $domainsIdsByLocale = [];
 
         foreach ($this->domain->getAllIncludingDomainConfigsWithoutDataCreated() as $domainConfig) {
@@ -29,15 +31,15 @@ protected function createDomainIdsByLocaleFunction(): void
         $domainIdsByLocaleSqlClauses = [];
 
         foreach ($domainsIdsByLocale as $locale => $domainIds) {
-            $sql = 'WHEN locale = \'' . $locale . '\' THEN ';
+            $sql = 'WHEN locale = ' . $databasePlatform->quoteStringLiteral($locale) . ' THEN ';
 
             foreach ($domainIds as $domainId) {
                 $sql .= ' RETURN NEXT ' . $domainId . ';';
             }
             $domainIdsByLocaleSqlClauses[] = $sql;
         }
 
-        $this->em->getConnection()->executeStatement(
+        $connection->executeStatement(
             'CREATE OR REPLACE FUNCTION get_domain_ids_by_locale(locale text) RETURNS SETOF integer AS $$
             BEGIN
                 CASE
@@ -51,15 +53,17 @@ protected function createDomainIdsByLocaleFunction(): void
 
     protected function createLocaleByDomainIdFunction(): void
     {
+        $connection = $this->em->getConnection();
+        $databasePlatform = $connection->getDatabasePlatform();
         $localeByDomainIdSqlClauses = [];
 
         foreach ($this->domain->getAllIncludingDomainConfigsWithoutDataCreated() as $domainConfig) {
             $localeByDomainIdSqlClauses[] =
                 'WHEN domain_id = ' . $domainConfig->getId()
-                . ' THEN RETURN \'' . $domainConfig->getLocale() . '\';';
+                . ' THEN RETURN ' . $databasePlatform->quoteStringLiteral($domainConfig->getLocale()) . ';';
         }
 
-        $this->em->getConnection()->executeStatement(
+        $connection->executeStatement(
             'CREATE OR REPLACE FUNCTION get_domain_locale(domain_id integer) RETURNS text AS $$
             BEGIN
                 CASE