DatabaseTrait::getQueries() - Code Metrics - Inspection of "Code improvement." - lagdo/dbadmin-driver-pgsql - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — main ( 559057...eb07f6 )

by Thierry

created 2022-01-21 02:49 UTC

DatabaseTrait::getQueries() A

↳ Parent: DatabaseTrait

Complexity

Conditions	2
Paths	2

Size

Total Lines	12
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
cc	2
eloc	7
c	2
b	0
f	0
nc	2
nop	1
dl	0
loc	12
rs	10

<?php

namespace Lagdo\DbAdmin\Driver\PgSql\Db;

use Lagdo\DbAdmin\Driver\Entity\TableEntity;

use function substr;
use function implode;
use function array_merge;
use function strtoupper;
use function array_map;

trait DatabaseTrait
{
    /**
     * @param TableEntity $tableAttrs
     * @param array $queries
     *
     * @return void
     */
    private function _getRenameColumnQueries(TableEntity $tableAttrs, array &$queries)
    {
        foreach ($tableAttrs->edited as $field) {
            $column = $this->driver->escapeId($field[0]);
            $val = $field[1];
            $val5 = $val[5] ?? '';
            if ($val[0] !== '' && $column !== $val[0]) {
                $queries[] = 'ALTER TABLE ' . $this->driver->table($tableAttrs->name) . " RENAME $column TO $val[0]";
            }
            if ($column !== '' || $val5 !== '') {
                $queries[] = 'COMMENT ON COLUMN ' . $this->driver->table($tableAttrs->name) .
                    ".$val[0] IS " . ($val5 !== '' ? substr($val5, 9) : "''");
            }
        }
    }

    /**
     * @param TableEntity $tableAttrs
     * @param array $queries
     *
     * @return void
     */
    private function _getColumnCommentQueries(TableEntity $tableAttrs, array &$queries)
    {
        foreach ($tableAttrs->fields as $field) {
            $column = $this->driver->escapeId($field[0]);
            $val = $field[1];
            $val5 = $val[5] ?? '';
            if ($column !== '' || $val5 !== '') {
                $queries[] = 'COMMENT ON COLUMN ' . $this->driver->table($tableAttrs->name) .
                    ".$val[0] IS " . ($val5 !== '' ? substr($val5, 9) : "''");
            }
        }
    }

    /**
     * Get queries to create or alter table.
     *
     * @param TableEntity $tableAttrs
     *
     * @return array
     */
    private function getQueries(TableEntity $tableAttrs): array
    {
        $queries = [];

        $this->_getRenameColumnQueries($tableAttrs, $queries);
        $this->_getColumnCommentQueries($tableAttrs, $queries);
        if ($tableAttrs->comment !== '') {
            $queries[] = 'COMMENT ON TABLE ' . $this->driver->table($tableAttrs->name) .
                ' IS ' . $this->driver->quote($tableAttrs->comment);
        }

        return $queries;
    }

    /**
     * Get queries to create or alter table.
     *
     * @param TableEntity $tableAttrs
     *
     * @return array
     */
    private function getNewColumns(TableEntity $tableAttrs): array
    {
        $columns = [];

        foreach ($tableAttrs->fields as $field) {
            $val = $field[1];
            if (isset($val[6])) { // auto increment
                $val[1] = ($val[1] === ' bigint' ? ' big' : ($val[1] === ' smallint' ? ' small' : ' ')) . 'serial';
            }
            $columns[] = implode($val);
            if (isset($val[6])) {
                $columns[] = " PRIMARY KEY ($val[0])";
            }
        }

        return $columns;
    }

    /**
     * @param TableEntity $tableAttrs
     * @param array $columns
     *
     * @return void
     */
    private function _getCreateColumnQueries(TableEntity $tableAttrs, array &$columns)
    {
        foreach ($tableAttrs->fields as $field) {
            $val = $field[1];
            if (isset($val[6])) { // auto increment
                $val[1] = ($val[1] === ' bigint' ? ' big' : ($val[1] === ' smallint' ? ' small' : ' ')) . 'serial';
            }
            $columns[] = 'ADD ' . implode($val);
            if (isset($val[6])) {
                $columns[] = "ADD PRIMARY KEY ($val[0])";
            }
        }
    }

