PostgreSQLTest::testInsertUpdateDelete() - Code Metrics - Inspection of "Initial commit for CI improvements" - abterphp/qb - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — main ( 312896...5e0bcd )

by Peter

created 2021-06-21 10:30 UTC

PostgreSQLTest::testInsertUpdateDelete() C

↳ Parent: PostgreSQLTest

Complexity

Conditions	8
Paths	278

Size

Total Lines	67
Code Lines	45

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	8
eloc	45
nc	278
nop	0
dl	0
loc	67
rs	6.5088
c	0
b	0
f	0

How to fix Long Method

<?php

declare(strict_types=1);

namespace QB\Test;

use PHPUnit\Framework\TestCase;
use QB\Generic\Clause\Column;
use QB\Generic\Clause\Table;
use QB\Generic\Expr\Expr;
use QB\PostgreSQL\Factory\Factory;

class PostgreSQLTest extends TestCase
{
    /** @var Factory */
    protected Factory $sut;

    protected \PDO $pdo;

    public function setUp(): void
    {
        $this->sut = new Factory();

        $dns      = sprintf(
            'pgsql:dbname=%s;host=%s',
            $_ENV['POSTGRES_DB'],
            'postgres'
        );
        $username = $_ENV['POSTGRES_USER'];
        $password = $_ENV['POSTGRES_PASSWORD'];
        $options  = null;

        $this->pdo = new \PDO($dns, $username, $password, $options);
    }

    public function testSelectOneCustomer()
    {
        $sql = (string)$this->sut->select()
            ->addFrom('customers')
            ->addColumns('customerName')
            ->setLimit(1);

        $statement = $this->pdo->query($sql);

        $this->assertSame('Atelier graphique', $statement->fetchColumn());
    }

    public function testSelectComplex()
    {
        $limit = 5;

        $columnQuery = $this->sut->select()
            ->addFrom(new Table('employees', 'boss'))
            ->addColumns('lastName')
            ->addWhere(new Expr('boss.employeeNumber = employees.reportsTo'));

        $customerTypeColumn = new Column(new Expr("'customer'"), 'type');
        $employeeTypeColumn = new Column(new Expr("'employee'"), 'type');

        $unionQuery = $this->sut->select()
            ->addFrom('customers')
            ->addColumns('contactLastName', 'NULL', $customerTypeColumn);

        $query = $this->sut->select()
            ->addFrom('employees')
            ->addColumns('lastName', new Column($columnQuery, 'bossLastName'), $employeeTypeColumn)
            ->addInnerJoin('offices', 'employees.officeCode = o.officeCode', 'o')
            ->addWhere(new Expr('employees.jobTitle = ?', ['Sales Rep']))
            ->addWhere('o.city = \'NYC\'')
            ->addUnion($unionQuery)
            ->addOuterOrderBy('type', 'DESC')
            ->addOuterOrderBy('lastName')
            ->setOuterLimit($limit);

        $statement = $this->pdo->prepare((string)$query);
        foreach ($query->getParams() as $k => $v) {
            if (is_numeric($k)) {
                $statement->bindParam($k + 1, $v[0], $v[1]);
            } else {
                $statement->bindParam($k, $v[0], $v[1]);
            }
        }

        $statement->execute();

        $this->assertCount($limit, $statement->fetchAll(\PDO::FETCH_ASSOC));
    }

