diff --git a/core/mvcc/cursor.rs b/core/mvcc/cursor.rs index e39dd7eb2..5fed0941f 100644 --- a/core/mvcc/cursor.rs +++ b/core/mvcc/cursor.rs @@ -22,6 +22,10 @@ impl ScanCursor { }) } + pub fn insert(&self, row: Row) -> Result<()> { + self.db.insert(self.tx_id, row) + } + pub fn current_row_id(&self) -> Option { if self.index >= self.row_ids.len() { return None;