Update

Jump to the Code block for a combined complete example.

Setup

The following examples will use the setup and record below to illustrate single record updates in an Aerospike database.

const Aerospike = require('aerospike');

// Define host configuration
let config = {hosts: '127.0.0.1:3000'};

// Creates a key with the namespace "sandbox", set "ufodata", and user key 5001
let key = new Aerospike.Key('sandbox', 'ufodata', 5001);

The record structure:

+------+----------+----------+----------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------+
| PK   | occurred | reported | posted   | report                                                                                                                                                                                                                 | location                                                   |
+------+----------+----------+----------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------+
| 5001 | 20220531 | 20220601 | 20220601 | MAP('{"shape":["circle", "flash", "disc"], "summary":"Large flying disc flashed in the sky above the student union. Craziest thing I've ever seen!", "city":"Ann Arbor", "state":"Michigan", "duration":"5 minutes"}') | GeoJSON('{"type":"Point","coordinates":[42.2808,83.743]}') |
+------+----------+----------+----------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------+

Policies

Create and Update both utilize write policies that can be defined per command. The client employs an exists action, specified within the write policy, to define the operation semantics when a record already exists. The default is IGNORE.

The following variants are available:

Action Type	Description
IGNORE	Create if record doesn’t exist, update otherwise.
CREATE	Create if record doesn’t exist already.
UPDATE	Update only, if record exists.
REPLACE	Replace only, if record exists.
CREATE_OR_REPLACE	Create if record doesn’t exist, replace otherwise.

The following example sets the policy to update the record, only if it already exists.

// Can use a previously defined write policy or create a new one
let updatePolicy = new Aerospike.WritePolicy({
    exists: Aerospike.policy.exists.UPDATE
});

Update a record

Update

With the write policy exists action set to UPDATE or IGNORE, new bins can be added to a record and existing bin values can be updated.

The following example updates the posted bin value to 20220602.

// Create bin with new value
let newPosted = {'posted': 20220602};

;(async () => {
    // Establishes a connection to the server
    let client = await Aerospike.connect(config);

    // Update record with new bin value
    client.put(key, newPosted, [], updatePolicy);

    // Close the connection to the server
    client.close();
})();

Type specific

Type specific updates can add integers or append/prepend strings to existing integer and string bin values, respectively.

The following example decrements the posted bin value by one.

// Create bin with value to be added
let newPosted = {'posted': -1};

;(async () => {
    // Establishes a connection to the server
    let client = await Aerospike.connect(config);

    // Add new bin value to existing bin
    client.incr(key, newPosted, [], updatePolicy);

    // Close the connection to the server
    client.close();
})();

Note

Best practice is to apply add and append/prepend operations as part of a command, and not to use the full-record operation variant described above. Refer to Transaction Operations for information on operations and more client examples.

Replace

To replace a record, set the exists action in the write policy to either CREATE_OR_REPLACE or REPLACE. Refer to the policies section above for more information on setting the policy and the create page for creating a record to replace the existing one.

The following example sets the existing write policy to replace ony if the record already exists.

// Updating the previously defined write policy
updatePolicy.exists = Aerospike.policy.exists.REPLACE;

Note

A replace can have a performance advantage over an update as a replace may not require reading the record from the device. Certain situations such as a stored key or a secondary index on a bin, and more, may still require a read on a replace, eliminating any performance advantage.

Delete a bin

A bin is deleted by setting it to null. Delete the posted bin by setting its value to null.

// Set bin value to null
let removeBin = {'posted': null};

;(async () => {
    // Establishes a connection to the server
    let client = await Aerospike.connect(config);

    // Update record with null bin
    client.put(key, removeBin);

    // Close the connection to the server
    client.close();
})();

Note

Updating a bin value to null, when it is the only bin in the record, deletes the record.

Code block

Expand this section for a single code block to read a record

const Aerospike = require('aerospike');

// Define host configuration
let config = {hosts: '127.0.0.1:3000'};

// Creates a key with the namespace "sandbox", set "ufodata", and user key 5001
let key = new Aerospike.Key('sandbox', 'ufodata', 5001);

// Create bin with new value
let newPosted = {'posted': 20220602};

;(async () => {
    // Establishes a connection to the server
    let client = await Aerospike.connect(config);

    // Update record with new bin value
    client.put(key, newPosted, [], updatePolicy);

    // Close the connection to the server
    client.close();
})();