Implement hasRevision

Author: owjs3901

Cargo.lock

@@ -66,6 +66,7 @@ describe('sqlite', async () => {
       }
 
       const hasRevision = await pool.hasRevision()
+      expect(hasRevision).toBe(false)
       if (!hasRevision) {
         await pool.setupRevision()
       }

__tests__/sql/index.test.ts

@@ -0,0 +1,8 @@
+[package]
+name = "database_strategy"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+sqlx = { version = "0.8" }
+async-trait = "0.1"

sql/core/database_strategy/Cargo.toml

@@ -0,0 +1,7 @@
+use async_trait::async_trait;
+use sqlx::{Any, Error, Pool};
+
+#[async_trait]
+pub trait DatabaseStrategy: Send + Sync {
+    async fn has_revision(&self, pool: &Pool<Any>) -> Result<bool, Error>;
+}

sql/core/database_strategy/src/lib.rs

@@ -0,0 +1,9 @@
+[package]
+name = "database_strategy_mysql"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+sqlx = { version = "0.8" }
+database_strategy = { path = "../database_strategy" }
+async-trait = "0.1"

sql/core/database_strategy_mysql/Cargo.toml

@@ -0,0 +1,21 @@
+use async_trait::async_trait;
+use database_strategy::DatabaseStrategy;
+use sqlx::Any;
+use sqlx::Error;
+use sqlx::Executor;
+use sqlx::Pool;
+use sqlx::Row;
+
+pub struct MysqlDatabaseStrategy;
+
+#[async_trait]
+impl DatabaseStrategy for MysqlDatabaseStrategy {
+    /// check to exists devup_revisions table
+    async fn has_revision(&self, pool: &Pool<Any>) -> Result<bool, Error> {
+        let query: sqlx::query::Query<'_, Any, sqlx::any::AnyArguments<'_>> = sqlx::query(
+            "SELECT COUNT(*) as count FROM information_schema.tables WHERE table_name = 'devup_revisions'",
+        );
+        let result = pool.fetch_one(query).await?;
+        Ok(result.try_get::<i32, usize>(0).unwrap_or(0) > 0)
+    }
+}

sql/core/database_strategy_mysql/src/lib.rs

@@ -0,0 +1,9 @@
+[package]
+name = "database_strategy_postgres"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+sqlx = { version = "0.8" }
+database_strategy = { path = "../database_strategy" }
+async-trait = "0.1"

sql/core/database_strategy_postgres/Cargo.toml

@@ -0,0 +1,21 @@
+use async_trait::async_trait;
+use database_strategy::DatabaseStrategy;
+use sqlx::Any;
+use sqlx::Error;
+use sqlx::Executor;
+use sqlx::Pool;
+use sqlx::Row;
+
+pub struct PostgresDatabaseStrategy;
+
+#[async_trait]
+impl DatabaseStrategy for PostgresDatabaseStrategy {
+    /// check to exists devup_revisions table
+    async fn has_revision(&self, pool: &Pool<Any>) -> Result<bool, Error> {
+        let query: sqlx::query::Query<'_, Any, sqlx::any::AnyArguments<'_>> = sqlx::query(
+            "SELECT COUNT(*) as count FROM information_schema.tables WHERE table_name = 'devup_revisions'",
+        );
+        let result = pool.fetch_one(query).await?;
+        Ok(result.try_get::<i32, usize>(0).unwrap_or(0) > 0)
+    }
+}

sql/core/database_strategy_postgres/src/lib.rs

@@ -0,0 +1,9 @@
+[package]
+name = "database_strategy_sqlite"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+sqlx = { version = "0.8" }
+database_strategy = { path = "../database_strategy" }
+async-trait = "0.1"

sql/core/database_strategy_sqlite/Cargo.toml

@@ -0,0 +1,21 @@
+use async_trait::async_trait;
+use database_strategy::DatabaseStrategy;
+use sqlx::Any;
+use sqlx::Error;
+use sqlx::Executor;
+use sqlx::Pool;
+use sqlx::Row;
+
+pub struct SqliteDatabaseStrategy;
+
+#[async_trait]
+impl DatabaseStrategy for SqliteDatabaseStrategy {
+    /// check to exists devup_revisions table
+    async fn has_revision(&self, pool: &Pool<Any>) -> Result<bool, Error> {
+        let query: sqlx::query::Query<'_, Any, sqlx::any::AnyArguments<'_>> = sqlx::query(
+            "SELECT COUNT(*) as count FROM sqlite_master WHERE type = 'table' AND name = 'devup_revisions'",
+        );
+        let result = pool.fetch_one(query).await?;
+        Ok(result.try_get::<i32, usize>(0).unwrap_or(0) > 0)
+    }
+}