FMWK-274 Set bin names in secondary index query (#48)

aerospike · Dec 5, 2023 · dd2ff23 · dd2ff23
1 parent 018e1b0
commit dd2ff23
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/main/java/com/aerospike/jdbc/async/SecondaryIndexQueryHandler.java b/src/main/java/com/aerospike/jdbc/async/SecondaryIndexQueryHandler.java
@@ -32,10 +32,15 @@ public RecordSet execute(QueryPolicy queryPolicy, AerospikeQuery query,
         statement.setIndexName(secondaryIndex.getIndexName());
         statement.setNamespace(query.getSchema());
         statement.setSetName(query.getTable());
+        statement.setBinNames(query.columnBins());
+
         if (Objects.nonNull(query.getPredicate())) {
             query.getPredicate().toFilter(secondaryIndex.getBinName()).ifPresent(statement::setFilter);
         }
 
+        if (query.isPrimaryKeyOnly()) {
+            queryPolicy.includeBinData = false;
+        }
         client.query(EventLoopProvider.getEventLoop(), listener, queryPolicy, statement);
 
         return listener.getRecordSet();