start 0.4.4

StartDB – Embedded NoSQL Database in Rust
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

use bson::Bson;
use log::trace;

use crate::{db::{catalog::{collection::RawDocument, session::Session}, operation_context::OperationContext, ops, service_context::ServiceContext}, HandleResult};

pub fn insert(
    session: &Session,
    collection: &str,
    document: Bson
) -> HandleResult<()> {
    trace!("__________________Insert____________________");
    let mut op_ctx = OperationContext::new(session)?;

    let catalog = 
        op_ctx.catalog().borrow_mut()
        .collection();

    let content = bson::to_vec(&document)?;
    
    let mut meta = catalog.borrow_mut().acquire_collection_or_create(collection, &mut op_ctx);

    ops::insert::insert(&mut op_ctx, &mut meta, &content);

    if session.transaction().borrow().is_none() {
        op_ctx.rc_unit().borrow_mut().commit();
    }
    trace!("___________________________________________");

    Ok(())
}