Struct PostgresIntrospector 

pub struct PostgresIntrospector { /* private fields */ }

PostgreSQL introspector for fact table metadata.

Implementations

impl PostgresIntrospector

pub const fn new(pool: Pool<Manager>) -> PostgresIntrospector

Create new PostgreSQL introspector from connection pool.

impl PostgresIntrospector

pub async fn get_index_definitions( &self, relation: &str, ) -> Result<Vec<IndexInfo>, FraiseQLError>

Every index on relation, keys in declared order (#1307).

Keys come from pg_get_indexdef(indexrelid, n, true) rather than from pg_attribute, because an expression key has no attnum: the JSONB identity a page is tie-broken on (data->>'id') is indexed as an expression, and reading indkey alone would report that index as having fewer keys than it has.

Returns an empty vector for a view — a view carries no indexes, so a caller holding a sql_source must resolve it with resolve_base_relations first.

Errors

Returns FraiseQLError::Database if the catalog query fails.

pub async fn resolve_base_relations( &self, view: &str, ) -> Result<Vec<String>, FraiseQLError>

The tables and materialized views a view reads from (#1307).

A query binds to v_invoice, and v_invoice has no indexes — the indexes that decide whether a page needs a sort live on tb_invoice. Resolved through pg_rewrite/pg_depend rather than by assuming a v_/tb_ naming convention, which is a project convention and not a guarantee about any particular database.

Returns every base relation the view depends on. More than one means the view is a join, and a caller cannot attribute an ordering to a single table without reading the view body.

Errors

Returns FraiseQLError::Database if the catalog query fails.

pub async fn get_view_columns( &self, view_name: &str, ) -> Result<Vec<String>, FraiseQLError>

Get all column names for a view/table.

Arguments

• view_name - Name of the view or table to introspect

Returns

List of all column names in the view/table.

Errors

Returns FraiseQLError::ConnectionPool if a connection cannot be acquired, or FraiseQLError::Database if the query fails.

Trait Implementations

impl DatabaseIntrospector for PostgresIntrospector

async fn list_fact_tables(&self) -> Result<Vec<String>, FraiseQLError>

List all fact tables in the database (tables starting with “tf_”).

async fn get_columns( &self, table_name: &str, ) -> Result<Vec<(String, String, bool)>, FraiseQLError>

Query column information for a table.

async fn get_indexed_columns( &self, table_name: &str, ) -> Result<Vec<String>, FraiseQLError>

Query indexes for a table.

fn database_type(&self) -> DatabaseType

Get database type (for SQL type parsing).

async fn list_relations(&self) -> Result<Vec<RelationInfo>, FraiseQLError>

List all relations (tables and views) in the database.

async fn get_sample_jsonb( &self, table_name: &str, column_name: &str, ) -> Result<Option<Value>, FraiseQLError>

Get sample JSONB data from a column to extract dimension paths.

async fn get_sample_json_rows( &self, table_name: &str, column_name: &str, limit: usize, ) -> Result<Vec<Value>, FraiseQLError>

Get sample JSON rows from a column for schema inference and the L3 JSONB-key drift check (#384).

async fn function_exists( &self, schema: Option<&str>, name: &str, ) -> Result<Option<bool>, FraiseQLError>

Probe whether a callable SQL function named name exists — in schema when given, else resolved against the connection search_path.

async fn qualified_relation_exists( &self, schema: &str, name: &str, ) -> Result<Option<bool>, FraiseQLError>

Probe whether a schema-qualified relation exists, resolved case-sensitively / verbatim — the same way the runtime resolves a qualified sql_source (quote_postgres_identifier + to_regclass), so a mixed-case relation in an off-search_path schema is not falsely reported missing.

async fn get_view_definition( &self, relation: &str, ) -> Result<Option<String>, FraiseQLError>

The SQL body of relation, when it is a view (#1303).