core: add CursorTrait imports where needed

This commit is contained in:
Pere Diaz Bou
2025-10-10 15:03:31 +02:00
parent b3ab51d66a
commit 160a84250e
6 changed files with 8 additions and 4 deletions

View File

@@ -2742,6 +2742,8 @@ mod tests {
// This reads the actual persisted data from the BTree
#[cfg(test)]
fn get_current_state(pager: Arc<Pager>, circuit: &DbspCircuit) -> Result<Delta> {
use crate::storage::btree::CursorTrait;
let mut delta = Delta::new();
let main_data_root = circuit.main_data_root;

View File

@@ -254,6 +254,7 @@ mod tests {
use super::*;
use crate::incremental::aggregate_operator::{AggregateOperator, AGG_TYPE_REGULAR};
use crate::incremental::dbsp::HashableRow;
use crate::storage::btree::CursorTrait;
use crate::storage::pager::CreateBTreeFlags;
use crate::types::Text;
use crate::util::IOExt;

View File

@@ -1,5 +1,5 @@
use crate::incremental::operator::{AggregateState, DbspStateCursors};
use crate::storage::btree::{BTreeCursor, BTreeKey};
use crate::storage::btree::{BTreeCursor, BTreeKey, CursorTrait};
use crate::types::{IOResult, ImmutableRecord, SeekKey, SeekOp, SeekResult};
use crate::{return_if_io, LimboError, Result, Value};

View File

@@ -2,7 +2,7 @@ use super::compiler::{DbspCircuit, DbspCompiler, DeltaSet};
use super::dbsp::Delta;
use super::operator::ComputationTracker;
use crate::schema::{BTreeTable, Schema};
use crate::storage::btree::BTreeCursor;
use crate::storage::btree::CursorTrait;
use crate::translate::logical::LogicalPlanBuilder;
use crate::types::{IOResult, Value};
use crate::util::{extract_view_columns, ViewColumnSchema};
@@ -1112,7 +1112,7 @@ impl IncrementalView {
&mut self,
conn: &std::sync::Arc<crate::Connection>,
pager: &std::sync::Arc<crate::Pager>,
_btree_cursor: &mut BTreeCursor,
_btree_cursor: &mut dyn CursorTrait,
) -> crate::Result<IOResult<()>> {
// Assert that this is a materialized view with a root page
assert!(

View File

@@ -5,6 +5,7 @@ use crate::state_machine::StateTransition;
use crate::state_machine::TransitionResult;
use crate::storage::btree::BTreeCursor;
use crate::storage::btree::BTreeKey;
use crate::storage::btree::CursorTrait;
use crate::storage::btree::CursorValidState;
use crate::storage::sqlite3_ondisk::DatabaseHeader;
use crate::storage::wal::TursoRwLock;

View File

@@ -72,7 +72,7 @@ impl Clone for View {
/// Type alias for regular views collection
pub type ViewsMap = HashMap<String, Arc<View>>;
use crate::storage::btree::BTreeCursor;
use crate::storage::btree::{BTreeCursor, CursorTrait};
use crate::translate::collate::CollationSeq;
use crate::translate::plan::{SelectPlan, TableReferences};
use crate::util::{