Add PostgreSQL specific implementation for includeIgnoreConflict.

Signed-off-by: Ole Ostergaard <ole.c.ostergaard@gmail.com>

diff --git a/lib/private/DB/AdapterPgSql.php b/lib/private/DB/AdapterPgSql.php
index 47ef4dff0378d634996ba5396e828444b2ac4d7f..86f2fe2e38423bf06ae44b1fbea71440c35db1da 100644 (file)
--- a/lib/private/DB/AdapterPgSql.php
+++ b/lib/private/DB/AdapterPgSql.php
@@ -35,4 +35,16 @@ class AdapterPgSql extends Adapter {
                $statement = str_ireplace( 'UNIX_TIMESTAMP()', self::UNIX_TIMESTAMP_REPLACEMENT, $statement );
                return $statement;
        }
+
+       public function insertIgnoreConflict($table, $input) : int {
+               $builder = $this->conn->getQueryBuilder();
+               $builder->insert($table)
+                       ->values($input);
+               foreach($input as $key => $value) {
+                       $builder->setValue($key, $builder->createNamedParameter($value));
+               }
+               $queryString = $builder->getSQL() . ' ON CONFLICT DO NOTHING';
+               $inserts = array_values($input);
+               return $this->conn->executeUpdate($queryString, $inserts);
+       }
 }