Fix issue with parameters

cdapio · Sep 12, 2024 · 564cdf6 · 564cdf6
1 parent 1aaeed7
commit 564cdf6
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...torage-ext-spanner/src/main/java/io/cdap/cdap/storage/spanner/SpannerStructuredTable.java b/...torage-ext-spanner/src/main/java/io/cdap/cdap/storage/spanner/SpannerStructuredTable.java
@@ -465,18 +465,16 @@ private Statement getCountStatement(Collection<Range> ranges,
 
     if (whereClause != null) {
       builder.append(" WHERE " + whereClause);
-      parameters.forEach((name, value) -> builder.bind(name).to(value));
     }
     if (!filterIndexes.isEmpty()) {
       if (whereClause != null) {
         builder.append(" AND ");
       } else {
         builder.append(" WHERE ");
       }
-      parameters = new HashMap<>();
       builder.append(getIndexesFilterClause(filterIndexes, parameters));
-      parameters.forEach((name, value) -> builder.bind(name).to(value));
     }
+    parameters.forEach((name, value) -> builder.bind(name).to(value));
     LOG.trace("SQL statement: {}", builder.build().getSql());
     return builder.build();
   }