In this Article, I will show How to insert single and bulk data into
Cassandra Database with Spring Data Cassandra Template.
How to create a maven project and add required dependencies.
Tools Uses :
1) spring-data-cassandra-1.2.1.RELEASE
2) Apache-cassandra-2.1.6
3) eclipse version Luna 4.4.1.
4) Maven 3.3.3
5) JDK 1.6
Steps to be follow :
1) Create a simple maven project.
2) Add the dependencies and
3) Write a simple program to insert data using Spring Cassandra Template.
4) Start the Cassandra server.
5) Run the program and verify the data in cassandra.
Add the given dependency to spring-data-cassandra API,
org.springframework.data spring-data-cassandra 1.2.1.RELEASE
Complete pom.xml file code is Here,
pom.xml
4.0.0 com.devjavasource.cassandra SpringDataCassandraExample 0.0.1-SNAPSHOT jar SpringDataCassandraExample http://maven.apache.org UTF-8 junit junit 3.8.1 test com.datastax.cassandra cassandra-driver-core 2.1.6 org.springframework.data spring-data-cassandra 1.2.1.RELEASE
Write a simple program to insert data using Spring Cassandra Template :
This program will do the following,
1) Create a Cluster object.
Cluster cluster = null;
cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
A cluster object maintains a permanent connection to one of
the cluster nodes. builder() is a static method of Cluster class.
2) Create a session object
private static Session session;
session = cluster.connect("devjavasource");
Here “devjavasource” is the existed keyspace, I am using the same.
we can create a session object by passing key space name as parameter
to connect() method of cluster class.
3) Create CassandraOperations :
CassandraOperations is interface that helps to do Operations like select, insert, delete…etc
for interacting with Cassandra.
CassandraOperations cassandraOps = new CassandraTemplate(session);
Using insert() method of CassandraTemplate class, we can insert single
or multiple records into Cassandra Database.
// To insert a single User information into Database final Users insertedUser = cassandraOps.insert(new Users(11104,"UK", "Alex")); // To insert multiple User information at a time. // Bulk insert operation final Users user1 = new Users(11105, "Australia", "Mike"); final Users user2 = new Users(11106, "India", "Ram"); final List<Users> userList = new ArrayList<>(); userList.add(user1); userList.add(user2); cassandraOps.insert(userList);
Four insert() methods are available in Spring Data CassandraTemplate,
// Using this, we can insert single Object data into Cassandra database. <T> T insert(T entity) // Using this, we can insert bulk data into Cassandra database. <T> List<T> insert(List<T> entities) // We can insert, with WriteOption <T> T insert(T entity, WriteOptions options) // Inserts the given entity asynchronously <T> List<T> insertAsynchronously(List<T> entities) //This method is deprecate, better check before using in your code.
What is WriteOption ?
Contains Query Options for Cassandra queries.
This controls the Consistency Tuning and Retry Policy for a Query.
we can create a WriteOptions instance with following constructor,
WriteOptions(ConsistencyLevel consistencyLevel, RetryPolicy retryPolicy)
(a) consistencyLevel – is the consistencyLevel associated
with Cassandra for this particular insert operation.
Possible values are
ANY, ONE, TWO, THREE, QUOROM, LOCAL_QUOROM, EACH_QUOROM,
ALL, LOCAL_ONE, SERIAL, LOCAL_SERIAL.
Suppose If we pass ONE as consistencyLevel, that means if cluseter is down.
Then Cassandra server returns server fault message only after try
with only one active cluser in ring.
(b) retryPolicy – is the retryPolicy associated
with Cassandra for this particular insert operation.
Possible values are
DEFAULT, DOWNGRADING_CONSISTENCY, FALLTHROUGH, LOGGING
Complete Source code is Here,
App.java
package com.devjavasource.cassandra.SpringDataCassandraExample;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import org.springframework.cassandra.core.WriteOptions;
import org.springframework.data.cassandra.core.CassandraOperations;
import org.springframework.data.cassandra.core.CassandraTemplate;
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
import com.datastax.driver.core.querybuilder.QueryBuilder;
import com.datastax.driver.core.querybuilder.Select;
import com.devjavasource.cassandra.dto.Users;
public class App {
private static Cluster cluster;
private static Session session;
public static void main(String[] args) {
try {
cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
session = cluster.connect("devjavasource");
CassandraOperations cassandraOps = new CassandraTemplate(session);
// To insert a single User information into Database
final Users insertedUsers = cassandraOps.insert(new Users(11104,
"UK", "Alex"));
System.out.println(insertedUsers.getId());
print(cassandraOps, insertedUsers.getId() );
// To insert multiple User information at a time.
// Bulk insert operation
final Users user1 = new Users(11105, "Australia", "Mike");
final Users user2 = new Users(11106, "India", "Ram");
final List<Users> userList = new ArrayList<>();
userList.add(user1);
userList.add(user2);
final List<Users> insertedUserList = cassandraOps.insert(userList);
System.out.println("\n" + insertedUserList );
printList(cassandraOps, Arrays.asList(11105, 11106));
cassandraOps.insert(userList, null);
} catch (Exception e) {
e.printStackTrace();
} finally {
cluster.close();
}
}
private static void print(final CassandraOperations inCassandraOps,
final int inId) {
System.out.println("Spring Data Cassandra Single insert Example");
System.out.println("============================================");
final String[] columns = new String[] { "id", "address", "name" };
Select select = QueryBuilder.select(columns).from("users");
select.where(QueryBuilder.eq("id", inId));
final List<Users> results = inCassandraOps.select(select, Users.class);
for (Users user : results) {
System.out.println("User Id is: " + user.getId());
System.out.println("User Address is: " + user.getAddress());
System.out.println("User Name is: " + user.getName());
}
}
private static void printList(final CassandraOperations inCassandraOps,
final List<Integer> inIdList) {
System.out.println("Spring Data Cassandra bulk insert Example");
System.out.println("============================================");
final String[] columns = new String[] { "id", "address", "name" };
Select select = QueryBuilder.select(columns).from("users");
select.where(QueryBuilder.in("id", inIdList));
final List<Users> results = inCassandraOps.select(select, Users.class);
for (Users user : results) {
System.out.println("User Id is: " + user.getId());
System.out.println("User Address is: " + user.getAddress());
System.out.println("User Name is: " + user.getName());
}
}
}
User.java
package com.devjavasource.cassandra.dto;
import org.springframework.data.cassandra.mapping.PrimaryKey;
import org.springframework.data.cassandra.mapping.Table;
@Table
public class User {
@PrimaryKey
private int id;
private String address;
private String name;
public User(int id, String address, String name) {
this.id = id;
this.address = address;
this.name = name;
}
public int getId() {
return id;
}
public String getAddress() {
return address;
}
public String getName() {
return name;
}
@Override
public String toString() {
return "User [id=" + id + ", address=" + address + ", name=" + name
+ "]";
}
}
4) Start the Cassandra server :
Cassandra server should be up and running.
If the server is not running, run the server using following command.
Command to start Casandra server is,
C:\apache-cassandra-2.1.6\bin>cassandra.bat -f
5) Run Maven project :
Select and Run As -> Java Application.
Out Put :
11104 Spring Data Cassandra Single insert Example ============================================ User Id is: 11104 User Address is: UK User Name is: Alex [User [id=11105, address=Australia, name=Mike], User [id=11106, address=India, name=Ram]] Spring Data Cassandra bulk insert Example ============================================ User Id is: 11105 User Address is: Australia User Name is: Mike User Id is: 11106 User Address is: India User Name is: Ram
Verify the data in cassandra :
Start cqlsh shell and use key space “devjavasource” and query
for the table Users.
You can download complete project, Here
*** Venkat – Happy leaning ****