remdb 0.3.1

嵌入式内存数据库
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

//! SQL DDL (Data Definition Language) Operations
//!
//! This module contains DDL operations like CREATE/DROP TABLE, DATABASE, INDEX, etc.

use crate::sql::{QueryExecutionError, ResultSet, SqlQuery};
use crate::RemDb;
use alloc::vec::Vec;

/// 执行DROP TABLE查询
pub fn execute_drop_table_query(
    db: &mut RemDb,
    query: &SqlQuery,
) -> Result<ResultSet, QueryExecutionError> {
    // 提取IF EXISTS和DEFERRED选项
    let mut if_exists = false;
    let mut is_deferred = false;

    if let Some((if_exists_str, is_deferred_str, _, _, _, _, _)) = query.table_def.first() {
        if_exists = if_exists_str == "true";
        is_deferred = is_deferred_str == "true";
    }

    // 调用RemDb的drop_table方法
    db.drop_table(&query.table_name, if_exists, is_deferred)
        .map_err(|err| match err {
            crate::RemDbError::NotAllowed => QueryExecutionError::NotAllowed,
            crate::RemDbError::TableNotFound => QueryExecutionError::TableNotFound,
            _ => QueryExecutionError::InternalError,
        })?;

    // 返回空结果集
    Ok(ResultSet::new(Vec::new()))
}

/// 执行CREATE DATABASE查询
pub fn execute_create_database_query(
    db: &mut RemDb,
    query: &SqlQuery,
) -> Result<ResultSet, QueryExecutionError> {
    // 提取数据库名称
    let database_name = query.table_name.clone();

    // 调用RemDb的create_database方法
    db.create_database(&database_name)
        .map_err(|err| match err {
            crate::RemDbError::DatabaseExists => QueryExecutionError::DatabaseExists,
            _ => QueryExecutionError::InternalError,
        })?;

    // 返回空结果集
    Ok(ResultSet::new(Vec::new()))
}

/// 执行USE DATABASE查询
pub fn execute_use_database_query(
    db: &mut RemDb,
    query: &SqlQuery,
) -> Result<ResultSet, QueryExecutionError> {
    // 提取数据库名称
    let database_name = query.table_name.clone();

    // 调用RemDb的use_database方法
    db.use_database(&database_name)
        .map_err(|_| QueryExecutionError::InternalError)?;

    // 返回空结果集
    Ok(ResultSet::new(Vec::new()))
}

/// 执行CLOSE DATABASE查询
pub fn execute_close_database_query(
    db: &mut RemDb,
    query: &SqlQuery,
) -> Result<ResultSet, QueryExecutionError> {
    // 提取数据库名称
    let database_name = query.table_name.clone();

    // 调用RemDb的close_database方法
    db.close_database(&database_name)
        .map_err(|_| QueryExecutionError::InternalError)?;

    // 返回空结果集
    Ok(ResultSet::new(Vec::new()))
}

/// 执行DROP DATABASE查询
pub fn execute_drop_database_query(
    db: &mut RemDb,
    query: &SqlQuery,
) -> Result<ResultSet, QueryExecutionError> {
    // 提取数据库名称
    let database_name = query.table_name.clone();

    // 调用RemDb的drop_database方法
    db.drop_database(&database_name)
        .map_err(|_| QueryExecutionError::InternalError)?;

    // 返回空结果集
    Ok(ResultSet::new(Vec::new()))
}