dbx-core 0.1.2-beta

High-performance file-based database engine with 5-Tier Hybrid Storage
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

//! Simple Query Builder Test

use arrow::datatypes::{DataType, Field, Schema};
use dbx_core::Database;

#[test]
fn test_query_builder_simple() -> dbx_core::DbxResult<()> {
    let db = Database::open_in_memory()?;

    // Create table using DDL API
    let schema = Schema::new(vec![
        Field::new("id", DataType::Int64, false),
        Field::new("name", DataType::Utf8, true),
    ]);
    db.create_table("test_users", schema)?;

    // Insert data using SQL (to avoid Binary type comparison issue)
    db.execute_sql("INSERT INTO test_users (id, name) VALUES (1, 'Alice')")?;
    db.execute_sql("INSERT INTO test_users (id, name) VALUES (2, 'Bob')")?;

    // Test Query Builder
    let results = db
        .query_builder()
        .select(&["id", "name"])
        .from("test_users")
        .execute()?;

    let total_rows: usize = results.iter().map(|b| b.num_rows()).sum();
    assert_eq!(total_rows, 2);

    Ok(())
}