Method execute

crates/vcsql/src/sql/engine.rs:140–154

Executes a SQL query and returns the results. The query can use any SQL features supported by SQLite, including JOINs, CTEs, window functions, and aggregations.

(&self, query: &str)

    /// The query can use any SQL features supported by SQLite, including JOINs,
    /// CTEs, window functions, and aggregations.
    pub fn execute(&self, query: &str) -> Result<QueryResult> {
        let mut stmt = self.conn.prepare(query)?;

        let column_names: Vec<String> = stmt.column_names().iter().map(|s| s.to_string()).collect();

        let rows: Vec<Vec<Value>> = stmt
            .query_map([], |row| Ok(row_to_values(row, column_names.len())))?
            .filter_map(|r| r.ok())
            .collect();

        Ok(QueryResult {
            columns: column_names,
            rows,
        })
    }
}

fn row_to_values(row: &Row, col_count: usize) -> Vec<Value> {