Skip to content

Commit

Permalink
Option to filter on migration state in info
Browse files Browse the repository at this point in the history
  • Loading branch information
Lyeeedar committed Nov 6, 2020
1 parent 90f7323 commit 54c40b3
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@

import org.flywaydb.commandline.ConsoleLog.Level;
import org.flywaydb.core.api.FlywayException;
import org.flywaydb.core.api.MigrationState;
import org.flywaydb.core.api.MigrationVersion;
import org.flywaydb.core.internal.util.StringUtils;

Expand Down Expand Up @@ -80,6 +81,7 @@ public static boolean isValid(String value) {
private static String INFO_UNTIL_DATE = "infoUntilDate";
private static String INFO_SINCE_VERSION = "infoSinceVersion";
private static String INFO_UNTIL_VERSION = "infoUntilVersion";
private static String INFO_OF_STATE = "infoOfState";

private static SimpleDateFormat DATE_FORMAT = new SimpleDateFormat("dd/MM/yyyy HH:mm");

Expand Down Expand Up @@ -179,7 +181,8 @@ private static boolean isConfigurationOptionIgnored(String configurationOptionNa
INFO_SINCE_DATE.equals(configurationOptionName) ||
INFO_UNTIL_DATE.equals(configurationOptionName) ||
INFO_SINCE_VERSION.equals(configurationOptionName) ||
INFO_UNTIL_VERSION.equals(configurationOptionName);
INFO_UNTIL_VERSION.equals(configurationOptionName) ||
INFO_OF_STATE.equals(configurationOptionName);
}

private static String getConfigurationOptionNameFromArg(String arg) {
Expand Down Expand Up @@ -280,6 +283,16 @@ MigrationVersion getInfoUntilVersion() {
return parseVersion(INFO_UNTIL_VERSION);
}

MigrationState getInfoOfState() {
String stateStr = getArgumentValue(INFO_OF_STATE, args);

if (!StringUtils.hasText(stateStr)) {
return null;
}

return MigrationState.valueOf(stateStr.toUpperCase(Locale.ENGLISH));
}

private MigrationVersion parseVersion(String argument) {
String versionStr = getArgumentValue(argument, args);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -285,6 +285,7 @@ private static OperationResultBase executeOperation(Flyway flyway, String operat




private static void printJson(CommandLineArguments commandLineArguments, OperationResult object) {
String json = convertObjectToJsonString(object);

Expand Down

0 comments on commit 54c40b3

Please sign in to comment.