Update keyv package version to 0.2.0

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "keyv"
-version = "0.1.0"
+version = "0.2.0"
 authors = ["Christian Llontop <chrisllontop@icloud.com>"]
 edition = "2021"
 description = "Simple key-value storage with support for multiple backends"

src/store/adapter/inmemory/inmemory.rs

@@ -41,17 +41,17 @@ impl Store for InMemoryStore {
         Ok(())
     }
 
-    async fn clear(&self) -> Result<(), StoreError> {
-        let mut db_lock = self.db.lock().await;
-        db_lock.clear();
-        Ok(())
-    }
-
     async fn remove_many(&self, keys: &[&str]) -> Result<(), StoreError> {
         let mut db_lock = self.db.lock().await;
         for key in keys {
             db_lock.remove(&key.to_string());
         }
         Ok(())
     }
+
+    async fn clear(&self) -> Result<(), StoreError> {
+        let mut db_lock = self.db.lock().await;
+        db_lock.clear();
+        Ok(())
+    }
 }

src/store/adapter/mysql/mysql.rs

@@ -90,9 +90,7 @@ impl Store for MySqlStore {
             .await
             .map_err(|_| StoreError::QueryError("Failed to fetch the value".to_string()))?;
 
-        Ok(result
-            .map(|row| serde_json::from_str(row.get("value")).ok())
-            .flatten())
+        Ok(result.and_then(|row| serde_json::from_str(row.get("value")).ok()))
     }
 
     async fn set(&self, key: &str, value: Value, ttl: Option<u64>) -> Result<(), StoreError> {

src/store/adapter/postgres/postgres.rs

@@ -11,6 +11,7 @@
     pub(crate) table_name: String,
     pub(crate) schema: Option<String>,
 }
+
 impl PostgresStore {
     fn get_table_name(&self) -> String {
         match &self.schema {
@@ -32,7 +33,7 @@
                     StoreError::QueryError(format!(
                         "Failed to create the schema '{}': {}",
                         schema,
                         e.to_string()
                     ))
                 })?;
         }
@@ -48,7 +49,7 @@
         sqlx::query(&sql).execute(&*self.pool).await.map_err(|e| {
             StoreError::QueryError(format!(
                 "Failed to initialize the database table: {}",
                 e.to_string()
             ))
         })?;
 
@@ -63,9 +64,7 @@
             .await
             .map_err(|_| StoreError::QueryError("Failed to fetch the value".to_string()))?;
 
-        Ok(result
-            .map(|row| serde_json::from_str(row.get("value")).ok())
-            .flatten())
+        Ok(result.and_then(|row| serde_json::from_str(row.get("value")).ok()))
     }
 
     async fn set(&self, key: &str, value: Value, ttl: Option<u64>) -> Result<(), StoreError> {
@@ -105,7 +104,7 @@
         let query = format!("DELETE FROM {} WHERE key = ANY($1)", self.get_table_name());
 
         sqlx::query(&query)
-            .bind(&keys)
+            .bind(keys)
             .execute(&*self.pool)
             .await
             .map_err(|_| StoreError::QueryError("Failed to remove the keys".to_string()))?;