Struct QueryRowIterator 

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

Streaming query result that yields rows one at a time.

This type enables true streaming output for SELECT queries by applying projection on-the-fly and yielding projected rows through an iterator.

Example

let mut iter = db.execute_sql_streaming("SELECT * FROM users")?;
while let Some(row) = iter.next_row()? {
    println!("{:?}", row);
}

Implementations

impl<'a> QueryRowIterator<'a>

pub fn new( inner: Box<dyn RowIterator + 'a>, projection: Projection, schema: Vec<ColumnMetadata>, ) -> Self

Create a new streaming query result.

pub fn columns(&self) -> &[ColumnInfo]

Returns column information for the result set.

pub fn next_row(&mut self) -> Result<Option<Vec<SqlValue>>, ExecutorError>

Advance and return the next projected row, or None if exhausted.

Errors

Returns an error if reading or projection fails.