Refactor

src/main.rs

@@ -1,29 +1,15 @@
 use actix_web::{get, post, web, App, HttpResponse, HttpServer, Responder};
-use sqlx::{MssqlPool, Row, Pool, Mssql};
+use sqlx::{MssqlPool};
 use std::sync::Mutex;
-use serde::Serialize;
 
-#[derive(Serialize, sqlx::FromRow)]
-struct Gerbil
-{
-    name: String
-}
+mod models;
+mod routes;
 
 #[get("/")]
 async fn hello() -> impl Responder {
     HttpResponse::Ok().body("Hello world!")
 }
 
-#[get("/renner")]
-async fn renner(data: web::Data<Mutex<Pool<Mssql>>>) -> impl Responder {
-    let data = data.lock().unwrap();
-    let rows = sqlx::query_as::<_,Gerbil>("SELECT name FROM renner")
-        .fetch_all(&(*data))
-        .await
-        .expect("no connection to database");
-    HttpResponse::Ok().json(rows)
-}
-
 #[post("/echo")]
 async fn echo(req_body: String) -> impl Responder {
     HttpResponse::Ok().body(req_body)
@@ -42,7 +28,7 @@ async fn main() -> std::io::Result<()> {
             .app_data(data.clone())
             .service(hello)
             .service(echo)
-            .service(renner)
+            .service(routes::renner::renner)
             .route("/hey", web::get().to(manual_hello))
     })
     .bind("127.0.0.1:8080")?

src/models/gerbil.rs

@@ -0,0 +1,5 @@
+#[derive(serde::Serialize, sqlx::FromRow)]
+pub struct Gerbil
+{
+    name: String
+}

src/models/mod.rs

@@ -0,0 +1 @@
+pub mod gerbil;

src/routes/mod.rs

@@ -0,0 +1 @@
+pub mod renner;

src/routes/renner.rs

@@ -0,0 +1,36 @@
+use actix_web::{get, web, web::Query, HttpResponse, Responder};
+use sqlx::{Pool, Mssql};
+use std::sync::Mutex;
+use serde::{Deserialize};
+
+use crate::models::gerbil::Gerbil;
+
+#[derive(Deserialize)]
+struct RennerQueryParam {
+    name: Option<String>,
+}
+
+
+#[get("/renner")]
+async fn renner(data: web::Data<Mutex<Pool<Mssql>>>, params: Query<RennerQueryParam>) -> impl Responder {
+    let mut sql = String::from("SELECT name FROM renner");
+
+    let mut pairs = Vec::new();
+    match &params.name
+    {
+        Some(val) => pairs.push(format!("name='{0}'", val)),
+        None => ()
+    }
+    if pairs.len() != 0
+    {
+        let ret = pairs.iter().skip(1).fold(String::from(&pairs[0]), |sum, x| {format!("{0} AND {1}", sum, x)});
+        sql.push_str(&format!(" WHERE {}",ret));
+    }
+    println!("{}",sql);
+    let data = data.lock().unwrap();
+    let rows = sqlx::query_as::<_,Gerbil>(&sql)
+        .fetch_all(&(*data))
+        .await
+        .expect("no connection to database");
+    HttpResponse::Ok().json(rows)
+}