rowdy-db 0.8.3

A fast, modern, and rowdy TUI database management tool written in Rust.
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

pub mod mysql;
pub mod postgres;
pub mod redis;
pub mod sqlite;
pub mod turso;
#[cfg(feature = "mongodb")]
pub mod mongodb;
#[cfg(feature = "duckdb")]
pub mod duckdb;

use crate::db::error::DbError;
use crate::db::traits::{KvClient, NoSqlClient, SqlClient};

/// Create and connect a SQL connector for the given driver name and URL.
pub async fn connect_sql(db_type: &str, url: &str) -> Result<Box<dyn SqlClient>, DbError> {
    match db_type.to_lowercase().as_str() {
        "postgres" | "postgresql" => {
            let mut c = postgres::PostgresConnector::new();
            c.connect(url).await?;
            Ok(Box::new(c))
        }
        "sqlite" => {
            let mut c = sqlite::SqliteConnector::new();
            c.connect(url).await?;
            Ok(Box::new(c))
        }
        "mysql" | "mariadb" => {
            let mut c = mysql::MySqlConnector::new();
            c.connect(url).await?;
            Ok(Box::new(c))
        }
        "turso" | "libsql" => {
            let mut c = turso::TursoClient::new();
            c.connect(url).await?;
            Ok(Box::new(c))
        }
        "duckdb" => {
            #[cfg(feature = "duckdb")]
            {
                let mut c = duckdb::DuckDbConnector::new();
                c.connect(url).await?;
                return Ok(Box::new(c));
            }
            #[cfg(not(feature = "duckdb"))]
            Err(DbError::Unsupported(
                "DuckDB support not compiled in — reinstall with --features duckdb".to_string(),
            ))
        }
        other => Err(DbError::Unsupported(format!("Unknown SQL driver: {other}"))),
    }
}

/// Create and connect a key-value connector for the given driver name and URL.
pub async fn connect_kv(db_type: &str, url: &str) -> Result<Box<dyn KvClient>, DbError> {
    match db_type.to_lowercase().as_str() {
        "redis" => {
            let mut c = redis::RedisConnector::new();
            c.connect(url).await?;
            Ok(Box::new(c))
        }
        other => Err(DbError::Unsupported(format!("Unknown KV driver: {other}"))),
    }
}

/// Create and connect a NoSQL connector for the given driver name and URL.
#[allow(dead_code, unused_variables)]
pub async fn connect_nosql(db_type: &str, url: &str) -> Result<Box<dyn NoSqlClient>, DbError> {
    match db_type.to_lowercase().as_str() {
        "mongodb" => {
            #[cfg(feature = "mongodb")]
            {
                let mut c = mongodb::MongoDbConnector::new();
                c.connect(url).await?;
                return Ok(Box::new(c));
            }
            #[cfg(not(feature = "mongodb"))]
            Err(DbError::Unsupported(
                "MongoDB support not compiled in — reinstall with --features mongodb".to_string(),
            ))
        }
        other => Err(DbError::Unsupported(format!("Unknown NoSQL driver: {other}"))),
    }
}