Struct PostgresIntrospector 

pub struct PostgresIntrospector { /* private fields */ }

PostgreSQL introspector for fact table metadata.

Implementations

impl PostgresIntrospector

pub const fn new(pool: Pool) -> Self

Create new PostgreSQL introspector from connection pool.

impl PostgresIntrospector

pub async fn get_indexed_nested_columns( &self, view_name: &str, ) -> Result<HashSet<String>>

Get indexed columns for a view/table that match the nested path naming convention.

This method introspects the database to find columns that follow the FraiseQL indexed column naming conventions:

• Human-readable: items__product__category__code (double underscore separated)
• Entity ID format: f{entity_id}__{field_name} (e.g., f200100__code)

These columns are created by DBAs to optimize filtering on nested GraphQL paths by avoiding JSONB extraction at runtime.

Arguments

• view_name - Name of the view or table to introspect

Returns

Set of column names that match the indexed column naming conventions.

Example

let introspector = PostgresIntrospector::new(pool);
let indexed_cols = introspector.get_indexed_nested_columns("v_order_items").await?;
// Returns: {"items__product__category__code", "f200100__code", ...}

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

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.

Trait Implementations

impl DatabaseIntrospector for PostgresIntrospector

fn list_fact_tables<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

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

fn get_columns<'life0, 'life1, 'async_trait>( &'life0 self, table_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, String, bool)>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Query column information for a table

fn get_indexed_columns<'life0, 'life1, 'async_trait>( &'life0 self, table_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Query indexes for a table

fn database_type(&self) -> DatabaseType

Get database type (for SQL type parsing)

fn get_sample_jsonb<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, table_name: &'life1 str, column_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get sample JSONB data from a column to extract dimension paths