Aerospike.Database.LINQPadDriver 2.0.5.1

Aerospike Database for LINQPad 7

Aerospike Database for LINQPad 7

Description

Aerospike Namespace, Set, Records, Bins, and Secondary Indexes

User-Defined Functions (UDFs)

Aerospike API

Serialization/Object-Mapper

JSON

Prerequisites

Installation

NuGet

Manual

Description

Aerospike for LINQPad 7 is a data context dynamic driver for querying and updating an Aerospike database. This driver can be used to explore an Aerospike data model, data mining, prototyping, testing, etc.

You can perform the following:

• query any Aerospike Set using any LINQ command.
• use the driver’s extension methods to perform operations like Aerospike Expression, CRUD operations, import/export, or execute an Aerospike User Defined Function (UDF) without understanding the underlying Aerospike API.
• Able to serialize and deserialize any C# object (ORM). These objects can be a class, structure, native type, nested classes, or collections.
• JSON support
• use the Aerospike API to perform advance operations or just to test code segments used in your application.

The driver can dynamically detect the structure of records in Aerospike Sets resulting in an easy-to-understand view. The driver can also detect multiple data types for the same Aerospike Bin within a record. Below screenshot show how Aerospike Sets and Bins are represented in LinqPad:

The LINQPad connection pane will display the different Aerospike components in an hierarchical manner where namespace is under Aerospike cluster connection. Aerospike Sets are under namespaces and bins are under Sets. Below screenshot shows the relationship between these components:

Each component can be dragged-and-dropped onto the LINQPad Query pane to be executed by LINQPad. The execution behavior will depend on the component. For example, a Set or Secondary Index will present the records within that component. For other components, the properties are displayed. In all cases, you can always execute the driver’s extension methods. These extension methods, greatly simplify Aerospike API commands like Get, Put, Query, Operate, etc. plus, the ability to perform things like importing or exporting data. Of course, you can always use LINQ against Aerospike Sets or Secondary Indexes. Below is an example of some of the driver extensions:

Aerospike Namespace, Set, Records, Bins, and Secondary Indexes

The LINQPad connection pane will display the different Aerospike components in a hierarchical manner where namespace is under Aerospike cluster connection. Aerospike Sets are under namespaces and bins are under Sets. Below screenshot shows the relationship between these components:

Each component can be dragged-and-dropped onto the LINQPad Query pane to be executed by LINQPad. The execution behavior will depend on the component. For example, a Set or Secondary Index will present the records within that component. For other components, the properties are displayed. In all cases, you can always execute the driver’s extension methods and properties. These extensions, greatly simplify Aerospike API commands like Get, Put, Query, Operate, etc. plus, the ability to perform things like importing or exporting data. Below is an example of some of the driver extensions:

Aerospike Sets and records are very easy to use. The detected bins in a record are integrated into LINQPad and are treated as C# properties. As such, features like Intellisense and Autocompletion just work. You can also access bins within a record by using the bin name.

Since Aerospike is a schemaless database, a record can consist of varying number of bins, or a bin can have different data types between records. The driver can handle these conditions seamlessly. This is done using extension methods and implicit data conversion.

Implicit data conversion eliminates the need to test and cast a bin’s value so that it can be used directly in any operation. Below is an example that shows how implicit conversion works. The set, “graphDeviceNodeIdSet”, has a bin named “nodeID” that consists of two different data type values. Some records have a list value while others have a string value. This example uses the “where” clause which compares each record in the set looking for a numeric value of 367 or the value “a” in the list values.

User-Defined Functions (UDFs)

The driver supports the execution of UDFs by calling the Execute extension method. The Execute method will reflect the actual arguments used in the UDF. Below is an example:

Aerospike API

At any time, you can use the underlying Aerospike API directly or a combination of API or driver extension methods. Below is an example:

void Main() 
{ 
    //Using Aerospike API 
     
    var cPolicy = new ClientPolicy(); 
    using var client = new AerospikeClient(cPolicy, "localhost", 3000); 

    //Insert 3 records, with MapPolicy KEY_ORDERED 

    var key1 = new Key("test", "s1", 1); 
    var key2 = new Key("test", "s1", 2); 
    var key3 = new Key("test", "s1", 3); 
    var policy = new WritePolicy(); 
    policy.recordExistsAction = RecordExistsAction.UPDATE; 

    client.Put(policy, key1, new Bin("id", "groupID1")); 
    client.Put(policy, key2, new Bin("id", "groupID2")); 
    client.Put(policy, key3, new Bin("id", "groupID3")); 

    for (int i = 0; i < 25; i++) 
    { 
        client.Operate(null, key1, 
                        ListOperation.Insert("myList", 0, Value.get(value)), 
                        ListOperation.Trim("myList", 0, 20) ); 
    } 

}

