[hotfix] Fix query result response after database uppgrade

apache · Feb 11, 2023 · 649f666 · 649f666
1 parent 8351fa0
commit 649f666
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/...lorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/DataExplorerQueryV4.java b/...lorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/DataExplorerQueryV4.java
@@ -169,7 +169,7 @@ protected SpQueryResult postQuery(QueryResult queryResult,
                                     boolean ignoreMissingValues) throws RuntimeException {
     SpQueryResult result = new SpQueryResult();
 
-    if (queryResult.getResults().get(0).getSeries() != null) {
+    if (hasResult(queryResult)) {
       result.setTotal(queryResult.getResults().get(0).getSeries().size());
       queryResult.getResults().get(0).getSeries().forEach(rs -> {
         DataSeries series = convertResult(rs, ignoreMissingValues);
@@ -185,6 +185,12 @@ protected SpQueryResult postQuery(QueryResult queryResult,
     return result;
   }
 
+  private boolean hasResult(QueryResult queryResult) {
+    return queryResult.getResults() != null
+        && queryResult.getResults().size() > 0
+        && queryResult.getResults().get(0).getSeries() != null;
+  }
+
   protected List<QueryElement<?>> getQueryElements() {
     List<QueryElement<?>> queryElements = new ArrayList<>();