Ignite.NET + Apache Cassandra integration for SQL cache

[crenique]

Hi,

 We create a cache using SQL DDL syntax.
How can I configure Cassandra persistent store to the cache in .NET
application ?

 It seems like default CacheConfiguration is automatically applied
internally in Java codes for SQL cache, so not able to load up Spring.XML
for that cache.


Here is the steps creating a SQL cache.


/Ignite: 2.6
OS: Windows Server 2016
Jdk: Java HotSpot(TM) 64-Bit Server VM (build 25.162-b12, mixed mode)
Programming language: C#/

*a)*
// Create dummy cache to act as an entry point for SQL queries (new SQL API
which do not require this
// will appear in future versions, JDBC and ODBC drivers do not require it
already).
var cacheCfg = new CacheConfiguration(m_odbcCacheName)
{
    SqlSchema = "PUBLIC",
    CacheMode = CacheMode.Replicated
};

m_odbcCache = m_ignite.GetOrCreateCache<object, object>(cacheCfg);


*b)*
// Create a VALUE_TYPE class 
public class UserData : IBinarizable
{
    [QuerySqlField]
    public DateTime LastUpdated { get; set; }
    
    [QuerySqlField]
    public byte[] Data { get; set; }

    public UserData() { }
    public UserData(byte[] btUserData)
    {
        LastUpdated = DateTime.UtcNow;
        Data = btUserData;
    }

    public void WriteBinary(IBinaryWriter writer)
    {
        writer.WriteTimestamp(nameof(LastUpdated), LastUpdated);
        writer.WriteByteArray(nameof(Data), Data);
    }

    public void ReadBinary(IBinaryReader reader)
    {
        LastUpdated = reader.ReadTimestamp(nameof(LastUpdated)) ??
DateTime.UtcNow;
        Data = reader.ReadByteArray(nameof(Data));
    }
}

*c)*
// Crete an actual UserData cache by running a DDL query on entry point
cache.
var qry = @"
CREATE TABLE IF NOT EXISTS [name]
(
    CacheKey VARCHAR,
    AffinityKey LONG,

    LastUpdated TIMESTAMP,
    Data VARBINARY(MAX),

    PRIMARY KEY (CacheKey, AffinityKey)
)
WITH ""BACKUPS=2, TEMPLATE=PARTITIONED,
WRITE_SYNCHRONIZATION_MODE=PRIMARY_SYNC, AFFINITYKEY=AffinityKey,
VALUE_TYPE=UserData""
";

var qryResults = m_odbcCache.Query(new SqlFieldsQuery(qry)).GetAll();




Thanks
Sam





--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/