    /**
     * @param TableEntity $tableAttrs
     * @param array $columns
     *
     * @return void
     */
    private function _getAlterColumnQueries(TableEntity $tableAttrs, array &$columns)
    {
        foreach ($tableAttrs->edited as $field) {
            $column = $this->driver->escapeId($field[0]);
            $val = $field[1];
            $columns[] = "ALTER $column TYPE$val[1]";
            if (!$val[6]) {
                $columns[] = "ALTER $column " . ($val[3] ? "SET$val[3]" : 'DROP DEFAULT');
                $columns[] = "ALTER $column " . ($val[2] === ' NULL' ? 'DROP NOT' : 'SET') . $val[2];
            }
        }
    }

    /**
     * Get queries to create or alter table.
     *
     * @param TableEntity $tableAttrs
     *
     * @return array
     */
    private function getColumnChanges(TableEntity $tableAttrs): array
    {
        $columns = [];

        $this->_getCreateColumnQueries($tableAttrs, $columns);
        $this->_getAlterColumnQueries($tableAttrs, $columns);
        foreach ($tableAttrs->dropped as $column) {
            $columns[] = 'DROP ' . $this->driver->escapeId($column);
        }

        return $columns;
    }

    /**
     * @inheritDoc
     */
    public function moveTables(array $tables, array $views, string $target)
    {
        foreach (array_merge($tables, $views) as $table) {
            $status = $this->driver->tableStatus($table);
            if (!$this->driver->execute('ALTER ' . strtoupper($status->engine) . ' ' .
                $this->driver->table($table) . ' SET SCHEMA ' . $this->driver->escapeId($target))) {
                return false;
            }
        }
        return true;
    }

    /**
     * @inheritDoc
     */
    public function truncateTables(array $tables)
    {
        $this->driver->execute('TRUNCATE ' . implode(', ', array_map(function ($table) {
            return $this->driver->table($table);
        }, $tables)));
        return true;
    }

    /**
     * @inheritDoc
     */
    public function userTypes()
    {
        $query = 'SELECT typname FROM pg_type WHERE typnamespace = ' .
            '(SELECT oid FROM pg_namespace WHERE nspname = current_schema()) ' .
            "AND typtype IN ('b','d','e') AND typelem = 0";
        return $this->driver->values($query);
    }
}


