sql-schema 0.6.3

Declarative SQL schema migrations
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

use thiserror::Error;

use crate::{ast, dialect, sealed::Sealed};

#[derive(Error, Debug)]
#[error("Oops, we couldn't parse that!")]
pub struct ParseError(#[from] sqlparser::parser::ParserError);

pub trait Parse: Sealed {
    fn parse_sql<'a, Dialect>(
        &self,
        sql: impl Into<&'a str>,
    ) -> Result<Vec<ast::Statement>, ParseError>;
}

fn parse_sql<'a>(
    dialect: Box<dyn sqlparser::dialect::Dialect>,
    sql: impl Into<&'a str>,
) -> Result<Vec<ast::Statement>, ParseError> {
    let tree = sqlparser::parser::Parser::parse_sql(dialect.as_ref(), sql.into())?;
    Ok(tree)
}

impl Parse for dialect::Generic {
    fn parse_sql<'a, Dialect>(
        &self,
        sql: impl Into<&'a str>,
    ) -> Result<Vec<ast::Statement>, ParseError> {
        parse_sql(Box::new(sqlparser::dialect::GenericDialect {}), sql)
    }
}

impl Parse for dialect::PostgreSQL {
    fn parse_sql<'a, Dialect>(
        &self,
        sql: impl Into<&'a str>,
    ) -> Result<Vec<ast::Statement>, ParseError> {
        parse_sql(Box::new(sqlparser::dialect::PostgreSqlDialect {}), sql)
    }
}

impl Parse for dialect::SQLite {
    fn parse_sql<'a, Dialect>(
        &self,
        sql: impl Into<&'a str>,
    ) -> Result<Vec<ast::Statement>, ParseError> {
        parse_sql(Box::new(sqlparser::dialect::SQLiteDialect {}), sql)
    }
}