Upgrade to Flyway 9.0.1

See gh-31723

Author: vpavic

spring-boot-project/spring-boot-actuator-autoconfigure/src/test/java/org/springframework/boot/actuate/autoconfigure/endpoint/web/documentation/FlywayEndpointDocumentationTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2012-2019 the original author or authors.
+ * Copyright 2012-2022 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -22,7 +22,6 @@
 import javax.sql.DataSource;
 
 import org.flywaydb.core.api.MigrationState;
-import org.flywaydb.core.api.MigrationType;
 import org.junit.jupiter.api.Test;
 
 import org.springframework.boot.actuate.flyway.FlywayEndpoint;
@@ -77,10 +76,8 @@ private List<FieldDescriptor> migrationFieldDescriptors() {
 						.optional(),
 				fieldWithPath("state")
 						.description("State of the migration. (" + describeEnumValues(MigrationState.class) + ")"),
-				fieldWithPath("type")
-						.description("Type of the migration. (" + describeEnumValues(MigrationType.class) + ")"),
-				fieldWithPath("version").description("Version of the database after applying the migration, if any.")
-						.optional());
+				fieldWithPath("type").description("Type of the migration."), fieldWithPath("version")
+						.description("Version of the database after applying the migration, if any.").optional());
 	}
 
 	@Configuration(proxyBeanMethods = false)

spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/flyway/FlywayEndpoint.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2012-2019 the original author or authors.
+ * Copyright 2012-2022 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -27,7 +27,6 @@
 import org.flywaydb.core.Flyway;
 import org.flywaydb.core.api.MigrationInfo;
 import org.flywaydb.core.api.MigrationState;
-import org.flywaydb.core.api.MigrationType;
 
 import org.springframework.boot.actuate.endpoint.annotation.Endpoint;
 import org.springframework.boot.actuate.endpoint.annotation.ReadOperation;
