alopex-sql 0.6.0

SQL parser components for the Alopex DB dialect
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

use thiserror::Error;

/// Result alias for storage operations.
pub type Result<T> = std::result::Result<T, StorageError>;

/// Storage-layer error type.
#[derive(Debug, Error)]
pub enum StorageError {
    #[error("primary key violation: table_id={table_id}, row_id={row_id}")]
    PrimaryKeyViolation { table_id: u32, row_id: u64 },

    #[error("unique constraint violation: index_id={index_id}")]
    UniqueViolation { index_id: u32 },

    #[error("null constraint violation: column={column}")]
    NullConstraintViolation { column: String },

    #[error("corrupted data: {reason}")]
    CorruptedData { reason: String },

    #[error("type mismatch: expected {expected}, got {actual}")]
    TypeMismatch { expected: String, actual: String },

    #[error("row not found: table_id={table_id}, row_id={row_id}")]
    RowNotFound { table_id: u32, row_id: u64 },

    #[error("transaction conflict")]
    TransactionConflict,

    #[error("transaction is read-only")]
    TransactionReadOnly,

    #[error("transaction closed")]
    TransactionClosed,

    #[error("invalid key format")]
    InvalidKeyFormat,

    #[error("kv error: {0}")]
    KvError(alopex_core::error::Error),
}

impl From<alopex_core::error::Error> for StorageError {
    fn from(err: alopex_core::error::Error) -> Self {
        use alopex_core::error::Error as CoreError;
        match err {
            CoreError::TxnConflict => StorageError::TransactionConflict,
            CoreError::TxnReadOnly => StorageError::TransactionReadOnly,
            CoreError::TxnClosed => StorageError::TransactionClosed,
            other => StorageError::KvError(other),
        }
    }
}