Skip to content
This repository has been archived by the owner. It is now read-only.
Switch branches/tags

Latest commit


Git stats


Failed to load latest commit information.
Latest commit message
Commit time

CqlPoco - an object mapper (micro-ORM) for Cassandra

UPDATE: CqlPoco is now part of the DataStax .NET Driver for Apache Cassandra

I'm really excited that CqlPoco has now been pulled back into the DataStax .NET driver for Apache Cassandra as the official Mapper component. The API has remained mostly intact, so it should be relatively simple to transition any existing code. For more details on the Mapper which is new in v2.5 of the DataStax driver, have a look at:

The code and this project will remain here for historical purposes, however going forward, you should use the Mapper in the driver as it will continue to be updated, improved, and supported there. Thanks to Jorge Bay Gondra for all his great work integrating CqlPoco with the driver.

Original Readme

CqlPoco is a lightweight object mapper (micro-ORM) for Apache Cassandra. You write queries with CQL, and CqlPoco will take care of mapping rows returned from Cassandra to your classes. It was inspired by PetaPoco, NPoco, Dapper.NET and the cqlengine project.

A simple query

public class User
    public Guid UserId { get; set; }
    public string Name { get; set; }

// Get a list of users from Cassandra
List<User> users = client.Fetch<User>("SELECT userid, name FROM users");

This works by mapping the column names in your CQL statement to the property names on the User class (using a case-insensitive match). Simple scenarios like this are possible without doing any mapping configuration.

Configuring CqlPoco

CqlPoco uses the DataStax .NET driver for Apache Cassandra to execute queries. When you install CqlPoco via the NuGet package, the driver will be installed as well. As such, you'll want to start by getting an ISession instance from the driver using the Cluster builder.

// Use the Cluster builder to connect to your Cassandra cluster
Cluster cluster = Cluster.Builder().AddContactPoint("").Build();
ISession session = cluster.Connect("mykeyspace");

Once you've got your ISession instance, you can configure CqlPoco pretty easily.

ICqlClient client = CqlClientConfiguration.ForSession(session).BuildCqlClient();

This ICqlClient instance is thread-safe and you'll want to take it and reuse it everywhere (maybe, for example, by registering it as a Singleton in your IoC container of choice).

Defining mappings

In many scenarios, you'll need more control over how your class is mapped to Cassandra. You have two options for telling CqlPoco how to map your classes: decorate your classes with attributes or define mappings in code using the fluent interface.

Attribute Example
public class User
    public Guid Id { get; set; }
    public string Name { get; set; }
Fluent Interface Example
public class MyMappings : Mappings
    public MyMappings()
        // Just define mappings in the constructor of your class that inherits from Mappings
                   .Column(u => u.Id, cm => cm.WithName("userid"));

If you decide to go the fluent interface route, you can tell CqlPoco about your mappings when you configure it. For example:

ICqlClient client = CqlClientConfiguration.ForSession(session)

Some other API examples

The simple query example is great, but CqlPoco's ICqlClient has a lot of other methods for doing things like Inserts, Updates, Deletes, selecting a single record and more. And all methods come with their async counterparts. Here's a quick sampling.

// All query methods (Fetch, Single, First, etc.) will auto generate the SELECT and FROM
// clauses if not specified
List<User> users = client.Fetch<User>();
List<User> users = client.Fetch<User>("FROM users WHERE name = ?", someName);
List<User> users = client.Fetch<User>("WHERE name = ?", someName);

// Single and SingleOrDefault for getting a single record
var user = client.Single<User>("WHERE userid = ?", userId);
var user = client.SingleOrDefault<User>("WHERE userid = ?", userId);

// First and FirstOrDefault for getting first record
var user = client.First<User>("SELECT * FROM users");
var user = client.FirstOrDefault<User>("SELECT * FROM users");

// All query methods also support "flattening" to just the column's value type when
// selecting a single column
Guid userId = client.First<Guid>("SELECT userid FROM users");
List<string> names = client.Fetch<string>("SELECT name FROM users");

// Insert a POCO
var newUser = new User { UserId = Guid.NewGuid(), Name = "SomeNewUser" };

// Update with POCO
someUser.Name = "A new name!";

// Update with CQL (will prepend table name to CQL)
client.Update<User>("SET name = ? WHERE userid = ?", someNewName, userId);

// Delete with POCO

// Delete with CQL (will prepend table name to CQL)
client.Delete<User>("WHERE userid = ?", userId);

Available on NuGet

CqlPoco is available on the NuGet gallery.

PM> Install-Package CqlPoco


Copyright 2014, Luke Tillman

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.


An object mapper for Apache Cassandra and .NET (think micro ORM like PetaPoco/NPoco or Dapper.NET)







No releases published


No packages published