Fixing PostgreSQL issue

Author: moufmouf

src/QueryFactory/AbstractQueryFactory.php

@@ -189,7 +189,7 @@ protected function getColumnsList(string $mainTable, array $additionalTablesFetc
                     'tableGroup' => $tableGroups[$table],
                 ];
                 $columnsList[] = $mysqlPlatform->quoteIdentifier($table).'.'.$mysqlPlatform->quoteIdentifier($columnName).' as '.
-                    $connection->quoteIdentifier($table.'____'.$columnName);
+                    $mysqlPlatform->quoteIdentifier($table.'____'.$columnName);
             }
         }
 

src/QueryFactory/FindObjectsQueryFactory.php

@@ -47,8 +47,9 @@ protected function compute(): void
         $sql = 'SELECT DISTINCT '.implode(', ', $columnsList).' FROM MAGICJOIN('.$this->mainTable.')';
 
         $pkColumnNames = $this->tdbmService->getPrimaryKeyColumns($this->mainTable);
-        $pkColumnNames = array_map(function ($pkColumn) {
-            return $this->tdbmService->getConnection()->quoteIdentifier($this->mainTable).'.'.$this->tdbmService->getConnection()->quoteIdentifier($pkColumn);
+        $mysqlPlatform = new MySqlPlatform();
+        $pkColumnNames = array_map(function ($pkColumn) use ($mysqlPlatform) {
+            return $mysqlPlatform->quoteIdentifier($this->mainTable).'.'.$mysqlPlatform->quoteIdentifier($pkColumn);
         }, $pkColumnNames);
 
         $subQuery = 'SELECT DISTINCT '.implode(', ', $pkColumnNames).' FROM MAGICJOIN('.$this->mainTable.')';

src/ResultIterator.php

@@ -3,6 +3,7 @@
 
 namespace TheCodingMachine\TDBM;
 
+use Doctrine\DBAL\Platforms\MySqlPlatform;
 use Psr\Log\NullLogger;
 use function array_map;
 use Doctrine\DBAL\Connection;
@@ -371,7 +372,8 @@ public function _getSubQuery(): string
 
         $pkDesc = array_pop($primaryKeyColumnDescs);
 
-        $sql = $this->tdbmService->getConnection()->quoteIdentifier($pkDesc['table']).'.'.$this->tdbmService->getConnection()->quoteIdentifier($pkDesc['column']).' IN ('.$sql.')';
+        $mysqlPlatform = new MySqlPlatform();
+        $sql = $mysqlPlatform->quoteIdentifier($pkDesc['table']).'.'.$mysqlPlatform->quoteIdentifier($pkDesc['column']).' IN ('.$sql.')';
 
         return $sql;
     }