Native CQL3 to object mapping

Introduction :

CQL (Cassandra Query language) is a standard way of manipulating data stored in Cassandra which is very much similar to SQL with some basic differences and constraints of a non relational and relational database.

With constant changes being made in Cassandra we are devising better and more optimum ways to facilitate leveraging its features in best possible manner using Kundera. However , you can query data objects in Cassandra using CQL3 native queries via Kundera.

Set CQL version 3:

  EntityManagerFactory emf = Persistence.createEntityManagerFactory("cassandra_pu");
  EntityManager em = emf.createEntityManager();
  em.setProperty("cql.version", "3.0.0");

Relation Mapping in Kundera and Cassandra :

An Employee entity to be persisted in cassandra using Kundera

@Entity
public class EmployeeInfo
{
    @Id
    @Column(name = "UserID")
    private Long userid;
    
    @ManyToOne(cascade = CascadeType.ALL, fetch = FetchType.LAZY)
    @JoinColumn(name = "address_id")
    private EmployeeAddress address;

Cassandra Equivalent :

CREATE TABLE "EmployeeInfo" (
  key bigint PRIMARY KEY,
  address_id bigint
) ;

CREATE INDEX EmployeeInfo_address_id_idx ON "EmployeeInfo" (address_id);

Employee's address entity to be persisted in cassandra using Kundera

@Entity
public class EmployeeAddress
{

    @Id
    @Column(name = "key")
    private Long address;
    
    @Column(name="street")
    private String street;

Cassandra Equivalent :

CREATE TABLE "EmployeeAddress" (
  key bigint PRIMARY KEY,
  street text
) ;

Persisting and querying the data using Kundera :

 EntityManager em = emf.createEntityManager();
 EmployeeInfo emp_info = new EmployeeInfo();
 EmployeeAddress address_info = new EmployeeAddress();
 address_info.setStreet("street");
 emp_info.setAddress(address_info);
 em.persist(emp_info);

final String noClause = "Select u from EmployeeInfo u";
Query q = em.createQuery(noClause);
List<EmployeeInfo> results = q.getResultList();

// With limit
q = em.createQuery(noClause);
q.setMaxResults(2);
results = q.getResultList();

Objects stored in Cassandra :

select * from "EmployeeInfo";

 key | address_id
-----+------------
   1 |          1

select * from "EmployeeAddress";

 key | street
-----+-----------
   1 | newStreet