Cycle\Database\Driver\Postgres\Schema\PostgresTable::fetchColumns()

Complexity

Conditions	4
Paths	3

Size

Total Lines	72
Code Lines	55

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	30
CRAP Score	4

Importance

Changes

0

<?php
    protected function fetchColumns(): array
    {
        [$tableSchema, $tableName] = $this->driver->parseSchemaAndTable($this->getFullName());

        //Required for constraints fetch
        $tableOID = $this->driver->query(
            'SELECT pgc.oid
                FROM pg_class as pgc
                JOIN pg_namespace as pgn
                    ON (pgn.oid = pgc.relnamespace)
                WHERE pgn.nspname = ?
                AND pgc.relname = ?',
            [$tableSchema, $tableName],
        )->fetchColumn();

        $query = $this->driver->query(
            'SELECT columns.*, pg_type.*, pg_description.description
               FROM information_schema.columns
               JOIN pg_catalog.pg_type
                   ON (pg_type.typname = columns.udt_name)
               JOIN pg_catalog.pg_statio_all_tables
	               ON (pg_statio_all_tables.relname = columns.table_name
	               AND pg_statio_all_tables.schemaname = columns.table_schema)
               LEFT JOIN pg_catalog.pg_description
	               ON (pg_description.objoid = pg_statio_all_tables.relid
	               AND pg_description.objsubid = columns.ordinal_position)
               WHERE columns.table_schema = ?
               AND columns.table_name = ?',
            [$tableSchema, $tableName],
        );

        $primaryKeys = \array_column($this->driver->query(
            'SELECT key_column_usage.column_name
                FROM information_schema.table_constraints
                JOIN information_schema.key_column_usage
                    ON (
                            key_column_usage.table_name = table_constraints.table_name AND
                            key_column_usage.table_schema = table_constraints.table_schema AND
                            key_column_usage.constraint_name = table_constraints.constraint_name
                        )
                WHERE table_constraints.constraint_type = \'PRIMARY KEY\' AND
                      key_column_usage.ordinal_position IS NOT NULL AND
                      table_constraints.table_schema = ? AND
                      table_constraints.table_name = ?',
            [$tableSchema, $tableName],
        )->fetchAll(), 'column_name');

        $result = [];
        foreach ($query->fetchAll() as $schema) {
            $name = $schema['column_name'];
            if (
                \is_string($schema['column_default'])
                && \preg_match(
                    '/^nextval\([\'"]([a-z0-9_"]+)[\'"](?:::regclass)?\)$/i',
                    $schema['column_default'],
                    $matches,
                )
            ) {
                //Column is sequential
                $this->sequences[$name] = $matches[1];
            }

            $schema['is_primary'] = \in_array($schema['column_name'], $primaryKeys, true);

            $result[] = PostgresColumn::createInstance(
                $tableSchema . '.' . $tableName,
                $schema + ['tableOID' => $tableOID],
                $this->driver,
            );
        }

        return $result;
    }