feat: hash query

src-tauri/Cargo.toml

@@ -38,6 +38,7 @@ tokio = { version = "1.32.0", features = ["full"] }
 tracing = "0.1.37"
 tracing-subscriber = "0.3.17"
 sqlparser = "0.38.0"
+md-5 = "0.10.6"
 
 [features]
 # this feature is used for production builds or when `devPath` points to the filesystem

src-tauri/src/handlers/queries.rs

@@ -30,6 +30,13 @@ pub async fn enqueue_query(
     match statements {
         Ok(statements) => {
             if let Some(conn) = conn {
+                // let mut stmts = vec![];
+                // // reduce to unique statements
+                // for stmt in statements.iter() {
+                //     if !stmts.contains(&stmt.to_string()) {
+                //         stmts.push(stmt.to_string());
+                //     }
+                // }
                 let async_proc_input_tx = async_state.tasks.lock().await;
                 for (idx, statement) in statements.iter().enumerate() {
                     info!("Got statement {:?}", statement.to_string());

src-tauri/src/queues/query.rs

@@ -1,11 +1,11 @@
 use crate::database::connections::ConnectedConnection;
+use crate::utils::crypto::md5_hash;
 use anyhow::Result;
 use serde::Deserialize;
 use serde::Serialize;
 use tauri::Manager;
 use tokio::sync::mpsc;
 use tracing::info;
-use uuid::Uuid;
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub enum QueryTaskStatus {
@@ -33,14 +33,15 @@ pub struct QueryTask {
 
 impl QueryTask {
     pub fn new(conn: ConnectedConnection, tab_id: &str, query: &str, query_idx: usize) -> Self {
-        let id = Uuid::new_v4();
+        let query_hash = md5_hash(query);
+        let id = conn.config.id.to_string() + tab_id + &query_hash;
         QueryTask {
             conn,
+            id,
             tab_id: tab_id.to_string(),
+            query_idx,
             query: query.to_string(),
-            id: id.to_string(),
             status: QueryTaskStatus::Queued,
-            query_idx,
         }
     }
 }

src-tauri/src/utils/crypto.rs

@@ -1,4 +1,5 @@
 use anyhow::Result;
+use md5::{Digest, Md5};
 use rand::{distributions::Alphanumeric, Rng};
 use simplecrypt::{decrypt, encrypt};
 use std::fs;
@@ -34,6 +35,13 @@ pub fn get_app_key() -> Result<String> {
     Ok(key)
 }
 
+pub fn md5_hash(data: &str) -> String {
+    let mut hasher = Md5::new();
+    hasher.update(data);
+    let result = hasher.finalize();
+    format!("{:x}", result)
+}
+
 #[cfg(test)]
 mod test {
     use anyhow::Result;