Struct ParallelSqlParser 

pub struct ParallelSqlParser { /* private fields */ }

Parallel SQL parser for batch processing

Implementations

impl ParallelSqlParser

pub fn new() -> Self

Create a new parallel SQL parser

pub fn with_thread_pool(thread_pool: Arc<ThreadPool>) -> Self

Create a new parallel SQL parser with a custom thread pool

pub fn parse(&self, sql: &str) -> DbxResult<Vec<Statement>>

Parse a single SQL string into AST

pub fn parse_batch(&self, sqls: &[&str]) -> DbxResult<Vec<Vec<Statement>>>

Parse multiple SQL strings in parallel with optimized scheduling

Applies three optimization layers:

1. Dynamic thread pool: adjusts parallelism based on workload complexity
2. Adaptive batch splitting: distributes work by estimated query complexity
3. Lock-free result collection: pre-allocated indexed output

Arguments

• sqls - A slice of SQL strings to parse

Example

use dbx_core::sql::parallel_parser::ParallelSqlParser;

let parser = ParallelSqlParser::new();
let sqls = vec![
    "SELECT * FROM users",
    "SELECT * FROM orders",
    "SELECT * FROM products",
];
let results = parser.parse_batch(&sqls).unwrap();
assert_eq!(results.len(), 3);

pub fn parse_batch_partial( &self, sqls: &[&str], ) -> (Vec<Vec<Statement>>, Vec<(usize, DbxError)>)

Parse multiple SQL strings in parallel, collecting only successful results

Returns a vector of successful parse results and a vector of errors. This is useful when you want to continue processing even if some SQL strings fail.

Arguments

• sqls - A slice of SQL strings to parse

Returns

A tuple of (successful_results, errors)

pub fn parse_batch_with_callback<F>( &self, sqls: &[&str], callback: F, ) -> DbxResult<()>

where F: FnMut(usize, DbxResult<Vec<Statement>>) -> DbxResult<()>,

Parse multiple SQL strings and execute a callback for each result

This is useful for streaming processing where you want to handle each result as it becomes available.

Arguments

• sqls - A slice of SQL strings to parse
• callback - A function to call for each parse result

Trait Implementations

impl Default for ParallelSqlParser

fn default() -> Self

Returns the “default value” for a type.