Cassandra Keyspaces repository .net

public class TestRepository : ITestRepository
{
    private readonly CassandraSessionCache _cassandra;
    private Mapper _mapper;

    public TestRepository(CassandraSessionCache cassandra)
    {
        _cassandra = cassandra;
    }

    public async Task DeleteAsync(Guid id, string keySpace)
    {
        SetSessionAndMapper(keySpace);

        await _mapper.DeleteAsync<Test>("WHERE id = ?", id);
    }

    public async Task<Install> GetAsync(string id, string keySpace)
    {
        SetSessionAndMapper(keySpace);

        return await _mapper.FirstOrDefaultAsync<Test>("SELECT * FROM \"Test\" WHERE id = ?", id);
    }

    public async Task PostAsync(Test data, string keySpace)
    {
        SetSessionAndMapper(keySpace);

        await _mapper.InsertAsync(data);
    }

    private void SetSessionAndMapper(string keySpace)
    {
        var session = _cassandra.GetSession(keySpace);
        _mapper = new Mapper(session);
    }
}

Source: stackoverflow.com

Cassandra Keyspaces repository .net

My current solve:Create Cluster:cluster = Cluster.Builder()  .AddContactPoint(cassandraData.ContactPoint)  .WithPort(int.Parse(cassandraData.Port))  .WithCredentials(cassandraData.User, cassandraData.Password)  .Build();After that i inject this by dependency injection to my Session Cache:public CassandraSessionCache(Cluster cluster){  _cluster = cluster;  _sessions = new ConcurrentDictionary<string, Lazy<ISession>>();}public ISession GetSession(string keyspaceName){  if (!_sessions.ContainsKey(keyspaceName))    _sessions.GetOrAdd(keyspaceName, key => new Lazy<ISession>(() =>   _cluster.Connect(key)));  var result = _sessions[keyspaceName];  return result.Value;}I Create also Map to Cassandra and use it my startup class.After this configuration my repository look like this:public class TestRepository : ITestRepository
{
    private readonly CassandraSessionCache _cassandra;
    private Mapper _mapper;

    public TestRepository(CassandraSessionCache cassandra)
    {
        _cassandra = cassandra;
    }

    public async Task DeleteAsync(Guid id, string keySpace)
    {
        SetSessionAndMapper(keySpace);

        await _mapper.DeleteAsync<Test>("WHERE id = ?", id);
    }

    public async Task<Install> GetAsync(string id, string keySpace)
    {
        SetSessionAndMapper(keySpace);

        return await _mapper.FirstOrDefaultAsync<Test>("SELECT * FROM \"Test\" WHERE id = ?", id);
    }

    public async Task PostAsync(Test data, string keySpace)
    {
        SetSessionAndMapper(keySpace);

        await _mapper.InsertAsync(data);
    }

    private void SetSessionAndMapper(string keySpace)
    {
        var session = _cassandra.GetSession(keySpace);
        _mapper = new Mapper(session);
    }
}

Source: stackoverflow.com

Similar codes

0 vote180 views3 answers
Reporting Progress from Async Tasks c#
C#
7 votes179 views6 answers
C# exit application
C#
0 vote169 views1 answer
C# regex double of some letters only
C#
0 vote177 views1 answer
Nuget Microsoft.EntityFrameworkCore.InMemory": "1.0.0"
C#
0 vote177 views1 answer
C# see if string is int
C#
0 vote167 views1 answer
Center an image horizontally and vertically
C#
1 vote197 views1 answer
Unity time.deltatime timescale 0
C#Unity
0 vote172 views1 answer
Unity set parent canvas
C#
40 votes171 views3 answers
How to create a list c#
C#
5 votes164 views3 answers
How to move a gameobject to another object
C#