devoyage-subgraph 0.0.15

Subgraph is a CLI that instantly generates a GraphQL API around Mongo, SQL, and HTTP APIs.
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

use log::{debug, error, trace};
use sqlx::{mysql::MySqlRow, Column, Row, TypeInfo};

pub trait FromMySqlRow {
    fn to_document(
        &self,
        fields: Option<Vec<&str>>,
    ) -> Result<bson::Document, async_graphql::Error>;
}

impl FromMySqlRow for MySqlRow {
    fn to_document(
        &self,
        fields: Option<Vec<&str>>,
    ) -> Result<bson::Document, async_graphql::Error> {
        debug!("Converting MySqlRow to Document");

        let mut document = bson::Document::new();

        for column in self.columns() {
            let column_name = column.name();

            if let Some(fields) = &fields {
                if !fields.contains(&column_name) {
                    continue;
                }
            }

            let column_type = column.type_info().name();

            match column_type {
                "VARCHAR" => {
                    let value: Option<&str> = self.try_get(column_name)?;
                    document.insert(column_name, value);
                }
                "INT" => {
                    let value: Option<i64> = self.try_get(column_name)?;
                    document.insert(column_name, value);
                }
                "INTEGER" => {
                    let value: Option<i64> = self.try_get(column_name)?;
                    document.insert(column_name, value);
                }
                "BOOL" => {
                    let value: Option<bool> = self.try_get(column_name)?;
                    document.insert(column_name, value);
                }
                "UUID" => {
                    let value: Option<&str> = self.try_get(column_name)?;
                    document.insert(column_name, value);
                }
                "DATETIME" => {
                    let value: Option<&str> = self.try_get(column_name)?;
                    document.insert(column_name, value);
                }
                "TEXT" => {
                    let value: Option<&str> = self.try_get(column_name)?;
                    document.insert(column_name, value);
                }
                "TIMESTAMP" => {
                    let value: Option<chrono::DateTime<chrono::Utc>> = self.try_get(column_name)?;
                    document.insert(column_name, value);
                }
                "BIGINT" => {
                    let value: Option<i64> = self.try_get(column_name)?;
                    document.insert(column_name, value);
                }
                "CHAR" => {
                    let value: Option<&str> = self.try_get(column_name)?;
                    document.insert(column_name, value);
                }
                _ => {
                    error!("Column type not supported: {}", column_type);
                    return Err(async_graphql::Error::new(format!(
                        "Column type not supported: {}",
                        column_type
                    )));
                }
            }
        }

        trace!("Document: {:?}", document);

        Ok(document)
    }
}