    public function testInsertUpdateDelete()
    {
        try {
            $this->pdo->exec('BEGIN');

            // INSERT
            $query = $this->sut->insert()
                ->addFrom(new Table('offices'))
                ->addColumns('officeCode', 'city', 'phone', 'addressLine1', 'country', 'postalCode', 'territory')
                ->addValues('abc', 'Berlin', '+49 101 123 4567', '', 'Germany', '10111', 'NA');

            $statement = $this->pdo->prepare((string)$query);

            $result = $statement->execute($query->getValues()[0]);
            $this->assertTrue($result);

            // UPDATE
            $query = $this->sut->update()
                ->addFrom(new Table('offices'))
                ->setValues(['territory' => 'Berlin'])
                ->addWhere('officeCode = \'oc\'');

            $num    = 1;
            $sql    = (string)$query;
            $values = $query->getValues();
            $params = $query->getParams();

            $statement = $this->pdo->prepare($sql);
            foreach ($values as $value) {
                $statement->bindParam($num++, $value);
            }
            foreach ($params as $k => $v) {
                if (is_numeric($k)) {
                    $statement->bindParam($num++, $v[0], $v[1]);
                } else {
                    $statement->bindParam($k, $v[0], $v[1]);
                }
            }
            $result = $statement->execute($values);
            $this->assertTrue($result);

            // DELETE
            $query = $this->sut->delete()
                ->addFrom(new Table('offices'))
                ->addWhere(new Expr('officeCode = ?', ['abc']));

            $sql    = (string)$query;
            $params = $query->getParams();

            $statement = $this->pdo->prepare($sql);
            foreach ($params as $k => $v) {
                if (is_numeric($k)) {
                    $statement->bindParam($k + 1, $v[0], $v[1]);
                } else {
                    $statement->bindParam($k, $v[0], $v[1]);
                }
            }
            $result = $statement->execute();
            $this->assertTrue($result);

            // COMMIT
            $this->pdo->exec('COMMIT');
        } catch (\Exception $e) {
            if ($this->pdo->inTransaction()) {
                $this->pdo->exec('ROLLBACK');
            }
            $this->fail($e->getMessage());
        }
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace QB\Test;
6
7			use PHPUnit\Framework\TestCase;
8			use QB\Generic\Clause\Column;
9			use QB\Generic\Clause\Table;
10			use QB\Generic\Expr\Expr;
11			use QB\PostgreSQL\Factory\Factory;
12
13			class PostgreSQLTest extends TestCase
14			{
15			/** @var Factory */
16			protected Factory $sut;
17
18			protected \PDO $pdo;
19
20			public function setUp(): void
21			{
22			$this->sut = new Factory();
23
24			$dns = sprintf(
25			'pgsql:dbname=%s;host=%s',
26			$_ENV['POSTGRES_DB'],
27			'postgres'
28			);
29			$username = $_ENV['POSTGRES_USER'];
30			$password = $_ENV['POSTGRES_PASSWORD'];
31			$options = null;
32
33			$this->pdo = new \PDO($dns, $username, $password, $options);
34			}
35
36			public function testSelectOneCustomer()
37			{
38			$sql = (string)$this->sut->select()
39			->addFrom('customers')
40			->addColumns('customerName')
41			->setLimit(1);
42
43			$statement = $this->pdo->query($sql);
44
45			$this->assertSame('Atelier graphique', $statement->fetchColumn());
46			}
47
48			public function testSelectComplex()
49			{
50			$limit = 5;
51
52			$columnQuery = $this->sut->select()
53			->addFrom(new Table('employees', 'boss'))
54			->addColumns('lastName')
55			->addWhere(new Expr('boss.employeeNumber = employees.reportsTo'));
56
57			$customerTypeColumn = new Column(new Expr("'customer'"), 'type');
58			$employeeTypeColumn = new Column(new Expr("'employee'"), 'type');
59
60			$unionQuery = $this->sut->select()
61			->addFrom('customers')
62			->addColumns('contactLastName', 'NULL', $customerTypeColumn);
63
64			$query = $this->sut->select()
65			->addFrom('employees')
66			->addColumns('lastName', new Column($columnQuery, 'bossLastName'), $employeeTypeColumn)
67			->addInnerJoin('offices', 'employees.officeCode = o.officeCode', 'o')
68			->addWhere(new Expr('employees.jobTitle = ?', ['Sales Rep']))
69			->addWhere('o.city = \'NYC\'')
70			->addUnion($unionQuery)
71			->addOuterOrderBy('type', 'DESC')
72			->addOuterOrderBy('lastName')
73			->setOuterLimit($limit);
74
75			$statement = $this->pdo->prepare((string)$query);
76			foreach ($query->getParams() as $k => $v) {
77			if (is_numeric($k)) {
78			$statement->bindParam($k + 1, $v[0], $v[1]);
79			} else {
80			$statement->bindParam($k, $v[0], $v[1]);
81			}
82			}
83
84			$statement->execute();
85
86			$this->assertCount($limit, $statement->fetchAll(\PDO::FETCH_ASSOC));
87			}
88
89			public function testInsertUpdateDelete()
90			{
91			try {
92			$this->pdo->exec('BEGIN');
93
94			// INSERT
95			$query = $this->sut->insert()
96			->addFrom(new Table('offices'))
97			->addColumns('officeCode', 'city', 'phone', 'addressLine1', 'country', 'postalCode', 'territory')
98			->addValues('abc', 'Berlin', '+49 101 123 4567', '', 'Germany', '10111', 'NA');
99
100			$statement = $this->pdo->prepare((string)$query);
101
102			$result = $statement->execute($query->getValues()[0]);
103			$this->assertTrue($result);
104
105			// UPDATE
106			$query = $this->sut->update()
107			->addFrom(new Table('offices'))
108			->setValues(['territory' => 'Berlin'])
109			->addWhere('officeCode = \'oc\'');
110
111			$num = 1;
112			$sql = (string)$query;
113			$values = $query->getValues();
114			$params = $query->getParams();
115
116			$statement = $this->pdo->prepare($sql);
117			foreach ($values as $value) {
118			$statement->bindParam($num++, $value);
119			}
120			foreach ($params as $k => $v) {
121			if (is_numeric($k)) {
122			$statement->bindParam($num++, $v[0], $v[1]);
123			} else {
124			$statement->bindParam($k, $v[0], $v[1]);
125			}
126			}
127			$result = $statement->execute($values);
128			$this->assertTrue($result);
129
130			// DELETE
131			$query = $this->sut->delete()
132			->addFrom(new Table('offices'))
133			->addWhere(new Expr('officeCode = ?', ['abc']));
134
135			$sql = (string)$query;
136			$params = $query->getParams();
137
138			$statement = $this->pdo->prepare($sql);
139			foreach ($params as $k => $v) {
140			if (is_numeric($k)) {
141			$statement->bindParam($k + 1, $v[0], $v[1]);
142			} else {
143			$statement->bindParam($k, $v[0], $v[1]);
144			}
145			}
146			$result = $statement->execute();
147			$this->assertTrue($result);
148
149			// COMMIT
150			$this->pdo->exec('COMMIT');
151			} catch (\Exception $e) {
152			if ($this->pdo->inTransaction()) {
153			$this->pdo->exec('ROLLBACK');
154			}
155			$this->fail($e->getMessage());
156			}
157			}
158			}
159

abterphp / qb

Push — main ( 312896...5e0bcd )

PostgreSQLTest::testInsertUpdateDelete() C

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like