Serialization/Object-Mapper

The driver supports serialize and deserialize any C# object to/from an Aerospike record. Native C# types are stored as Aerospike data type. Unsupported types like DateTime, DateTimeOffset, Timespan, etc. are serialized as an ISO string or a numeric value based on behavior defined in the connection dialog. This behavior can also be changed programmability by the driver’s API or by providing a custom serializer.

C# collections will be serialized into an Aerospike CDT. C# public properties or fields will be serialized into an Aerospike bin where the bin name is the same name as the property/field. Fields can be ignored, and bin names can be different based on the use of C# attributes (Aerospike.Client.BinIgnore, Aerospike.Client.BinName). Any nested class will be serialized as an Aerospike JSON document.

The driver can deserialize an Aerospike record into a C# class. Just like serialization, bins are mapped to properties and fields using attributes as defined above. The driver will determine the best possible constructor to instantiate the class. This behavior can be changed by using the “Aerospike.Client.Constructor” attribute. Below is an example:

public enum Tiers 
{ 
    None = 0, 
    Low = 4, 
    Medium = 3, 
    High = 2, 
    VeryHigh = 1 
} 

public class Player 
{ 
    //Attributes used to indicate which constructor to use. 
    //If not provided, the driver will choose the best constructor based on signure. 
    //A class constructor is NOT required. 
    [Aerospike.Client.Constructor] 
    public Player(int playerId, 
                    string userName, 
                    string firstName, 
                    string lastname, 
                    List<WagerResultTransaction> wagersResults) 
    { 
        this.PlayerId = playerId; 
        this.UserName = userName; 
        this.FirstName = firstName; 
        this.LastName = lastname; 
        this.WagersResults = wagersResults; 
    } 

    //Attribute to indicate that this property shoule be ignored in the Mapping 
    [Aerospike.Client.BinIgnore] 
    public string Tag { get; } = "Player"; 

    public int PlayerId { get; } //Note Read-Only, being set in the constructor 
    public string UserName { get; } 
    public string FirstName { get; } 
    public string LastName { get; } 

    //Attribute to indicate that the Bin Name is Different from the Property Name. 
    [Aerospike.Client.BinName("EmailAddress")] 
    public string Email { get; set; } 

    public Game Game { get; set; } //nested class 
     
    public List<WagerResultTransaction> WagersResults { get; } //A list of objects 
} 

public sealed class Game 
{ 
    public Game() 
    { } 

    public string Tag; 
    public string Name; 
    public decimal MinimumWager; 
    public decimal MaximumWager; 
} 

public sealed class WagerResultTransaction 
{ 
    public enum Types 
    { 
        Wager, 
        Win, 
        Loss 
    } 
    public WagerResultTransaction(long id, DateTimeOffset timestamp) 
    {  
        this.Id = id; 
        this.Timestamp = timestamp; 
    }  
    public long Id { get;} 
    public DateTimeOffset Timestamp { get; } 
     
    public string Game { get; private set; } 
    public string BetType { get; private set; } 
    public Types Type { get; set; } 
    public decimal Amount { get; set; } 
    public decimal PlayerBalance { get; set; }     
} 


// Read 5 records from the Player Aerospike set. 
// Instantiate 5 new instances of Player based on the records. 
// Change the Primary Key Value and Player's ID and thoses changed instances back to the Player set. 
// Read back the newly inserted records and display. 
// Removed the newly inserted records from the Player set. 
void Main() 
{ 
    var players = test.players.Take(5).Dump("DB Records", 0) //Read 5 records from the DB 
                        .Select(i => i.Cast<Player>()); //Create 5 new instances of the Player class from the DB 

    players.Dump("Player Instances", 0); 
     
    //Change The Player Id and Write Back to the DB 
    var newPlayerIds = new List<int>();         
    foreach (var player in players) 
    { 
        var newPlayerId = player.PlayerId * 100; 
        newPlayerIds.Add(newPlayerId); 
         
        // We can write the object as a collection of bins or as a Document to a single bin in the DB. 
        //Defaults to writing a bin for each Property in the class.  
        //Nested classes will be treated as documents. 
        test.players.WriteObject(newPlayerId, player); //Like Put we can set a TTL 
    } 
     
    //Let’s Get the newly added players from the DB 
    newPlayerIds 
        .Select(pi => test.players.Get(pi)) 
        .ToList() //Need to Get Linq to Execute the Get 
        .Dump("New Players from the DB as Records", 0); 
         
    //Remove the New PlayerIds from the DB (Cleanup) 
    newPlayerIds.All(pi => test.players.Delete(pi)).Dump("Cleanup Successfull:"); 
}

Below is the output from LINQPad:

JSON

