Struct SqlStreamParser 

pub struct SqlStreamParser { /* private fields */ }

Streaming SQL statement parser

Parses SQL statements from a byte stream without loading all statements into memory. Uses a state machine to correctly handle quotes, escapes, and comments.

Implementations

impl SqlStreamParser

pub fn new() -> Self

Create a new streaming parser

pub async fn parse_file_from_index_collect( &mut self, file_path: &Path, start_index: usize, ) -> Result<Vec<String>>

Parse SQL statements from a file, starting from a specific index

This is a convenience method that collects all statements into a Vec. For true streaming without memory accumulation, use parse_stream with a custom callback.

pub async fn parse_stream_collect<R>( &mut self, reader: R, start_index: usize, ) -> Result<Vec<String>>

where R: AsyncRead + Unpin,

Parse SQL statements from a reader with callback

Internal method kept for potential future streaming use cases Parse SQL statements from any async reader, collecting into a Vec

pub fn parse_line(&mut self, line: &str, out: &mut Vec<String>) -> Result<()>

Parse a single line and push any completed statements into out.

pub fn count_line(&mut self, line: &str) -> usize

Count completed statements in line WITHOUT allocating per statement. Mirrors parse_line’s state machine exactly (quotes/brackets/escapes), but instead of buffering bytes it tracks whether the in-progress statement contains any non-whitespace byte, so a trailing ; on a blank/whitespace-only buffer is not counted (parity with take_trimmed_statement returning None on empty).

pub fn finish_count(&mut self) -> bool

Mirror of finish_statement().is_some() for the count-only path.

pub fn finish_statement(&mut self) -> Option<String>

Finalize parsing at EOF and return the remaining statement, if any