Struct PreprocessingPipeline 

pub struct PreprocessingPipeline { /* private fields */ }

The main preprocessing pipeline

Orchestrates the application of multiple AST transformers in sequence. Provides logging, debugging, and statistics collection.

Example

use sql_cli::query_plan::{PreprocessingPipeline, PipelineConfig};
use sql_cli::query_plan::{CTEHoister, ExpressionLifter};

let mut pipeline = PreprocessingPipeline::new(PipelineConfig::default());
pipeline.add_transformer(Box::new(CTEHoister::new()));
pipeline.add_transformer(Box::new(ExpressionLifter::new()));

let transformed = pipeline.process(statement)?;

Implementations

impl PreprocessingPipeline

pub fn new(config: PipelineConfig) -> Self

Create a new empty pipeline with the given configuration

pub fn add_transformer(&mut self, transformer: Box<dyn ASTTransformer>)

Add a transformer to the pipeline

Transformers are applied in the order they are added.

pub fn stats(&self) -> &PreprocessingStats

Get the collected statistics

pub fn reset_stats(&mut self)

Reset statistics

pub fn process(&mut self, stmt: SelectStatement) -> Result<SelectStatement>

Process a SQL statement through the pipeline

Applies each enabled transformer in sequence, collecting statistics and logging as configured.

pub fn transformer_summary(&self) -> String

Get a summary of what transformers are in the pipeline

Trait Implementations

impl Default for PreprocessingPipeline

fn default() -> Self

Returns the “default value” for a type.