~desarrollokumbia/kumbia/ActiveRecord

    /**

     * Obtiene la metadata de una Tabla

     * 

     * @param string $schema

     * @param string $table

     * @return Rows

     * 

     */

    public function describe($table, $schema=null)

    {

        $sql = "SELECT c.column_name as name,

                CASE

                WHEN ct.constraint_type='PRIMARY KEY' THEN 'PRI'

                WHEN ct.constraint_type='UNIQUE' THEN 'UNI'

                WHEN ct.constraint_type='FOREIGN KEY' THEN 'FK'

                WHEN ct.constraint_type='CHECK' THEN 'CHK'

                ELSE '' END AS Index,

                c.column_default as Default, 

                c.is_nullable as Null, 

                c.udt_name as Type,

                CASE 

                WHEN c.character_maximum_length is null THEN (c.numeric_precision) ELSE c.character_maximum_length END as length

                FROM information_schema.columns c

                LEFT JOIN information_schema.constraint_column_usage cu ON

                cu.table_catalog = c.table_catalog AND cu.table_schema = c.table_schema AND cu.table_name = c.table_name

                AND cu.column_name = c.column_name

                LEFT JOIN information_schema.table_constraints ct ON

                ct.constraint_name = cu.constraint_name

                WHERE c.table_catalog = :database AND c.table_schema = :schema AND c.table_name = :table

                ORDER BY c.ordinal_position";

        try {

            $prepare = $this->pdo()->prepare($sql);

            //ejecutando la consulta preparada

            $results = $prepare->execute(array('database'=>'test', 'schema'=>'public', 'table'=>'prueba'));

            if ($results) {

                require_once CORE_PATH . 'libs/ActiveRecord/db_pool/rows.php';

                $row = new Rows();

                while ($field = $prepare->fetchObject()) {

                    //Nombre del Campo

                    $column = $row->column($field->name);

                    $column->setAlias($field->name);

                    //valor por defecto

                    if (! is_null($field->default)) {

                        if (strpos($field->default, 'nextval(') !== FALSE) {

                            $column->_isAutoIncrement = TRUE;

                        } elseif ($field->type == 'serial' || $field->type == 'bigserial') {

                            $column->_isAutoIncrement = TRUE;

                        } else {

                            $column->_default = $field->default;

                        }

                    }

                    //puede ser null?

                    if($field->null == 'NO'){

                        $column->_isNull = FALSE;

                    }

                    //Relaciones

                    if(substr($field->name, strlen($field->name) -3, 3) == '_id'){

                        $column->_relation = substr($field->name, 0, -3);

                        $row->setRelation($field->name, $column->_relation);

                    }

                    //tipo de dato

                    $column->_dbType = $field->type;

                    //longitud

                    $column->_length = $field->length;

                    //indices

                    switch ($field->index){

                        case 'PRI':

                            $row->setPK($field->name);

                            break;

                        case 'FK':

                            $row->setFK($field->name);

                            break;

                        case 'UNI':

                            $column->_isUni = TRUE;

                            break;

                    }

                }

            }

        } catch (PDOException $e) {

            throw new KumbiaException($e->getMessage());

        }

        return $row;

    }