1			<?php
2
3			namespace Lagdo\DbAdmin\Driver\PgSql\Db;
4
5			use Lagdo\DbAdmin\Driver\Entity\TableEntity;
6
7			use function substr;
8			use function implode;
9			use function array_merge;
10			use function strtoupper;
11			use function array_map;
12
13			trait DatabaseTrait
14			{
15			/**
16			* @param TableEntity $tableAttrs
17			* @param array $queries
18			*
19			* @return void
20			*/
21			private function _getRenameColumnQueries(TableEntity $tableAttrs, array &$queries)
22			{
23			foreach ($tableAttrs->edited as $field) {
24			$column = $this->driver->escapeId($field[0]);
25			$val = $field[1];
26			$val5 = $val[5] ?? '';
27			if ($val[0] !== '' && $column !== $val[0]) {
28			$queries[] = 'ALTER TABLE ' . $this->driver->table($tableAttrs->name) . " RENAME $column TO $val[0]";
29			}
30			if ($column !== '' \|\| $val5 !== '') {
31			$queries[] = 'COMMENT ON COLUMN ' . $this->driver->table($tableAttrs->name) .
32			".$val[0] IS " . ($val5 !== '' ? substr($val5, 9) : "''");
33			}
34			}
35			}
36
37			/**
38			* @param TableEntity $tableAttrs
39			* @param array $queries
40			*
41			* @return void
42			*/
43			private function _getColumnCommentQueries(TableEntity $tableAttrs, array &$queries)
44			{
45			foreach ($tableAttrs->fields as $field) {
46			$column = $this->driver->escapeId($field[0]);
47			$val = $field[1];
48			$val5 = $val[5] ?? '';
49			if ($column !== '' \|\| $val5 !== '') {
50			$queries[] = 'COMMENT ON COLUMN ' . $this->driver->table($tableAttrs->name) .
51			".$val[0] IS " . ($val5 !== '' ? substr($val5, 9) : "''");
52			}
53			}
54			}
55
56			/**
57			* Get queries to create or alter table.
58			*
59			* @param TableEntity $tableAttrs
60			*
61			* @return array
62			*/
63			private function getQueries(TableEntity $tableAttrs): array
64			{
65			$queries = [];
66
67			$this->_getRenameColumnQueries($tableAttrs, $queries);
68			$this->_getColumnCommentQueries($tableAttrs, $queries);
69			if ($tableAttrs->comment !== '') {
70			$queries[] = 'COMMENT ON TABLE ' . $this->driver->table($tableAttrs->name) .
71			' IS ' . $this->driver->quote($tableAttrs->comment);
72			}
73
74			return $queries;
75			}
76
77			/**
78			* Get queries to create or alter table.
79			*
80			* @param TableEntity $tableAttrs
81			*
82			* @return array
83			*/
84			private function getNewColumns(TableEntity $tableAttrs): array
85			{
86			$columns = [];
87
88			foreach ($tableAttrs->fields as $field) {
89			$val = $field[1];
90			if (isset($val[6])) { // auto increment
91			$val[1] = ($val[1] === ' bigint' ? ' big' : ($val[1] === ' smallint' ? ' small' : ' ')) . 'serial';
92			}
93			$columns[] = implode($val);
94			if (isset($val[6])) {
95			$columns[] = " PRIMARY KEY ($val[0])";
96			}
97			}
98
99			return $columns;
100			}
101
102			/**
103			* @param TableEntity $tableAttrs
104			* @param array $columns
105			*
106			* @return void
107			*/
108			private function _getCreateColumnQueries(TableEntity $tableAttrs, array &$columns)
109			{
110			foreach ($tableAttrs->fields as $field) {
111			$val = $field[1];
112			if (isset($val[6])) { // auto increment
113			$val[1] = ($val[1] === ' bigint' ? ' big' : ($val[1] === ' smallint' ? ' small' : ' ')) . 'serial';
114			}
115			$columns[] = 'ADD ' . implode($val);
116			if (isset($val[6])) {
117			$columns[] = "ADD PRIMARY KEY ($val[0])";
118			}
119			}
120			}
121
122			/**
123			* @param TableEntity $tableAttrs
124			* @param array $columns
125			*
126			* @return void
127			*/
128			private function _getAlterColumnQueries(TableEntity $tableAttrs, array &$columns)
129			{
130			foreach ($tableAttrs->edited as $field) {
131			$column = $this->driver->escapeId($field[0]);
132			$val = $field[1];
133			$columns[] = "ALTER $column TYPE$val[1]";
134			if (!$val[6]) {
135			$columns[] = "ALTER $column " . ($val[3] ? "SET$val[3]" : 'DROP DEFAULT');
136			$columns[] = "ALTER $column " . ($val[2] === ' NULL' ? 'DROP NOT' : 'SET') . $val[2];
137			}
138			}
139			}
140
141			/**
142			* Get queries to create or alter table.
143			*
144			* @param TableEntity $tableAttrs
145			*
146			* @return array
147			*/
148			private function getColumnChanges(TableEntity $tableAttrs): array
149			{
150			$columns = [];
151
152			$this->_getCreateColumnQueries($tableAttrs, $columns);
153			$this->_getAlterColumnQueries($tableAttrs, $columns);
154			foreach ($tableAttrs->dropped as $column) {
155			$columns[] = 'DROP ' . $this->driver->escapeId($column);
156			}
157
158			return $columns;
159			}
160
161			/**
162			* @inheritDoc
163			*/
164			public function moveTables(array $tables, array $views, string $target)
165			{
166			foreach (array_merge($tables, $views) as $table) {
167			$status = $this->driver->tableStatus($table);
168			if (!$this->driver->execute('ALTER ' . strtoupper($status->engine) . ' ' .
169			$this->driver->table($table) . ' SET SCHEMA ' . $this->driver->escapeId($target))) {
170			return false;
171			}
172			}
173			return true;
174			}
175
176			/**
177			* @inheritDoc
178			*/
179			public function truncateTables(array $tables)
180			{
181			$this->driver->execute('TRUNCATE ' . implode(', ', array_map(function ($table) {
182			return $this->driver->table($table);
183			}, $tables)));
184			return true;
185			}
186
187			/**
188			* @inheritDoc
189			*/
190			public function userTypes()
191			{
192			$query = 'SELECT typname FROM pg_type WHERE typnamespace = ' .
193			'(SELECT oid FROM pg_namespace WHERE nspname = current_schema()) ' .
194			"AND typtype IN ('b','d','e') AND typelem = 0";
195			return $this->driver->values($query);
196			}
197			}
198

lagdo / dbadmin-driver-pgsql

Push — main ( 559057...eb07f6 )

DatabaseTrait::getQueries() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like