prepare options in IndexQueryHandler#processStatement

instaclustr · Dec 5, 2024 · 6cbf40f · 6cbf40f
1 parent 387b4f6
commit 6cbf40f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/plugin/src/main/scala/com/stratio/cassandra/lucene/IndexQueryHandler.scala b/plugin/src/main/scala/com/stratio/cassandra/lucene/IndexQueryHandler.scala
@@ -97,6 +97,10 @@ class IndexQueryHandler extends QueryHandler with Logging {
       options: QueryOptions,
       queryStartNanoTime: Long): ResultMessage = {
 
+    options.prepare(statement.getBindVariables)
+    if (statement.getBindVariables.size != options.getValues.size) throw new InvalidRequestException("Invalid amount of bind variables")
+    if (!state.getClientState.isInternal) QueryProcessor.metrics.regularStatementsExecuted.inc()
+
     // Intercept Lucene index searches
     statement match {
       case select: SelectStatement =>