Primary index

The following code example demonstrates a primary index query with the PHP client.

<?php
 
use Aerospike\Client;
use Aerospike\WritePolicy;
use Aerospike\ScanPolicy;
use Aerospike\Bin;
use Aerospike\Key;
use Aerospike\PartitionFilter;
 
 
$socket = "/tmp/asld_grpc.sock";
// Establish connection to Aerospike server
$client = Client::connect($socket);
 
// Define namespace and set
$namespace = "test";
$set = "users";
 
// Define bins (attributes) for user data
$userBins = [
 new Bin("username", "john_doe"),
 new Bin("email", "john.doe@example.com"),
 new Bin("age", 30)
];
 
// Define write policy for adding data
$writePolicy = new WritePolicy();
$writePolicy->sendKey = true; // Ensure server returns the key upon write
 
// Add sample user data to the server
$userKeys = [];
for ($i = 0; $i < 5; $i++) {
 $key = new Key($namespace, $set, "user_" . $i);
 $client->put($writePolicy, $key, $userBins);
 $userKeys[] = $key; // Store keys for later retrieval
}
 
// Define bins to retrieve during scan
$scanBins = ["username", "email", "age"];
 
// Define scan policy
$scanPolicy = new ScanPolicy();
$pf = PartitionFilter::all();
 
// Perform scan
$recordSet = $client->scan($scanPolicy, $pf, $namespace, $set, $scanBins);
 
// Iterate over scan results
while ($record = $recordSet->next()) {
 // Access bin values of each record
 $username = $record->bins["username"];
 $email = $record->bins["email"];
 $age = $record->bins["age"];
 
 // Display retrieved data
 echo "Username: $username, Email: $email, Age: $age\n";
}
 
// Close record set after processing
$recordSet->close();