The driver supports the use of the Aerospike JSON support. This feature can be turned on or off from within the connection dialog. Below is an example where we show three different methods of obtaining a value within a JSON document. They are:

• Using the Aerospike Operate API
• Using JSON Pathing
• Using an Aerospike secondary index with the driver’s Query extension method with Aerospike filter expressions
  The secondary index is defined on “neighbors” bin

test.graphG1Set.Get("201").Dump("Obtain the complete record from the DB"); 

test.graphG1Set.Operate("201", //PK 
                        MapOperation.GetByKey("neighbors", //Aerospike API 
                                                    Value.Get("attr01"), 
                                                    MapReturnType.VALUE, 
                                                CTX.MapKey(Value.Get("201.02")))).Dump("Using Operation"); 
                                                 
test.graphG1Set.Get("201") //PK 
                .neighbors 
                .JsonPath("$.['201.02']['attr01']").Dump("Using JSON Path (JToken)"); 

test.graphG1Set.graphG1Set_idx.Query(Filter.Contains("neighbors", //Aerospike API 
                                                        IndexCollectionType.MAPKEYS, 
                                                        "201.02")) 
                                .AsEnumerable() 
                                .Select(gs => gs.neighbors["201.02"]["attr01"]).Dump("Linq using secondary index");

Below is the output from LINQPad:

Importing/Exporting

The driver can import a valid JSON file into an Aerospike set. The set can be an existing set or a set will be created. Each JSON property will be mapped to an Aerospike bin. Any JSON collection types will be transformed into the corresponding Aerospike CDT. Nested JSON objects will be treated as Aerospike JSON documents.

The driver can also export an Aerospike set into a JSON file. Below is an example of an export from the “players” Aerospike set.

test.players.Export(@"c:\users\randersen_aerospike\Desktop\player.json");

Below is an example of importing a JSON file:

test.players.Import(@"c:\users\randersen_aerospike\Desktop\player.json"); 
test.Import(@"c:\users\randersen_aerospike\Desktop\player.json", "players");

Below is an example of the JSON file (truncated to one record):

[

{

"$type": "Aerospike.Database.LINQPadDriver.Extensions.JsonExportStructure, Aerospike.Database.LINQPadDriver",

"NameSpace": "test",

"SetName": "players",

"Generation": 1,

"Digest": {

"$type": "System.Byte[], System.Private.CoreLib",

"$value": "iFPrctmVIIjlveDF/lqIv/Zwg+4="

},

"KeyValue": 5220,

"Values": {

"$type": "System.Collections.Generic.Dictionary`2[[System.String, System.Private.CoreLib],[System.Object, System.Private.CoreLib]], System.Private.CoreLib",

"PlayerId": 522,

"UserName": "Roberts.Eunice",

"FirstName": "Eunice",

"LastName": "Roberts",

"EmailAddress": "RobertsEunice52@prohaska.name",

"Game": {

"$type": "System.Collections.Generic.Dictionary`2[[System.Object, System.Private.CoreLib],[System.Object, System.Private.CoreLib]], System.Private.CoreLib",

"Tag": "Game",

"Name": "Roulette",

"MinimumWager": 0.1,

"MaximumWager": 50.0

},

"WagersResults": {

"$type": "System.Collections.Generic.List`1[[System.Object, System.Private.CoreLib]], System.Private.CoreLib",

"$values": [

{

"$type": "System.Collections.Generic.Dictionary`2[[System.Object, System.Private.CoreLib],[System.Object, System.Private.CoreLib]], System.Private.CoreLib",

"Id": 2245872720943,

"Timestamp": "2022-12-20T09:18:33.3706-04:00",

"Game": "Roulette",

"BetType": "Dozen",

"Type": "Loss",

"Amount": 9.15,

"PlayerBalance": 821.57

},

{

"$type": "System.Collections.Generic.Dictionary`2[[System.Object, System.Private.CoreLib],[System.Object, System.Private.CoreLib]], System.Private.CoreLib",

"Id": 2244231101892,

"Timestamp": "2022-12-20T09:18:25.3706-04:00",

"Game": "Roulette",

"BetType": null,

"Type": "Wager",

"Amount": 9.15,

"PlayerBalance": 830.72

}

]

}

}

},

]

Prerequisites

• LINQPad 7: .NET 7/.NET 6/.NET 5/.NET Core 3.1
• LINQPad 6: .NET 5/.NET Core 3.1

Installation

NuGet

• Open LINQPad
• Click Add Connection Link.
• Click button View more drivers…
• Click radio button Show all drivers and type Aerospike.
• Install

Manual

Obtain the latest driver from the Driver folder and download to your computer.

• Open LINQPad
• Click Add Connection Link.
• Click button View more drivers…
• Click button Install driver from .LPX6 file… and select downloaded lpx6 file.