1.4 KiB
1.4 KiB
casser 
Cutting edge Java 8 Cassandra Client
Current status: Active development
Features
- Leverages Java 8 language capabilities to build CQL queries
- Simple function-style stream API
- Reactive asynchronous and synchronous API
- Provides Java mapping for Tables and User Defined Types
Requirements
- Only JVM 8
- Latest Datastax Driver 2.1.5
- Latest Cassandra
- Maven
Maven
Active development dependency:
<dependency>
<groupId>com.noorq.casser</groupId>
<artifactId>casser-core</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
Example
Entity definition:
@Table("timelines")
public interface Timeline {
@PartitionKey
UUID userId();
@ClusteringColumn
@DataTypeName(Name.TIMEUUID)
Date timestamp();
@Column
String text();
}
Session initialization:
Timeline timeline = Casser.dsl(Timeline.class);
CasserSession session = Casser.init(getSession()).showCql().add(Timeline.class).autoCreateDrop().get();
Select information:
session.select(timeline::userId, timeline::timestamp, timeline::text)
.where(timeline::userId, Operator.EQ, userId)
.orderBy(timeline::timestamp, "desc").limit(5).sync()
.forEach(System.out::println);
Insert information:
TimelineImpl post = new TimelineImpl();
post.userId=userId;
post.timestamp=new Date(postTime+1000L*i);
post.text="hello";
session.upsert(post).sync();