[xitca-web] fix diesel update bench (#10429)

* [xitca-web] fix diesel update bench

* module clean up. resolve majority of dead code

* improve toasty perf

Author: fakeshadow

frameworks/Rust/xitca-web/Cargo.lock

@@ -98,8 +98,8 @@ codegen-units = 1
 panic = "abort"
 
 [patch.crates-io]
-xitca-postgres-diesel = { git = "https://github.com/fakeshadow/xitca-postgres-diesel", rev = "1bd39ac" }
-xitca-postgres-toasty = { git = "https://github.com/fakeshadow/xitca-postgres-toasty", rev = "270fe35" }
+xitca-postgres-diesel = { git = "https://github.com/fakeshadow/xitca-postgres-diesel", rev = "b6d1922" }
+xitca-postgres-toasty = { git = "https://github.com/fakeshadow/xitca-postgres-toasty", rev = "6034a22" }
 
 toasty = { git = "https://github.com/fakeshadow/toasty", branch = "engine" }
 toasty-core = { git = "https://github.com/fakeshadow/toasty", branch = "engine" }
@@ -108,9 +108,9 @@ toasty-sql = { git = "https://github.com/fakeshadow/toasty", branch = "engine" }
 # personal fork of tokio-uring with tokio local runtime enabled
 tokio-uring = { git = "http://github.com/fakeshadow/tokio-uring", rev = "c3d5887" }
 
-xitca-codegen = { git = "http://github.com/HFQR/xitca-web", rev = "faf1ae2" }
-xitca-http = { git = "http://github.com/HFQR/xitca-web", rev = "faf1ae2" }
-xitca-postgres = { git = "http://github.com/HFQR/xitca-web", rev = "faf1ae2" }
-xitca-server = { git = "http://github.com/HFQR/xitca-web", rev = "faf1ae2" }
-xitca-service = { git = "http://github.com/HFQR/xitca-web", rev = "faf1ae2" }
-xitca-web = { git = "http://github.com/HFQR/xitca-web", rev = "faf1ae2" }
+xitca-codegen = { git = "http://github.com/HFQR/xitca-web", rev = "3f38156" }
+xitca-http = { git = "http://github.com/HFQR/xitca-web", rev = "3f38156" }
+xitca-postgres = { git = "http://github.com/HFQR/xitca-web", rev = "3f38156" }
+xitca-server = { git = "http://github.com/HFQR/xitca-web", rev = "3f38156" }
+xitca-service = { git = "http://github.com/HFQR/xitca-web", rev = "3f38156" }
+xitca-web = { git = "http://github.com/HFQR/xitca-web", rev = "3f38156" }

frameworks/Rust/xitca-web/Cargo.toml

@@ -50,6 +50,7 @@
         "db_url": "/db",
         "fortune_url": "/fortunes",
         "query_url": "/queries?q=",
+        "update_url": "/updates?q=",
         "port": 8080,
         "approach": "realistic",
         "classification": "fullstack",

frameworks/Rust/xitca-web/benchmark_config.json

@@ -25,9 +25,9 @@ pub struct Exec {
 impl Exec {
     pub const FORTUNE_STMT: StatementNamed<'_> = Statement::named("SELECT id,message FROM fortune", &[]);
     pub const WORLD_STMT: StatementNamed<'_> =
-        Statement::named("SELECT id,randomnumber FROM world WHERE id=$1", &[Type::INT4]);
+        Statement::named("SELECT id,randomNumber FROM world WHERE id=$1", &[Type::INT4]);
     pub const UPDATE_STMT: StatementNamed<'_> = Statement::named(
-        "UPDATE world SET randomnumber=w.r FROM (SELECT unnest($1) as i,unnest($2) as r) w WHERE world.id=w.i",
+        "UPDATE world SET randomNumber=w.r FROM (SELECT unnest($1) as i,unnest($2) as r) w WHERE world.id=w.i",
         &[Type::INT4_ARRAY, Type::INT4_ARRAY],
     );
 
@@ -92,7 +92,7 @@ impl Exec {
                 })
                 .collect::<(Vec<_>, Vec<_>, Vec<_>)>();
 
-            let update = update_stmt.bind([&ids, &rngs]).query(&conn);
+            let update = update_stmt.bind([&ids, &rngs]).execute(&conn);
 
             drop(conn);
 
@@ -119,7 +119,7 @@ impl Exec {
         let mut fortunes = Vec::with_capacity(16);
 
         while let Some(row) = res.try_next().await? {
-            fortunes.push(Fortune::new(row.get(0), row.get::<String>(1)));
+            fortunes.push(Fortune::new(row.get(0), row.get_zc(1)));
         }
 
         Ok(Fortunes::new(fortunes))

frameworks/Rust/xitca-web/src/db.rs

@@ -21,7 +21,9 @@ pub struct Client {
 
 impl Client {
     pub async fn create() -> HandleResult<Self> {
-        let (cli, mut drv) = xitca_postgres::Postgres::new(DB_URL).connect().await?;
+        let (cli, drv) = xitca_postgres::Postgres::new(DB_URL).connect().await?;
+
+        let mut drv = drv.try_into_tcp().expect("raw tcp is used for database connection");
 
         tokio::task::spawn(async move {
             while drv.try_next().await?.is_some() {}