Method clear_cache

graphlite/src/catalog/system_procedures.rs:901–969

CALL gql.clear_cache([cache_type]) YIELD status, cleared_caches

(&self, args: Vec<Value>)

    /// CALL gql.clear_cache([cache_type]) YIELD status, cleared_caches
    fn clear_cache(&self, args: Vec<Value>) -> Result<QueryResult, ExecutionError> {
        let cache_type = if !args.is_empty() {
            match &args[0] {
                Value::String(s) => Some(s.as_str()),
                _ => None,
            }
        } else {
            None
        };

        let mut cleared_caches = Vec::new();
        let status = "success";

        match cache_type {
            Some("storage_cache") => {
                let _ = self.storage.clear_cache();
                cleared_caches.push("storage_cache");
            }
            Some("result_cache") | Some("plan_cache") | Some("subquery_cache") => {
                if let Some(cache_manager) = &self.cache_manager {
                    cache_manager.clear_all();
                    cleared_caches.push("result_cache");
                    cleared_caches.push("plan_cache");
                    cleared_caches.push("subquery_cache");
                } else {
                    return Err(ExecutionError::RuntimeError(
                        "Cache manager not available".to_string(),
                    ));
                }
            }
            Some(unknown) => {
                return Err(ExecutionError::RuntimeError(
                    format!("Unknown cache type: {}. Valid types: storage_cache, result_cache, plan_cache, subquery_cache", unknown)
                ));
            }
            None => {
                // Clear all caches
                let _ = self.storage.clear_cache();
                cleared_caches.push("storage_cache");

                if let Some(cache_manager) = &self.cache_manager {
                    cache_manager.clear_all();
                    cleared_caches.push("result_cache");
                    cleared_caches.push("plan_cache");
                    cleared_caches.push("subquery_cache");
                }
            }
        }

        let columns = vec!["status".to_string(), "cleared_caches".to_string()];
        let mut row_values = HashMap::new();
        row_values.insert("status".to_string(), Value::String(status.to_string()));
        row_values.insert(
            "cleared_caches".to_string(),
            Value::String(cleared_caches.join(", ")),
        );

        let rows = vec![Row::from_values(row_values)];