@@ -136,7 +135,7 @@ public List<FlywayMigration> getMigrations() {
 	 */
 	public static final class FlywayMigration {
 
-		private final MigrationType type;
+		private final String type;
 
 		private final Integer checksum;
 
@@ -157,7 +156,7 @@ public static final class FlywayMigration {
 		private final Integer executionTime;
 
 		private FlywayMigration(MigrationInfo info) {
-			this.type = info.getType();
+			this.type = info.getType().name();
 			this.checksum = info.getChecksum();
 			this.version = nullSafeToString(info.getVersion());
 			this.description = info.getDescription();
@@ -177,7 +176,7 @@ private Instant nullSafeToInstant(Date date) {
 			return (date != null) ? Instant.ofEpochMilli(date.getTime()) : null;
 		}
 
-		public MigrationType getType() {
+		public String getType() {
 			return this.type;
 		}
 

spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/flyway/FlywayEndpointTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2012-2019 the original author or authors.
+ * Copyright 2012-2022 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -62,7 +62,7 @@ void whenFlywayHasBeenBaselinedFlywayReportIsProduced() {
 					Map<String, FlywayDescriptor> flywayBeans = context.getBean(FlywayEndpoint.class).flywayBeans()
 							.getContexts().get(context.getId()).getFlywayBeans();
 					assertThat(flywayBeans).hasSize(1);
-					assertThat(flywayBeans.values().iterator().next().getMigrations()).hasSize(3);
+					assertThat(flywayBeans.values().iterator().next().getMigrations()).hasSize(4);
 				});
 	}
 

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/flyway/FlywayAutoConfiguration.java

@@ -32,7 +32,6 @@
 import org.flywaydb.core.api.callback.Callback;
 import org.flywaydb.core.api.configuration.FluentConfiguration;
 import org.flywaydb.core.api.migration.JavaMigration;
-import org.flywaydb.core.internal.plugin.PluginRegister;
 import org.flywaydb.database.sqlserver.SQLServerConfigurationExtension;
 
 import org.springframework.beans.factory.ObjectProvider;
@@ -202,7 +201,6 @@ private void configureProperties(FluentConfiguration configuration, FlywayProper
 			map.from(properties.isCleanDisabled()).to(configuration::cleanDisabled);
 			map.from(properties.isCleanOnValidationError()).to(configuration::cleanOnValidationError);
 			map.from(properties.isGroup()).to(configuration::group);
-			configureIgnoredMigrations(configuration, properties, map);
 			map.from(properties.isMixed()).to(configuration::mixed);
 			map.from(properties.isOutOfOrder()).to(configuration::outOfOrder);
 			map.from(properties.isSkipDefaultCallbacks()).to(configuration::skipDefaultCallbacks);
@@ -242,7 +240,8 @@ private void configureProperties(FluentConfiguration configuration, FlywayProper
 			map.from(properties.getOutputQueryResults())
 					.to((outputQueryResults) -> configuration.outputQueryResults(outputQueryResults));
 			map.from(properties.getSqlServerKerberosLoginFile()).whenNonNull()
-					.to(this::configureSqlServerKerberosLoginFile);
+					.to((sqlServerKerberosLoginFile) -> configureSqlServerKerberosLoginFile(configuration,
+							sqlServerKerberosLoginFile));
 			// No method reference for compatibility with Flyway 6.x
 			map.from(properties.getSkipExecutingMigrations())
 					.to((skipExecutingMigrations) -> configuration.skipExecutingMigrations(skipExecutingMigrations));
@@ -253,18 +252,6 @@ private void configureProperties(FluentConfiguration configuration, FlywayProper
 			// No method reference for compatibility with Flyway version < 7.9
 			map.from(properties.getDetectEncoding())
 					.to((detectEncoding) -> configuration.detectEncoding(detectEncoding));
-			// No method reference for compatibility with Flyway version < 8.0
-			map.from(properties.getBaselineMigrationPrefix())
-					.to((baselineMigrationPrefix) -> configuration.baselineMigrationPrefix(baselineMigrationPrefix));
-		}
-
-		@SuppressWarnings("deprecation")
-		private void configureIgnoredMigrations(FluentConfiguration configuration, FlywayProperties properties,
-				PropertyMapper map) {
-			map.from(properties.isIgnoreMissingMigrations()).to(configuration::ignoreMissingMigrations);
-			map.from(properties.isIgnoreIgnoredMigrations()).to(configuration::ignoreIgnoredMigrations);
-			map.from(properties.isIgnorePendingMigrations()).to(configuration::ignorePendingMigrations);
-			map.from(properties.isIgnoreFutureMigrations()).to(configuration::ignoreFutureMigrations);
 		}
 
 		private void configureFailOnMissingLocations(FluentConfiguration configuration,
@@ -286,9 +273,11 @@ private void configureCreateSchemas(FluentConfiguration configuration, boolean c
 			}
 		}
 
-		private void configureSqlServerKerberosLoginFile(String sqlServerKerberosLoginFile) {
-			SQLServerConfigurationExtension sqlServerConfigurationExtension = PluginRegister
+		private void configureSqlServerKerberosLoginFile(FluentConfiguration configuration,
+				String sqlServerKerberosLoginFile) {
+			SQLServerConfigurationExtension sqlServerConfigurationExtension = configuration.getPluginRegister()
 					.getPlugin(SQLServerConfigurationExtension.class);
+			Assert.state(sqlServerConfigurationExtension != null, "Flyway SQL Server extension missing");
 			sqlServerConfigurationExtension.setKerberosLoginFile(sqlServerKerberosLoginFile);
 		}
 

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/flyway/FlywayProperties.java

@@ -28,7 +28,6 @@
 import java.util.Map;
 
 import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.boot.context.properties.DeprecatedConfigurationProperty;
 import org.springframework.boot.convert.DurationUnit;
 
 /**
@@ -209,7 +208,7 @@ public class FlywayProperties {
 	/**
 	 * Whether to disable cleaning of the database.
 	 */
-	private boolean cleanDisabled;
+	private boolean cleanDisabled = true;
 
 	/**
 	 * Whether to automatically call clean when a validation error occurs.
@@ -222,30 +221,6 @@ public class FlywayProperties {
 	 */
 	private boolean group;
 
-	/**
-	 * Whether to ignore missing migrations when reading the schema history table.
-	 */
-	@Deprecated
-	private boolean ignoreMissingMigrations;
-
-	/**
-	 * Whether to ignore ignored migrations when reading the schema history table.
-	 */
-	@Deprecated
-	private boolean ignoreIgnoredMigrations;
-
-	/**
-	 * Whether to ignore pending migrations when reading the schema history table.
-	 */
-	@Deprecated
-	private boolean ignorePendingMigrations;
-
-	/**
-	 * Whether to ignore future migrations when reading the schema history table.
-	 */
-	@Deprecated
-	private boolean ignoreFutureMigrations = true;
-
 	/**
 	 * Whether to allow mixing transactional and non-transactional statements within the
 	 * same migration.
@@ -377,11 +352,6 @@ public class FlywayProperties {
 	 */
 	private Boolean detectEncoding;
 
-	/**
-	 * Filename prefix for baseline migrations. Requires Flyway Teams.
-	 */
-	private String baselineMigrationPrefix;
-
 	/**
 	 * Prefix of placeholders in migration scripts.
 	 */
@@ -664,50 +634,6 @@ public void setGroup(boolean group) {
 		this.group = group;
 	}
 
-	@Deprecated
-	@DeprecatedConfigurationProperty(replacement = "spring.flyway.ignore-migration-patterns")
-	public boolean isIgnoreMissingMigrations() {
-		return this.ignoreMissingMigrations;
-	}
-
-	@Deprecated
-	public void setIgnoreMissingMigrations(boolean ignoreMissingMigrations) {
-		this.ignoreMissingMigrations = ignoreMissingMigrations;
-	}
-
-	@Deprecated
-	@DeprecatedConfigurationProperty(replacement = "spring.flyway.ignore-migration-patterns")
-	public boolean isIgnoreIgnoredMigrations() {
-		return this.ignoreIgnoredMigrations;
-	}
-
-	@Deprecated
-	public void setIgnoreIgnoredMigrations(boolean ignoreIgnoredMigrations) {
-		this.ignoreIgnoredMigrations = ignoreIgnoredMigrations;
-	}
-
-	@Deprecated
-	@DeprecatedConfigurationProperty(replacement = "spring.flyway.ignore-migration-patterns")
-	public boolean isIgnorePendingMigrations() {
-		return this.ignorePendingMigrations;
-	}
-
-	@Deprecated
-	public void setIgnorePendingMigrations(boolean ignorePendingMigrations) {
-		this.ignorePendingMigrations = ignorePendingMigrations;
-	}
-
-	@Deprecated
-	@DeprecatedConfigurationProperty(replacement = "spring.flyway.ignore-migration-patterns")
-	public boolean isIgnoreFutureMigrations() {
-		return this.ignoreFutureMigrations;
-	}
-
-	@Deprecated
-	public void setIgnoreFutureMigrations(boolean ignoreFutureMigrations) {
-		this.ignoreFutureMigrations = ignoreFutureMigrations;
-	}
-
 	public boolean isMixed() {
 		return this.mixed;
 	}
@@ -860,17 +786,6 @@ public void setOracleKerberosCacheFile(String oracleKerberosCacheFile) {
 		this.oracleKerberosCacheFile = oracleKerberosCacheFile;
 	}
 
-	@DeprecatedConfigurationProperty(replacement = "spring.flyway.kerberos-config-file")
-	@Deprecated
-	public String getOracleKerberosConfigFile() {
-		return getKerberosConfigFile();
-	}
-
-	@Deprecated
-	public void setOracleKerberosConfigFile(String oracleKerberosConfigFile) {
-		setKerberosConfigFile(oracleKerberosConfigFile);
-	}
-
 	public Boolean getOutputQueryResults() {
 		return this.outputQueryResults;
 	}
@@ -911,14 +826,6 @@ public void setDetectEncoding(final Boolean detectEncoding) {
 		this.detectEncoding = detectEncoding;
 	}
 
-	public String getBaselineMigrationPrefix() {
-		return this.baselineMigrationPrefix;
-	}
-
-	public void setBaselineMigrationPrefix(String baselineMigrationPrefix) {
-		this.baselineMigrationPrefix = baselineMigrationPrefix;
-	}
-
 	public String getScriptPlaceholderPrefix() {
 		return this.scriptPlaceholderPrefix;
 	}

spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/flyway/Flyway5xAutoConfigurationTests.java

@@ -103,11 +103,6 @@ public Integer getChecksum() {
 			return 1;
 		}
 
-		@Override
-		public boolean isUndo() {
-			return false;
-		}
-
 		@Override
 		public boolean canExecuteInTransaction() {
 			return true;
@@ -118,11 +113,6 @@ public void migrate(org.flywaydb.core.api.migration.Context context) {
 
 		}
 
-		@Override
-		public boolean isBaselineMigration() {
-			return false;
-		}
-
 	}
 
 }