tegdb 0.5.0

The name TegridyDB (short for TegDB) is inspired by the Tegridy Farm in South Park and tries to correct some of the wrong database implementations, such as null support, implicit conversion support, etc.
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

//! Protocol utilities for storage identifier parsing
//!
//! TegDB now targets native platforms exclusively, so only the `file://` protocol
//! is supported when opening databases.

/// File-based storage protocol prefix
pub const PROTOCOL_FILE: &str = "file://";

/// Canonical protocol name
pub const PROTOCOL_NAME_FILE: &str = "file";

/// Parse a storage identifier to extract the protocol and path
///
/// Supports the following forms:
/// - `file://` absolute paths (preferred)
/// - Identifiers without a protocol, which default to `file`
///
/// # Examples
///
/// ```
/// use tegdb::protocol_utils::parse_storage_identifier;
///
/// let (protocol, path) = parse_storage_identifier("file:///path/to/db");
/// assert_eq!(protocol, "file");
/// assert_eq!(path, "/path/to/db");
///
/// let (protocol, path) = parse_storage_identifier("my_database.db");
/// assert_eq!(protocol, "file");
/// assert_eq!(path, "my_database.db");
/// ```
pub fn parse_storage_identifier(identifier: &str) -> (&str, &str) {
    if identifier.starts_with(PROTOCOL_FILE) {
        (
            PROTOCOL_NAME_FILE,
            identifier.trim_start_matches(PROTOCOL_FILE),
        )
    } else {
        // Default to file protocol for backward compatibility
        (PROTOCOL_NAME_FILE, identifier)
    }
}

/// Check if an identifier uses the `file://` protocol explicitly
pub fn has_protocol(identifier: &str, protocol: &str) -> bool {
    protocol == PROTOCOL_NAME_FILE && identifier.starts_with(PROTOCOL_FILE)
}

/// Extract the path part from a storage identifier
pub fn extract_path(identifier: &str) -> &str {
    parse_storage_identifier(identifier).1
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_parse_file_protocol() {
        let (protocol, path) = parse_storage_identifier("file:///path/to/db");
        assert_eq!(protocol, "file");
        assert_eq!(path, "/path/to/db");
    }

    #[test]
    fn test_parse_no_protocol() {
        let (protocol, path) = parse_storage_identifier("my_database.db");
        assert_eq!(protocol, "file");
        assert_eq!(path, "my_database.db");
    }

    #[test]
    fn test_has_protocol() {
        assert!(has_protocol("file:///path/to/db", "file"));
        assert!(!has_protocol("my_database.db", "file"));
    }

    #[test]
    fn test_extract_path() {
        assert_eq!(extract_path("file:///path/to/db"), "/path/to/db");
        assert_eq!(extract_path("my_database.db"), "my_database.db");
    }
}