Method execute_basic_query

src/optimization/statement_cache_optimizer.rs:164–201

Execute basic query without statement caching

(
        &self,
        conn: &Connection,
        query: &str,
        params: P,
    )

    /// Execute basic query without statement caching
    fn execute_basic_query<P: rusqlite::Params>(
        &self,
        conn: &Connection,
        query: &str,
        params: P,
    ) -> Result<(Vec<String>, crate::session::db_handler::DbRows), rusqlite::Error> {
        let mut stmt = conn.prepare(query)?;
        let column_names: Vec<String> = stmt.column_names().iter().map(|&s| s.to_string()).collect();
        
        let mut results = Vec::new();
        let rows = stmt.query_map(params, |row| {
            let mut row_data = Vec::new();
            for i in 0..column_names.len() {
                match row.get_ref(i)? {
                    rusqlite::types::ValueRef::Null => row_data.push(None),
                    rusqlite::types::ValueRef::Integer(val) => {
                        row_data.push(Some(val.to_string().into_bytes()));
                    },
                    rusqlite::types::ValueRef::Real(val) => {
                        row_data.push(Some(val.to_string().into_bytes()));
                    },
                    rusqlite::types::ValueRef::Text(val) => {
                        row_data.push(Some(val.to_vec()));
                    },
                    rusqlite::types::ValueRef::Blob(val) => {
                        row_data.push(Some(val.to_vec()));
                    },
                }
            }
            Ok(row_data)
        })?;

        for row_result in rows {
            results.push(row_result?);
        }

        Ok((column_names, results))
    }

    /// Determine if a query should use statement caching based on pattern and hints
    fn should_use_statement_cache(&self, pattern: &QueryPattern, hints: &OptimizationHints) -> bool {