Struct DeploymentExecutor 

pub struct DeploymentExecutor<'a> { /* private fields */ }

Helper for executing database object deployments.

This struct consolidates the pattern of executing a database object’s SQL statements (main statement + indexes + grants + comments) with consistent error handling. Supports dry-run mode where SQL is printed instead of executed.

In dry-run mode, statements are always recorded in an internal log that can be drained per-object via take_statements().

Implementations

impl<'a> DeploymentExecutor<'a>

pub fn new(client: &'a Client) -> Self

Create a new deployment executor that executes SQL.

pub fn new_dry_run(client: &'a Client) -> Self

Create a deployment executor that always runs in dry-run mode (for planning).

pub fn with_dry_run(client: &'a Client, dry_run: bool) -> Self

Create a deployment executor with configurable dry-run mode.

pub fn is_dry_run(&self) -> bool

Returns true if this executor is in dry-run mode.

pub fn take_statements(&self) -> Vec<String>

Drain and return all statements recorded since the last call.

Use this between objects to capture per-object statement lists for ObjectResult.

pub async fn execute_object( &self, typed_obj: &DatabaseObject, ) -> Result<(), CliError>

Execute all SQL statements for a database object.

This executes the main CREATE statement, followed by any indexes, grants, and comments associated with the object.

pub async fn prepare_databases_and_schemas( &self, planned_project: &Project, schema_set: &BTreeSet<SchemaQualifier>, staging_suffix: Option<&str>, ) -> Result<(), CliError>

Create databases and schemas for schema_set, then execute filtered mod_statements.

When staging_suffix is Some, schema names are suffixed and mod_statement schema references are rewritten at the AST level to target staging schemas.

pub async fn execute_sql(&self, stmt: &impl ToString) -> Result<(), CliError>

Execute (or print in dry-run mode) a single SQL statement.

In dry-run mode, statements are always logged to the internal statement buffer (retrievable via take_statements()).

pub async fn ensure_database(&self, name: &str) -> Result<(), CliError>

Ensure a database exists.

Real mode: delegates to client.provisioning().create_database(). Dry-run: logs CREATE DATABASE IF NOT EXISTS ....

pub async fn ensure_schema( &self, database: &str, schema: &str, ) -> Result<(), CliError>

Ensure a schema exists in the given database.

Real mode: delegates to client.provisioning().create_schema(). Dry-run: logs CREATE SCHEMA IF NOT EXISTS ....

pub async fn create_cluster( &self, staging_name: &str, prod_name: &str, config: &ClusterConfig, ) -> Result<(), CliError>

Create a staging cluster by cloning a production cluster’s configuration.

Real mode: delegates to client.provisioning().create_cluster_with_config(). Dry-run: logs a placeholder CREATE CLUSTER ... statement.

pub async fn record_deployment_clusters( &self, stage_name: &str, clusters: &[String], ) -> Result<(), CliError>

Record cluster mappings for a deployment.

Real mode: delegates to client.deployments().insert_deployment_clusters(). Dry-run: no-op (internal bookkeeping).