Merge pull request #38 from spiral/fix_postgresql_duplicated_queries

Fix postgresql duplicated queries

src/Driver/Postgres/Query/PostgresInsertQuery.php

@@ -55,6 +55,7 @@ public function withDriver(DriverInterface $driver, string $prefix = null): Quer
     public function returning(string $column): self
     {
         $this->returning = $column;
+
         return $this;
     }
 
@@ -69,7 +70,7 @@ public function run()
         $result = $this->driver->query($queryString, $params->getParameters());
 
         try {
-            if ($this->driver->getPrimaryKey($this->prefix, $this->table) !== null) {
+            if ($this->getPrimaryKey() !== null) {
                 return $result->fetchColumn();
             }
 
@@ -83,20 +84,29 @@ public function run()
      * @return array
      */
     public function getTokens(): array
+    {
+        return [
+            'table'   => $this->table,
+            'return'  => $this->getPrimaryKey(),
+            'columns' => $this->columns,
+            'values'  => $this->values
+        ];
+    }
+
+    /**
+     * @return string
+     */
+    private function getPrimaryKey(): ?string
     {
         $primaryKey = $this->returning;
         if ($primaryKey === null && $this->driver !== null && $this->table !== null) {
             try {
                 $primaryKey = $this->driver->getPrimaryKey($this->prefix, $this->table);
             } catch (Throwable $e) {
+                return null;
             }
         }
 
-        return [
-            'table'   => $this->table,
-            'return'  => $primaryKey,
-            'columns' => $this->columns,
-            'values'  => $this->values
-        ];
+        return $primaryKey;
     }
 }