rusticx-sql 1.0.0

Shared SQL dialect compiler (DDL + DML) for the Rusticx multi-database ORM
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
113
114
115
116
117
118
119
120
121

use rusticx_core::column::ColumnType;

/// SQL dialect controls syntax differences between backends.
pub trait SqlDialect: Send + Sync {
    /// Placeholder style: `$1` for Postgres, `?` for MySQL.
    fn placeholder(&self, index: usize) -> String;

    /// Quote an identifier (table name, column name).
    fn quote_ident(&self, name: &str) -> String;

    /// Map a ColumnType to dialect-specific SQL type string.
    fn sql_type(&self, col_type: &ColumnType) -> String;

    /// Whether RETURNING clause is supported (Postgres yes, MySQL no).
    fn supports_returning(&self) -> bool;

    /// Whether INSERT OR IGNORE / ON CONFLICT DO NOTHING is supported.
    fn upsert_syntax(&self) -> UpsertSyntax;
}

#[derive(Debug, Clone, Copy)]
pub enum UpsertSyntax {
    /// PostgreSQL: ON CONFLICT DO NOTHING
    OnConflict,
    /// MySQL: INSERT IGNORE
    InsertIgnore,
    /// Not supported
    None,
}

// ── Postgres dialect ──────────────────────────────────────────────────────────

pub struct PostgresDialect;

impl SqlDialect for PostgresDialect {
    fn placeholder(&self, index: usize) -> String {
        format!("${index}")
    }

    fn quote_ident(&self, name: &str) -> String {
        format!("\"{name}\"")
    }

    fn sql_type(&self, col_type: &ColumnType) -> String {
        match col_type {
            ColumnType::Bool => "BOOLEAN".into(),
            ColumnType::SmallInt => "SMALLINT".into(),
            ColumnType::Int => "INTEGER".into(),
            ColumnType::BigInt => "BIGINT".into(),
            ColumnType::Float => "REAL".into(),
            ColumnType::Double => "DOUBLE PRECISION".into(),
            ColumnType::Decimal { precision, scale } => format!("DECIMAL({precision},{scale})"),
            ColumnType::Text => "TEXT".into(),
            ColumnType::Varchar(n) => format!("VARCHAR({n})"),
            ColumnType::Char(n) => format!("CHAR({n})"),
            ColumnType::Bytes => "BYTEA".into(),
            ColumnType::Uuid => "UUID".into(),
            ColumnType::Timestamp => "TIMESTAMP".into(),
            ColumnType::TimestampTz => "TIMESTAMPTZ".into(),
            ColumnType::Date => "DATE".into(),
            ColumnType::Time => "TIME".into(),
            ColumnType::Json => "JSON".into(),
            ColumnType::Jsonb => "JSONB".into(),
            ColumnType::Array(inner) => format!("{}[]", self.sql_type(inner)),
            ColumnType::Dynamic => "JSONB".into(),
        }
    }

    fn supports_returning(&self) -> bool {
        true
    }

    fn upsert_syntax(&self) -> UpsertSyntax {
        UpsertSyntax::OnConflict
    }
}

// ── MySQL / MariaDB dialect ───────────────────────────────────────────────────

pub struct MysqlDialect;

impl SqlDialect for MysqlDialect {
    fn placeholder(&self, _index: usize) -> String {
        "?".into()
    }

    fn quote_ident(&self, name: &str) -> String {
        format!("`{name}`")
    }

    fn sql_type(&self, col_type: &ColumnType) -> String {
        match col_type {
            ColumnType::Bool => "TINYINT(1)".into(),
            ColumnType::SmallInt => "SMALLINT".into(),
            ColumnType::Int => "INT".into(),
            ColumnType::BigInt => "BIGINT".into(),
            ColumnType::Float => "FLOAT".into(),
            ColumnType::Double => "DOUBLE".into(),
            ColumnType::Decimal { precision, scale } => format!("DECIMAL({precision},{scale})"),
            ColumnType::Text => "TEXT".into(),
            ColumnType::Varchar(n) => format!("VARCHAR({n})"),
            ColumnType::Char(n) => format!("CHAR({n})"),
            ColumnType::Bytes => "BLOB".into(),
            ColumnType::Uuid => "CHAR(36)".into(),
            ColumnType::Timestamp | ColumnType::TimestampTz => "DATETIME(6)".into(),
            ColumnType::Date => "DATE".into(),
            ColumnType::Time => "TIME".into(),
            ColumnType::Json | ColumnType::Jsonb => "JSON".into(),
            ColumnType::Array(_) => "JSON".into(), // MySQL has no array type
            ColumnType::Dynamic => "JSON".into(),
        }
    }

    fn supports_returning(&self) -> bool {
        false
    }

    fn upsert_syntax(&self) -> UpsertSyntax {
        UpsertSyntax::InsertIgnore
    }
}