Add some functions for redis client.

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "tardis"
-version = "0.1.0-alpha10"
+version = "0.1.0-alpha11"
 authors = ["gudaoxuri <[email protected]>"]
 description = "Elegant, clean Rust development framework"
 keywords = ["http", "database", "web", "redis", "mq"]

src/cache/cache_client.rs

@@ -198,6 +198,20 @@ impl TardisCacheClient {
         (*self.con.lock().await).hlen(key).await
     }
 
+    pub async fn flushdb(&self) -> RedisResult<()> {
+        match redis::cmd("FLUSHDB").query_async(&mut (*self.con.lock().await)).await {
+            Ok(()) => Ok(()),
+            Err(e) => Err(e),
+        }
+    }
+
+    pub async fn flushall(&self) -> RedisResult<()> {
+        match redis::cmd("FLUSHALL").query_async(&mut (*self.con.lock().await)).await {
+            Ok(()) => Ok(()),
+            Err(e) => Err(e),
+        }
+    }
+
     // custom
     pub async fn cmd(&self) -> MutexGuard<'_, Connection> {
         self.con.lock().await

tests/test_cache_client.rs

@@ -181,6 +181,13 @@ async fn test_cache_client() -> TardisResult<()> {
         .await
         .unwrap();
 
+        // flush
+
+        client.set("flush_test", "测试").await?;
+        assert!(client.exists("flush_test").await?);
+        client.flushdb().await?;
+        assert!(!client.exists("flush_test").await?);
+
         Ok(())
     })
     .await