Documentation
Repository
 
Code Coverage
 
Lines
Functions and Methods
Classes and Traits
Total
100.00%
9 / 9
100.00%
2 / 2
 CRAP
100.00%
1 / 1
PostgresqlDriver
100.00%
9 / 9
100.00%
2 / 2
 2
100.00%
1 / 1
 buildSaveSql
100.00%
8 / 8
100.00%
1 / 1
 1
 quoteTableName
100.00%
1 / 1
100.00%
1 / 1
 1
1<?php
2
3// ╔════════════════════════════════════════════════════════════╗
4// ║ MIT Licence (#Expat) - https://opensource.org/licenses/MIT ║
5// ║ Copyright 2026 Frederic Poeydomenge <dyno@phexium.com>     ║
6// ╚════════════════════════════════════════════════════════════╝
7
8declare(strict_types=1);
9
10namespace Phexium\Plugin\SqlDriver\Adapter;
11
12use Override;
13use Phexium\Plugin\SqlDriver\Internal\AbstractSqlDriver;
14use Phexium\Plugin\SqlDriver\Port\SqlDriverInterface;
15
16final class PostgresqlDriver extends AbstractSqlDriver implements SqlDriverInterface
17{
18    #[Override]
19    protected function buildSaveSql(string $quotedTable, array $columns, array $placeholders): string
20    {
21        $updateSet = array_map(fn (string $col): string => sprintf('%s = EXCLUDED.%s', $col, $col), $columns);
22
23        return sprintf(
24            'INSERT INTO %s (%s) VALUES (%s) ON CONFLICT (id) DO UPDATE SET %s',
25            $quotedTable,
26            implode(', ', $columns),
27            implode(', ', $placeholders),
28            implode(', ', $updateSet)
29        );
30    }
31
32    #[Override]
33    protected function quoteTableName(string $tableName): string
34    {
35        return sprintf('"%s"', $tableName);
36    }
37}