#[derive(Clone, Debug, Eq, PartialEq, elephantry_derive::Entity)]
#[elephantry(internal)]
pub struct Enum {
pub name: String,
pub elements: Vec<String>,
pub description: Option<String>,
}
pub fn enums(
connection: &crate::Connection,
schema: &str,
) -> crate::Result<Vec<crate::inspect::Enum>> {
types(connection, schema, super::Type::Enum).map(Iterator::collect)
}
#[derive(Clone, Debug, Eq, PartialEq, elephantry_derive::Entity)]
#[elephantry(internal)]
pub struct Domain {
pub oid: crate::pq::Oid,
pub name: String,
pub ty: String,
#[elephantry(default)]
pub constraints: Vec<super::Constraint>,
pub description: Option<String>,
pub is_notnull: bool,
pub default: Option<String>,
}
pub fn domains(
connection: &crate::Connection,
schema: &str,
) -> crate::Result<Vec<crate::inspect::Domain>> {
super::schema_oid(connection, schema)?;
connection
.query::<crate::inspect::Domain>(
r#"
select t.oid as "oid",
pg_catalog.format_type(t.oid, null) as "name",
pg_catalog.obj_description(t.oid, 'pg_type') as "description",
tt.typname as "ty",
t.typnotnull as is_notnull,
t.typdefault as default
from pg_catalog.pg_type t
inner join pg_catalog.pg_type tt on t.typbasetype = tt.oid
left join pg_catalog.pg_namespace n on n.oid = t.typnamespace
left join pg_catalog.pg_constraint con on con.contypid = t.oid
where t.typtype = $*
and n.nspname = $*
and (t.typrelid = 0 or (select c.relkind = 'c' from pg_catalog.pg_class c where c.oid = t.typrelid))
and not exists(select 1 from pg_catalog.pg_type el where el.oid = t.typelem and el.typarray = t.oid)
and n.nspname <> 'pg_catalog'
and n.nspname <> 'information_schema'
and pg_catalog.pg_type_is_visible(t.oid)
order by 1;
"#,
&[&super::Type::Domain, &schema],
)?
.map(|mut x| {
x.constraints = super::constraints(connection, x.oid)?;
Ok(x)
})
.collect()
}
#[derive(Clone, Debug, Eq, PartialEq, elephantry_derive::Entity)]
#[elephantry(internal)]
pub struct Composite {
pub name: String,
#[elephantry(default)]
pub fields: Vec<crate::inspect::Column>,
pub description: Option<String>,
}
pub fn composites(
connection: &crate::Connection,
schema: &str,
) -> crate::Result<Vec<crate::inspect::Composite>> {
let mut composites = types(connection, schema, super::Type::Composite)?
.collect::<Vec<crate::inspect::Composite>>();
for composite in &mut composites {
composite.fields = crate::inspect::relation(connection, schema, &composite.name)?;
}
Ok(composites)
}
pub(crate) fn types<E: crate::Entity>(
connection: &crate::Connection,
schema: &str,
typtype: super::Type,
) -> crate::Result<crate::Rows<E>> {
super::schema_oid(connection, schema)?;
connection
.query(
r#"
select pg_catalog.format_type(t.oid, null) as "name",
array(
select e.enumlabel
from pg_catalog.pg_enum e
where e.enumtypid = t.oid
order by e.enumsortorder
) as "elements",
pg_catalog.obj_description(t.oid, 'pg_type') as "description"
from pg_catalog.pg_type t
left join pg_catalog.pg_namespace n on n.oid = t.typnamespace
where t.typtype = $*
and n.nspname = $*
and (t.typrelid = 0 or (select c.relkind = 'c' from pg_catalog.pg_class c where c.oid = t.typrelid))
and not exists(select 1 from pg_catalog.pg_type el where el.oid = t.typelem and el.typarray = t.oid)
and n.nspname <> 'pg_catalog'
and n.nspname <> 'information_schema'
and pg_catalog.pg_type_is_visible(t.oid)
order by 1;
"#,
&[&typtype, &schema],
)
}