rasterizeddb_core 0.0.8

A schemaless, high-performance database written in Rust, designed for speed and scalability.
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111

use std::{fs::remove_file, mem::ManuallyDrop};
use tokio::runtime;

use rasterizeddb_core::core::{
    column::Column,
    row::InsertOrUpdateRow,
    storage_providers::{file_sync::LocalStorageProvider, memory::MemoryStorageProvider},
    table::Table,
};

pub fn rebuild_indexes_file() {
    _ = remove_file("C:\\Tests\\database.db");

    let rt = runtime::Builder::new_current_thread().build().unwrap();

    rt.block_on(async {
        let io_sync = LocalStorageProvider::new("C:\\Tests", "database.db").await;

        let mut table = Table::init(io_sync, false, false).await.unwrap();

        for i in 0..500 {
            if i == 450 {
                let c1 = Column::new(1000).unwrap();
                let c2 = Column::new(i * -1).unwrap();
                let c3 = Column::new("This is awesome.").unwrap();

                let mut columns_buffer: Vec<u8> =
                    Vec::with_capacity(c1.len() + c2.len() + c3.len());

                columns_buffer.append(&mut c1.content.to_vec());
                columns_buffer.append(&mut c2.content.to_vec());
                columns_buffer.append(&mut c3.content.to_vec());

                let insert_row = InsertOrUpdateRow {
                    columns_data: columns_buffer,
                };

                table.insert_row(insert_row).await;
            } else {
                let c1 = Column::new(i).unwrap();
                let c2 = Column::new(i * -1).unwrap();
                let c3 = Column::new("This is also awesome.").unwrap();

                let mut columns_buffer: Vec<u8> =
                    Vec::with_capacity(c1.len() + c2.len() + c3.len());

                columns_buffer.append(&mut c1.content.to_vec());
                columns_buffer.append(&mut c2.content.to_vec());
                columns_buffer.append(&mut c3.content.to_vec());

                let insert_row = InsertOrUpdateRow {
                    columns_data: columns_buffer,
                };

                table.insert_row(insert_row).await;
            }
        }

        table.rebuild_in_memory_indexes().await;
    });
}

pub fn rebuild_indexes_memory() {
    let rt = runtime::Builder::new_current_thread().build().unwrap();

    rt.block_on(async {
        let io_sync = MemoryStorageProvider::new();

        let mut table = Table::init(io_sync, false, false).await.unwrap();

        for i in 0..500 {
            if i == 450 {
                let c1 = Column::new(1000).unwrap();
                let c2 = Column::new(i * -1).unwrap();
                let c3 = Column::new("This is awesome.").unwrap();

                let mut columns_buffer: Vec<u8> =
                    Vec::with_capacity(c1.len() + c2.len() + c3.len());

                columns_buffer.append(&mut c1.content.to_vec());
                columns_buffer.append(&mut c2.content.to_vec());
                columns_buffer.append(&mut c3.content.to_vec());

                let insert_row = InsertOrUpdateRow {
                    columns_data: columns_buffer,
                };

                table.insert_row(insert_row).await;
            } else {
                let c1 = Column::new(i).unwrap();
                let c2 = Column::new(i * -1).unwrap();
                let c3 = Column::new("This is also awesome.").unwrap();

                let mut columns_buffer: Vec<u8> =
                    Vec::with_capacity(c1.len() + c2.len() + c3.len());

                columns_buffer.append(&mut c1.content.to_vec());
                columns_buffer.append(&mut c2.content.to_vec());
                columns_buffer.append(&mut c3.content.to_vec());

                let insert_row = InsertOrUpdateRow {
                    columns_data: columns_buffer,
                };

                table.insert_row(insert_row).await;
            }
        }

        table.rebuild_in_memory_indexes().await;
    });
}