Struct coord::catalog::ConnCatalog

pub struct ConnCatalog<'a> {
    catalog: &'a Catalog,
    conn_id: u32,
    database: String,
    search_path: &'a [&'a str],
    user: String,
    prepared_statements: Option<&'a HashMap<String, PreparedStatement>>,
}

Fields

catalog: &'a Catalog

conn_id: u32

database: String

search_path: &'a [&'a str]

user: String

prepared_statements: Option<&'a HashMap<String, PreparedStatement>>

Implementations

impl ConnCatalog<'_>

pub fn conn_id(&self) -> u32

impl ConnCatalog<'_>

fn resolve_item_name(
    &self,
    name: &PartialName
) -> Result<&FullName, SqlCatalogError>

fn minimal_qualification(&self, full_name: &FullName) -> PartialName

Trait Implementations

impl<'a> Debug for ConnCatalog<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ExprHumanizer for ConnCatalog<'_>

fn humanize_id(&self, id: GlobalId) -> Option<String>

Attempts to return the a human-readable string for the relation identified by id.

fn humanize_scalar_type(&self, typ: &ScalarType) -> String

Returns a human-readable name for the specified scalar type.

fn humanize_column_type(&self, typ: &ColumnType) -> String

Returns a human-readable name for the specified scalar type.

impl SessionCatalog for ConnCatalog<'_>

fn search_path(&self, include_system_schemas: bool) -> Vec<&str>

Returns the search path used by the catalog.

fn user(&self) -> &str

Returns the name of the user who is issuing the query.

fn get_prepared_statement_desc(&self, name: &str) -> Option<&StatementDesc>

Returns the descriptor of the named prepared statement on the session, or None if the prepared statement does not exist.

fn default_database(&self) -> &str

Returns the database to use if one is not explicitly specified.

fn resolve_database(
    &self,
    database_name: &str
) -> Result<&dyn CatalogDatabase, SqlCatalogError>

Resolves the named database.

fn resolve_schema(
    &self,
    database: Option<String>,
    schema_name: &str
) -> Result<&dyn CatalogSchema, SqlCatalogError>

Resolves a partially-specified schema name.

fn resolve_role(
    &self,
    role_name: &str
) -> Result<&dyn CatalogRole, SqlCatalogError>

Resolves the named role.

fn resolve_item(
    &self,
    name: &PartialName
) -> Result<&dyn CatalogItem, SqlCatalogError>

Resolves a partially-specified item name.

fn resolve_function(
    &self,
    name: &PartialName
) -> Result<&dyn CatalogItem, SqlCatalogError>

Performs the same operation as SessionCatalog::resolve_item but for functions within the catalog.

fn try_get_item_by_id(&self, id: &GlobalId) -> Option<&dyn CatalogItem>

Gets an item by its ID.

fn get_item_by_id(&self, id: &GlobalId) -> &dyn CatalogItem

Gets an item by its ID.

fn get_item_by_oid(&self, oid: &u32) -> &dyn CatalogItem

Gets an item by its OID.

fn item_exists(&self, name: &FullName) -> bool

Reports whether the specified type exists in the catalog.

fn try_get_lossy_scalar_type_by_id(&self, id: &GlobalId) -> Option<ScalarType>

Returns a lossy ScalarType associated with id if one exists.

fn config(&self) -> &CatalogConfig

Returns the configuration of the catalog.

fn now(&self) -> EpochMillis

Returns the number of milliseconds since the system epoch. For normal use this means the Unix epoch. This can safely be mocked in tests and start at 0.

fn find_available_name(&self, name: FullName) -> FullName

Finds a name like name that is not already in use.