Adding examples realted to Spring Data Repository.

Author: nitinware

src/main/java/com/springdata/example/Main.java

@@ -1,6 +1,9 @@
 package com.springdata.example;
 
 import java.util.Date;
+import java.util.Iterator;
+import java.util.List;
+
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 import org.springframework.data.cassandra.core.CassandraOperations;
@@ -9,15 +12,30 @@
 import com.datastax.driver.core.querybuilder.Insert;
 import com.datastax.driver.core.querybuilder.QueryBuilder;
 import com.springdata.example.model.Person;
+import com.springdata.example.repo.PersonRepository;
 
 public class Main {
 
 	public static void main(String[] args) {
 		ApplicationContext context = new ClassPathXmlApplicationContext("classpath:application-context.xml");
-		CassandraOperations cassandraOperations = context.getBean("cassandraTemplate", CassandraOperations.class);
+		CassandraOperations cassandraOperations = context.getBean("cqlTemplate", CassandraOperations.class);
+		
+		PersonRepository personRepo = context.getBean(PersonRepository.class);
+		
+		Iterator<Person> personIterator = personRepo.findAll().iterator();
+		
+		while(personIterator.hasNext()) {
+			System.out.println(personIterator.next());
+		}
+		
+		List<Person> persons = personRepo.findByLastname("Ware");
+		
+		for(Person person : persons) {
+			System.out.println(person);
+		}
 		//insertPerson(cassandraOperations);
-		Person person = selectPerson(cassandraOperations);
-		insertLoginEventByQueryBuilder(cassandraOperations, person);
+		//Person person = selectPerson(cassandraOperations);
+		//insertLoginEventByQueryBuilder(cassandraOperations, person);
 	}
 
 	private static void insertLoginEventByQueryBuilder(
@@ -35,14 +53,14 @@ private static void insertLoginEventByQueryBuilder(
 	}
 
 	private static Person selectPerson(CassandraOperations cassandraOperations) {
-		String cqlOne = "select * from person where id = '1234567890'";
+		String cqlOne = "select * from person where id = '123123123'";
 		Person person = cassandraOperations.selectOne(cqlOne, Person.class);
-		System.out.println(String.format("Found People with Name [%s] for id [%s]", person.getName(), person.getId()));
+		System.out.println(String.format("Found People with FirstName [%s] LastName [%s] for id [%s]", person.getFirstname(), person.getLastname(), person.getId()));
 		return person;
 	}
 
 	private static void insertPerson(CassandraOperations cassandraOperations) {
-		cassandraOperations.update(new Person("123123123", "Alison", 35));
+		cassandraOperations.update(new Person("123123123", "Nathan", "Ware", 35, "nathanware@gmail.com"));
 	}
 
 }

src/main/java/com/springdata/example/model/Person.java

@@ -8,31 +8,43 @@ public class Person {
 
 	@PrimaryKey
 	private String id;
-
-	private String name;
+	private String firstname;
+	private String lastname;
 	private int age;
+	private String emailAddress;
+
 
-	public Person(String id, String name, int age) {
+	public Person(String id, String firstname, String lastname, int age, String emailAddress) {
 		this.id = id;
-		this.name = name;
+		this.firstname = firstname;
+		this.lastname = lastname;
 		this.age = age;
+		this.emailAddress = emailAddress;
 	}
 
 	public String getId() {
 		return id;
 	}
+	
+	public String getFirstname() {
+		return firstname;
+	}
 
-	public String getName() {
-		return name;
+	public String getLastname() {
+		return lastname;
 	}
 
 	public int getAge() {
 		return age;
 	}
 
+	public String getEmailAddress() {
+		return emailAddress;
+	}
+
 	@Override
 	public String toString() {
-		return "Person [id=" + id + ", name=" + name + ", age=" + age + "]";
+		return "Person [id=" + id + ", name=" + firstname + " " + lastname + ", age=" + age + ", email=" + emailAddress + "]";
 	}
 
 }

src/main/java/com/springdata/example/repo/PersonRepository.java

@@ -0,0 +1,15 @@
+package com.springdata.example.repo;
+
+import java.util.List;
+
+import org.springframework.data.cassandra.repository.Query;
+import org.springframework.data.repository.CrudRepository;
+
+import com.springdata.example.model.Person;
+
+public interface PersonRepository extends CrudRepository<Person, String> {
+	
+	@Query("select * from Person where lastname=?0")
+	List<Person> findByLastname(String lastname);
+	
+}

src/resources/application-context.xml

@@ -20,14 +20,14 @@
   <cassandra:session keyspace-name="${cassandra.keyspace}" />
 
   <!-- REQUIRED: The Default Cassandra Mapping Context used by CassandraConverter -->
-  <cassandra:mapping />
+  <cassandra:mapping entity-base-packages="com.springdata.example.model" />
 
   <!-- REQUIRED: The Default Cassandra Converter used by CassandraTemplate -->
   <cassandra:converter />
 
   <!-- REQUIRED: The Cassandra Template is the building block of all Spring 
     Data Cassandra -->
-  <cassandra:template id="cassandraTemplate" />
+  <cassandra:template id="cqlTemplate" />
 
   <!-- OPTIONAL: If you are using Spring Data Cassandra Repositories, add 
     your base packages to scan here -->

target/classes/META-INF/MANIFEST.MF

@@ -1,5 +1,5 @@
 Manifest-Version: 1.0
 Built-By: nitin
-Build-Jdk: 1.8.0_05
+Build-Jdk: 1.8.0_66
 Created-By: Maven Integration for Eclipse
 

target/classes/META-INF/maven/com.test.springdata.example/SpringDataCassandra/pom.properties

@@ -1,5 +1,5 @@
 #Generated by Maven Integration for Eclipse
-#Thu Aug 20 21:21:27 EDT 2015
+#Sat Jun 04 09:22:37 EDT 2016
 version=0.0.1-SNAPSHOT
 groupId=com.test.springdata.example
 m2e.projectName=SpringDataCassandra

target/classes/application-context.xml

@@ -20,14 +20,14 @@
   <cassandra:session keyspace-name="${cassandra.keyspace}" />
 
   <!-- REQUIRED: The Default Cassandra Mapping Context used by CassandraConverter -->
-  <cassandra:mapping />
+  <cassandra:mapping entity-base-packages="com.springdata.example.model" />
 
   <!-- REQUIRED: The Default Cassandra Converter used by CassandraTemplate -->
   <cassandra:converter />
 
   <!-- REQUIRED: The Cassandra Template is the building block of all Spring 
     Data Cassandra -->
-  <cassandra:template id="cassandraTemplate" />
+  <cassandra:template id="cqlTemplate" />
 
   <!-- OPTIONAL: If you are using Spring Data Cassandra Repositories, add 
     your base packages to scan here -->