Create ExecuteProcessReporter (apache#9674)

shardingsphere-governance/shardingsphere-governance-context/pom.xml

@@ -34,6 +34,11 @@
             <artifactId>shardingsphere-infra-context</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.shardingsphere</groupId>
+            <artifactId>shardingsphere-infra-executor</artifactId>
+            <version>${project.version}</version>
+        </dependency>
         <dependency>
             <groupId>org.apache.shardingsphere</groupId>
             <artifactId>shardingsphere-governance-core</artifactId>

shardingsphere-governance/shardingsphere-governance-context/src/main/java/org/apache/shardingsphere/governance/context/process/GovernanceExecuteProcessReporter.java

@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.shardingsphere.governance.context.process;
+
+import org.apache.shardingsphere.infra.binder.statement.SQLStatementContext;
+import org.apache.shardingsphere.infra.executor.kernel.model.ExecutionGroupContext;
+import org.apache.shardingsphere.infra.executor.sql.execute.engine.SQLExecutionUnit;
+import org.apache.shardingsphere.infra.executor.sql.process.model.ExecuteProcessStatus;
+import org.apache.shardingsphere.infra.executor.sql.process.spi.ExecuteProcessReporter;
+
+/**
+ * Governance execute process reporter.
+ */
+public final class GovernanceExecuteProcessReporter implements ExecuteProcessReporter {
+
+    @Override
+    public void report(final SQLStatementContext<?> context, final ExecutionGroupContext<SQLExecutionUnit> executionGroupContext, final ExecuteProcessStatus status) {
+        // TODO :Call API of configCenter
+    }
+
+    @Override
+    public void report(final String executionID, final SQLExecutionUnit executionUnit, final ExecuteProcessStatus status) {
+        // TODO :Call API of configCenter
+    }
+}

shardingsphere-governance/shardingsphere-governance-context/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.executor.sql.process.spi.ExecuteProcessReporter

@@ -0,0 +1,18 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+org.apache.shardingsphere.governance.context.process.GovernanceExecuteProcessReporter

shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/process/ExecuteProcessEngine.java

@@ -20,39 +20,48 @@
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;
 import org.apache.shardingsphere.infra.binder.statement.SQLStatementContext;
-import org.apache.shardingsphere.infra.eventbus.ShardingSphereEventBus;
 import org.apache.shardingsphere.infra.executor.kernel.model.ExecutionGroupContext;
 import org.apache.shardingsphere.infra.executor.sql.execute.engine.SQLExecutionUnit;
-import org.apache.shardingsphere.infra.executor.sql.process.event.ExecuteProcessCreatedEvent;
-import org.apache.shardingsphere.infra.executor.sql.process.event.ExecuteProcessUnitCreatedEvent;
 import org.apache.shardingsphere.infra.executor.sql.process.model.ExecuteProcessStatus;
+import org.apache.shardingsphere.infra.executor.sql.process.spi.ExecuteProcessReporter;
+import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
+
+import java.util.Collection;
 
 /**
  * Execute process engine.
  */
 @NoArgsConstructor(access = AccessLevel.PRIVATE)
 public final class ExecuteProcessEngine {
 
+    private static final Collection<ExecuteProcessReporter> HANDLERS;
+
+    static {
+        ShardingSphereServiceLoader.register(ExecuteProcessReporter.class);
+        HANDLERS = ShardingSphereServiceLoader.newServiceInstances(ExecuteProcessReporter.class);
+    }
+
     /**
-     * Submit.
+     * Initialize.
      *
      * @param context context
      * @param executionGroupContext execution group context
      */
-    public static void submit(final SQLStatementContext<?> context, final ExecutionGroupContext<SQLExecutionUnit> executionGroupContext) {
-        if (ExecuteProcessStrategyEvaluator.evaluate(context, executionGroupContext)) {
-            ShardingSphereEventBus.getInstance().post(new ExecuteProcessCreatedEvent(executionGroupContext));
+    public static void initialize(final SQLStatementContext<?> context, final ExecutionGroupContext<SQLExecutionUnit> executionGroupContext) {
+        if (!HANDLERS.isEmpty() && ExecuteProcessStrategyEvaluator.evaluate(context, executionGroupContext)) {
+            HANDLERS.iterator().next().report(context, executionGroupContext, ExecuteProcessStatus.DOING);
         }
     }
 
     /**
-     * Submit.
+     * Complete.
      *
      * @param executionID execution ID
      * @param executionUnit execution unit
-     * @param status status
      */
-    public static void submit(final String executionID, final SQLExecutionUnit executionUnit, final ExecuteProcessStatus status) {
-        ShardingSphereEventBus.getInstance().post(new ExecuteProcessUnitCreatedEvent(executionID, executionUnit, status));
+    public static void complete(final String executionID, final SQLExecutionUnit executionUnit) {
+        if (!HANDLERS.isEmpty()) {
+            HANDLERS.iterator().next().report(executionID, executionUnit, ExecuteProcessStatus.DONE);
+        }
     }
 }

shardingsphere-infra/shardingsphere-infra-executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/process/spi/ExecuteProcessReporter.java

@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.shardingsphere.infra.executor.sql.process.spi;
+
+import org.apache.shardingsphere.infra.binder.statement.SQLStatementContext;
+import org.apache.shardingsphere.infra.executor.kernel.model.ExecutionGroupContext;
+import org.apache.shardingsphere.infra.executor.sql.execute.engine.SQLExecutionUnit;
+import org.apache.shardingsphere.infra.executor.sql.process.model.ExecuteProcessStatus;
+
+/**
+ * Execute process report.
+ */
+public interface ExecuteProcessReporter {
+
+    /**
+     * Report the summary of this task.
+     * @param context context
+     * @param executionGroupContext execution group context
+     * @param status status
+     */
+    void report(SQLStatementContext<?> context, ExecutionGroupContext<SQLExecutionUnit> executionGroupContext, ExecuteProcessStatus status);
+
+    /**
+     * Report a unit of this task.
+     * @param executionID execution ID
+     * @param executionUnit execution unit
+     * @param status status
+     */
+    void report(String executionID, SQLExecutionUnit executionUnit, ExecuteProcessStatus status);
+}