add: api to get migrations

packages/apalis-sql/src/mysql.rs

@@ -48,11 +48,17 @@ impl<T> MysqlStorage<T> {
         Ok(Self::new(pool))
     }
 
-    /// Setup
+    /// Get mysql migrations without running them
+    #[cfg(feature = "migrate")]
+    pub fn migrations() -> sqlx::migrate::Migrator {
+        sqlx::migrate!("migrations/mysql")
+    }
+
+    /// Do migrations for mysql
     #[cfg(feature = "migrate")]
     pub async fn setup(&self) -> Result<(), sqlx::Error> {
         let pool = self.pool.clone();
-        sqlx::migrate!("migrations/mysql").run(&pool).await?;
+        Self::migrations().run(&pool).await?;
         Ok(())
     }
 

packages/apalis-sql/src/postgres.rs

@@ -62,11 +62,17 @@ impl<T> PostgresStorage<T> {
         Ok(Self::new(pool))
     }
 
+    /// Get postgres migrations without running them
+    #[cfg(feature = "migrate")]
+    pub fn migrations() -> sqlx::migrate::Migrator {
+        sqlx::migrate!("migrations/postgres")
+    }
+
     /// Do migrations for Postgres
     #[cfg(feature = "migrate")]
     pub async fn setup(&self) -> Result<(), sqlx::Error> {
         let pool = self.pool.clone();
-        sqlx::migrate!("migrations/postgres").run(&pool).await?;
+        Self::migrations().run(&pool).await?;
         Ok(())
     }
 

packages/apalis-sql/src/sqlite.rs

@@ -63,10 +63,16 @@ impl<T: Job> SqliteStorage<T> {
         sqlx::query("PRAGMA cache_size = 64000;")
             .execute(&pool)
             .await?;
-        sqlx::migrate!("migrations/sqlite").run(&pool).await?;
+        Self::migrations().run(&pool).await?;
         Ok(())
     }
 
+    /// Get sqlite migrations without running them
+    #[cfg(feature = "migrate")]
+    pub fn migrations() -> sqlx::migrate::Migrator {
+        sqlx::migrate!("migrations/sqlite")
+    }
+
     /// Keeps a storage notified that the worker is still alive manually
     pub async fn keep_alive_at<Service>(
         &mut self,