HOP-4555, HOP-4556

core/src/main/java/org/apache/hop/core/gui/plugin/tab/GuiTab.java

@@ -23,6 +23,10 @@
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
 
+/**
+ * The method annotated with this class is going to receive a single CTabFolder argument when called.
+ * The class is simply going to be created with an empty constructor, once for every tab in every viewer.
+ */
 @Documented
 @Retention(RetentionPolicy.RUNTIME)
 @Target({ElementType.FIELD, ElementType.METHOD})

plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/NeoExecutionInfoLocation.java

@@ -1621,4 +1621,22 @@ public String getConnectionName() {
   public void setConnectionName(String connectionName) {
     this.connectionName = connectionName;
   }
+
+  /**
+   * Gets driver
+   *
+   * @return value of driver
+   */
+  public Driver getDriver() {
+    return driver;
+  }
+
+  /**
+   * Gets session
+   *
+   * @return value of session
+   */
+  public Session getSession() {
+    return session;
+  }
 }

plugins/tech/neo4j/src/main/java/org/apache/hop/neo4j/execution/path/PathResult.java

@@ -0,0 +1,265 @@
+/*
+ * 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.hop.neo4j.execution.path;
+
+import org.apache.hop.core.Const;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+public class PathResult {
+
+  private String id;
+  private String name;
+  private String type;
+  private String copy;
+  private Date registrationDate;
+  private Boolean failed;
+
+  private List<List<PathResult>> shortestPaths;
+  private Boolean root;
+
+  public PathResult() {
+    shortestPaths = new ArrayList<>();
+  }
+
+  /**
+   * Gets id
+   *
+   * @return value of id
+   */
+  public String getId() {
+    return id;
+  }
+
+  /** @param id The id to set */
+  public void setId(String id) {
+    this.id = id;
+  }
+
+  /**
+   * Gets name
+   *
+   * @return value of name
+   */
+  public String getName() {
+    return name;
+  }
+
+  /** @param name The name to set */
+  public void setName(String name) {
+    this.name = name;
+  }
+
+  /**
+   * Gets type
+   *
+   * @return value of type
+   */
+  public String getType() {
+    return type;
+  }
+
+  /** @param type The type to set */
+  public void setType(String type) {
+    this.type = type;
+  }
+
+  /**
+   * Gets registrationDate
+   *
+   * @return value of registrationDate
+   */
+  public Date getRegistrationDate() {
+    return registrationDate;
+  }
+
+  /** @param registrationDate The registrationDate to set */
+  public void setRegistrationDate(Date registrationDate) {
+    this.registrationDate = registrationDate;
+  }
+
+
+  /**
+   * Gets root
+   *
+   * @return value of root
+   */
+  public Boolean getRoot() {
+    return root;
+  }
+
+  /**
+   * Gets copy
+   *
+   * @return value of copy
+   */
+  public String getCopy() {
+    return copy;
+  }
+
+  /**
+   * Sets copy
+   *
+   * @param copy value of copy
+   */
+  public void setCopy(String copy) {
+    this.copy = copy;
+  }
+
+  /**
+   * Gets failed
+   *
+   * @return value of failed
+   */
+  public Boolean getFailed() {
+    return failed;
+  }
+
+  /**
+   * Sets failed
+   *
+   * @param failed value of failed
+   */
+  public void setFailed(Boolean failed) {
+    this.failed = failed;
+  }
+
+  /**
+   * Gets shortestPaths
+   *
+   * @return value of shortestPaths
+   */
+  public List<List<PathResult>> getShortestPaths() {
+    return shortestPaths;
+  }
+
+  /** @param shortestPaths The shortestPaths to set */
+  public void setShortestPaths(List<List<PathResult>> shortestPaths) {
+    this.shortestPaths = shortestPaths;
+  }
+
+  public void setRoot(Boolean root) {
+    this.root = root;
+  }
+
+  public Boolean isRoot() {
+    return root;
+  }
+
+  public String getExecutionInfoCommand() {
+    StringBuilder cmd = new StringBuilder();
+
+    cmd.append(
+            "MATCH(ex:Execution { name : \""
+                + getName()
+                + "\", type : \""
+                + getType()
+                + "\", id : \""
+                + getId()
+                + "\"}) ")
+        .append(Const.CR);
+    cmd.append("RETURN ex ").append(Const.CR);
+
+    return cmd.toString();
+  }
+
+  public String getErrorPathCommand() {
+    StringBuilder cmd = new StringBuilder();
+
+    cmd.append(
+            "MATCH(top:Execution { name : \""
+                + getName()
+                + "\", type : \""
+                + getType()
+                + "\", id : \""
+                + getId()
+                + "\"})-[rel:EXECUTES*]-(err:Execution) ")
+        .append(Const.CR);
+    cmd.append("   , p=shortestpath((top)-[:EXECUTES*]-(err)) ").append(Const.CR);
+    cmd.append("WHERE top.registrationDate IS NOT NULL ").append(Const.CR);
+    cmd.append("  AND err.errors > 0 ").append(Const.CR);
+    cmd.append("  AND size((err)-[:EXECUTES]->())=0 ").append(Const.CR);
+    cmd.append("RETURN p ").append(Const.CR);
+    cmd.append("ORDER BY size(RELATIONSHIPS(p)) DESC ").append(Const.CR);
+    cmd.append("LIMIT 5").append(Const.CR);
+
+    return cmd.toString();
+  }
+
+  public String getErrorPathWithMetadataCommand(int pathIndex) {
+    StringBuilder cmd = new StringBuilder();
+
+    cmd.append(
+            "MATCH(top:Execution { name : \""
+                + getName()
+                + "\", type : \""
+                + getType()
+                + "\", id : \""
+                + getId()
+                + "\"})-[rel:EXECUTES*]-(err:Execution) ")
+        .append(Const.CR);
+    cmd.append("   , p=shortestpath((top)-[:EXECUTES*]-(err)) ").append(Const.CR);
+    cmd.append("WHERE top.registrationDate IS NOT NULL ").append(Const.CR);
+    cmd.append("  AND err.errors > 0 ").append(Const.CR);
+    cmd.append("  AND size((err)-[:EXECUTES]->())=0 ").append(Const.CR);
+
+    // Now link the metadata...
+    //
+    StringBuilder returns = new StringBuilder("RETURN p");
+    int matchIndex = 1;
+
+    List<PathResult> shortestPath = getShortestPaths().get(pathIndex);
+
+    for (PathResult result : shortestPath) {
+      String metaLabel = null;
+      if (result.getType().equals("PIPELINE")) {
+        metaLabel = "Pipeline";
+      } else if (result.getType().equals("WORKFLOW")) {
+        metaLabel = "Workflow";
+      } else if (result.getType().equals("ACTION")) {
+        metaLabel = "Action";
+      } else if (result.getType().equals("TRANSFORM")) {
+        metaLabel = "Transform";
+      }
+      if (metaLabel != null) {
+        cmd.append(
+                "MATCH (:Execution { type : \""
+                    + result.getType()
+                    + "\", id : \""
+                    + result.getId()
+                    + "\"})-[metaRel"
+                    + matchIndex
+                    + "]->(meta"
+                    + matchIndex
+                    + ":"
+                    + metaLabel
+                    + ") ")
+            .append(Const.CR);
+        returns.append(", metaRel" + matchIndex + ", meta" + matchIndex);
+        matchIndex++;
+      }
+    }
+    cmd.append(returns.toString()).append(" ").append(Const.CR);
+    cmd.append("LIMIT 1 ").append(Const.CR);
+
+    return cmd.toString();
+  }
+}