feat: delete transaction schema

1 files changed, 6 insertions, 7 deletions

diff --git a/lib/api-config/src/schema/mod.rs b/lib/api-config/src/schema/mod.rs
index b058060..4e68129 100644
--- a/lib/api-config/src/schema/mod.rs
+++ b/lib/api-config/src/schema/mod.rs
@@ -74,13 +74,12 @@ impl SchemaDriver for AppState {
         kind: impl AsRef<str> + Send + Sync,
         version: impl AsRef<str> + Send + Sync,
     ) -> Result<(), crate::ConfigurationError> {
-        // sqlx::query!("delete * from transaction_schema where type = $1 and version $2",
-        //     name.as_ref(),
-        //     version.as_ref(),
-        // )
-        // .execute(&self.database)
-        // .await
-        // .map_err(|e| e.into())
+        sqlx::query!("delete from transaction_schema where type = $1 and version = $2",
+            kind.as_ref(),
+            version.as_ref(),
+        )
+        .execute(&self.database)
+        .await?;
         Ok(())
     }
 }