add liquibase flow and flow.validate goals to maven plugin (DAT-10576)

liquibase-core/src/main/java/liquibase/integration/commandline/Main.java

@@ -291,8 +291,10 @@ public Integer run() throws Exception {
                         java.util.logging.Logger liquibaseLogger = java.util.logging.Logger.getLogger("liquibase");
                         liquibaseLogger.setParent(rootLogger);
 
-                        final JavaLogService logService = (JavaLogService) Scope.getCurrentScope().get(Scope.Attr.logService, LogService.class);
-                        logService.setParent(liquibaseLogger);
+                        LogService logService = Scope.getCurrentScope().get(Scope.Attr.logService, LogService.class);
+                        if (logService instanceof JavaLogService) {
+                            ((JavaLogService) logService).setParent(liquibaseLogger);
+                        }
 
                         if (main.logLevel == null) {
                             String defaultLogLevel = System.getProperty("liquibase.log.level");

liquibase-maven-plugin/src/main/java/org/liquibase/maven/plugins/AbstractLiquibaseFlowMojo.java

@@ -0,0 +1,50 @@
+package org.liquibase.maven.plugins;
+
+import liquibase.Liquibase;
+import liquibase.command.CommandScope;
+import liquibase.exception.CommandExecutionException;
+import liquibase.exception.LiquibaseException;
+import org.liquibase.maven.property.PropertyElement;
+
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+
+public abstract class AbstractLiquibaseFlowMojo extends AbstractLiquibaseMojo {
+    /**
+     * Specifies the <i>flowFile</i> to use. If not specified, the default
+     * checks will be used and no file will be created.
+     *
+     * @parameter property="liquibase.flowFile"
+     */
+    @PropertyElement
+    protected String flowFile;
+
+    /**
+     * @parameter property="liquibase.outputFile"
+     */
+    @PropertyElement
+    protected File outputFile;
+
+    @Override
+    public boolean databaseConnectionRequired() {
+        return false;
+    }
+
+    @Override
+    protected void performLiquibaseTask(Liquibase liquibase) throws LiquibaseException {
+        CommandScope liquibaseCommand = new CommandScope(getCommandName());
+        liquibaseCommand.addArgumentValue("flowFile", flowFile);
+        liquibaseCommand.addArgumentValue("flowIntegration", "maven");
+        if (outputFile != null) {
+            try {
+                liquibaseCommand.setOutput(new FileOutputStream(outputFile));
+            } catch (FileNotFoundException e) {
+                throw new CommandExecutionException(e);
+            }
+        }
+        liquibaseCommand.execute();
+    }
+
+    public abstract String[] getCommandName();
+}

liquibase-maven-plugin/src/main/java/org/liquibase/maven/plugins/LiquibaseFlowMojo.java

@@ -0,0 +1,14 @@
+package org.liquibase.maven.plugins;
+
+/**
+ * Run a series of commands contained in one or more stages, as configured in a liquibase flow-file.
+ *
+ * @goal flow
+ */
+public class LiquibaseFlowMojo extends AbstractLiquibaseFlowMojo {
+
+    @Override
+    public String[] getCommandName() {
+        return new String[]{"flow"};
+    }
+}

liquibase-maven-plugin/src/main/java/org/liquibase/maven/plugins/LiquibaseFlowValidateMojo.java

@@ -0,0 +1,13 @@
+package org.liquibase.maven.plugins;
+
+/**
+ * Validate a series of commands contained in one or more stages, as configured in a liquibase flow-file.
+ *
+ * @goal flow.validate
+ */
+public class LiquibaseFlowValidateMojo extends AbstractLiquibaseFlowMojo{
+    @Override
+    public String[] getCommandName() {
+        return new String[]{"flow", "validate"};
+    }
+}