From e9b1ca12b6061589e4c5801faedb11053ba1ee0c Mon Sep 17 00:00:00 2001
From: Nikita Sivukhin <sivukhin@turso.tech>
Date: Mon, 27 Oct 2025 18:10:20 +0400
Subject: [PATCH] add new access operation through IndexMethod

---
 core/translate/plan.rs | 46 +++++++++++++++++++++++++++++++-----------
 1 file changed, 34 insertions(+), 12 deletions(-)

diff --git a/core/translate/plan.rs b/core/translate/plan.rs
index 653763d07..a8c5cac52 100644
--- a/core/translate/plan.rs
+++ b/core/translate/plan.rs
@@ -1,7 +1,5 @@
-use std::{cmp::Ordering, sync::Arc};
-use turso_parser::ast::{
-    self, FrameBound, FrameClause, FrameExclude, FrameMode, SortOrder, SubqueryType,
-};
+use std::{cmp::Ordering, collections::HashMap, sync::Arc};
+use turso_parser::ast::{self, FrameBound, FrameClause, FrameExclude, FrameMode, SortOrder};
 
 use crate::{
     function::AggFunc,
@@ -38,7 +36,13 @@ impl ResultSetColumn {
         }
         match &self.expr {
             ast::Expr::Column { table, column, .. } => {
-                let (_, table_ref) = tables.find_table_by_internal_id(*table).unwrap();
+                let joined_table_ref = tables.find_joined_table_by_internal_id(*table).unwrap();
+                if let Operation::IndexMethodQuery(module) = &joined_table_ref.op {
+                    if module.covered_columns.contains_key(column) {
+                        return None;
+                    }
+                }
+                let table_ref = &joined_table_ref.table;
                 table_ref.get_column_at(*column).unwrap().name.as_deref()
             }
             ast::Expr::RowId { table, .. } => {
@@ -851,6 +855,8 @@ pub enum Operation {
     // This operation is used to search for a row in a table using an index
     // (i.e. a primary key or a secondary index)
     Search(Search),
+    // Access through custom index method query
+    IndexMethodQuery(IndexMethodQuery),
 }
 
 impl Operation {
@@ -872,9 +878,10 @@ impl Operation {
     pub fn index(&self) -> Option<&Arc<Index>> {
         match self {
             Operation::Scan(Scan::BTreeTable { index, .. }) => index.as_ref(),
+            Operation::Search(Search::Seek { index, .. }) => index.as_ref(),
+            Operation::IndexMethodQuery(IndexMethodQuery { index, .. }) => Some(index),
             Operation::Scan(_) => None,
             Operation::Search(Search::RowidEq { .. }) => None,
-            Operation::Search(Search::Seek { index, .. }) => index.as_ref(),
         }
     }
 }
@@ -1000,12 +1007,14 @@ impl JoinedTable {
                     )
                 };
 
-                let index_cursor_id = index.map(|index| {
-                    program.alloc_cursor_id_keyed(
-                        CursorKey::index(self.internal_id, index.clone()),
-                        CursorType::BTreeIndex(index.clone()),
-                    )
-                });
+                let index_cursor_id = index
+                    .map(|index| {
+                        program.alloc_cursor_index(
+                            Some(CursorKey::index(self.internal_id, index.clone())),
+                            index,
+                        )
+                    })
+                    .transpose()?;
                 Ok((table_cursor_id, index_cursor_id))
             }
             Table::Virtual(virtual_table) => {
@@ -1221,6 +1230,19 @@ pub enum Search {
     },
 }
 
+#[allow(clippy::large_enum_variant)]
+#[derive(Clone, Debug)]
+pub struct IndexMethodQuery {
+    /// index method to use
+    pub index: Arc<Index>,
+    /// idx of the pattern from [crate::index_method::IndexMethodAttachment::definition] which planner chose to use for the access
+    pub pattern_idx: usize,
+    /// captured arguments for the pattern chosen by the planner
+    pub arguments: Vec<Expr>,
+    /// mapping from index of [ast::Expr::Column] to the column index of IndexMethod response
+    pub covered_columns: HashMap<usize, usize>,
+}
+
 #[derive(Debug, Clone, PartialEq)]
 pub struct Aggregate {
     pub func: AggFunc,