start 0.1.9

Start – Your embedded database.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

use bson::Bson;

use crate::db::{catalog::collection::RawDocument, operation_context::OperationContext, query::query_planner::QueryPlan};

pub fn execute_plan(op_ctx: OperationContext, plan: QueryPlan) -> Vec<Bson> {
    println!("QueryPlan: {:?}", plan);

    let mut result = vec![];
    
    let mut next_offset = plan.collection.next_document as usize;
    let rc_unit = op_ctx.rc_unit();
    
    while next_offset != 0 {
        let raw_doc = RawDocument::parse(&rc_unit.borrow(), next_offset);
        println!("RawDoc: {:?}", raw_doc);

        if let Ok(text) = std::str::from_utf8(&raw_doc.content) {
            println!("{}. '{}'", next_offset, text);
        }

        result.push(bson::from_slice(&raw_doc.content).unwrap());

        // if next_offset == plan.collection.next_document as usize {
            // next_offset = plan.collection.next_document as usize; // Move to the next document
        // } else {
            // next_offset = raw_doc.next_document as usize; // Move to the next document
        // }

        next_offset = raw_doc.next_document as usize;
    }


    result
}