Method register_catalog

crates/integrations/datafusion/src/sql_context.rs:114–146

Registers a Paimon catalog under the given name. The first registered catalog automatically becomes the current catalog for both Paimon-handled SQL and DataFusion-delegated SQL (SELECT, etc.). A "default" database is created if it does not already exist (matching the behavior of Spark/Flink Paimon catalogs).

(
        &mut self,
        catalog_name: impl Into<String>,
        catalog: Arc<dyn Catalog>,
    )

    /// A "default" database is created if it does not already exist (matching
    /// the behavior of Spark/Flink Paimon catalogs).
    pub async fn register_catalog(
        &mut self,
        catalog_name: impl Into<String>,
        catalog: Arc<dyn Catalog>,
    ) -> DFResult<()> {
        let catalog_name = catalog_name.into();
        let is_first = self.catalogs.is_empty();
        let default_db = "default";
        match catalog.get_database(default_db).await {
            Ok(_) => {}
            Err(paimon::Error::DatabaseNotExist { .. }) => {
                catalog
                    .create_database(default_db, true, Default::default())
                    .await
                    .map_err(|e| DataFusionError::External(Box::new(e)))?;
            }
            Err(e) => return Err(DataFusionError::External(Box::new(e))),
        }
        self.ctx.register_catalog(
            &catalog_name,
            Arc::new(crate::catalog::PaimonCatalogProvider::with_dynamic_options(
                catalog.clone(),
                self.dynamic_options.clone(),
            )),
        );
        register_table_functions(&self.ctx, &catalog, default_db);
        self.catalogs.insert(catalog_name.clone(), catalog);
        if is_first {
            self.set_current_catalog(catalog_name).await?;
            self.set_current_database(default_db).await?;
        }
        Ok(())
    }

    /// Sets the current catalog for unqualified table references.
    pub async fn set_current_catalog(&mut self, catalog_name: impl Into<String>) -> DFResult<()> {