pomm-project / Foundation

     * @param  string   $table

     * @return int|null

     */

    public function getTableOid($schema, $table)

    {

        $sql = <<<SQL

select

  c.oid as oid

from

    pg_catalog.pg_class c

        left join pg_catalog.pg_namespace n on n.oid = c.relnamespace

where

:condition

SQL;

        $where = Where::create('n.nspname =  $*', [$schema])

            ->andWhere('c.relname = $*', [$table])

            ;

        $iterator = $this->executeSql($sql, $where);

        return $iterator->isEmpty() ? null : $iterator->current()['oid'];

    }

    /**

     * getTableFieldInformation

     * @param  Where    $where optional where clause.

     * @return int|null

     */

    public function getSchemaOid($schema, Where $where = null)

    {

        $condition =

            Where::create("s.nspname = $*", [$schema])

            ->andWhere($where)

            ;

        $sql = <<<SQL

select

    s.oid as oid

from

    pg_catalog.pg_namespace s

where

    :condition

SQL;

        $iterator = $this->executeSql($sql, $condition);

        return $iterator->isEmpty() ? null : $iterator->current()['oid'];

    }

    /**

     * getPrimaryKey