Merge pull request #16563 from tioback/feature/16561

Adds `cleanDisabled` to Flyway configuration
quarkusio · Apr 20, 2021 · 98bf638 · 98bf638
2 parents 6978921 + 9aa6d6f
commit 98bf638
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 0 deletions.
diff --git a/extensions/flyway/runtime/src/main/java/io/quarkus/flyway/runtime/FlywayCreator.java b/extensions/flyway/runtime/src/main/java/io/quarkus/flyway/runtime/FlywayCreator.java
@@ -51,6 +51,7 @@ public Flyway createFlyway(DataSource dataSource) {
         if (flywayRuntimeConfig.repeatableSqlMigrationPrefix.isPresent()) {
             configure.repeatableSqlMigrationPrefix(flywayRuntimeConfig.repeatableSqlMigrationPrefix.get());
         }
+        configure.cleanDisabled(flywayRuntimeConfig.cleanDisabled);
         configure.baselineOnMigrate(flywayRuntimeConfig.baselineOnMigrate);
         configure.validateOnMigrate(flywayRuntimeConfig.validateOnMigrate);
         configure.ignoreMissingMigrations(flywayRuntimeConfig.ignoreMissingMigrations);

diff --git a/...flyway/runtime/src/main/java/io/quarkus/flyway/runtime/FlywayDataSourceRuntimeConfig.java b/...flyway/runtime/src/main/java/io/quarkus/flyway/runtime/FlywayDataSourceRuntimeConfig.java
@@ -71,6 +71,12 @@ public static final FlywayDataSourceRuntimeConfig defaultConfig() {
     @ConfigItem
     public boolean cleanAtStart;
 
+    /**
+     * true to prevent Flyway clean operations, false otherwise.
+     */
+    @ConfigItem
+    public boolean cleanDisabled;
+
     /**
      * true to execute Flyway automatically when the application starts, false otherwise.
      *

diff --git a/extensions/flyway/runtime/src/test/java/io/quarkus/flyway/runtime/FlywayCreatorTest.java b/extensions/flyway/runtime/src/test/java/io/quarkus/flyway/runtime/FlywayCreatorTest.java
@@ -167,6 +167,22 @@ void testValidateOnMigrate() {
         assertTrue(runtimeConfig.validateOnMigrate);
     }
 
+    @Test
+    @DisplayName("clean disabled default matches to false")
+    void testCleanDisabled() {
+        creator = new FlywayCreator(runtimeConfig, buildConfig);
+        assertEquals(runtimeConfig.cleanDisabled, createdFlywayConfig().isCleanDisabled());
+        assertFalse(runtimeConfig.cleanDisabled);
+
+        runtimeConfig.cleanDisabled = false;
+        creator = new FlywayCreator(runtimeConfig, buildConfig);
+        assertFalse(createdFlywayConfig().isCleanDisabled());
+
+        runtimeConfig.cleanDisabled = true;
+        creator = new FlywayCreator(runtimeConfig, buildConfig);
+        assertTrue(createdFlywayConfig().isCleanDisabled());
+    }
+
     @Test
     @DisplayName("outOfOrder is correctly set")
     void testOutOfOrder() {