Method process_query

graphlite/src/coordinator/query_coordinator.rs:247–271

Execute a query with session ID This is the main entry point for query execution. # Arguments `query_text` - The GQL query string to execute `session_id` - Session ID for the query # Returns `Ok(QueryResult)` - Query result on success `Err(String)` - Error message on failure

(&self, query_text: &str, session_id: &str)

    /// * `Ok(QueryResult)` - Query result on success
    /// * `Err(String)` - Error message on failure
    pub fn process_query(&self, query_text: &str, session_id: &str) -> Result<QueryResult, String> {
        // Parse query
        let document = parse_query(query_text).map_err(|e| format!("Parse error: {:?}", e))?;

        // Get session
        let session = self.session_provider.get_session(session_id);

        // Create execution request
        let request = ExecutionRequest::new(document.statement)
            .with_session(session)
            .with_query_text(Some(query_text.to_string()));

        // Execute query
        let result = self
            .executor
            .execute_query(request)
            .map_err(|e| format!("Execution error: {:?}", e))?;

        // Process any session results (SET GRAPH, SET SCHEMA, etc.)
        if let Some(ref session_result) = result.session_result {
            self.handle_session_result(session_result, session_id)?;
        }

        Ok(result)
    }

    /// Handle session-modifying results (SET GRAPH, SET SCHEMA)
    fn handle_session_result(