CODEWITHSUNDEEP
luaudfaerospike
Sandeep B
Sandeep B

Reputation: 775

Aerospike: How to perform IN query on PK

How to perform (sql like) IN queries in aerospike. Do we need an UDF for this?

Something like this: Select * from ns.set where PK in (1,2,3)

If this requires a UDF how to go about it as the UDF is executed on a key:

EXECUTE <module>.<function>(<args>) ON <ns>[.<set>] WHERE PK = <key>

Upvotes: 3

Views: 563

Answers (2)

Ronen Botzer
Ronen Botzer

Reputation: 7117

You're basically looking at retrieving records by a list of keys. This is a batch-read operation in Aerospike. Every language client for Aerospike should have this capability.

For example, in the Python client this is the Client.get_many method:

from __future__ import print_function
import aerospike
from aerospike.exception import AerospikeError
import sys

config = { 'hosts': [('127.0.0.1', 3000)] }
client = aerospike.client(config).connect()

try:
    # assume the fourth key has no matching record
    keys = [
      ('test', 'demo', '1'),
      ('test', 'demo', '2'),
      ('test', 'demo', '3'),
      ('test', 'demo', '4')
    ]
    records = client.get_many(keys)
    print records
except AerospikeError as e:
    print("Error: {0} [{1}]".format(e.msg, e.code))
    sys.exit(1)
finally:
    client.close()

Similarly, in the Java client the AerospikeClient.get() method can take a list of keys.

Upvotes: 2

pgupta
pgupta

Reputation: 5415

In Ver 3.12.1+, you can run such queries if you store your Primary Key in a bin and then run predicate filtering on that bin. See http://www.aerospike.com/docs/guide/predicate.html

Aerospike by default does not store the PK in its raw string or numeric form as you assign it. It stores a RIPEMD160 hash of the PK+Set name.

Upvotes: 2

Related Questions