yf_db_installer_pgsql class

    public function db_query_safe($sql, $db)
    {
        if (isset($db->_repairs_by_sql[$sql]) && $db->_repairs_by_sql[$sql] >= $this->NUM_RETRIES) {
            return false;
        }
        @$db->_repairs_by_sql[$sql]++;
        return $db->query($sql);
    }

    public function do_alter_table($full_table_name, $column_name, array $sql_php, $db)
    {
        $column_data = (array) $sql_php['fields'][$column_name];
        $column_data['name'] = $column_name;
        $line = $db->utils()->_ddl_column_line($column_data);
        $table = $db->utils()->_escape_table_name($full_table_name);
        if ( ! $line || ! $table) {
            return false;
        }
        // Existing rows get the MySQL implicit default of a NOT NULL column without one
        if (empty($column_data['nullable']) && empty($column_data['auto_inc']) && ($column_data['default'] ?? null) === null) {
            $col = $db->escape_key(strtolower($column_name));
            return $db->query('ALTER TABLE ' . $table . ' ADD COLUMN ' . $line . ' DEFAULT ' . $db->utils()->_quote($this->_implicit_default($column_data)) . ';'
                . ' ALTER TABLE ' . $table . ' ALTER COLUMN ' . $col . ' DROP DEFAULT;');
        }
        return $db->query('ALTER TABLE ' . $table . ' ADD COLUMN ' . $line);
    }

    public function do_create_table($full_table_name, array $sql_php, $db)
    {
        if ( ! empty($this->NO_REPAIR_TABLES) && in_array($full_table_name, $this->NO_REPAIR_TABLES)) {
            return false;
        }
        $sql_php = $this->fix_sql_php($sql_php, $db);
        $sql_php['name'] = $full_table_name;
        $sql = $db->utils()->_ddl_create_sql($sql_php, $error);
        if ( ! $sql) {
            return false;
        }
        return $db->query($sql);
    }

    public function fix_sql_php(array $sql_php, $db)
    {
        if ($db->utils()->FULLTEXT_AS_GIN) {
            return $sql_php;
        }
        foreach ((array) ($sql_php['indexes'] ?? []) as $iname => $idx) {
            if (($idx['type'] ?? '') == 'fulltext') {
                unset($sql_php['indexes'][$iname]);
            }
        }
        return $sql_php;
    }

    public function get_table_struct_array_by_name($table_name, $db)
    {
        $utils = $db->utils();
        return [
            'name' => $table_name,
            'fields' => $utils->list_columns($table_name),
            'indexes' => $utils->list_indexes($table_name),
            'foreign_keys' => $utils->list_foreign_keys($table_name),
            'options' => $utils->table_options($table_name),
        ];
    }

    public function import_data($full_table_name, array $data, $db)
    {
        $name = $this->_strip_table_name($full_table_name, $db);
        $sql_php = $this->TABLES_SQL_PHP[$name] ?? $this->TABLES_SQL_PHP['sys_' . $name] ?? [];
        $data = $this->_fill_implicit_defaults($data, $sql_php);
        $first = reset($data);
        $cols = is_array($first) ? array_keys($first) : array_keys($data);
        // upsert on the primary key like REPLACE INTO; rows without the whole key can only be insert-ignore
        $pk_cols = $db->query_builder()->_primary_key_columns($full_table_name);
        $result = $pk_cols && ! array_diff($pk_cols, $cols)
            ? $db->insert_safe($full_table_name, $data, false, false, false, true)
            : $db->insert_safe($full_table_name, $data, false, false, true);
        if ($result && $sql_php) {
            $this->seed_table_post($full_table_name, $sql_php, $db);
        }
        return $result;
    }

    public function innodb_has_fulltext($db)
    {
        return false;
    }

    public function repair($sql, $db_error, $db)
    {
        $sql = trim($sql);
        $state = (string) ($db_error['sqlstate'] ?? '');
        $message = (string) ($db_error['message'] ?? '');
        if ( ! strlen($state)) {
            // Drivers without SQLSTATE: the text is English unless lc_messages was changed
            if (preg_match('~relation "[^"]+" does not exist~i', $message)) {
                $state = '42P01';
            } elseif (preg_match('~column [^ ]+ (of relation "[^"]+" )?does not exist~i', $message)) {
                $state = '42703';
            }
        }
        if ($state === '42P01') {
            if ( ! preg_match('~relation "([^"]+)" does not exist~i', $message, $m)) {
                return false;
            }
            $table = $this->_strip_table_name($m[1], $db);
            if ( ! strlen($table) || ! $this->create_table($table, $db)) {
                return false;
            }
            return $this->db_query_safe($sql, $db);
        }
        if ($state === '42703') {
            // column "x" does not exist / column "x" of relation "t" does not exist / column t.x does not exist
            if ( ! preg_match('~column ["]?(?:[a-z_0-9]+\.)?([a-z_0-9]+)["]? (?:of relation "([^"]+)" )?does not exist~i', $message, $m)) {
                return false;
            }
            $column = $m[1];
            $table = $m[2] ?? '';
            if ( ! strlen($table) && preg_match('~\b(?:UPDATE|FROM|INTO)\s+(?:ONLY\s+)?["`]?([a-z_0-9.]+)["`]?~i', $sql, $m2)) {
                $table = $m2[1];
            }
            $table = $this->_strip_table_name($table, $db);
            if ( ! strlen($table) || ! $this->alter_table($table, $column, $db)) {
                return false;
            }
            return $this->db_query_safe($sql, $db);
        }
        return false;
    }

    public function seed_data($full_table_name, array $data, $sql_php, $db)
    {
        return $db->insert_safe($full_table_name, $this->_fill_implicit_defaults($data, $sql_php));
    }

    public function seed_table_post($full_table_name, $sql_php, $db)
    {
        $utils = $db->utils();
        $table = $utils->_escape_table_name($full_table_name);
        if ( ! $table) {
            return false;
        }
        foreach ((array) $sql_php['fields'] as $name => $field) {
            if (empty($field['auto_inc'])) {
                continue;
            }
            $col = $db->escape_key(strtolower($field['name'] ?? $name));
            $db->query('SELECT setval(pg_get_serial_sequence(' . $utils->_quote($table) . ', ' . $utils->_quote(strtolower($field['name'] ?? $name)) . '), COALESCE(MAX(' . $col . '), 1), MAX(' . $col . ') IS NOT NULL) FROM ' . $table);
        }
        return true;
    }

    public function _fill_implicit_defaults(array $data, $sql_php)
    {
        $first = reset($data);
        $rows = is_array($first) ? $data : [$data];
        foreach ((array) ($sql_php['fields'] ?? []) as $name => $field) {
            if ( ! empty($field['nullable']) || ! empty($field['auto_inc']) || ($field['default'] ?? null) !== null) {
                continue;
            }
            $value = $this->_implicit_default($field);
            $col = $field['name'] ?? $name;
            foreach ($rows as $i => $row) {
                if ( ! array_key_exists($col, $row)) {
                    $rows[$i][$col] = $value;
                }
            }
        }
        return is_array($first) ? $rows : $rows[0];
    }

    public function _implicit_default(array $field)
    {
        $type = strtolower($field['type'] ?? '');
        if (in_array($type, ['int', 'tinyint', 'smallint', 'mediumint', 'bigint', 'float', 'double', 'decimal', 'numeric', 'bit', 'year'])) {
            return 0;
        } elseif ($type === 'date') {
            return '1970-01-01';
        } elseif (in_array($type, ['datetime', 'timestamp'])) {
            return '1970-01-01 00:00:00';
        } elseif ($type === 'time') {
            return '00:00:00';
        } elseif ($type === 'enum' || $type === 'set') {
            return (string) (array_values((array) ($field['values'] ?? []))[0] ?? '');
        }
        return '';
    }

    public function _strip_table_name($name, $db)
    {
        $name = trim(str_replace(['"', '`'], '', (string) $name));
        $dot = strrpos($name, '.');
        if ($dot !== false) {
            $name = substr($name, $dot + 1);
        }
        $plen = strlen($db->DB_PREFIX);
        if ($plen && substr($name, 0, $plen) === $db->DB_PREFIX) {
            $name = substr($name, $plen);
        }
        // the mysql installer strips the same test-table marker
        return str_replace('dbt_', '', $name);
    }