QB\PostgreSQL\Statement\InsertTest

Complexity

Total Complexity

5

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getSut()	0	3	1
A	testAddOnConflictDoUpdate()	0	18	1
A	testWitDefaultValues()	0	11	1
A	testAddOnConflictDoNothing()	0	16	1
A	testAddMultipleRows()	0	20	1

<?php

declare(strict_types=1);

namespace QB\PostgreSQL\Statement;

use QB\Generic\Clause\Table;
use QB\Generic\Statement\IInsert;
use QB\Generic\Statement\InsertTest as GenericInsertTest;

class InsertTest extends GenericInsertTest
{
    public function testWitDefaultValues()
    {
        $sql = (string)$this->getSut('foo');

        $parts   = [];
        $parts[] = 'INSERT INTO foo';
        $parts[] = 'DEFAULT VALUES';

        $expectedSql = implode(PHP_EOL, $parts);

        $this->assertSame($expectedSql, $sql);
    }

    public function testAddMultipleRows()
    {
        $query = $this->getSut('offices')
            ->setInto(new Table('offices'))
            ->addColumns('officeCode', 'city', 'phone', 'addressLine1', 'country', 'postalCode', 'territory')
            ->addValues('abc', 'Berlin', '+49 101 123 4567', '', 'Germany', '10111', 'NA')
            ->addValues('bcd', 'Budapest', '+36 70 101 1234', '', 'Hungary', '1011', 'NA')
            ->addValues('cde', 'Pécs', '+36 70 222 3456', 'Rákóczi út', 'Hungary', '723', 'NA')
            ->setReturning('*');

        $parts   = [];
        $parts[] = 'INSERT INTO offices (officeCode, city, phone, addressLine1, country, postalCode, territory)';
        $parts[] = 'VALUES (?, ?, ?, ?, ?, ?, ?),';
        $parts[] = '(?, ?, ?, ?, ?, ?, ?),';
        $parts[] = '(?, ?, ?, ?, ?, ?, ?)';
        $parts[] = 'RETURNING *';

        $expectedSql = implode(PHP_EOL, $parts);

        $this->assertSame($expectedSql, (string)$query);
    }

    public function testAddOnConflictDoNothing()
    {
        $query = $this->getSut('offices')
            ->setInto(new Table('offices'))
            ->addColumns('officeCode', 'city', 'phone', 'addressLine1', 'country', 'postalCode', 'territory')
            ->addValues('abc', 'Berlin', '+49 101 123 4567', '', 'Germany', '10111', 'NA')
            ->setDoNothing();

        $parts   = [];
        $parts[] = 'INSERT INTO offices (officeCode, city, phone, addressLine1, country, postalCode, territory)';
        $parts[] = 'VALUES (?, ?, ?, ?, ?, ?, ?)';
        $parts[] = 'ON CONFLICT DO NOTHING';

        $expectedSql = implode(PHP_EOL, $parts);

        $this->assertSame($expectedSql, (string)$query);
    }

    public function testAddOnConflictDoUpdate()
    {
        $query = $this->getSut('offices')
            ->setInto(new Table('offices'))
            ->addColumns('officeCode', 'city', 'phone', 'addressLine1', 'country', 'postalCode', 'territory')
            ->addValues('abc', 'Berlin', '+49 101 123 4567', '', 'Germany', '10111', 'NA')
            ->setOnConflict('officeCode', 'city')
            ->setDoUpdate('officeCode = EXCLUDED.officeCode', 'city = EXCLUDED.city');

        $parts   = [];
        $parts[] = 'INSERT INTO offices (officeCode, city, phone, addressLine1, country, postalCode, territory)';
        $parts[] = 'VALUES (?, ?, ?, ?, ?, ?, ?)';
        $parts[] = 'ON CONFLICT (officeCode, city) DO UPDATE';
        $parts[] = 'SET officeCode = EXCLUDED.officeCode, city = EXCLUDED.city';

        $expectedSql = implode(PHP_EOL, $parts);

        $this->assertSame($expectedSql, (string)$query);
    }

    /**
     * @param string $table
     *
     * @return Insert
     */
    protected function getSut(string $table): IInsert
    {
        return (new Insert())->setInto($table);
    }
}