motedb 0.1.1

AI-native embedded multimodal database for embodied intelligence (robots, AR glasses, industrial arms).
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
112

//! FFI (Foreign Function Interface) for C/Python/Node.js
//! 
//! C ABI 导出接口，用于动态链接库

use std::ffi::{CStr, CString};
use std::os::raw::c_char;
use std::ptr;
use std::sync::Arc;
use crate::MoteDB;

/// 不透明指针类型
pub struct MoteDBHandle {
    db: Arc<MoteDB>,
}

/// 打开数据库
/// 
/// # Safety
/// - path 必须是有效的 C 字符串
#[no_mangle]
pub unsafe extern "C" fn motedb_open(path: *const c_char) -> *mut MoteDBHandle {
    if path.is_null() {
        return ptr::null_mut();
    }
    
    let c_str = unsafe { CStr::from_ptr(path) };
    let path_str = match c_str.to_str() {
        Ok(s) => s,
        Err(_) => return ptr::null_mut(),
    };
    
    match MoteDB::open(path_str) {
        Ok(db) => Box::into_raw(Box::new(MoteDBHandle {
            db: Arc::new(db),
        })),
        Err(_) => ptr::null_mut(),
    }
}

/// 关闭数据库
/// 
/// # Safety
/// - handle 必须是有效的 MoteDBHandle 指针
#[no_mangle]
pub unsafe extern "C" fn motedb_close(handle: *mut MoteDBHandle) {
    if !handle.is_null() {
        let _ = unsafe { Box::from_raw(handle) };
    }
}

/// 执行 SQL 查询
/// 
/// # Safety
/// - handle 必须是有效的 MoteDBHandle 指针
/// - sql 必须是有效的 C 字符串
#[no_mangle]
pub unsafe extern "C" fn motedb_execute(
    handle: *mut MoteDBHandle,
    sql: *const c_char,
) -> *mut c_char {
    if handle.is_null() || sql.is_null() {
        return ptr::null_mut();
    }
    
    let handle = unsafe { &mut *handle };
    let c_str = unsafe { CStr::from_ptr(sql) };
    let sql_str = match c_str.to_str() {
        Ok(s) => s,
        Err(_) => return ptr::null_mut(),
    };
    
    // ✅ 使用流式 API 并立即物化
    use crate::sql::{Lexer, Parser, QueryExecutor};
    
    let result = (|| -> crate::Result<_> {
        let mut lexer = Lexer::new(sql_str);
        let tokens = lexer.tokenize()?;
        let mut parser = Parser::new(tokens);
        let statement = parser.parse()?;
        let executor = QueryExecutor::new(handle.db.clone());
        let streaming_result = executor.execute_streaming(statement)?;
        streaming_result.materialize()
    })();
    
    match result {
        Ok(result) => {
            let json = format!("{:?}", result);
            match CString::new(json) {
                Ok(c_string) => c_string.into_raw(),
                Err(_) => ptr::null_mut(),
            }
        }
        Err(e) => {
            let error = format!("Error: {}", e);
            match CString::new(error) {
                Ok(c_string) => c_string.into_raw(),
                Err(_) => ptr::null_mut(),
            }
        }
    }
}

/// 释放字符串内存
/// 
/// # Safety
/// - s 必须是由 motedb_execute 返回的指针
#[no_mangle]
pub unsafe extern "C" fn motedb_free_string(s: *mut c_char) {
    if !s.is_null() {
        let _ = unsafe { CString::from_raw(s) };
    }
}