feat: add basic connection to database

docs/samples/impl.fkl

@@ -58,8 +58,7 @@ impl UserCreated {
 
 env Local {
   datasource {
-    url: "postgresql://localhost:5432/yourdb"
-    // two different types?
+    url: "mysql://localhost:5432/yourdb"
     driver: postgresql
     host: "localhost"
     port: 5432

fkl_cli/Cargo.toml

@@ -64,9 +64,11 @@ sqlx = { version = "0.6", features = [
 # microsoft sql server
 #tiberius = { version = "0.11" }
 #oracle = { version = "0.5" }
-
+futures = "0.3"
 tokio = { version = "1", features = ["full"] }
 
+async-trait = "0.1.58"
+
 [dev-dependencies]
 trycmd = "0.14.0"
 

fkl_cli/src/builtin/mod.rs

@@ -1,10 +1,11 @@
 use std::path::PathBuf;
 use std::process;
 
-use log::error;
+use log::{error, info};
 
-use fkl_parser::mir::LayeredArchitecture;
+use fkl_parser::mir::{Datasource, Environment, LayeredArchitecture};
 
+use crate::datasource::mysql_connector::MysqlConnector;
 use crate::exec::LayeredGuardingExec;
 
 pub mod endpoint_runner;
@@ -20,3 +21,14 @@ pub fn guarding_runner(root: PathBuf, layered: &LayeredArchitecture) {
     process::exit(0x0100);
   }
 }
+
+pub(crate) async fn test_connection_runner(env: &Environment) {
+  info!("test connection: {:?}", env);
+  match &env.datasources[0] {
+    Datasource::MySql(mysql) => {
+      MysqlConnector::new(mysql.clone()).test_connection().await;
+    }
+
+    Datasource::Postgres(_) => {}
+  }
+}

fkl_cli/src/datasource/mod.rs

@@ -1,5 +1,7 @@
 pub mod mysql_connector;
+use async_trait::async_trait;
 
+#[async_trait]
 pub trait DatasourceConnector {
   fn test_connection(&self) -> bool;
 }

fkl_cli/src/datasource/mysql_connector.rs

@@ -1,6 +1,9 @@
+use std::time::Duration;
+
+use log::error;
 use sqlx::mysql::MySqlPoolOptions;
+
 use fkl_parser::mir::MySqlDatasource;
-use crate::datasource::DatasourceConnector;
 
 pub struct MysqlConnector {
   config: MySqlDatasource,
@@ -14,12 +17,21 @@ impl MysqlConnector {
   }
 }
 
-// impl DatasourceConnector for MysqlConnector {
-//   fn test_connection(&self) -> bool {
-//     let pool = MySqlPoolOptions::new()
-//       .max_connections(5)
-//       .connect("postgres://postgres:password@localhost/test").await?;
-//
-//
-//   }
-// }
+impl MysqlConnector {
+  pub(crate) async fn test_connection(&self) -> bool {
+    let options = MySqlPoolOptions::new();
+
+    match options
+      .max_connections(5)
+      .max_lifetime(Duration::from_secs(10 * 60))
+      .connect(&self.config.url()).await {
+      Ok(_) => {
+        true
+      }
+      Err(err) => {
+        error!("error: {:?}", err);
+        false
+      }
+    }
+  }
+}

fkl_cli/src/main.rs

@@ -117,7 +117,8 @@ async fn main() {
           builtin::guarding_runner(root, &layered);
         }
         RunFuncName::TestConnection => {
-
+          let env = mir.envs;
+          builtin::test_connection_runner( &env[0]).await;
         }
       }
     }

fkl_parser/src/mir/implementation/datasource.rs

@@ -35,6 +35,7 @@ impl Datasource {
     }
   }
 
+  #[allow(dead_code)]
   fn url(&self) -> String {
     match self {
       Datasource::MySql(config) => MySqlDatasource::url(config),