Functioning application context.

src/main/java/org/springframework/data/cassandra/repository/CassandraPersistenceExceptionTranslator.java

@@ -0,0 +1,37 @@
+/*
+ * Copyright 2010-2011 the original author or authors.
+ *
+ * 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
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * 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.
+ */
+package org.springframework.data.cassandra.repository;
+
+import org.springframework.dao.DataAccessException;
+import org.springframework.dao.support.PersistenceExceptionTranslator;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Brian O'Neill
+ */
+@Component
+public class CassandraPersistenceExceptionTranslator implements PersistenceExceptionTranslator {
+
+/*
+ * (non-Javadoc)
+ *
+ * @see org.springframework.dao.support.PersistenceExceptionTranslator#
+ * translateExceptionIfPossible(java.lang.RuntimeException)
+ */
+public DataAccessException translateExceptionIfPossible(RuntimeException ex) {
+return null;
+}
+}

src/test/java/org/springframework/data/cassandra/repository/UserRepositoryTest.java

@@ -0,0 +1,27 @@
+package org.springframework.data.cassandra.repository;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.cassandra.repository.example.User;
+import org.springframework.data.cassandra.repository.example.UserRepository;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration("classpath:beans.xml")
+public class UserRepositoryTest {
+ @Autowired
+ UserRepository userRepository;
+
+ @Test
+ public void testWrite() {
+ User user = new User();
+ user.setUserId("0001");
+ user.setFirstName("John");
+ user.setLastName("Smith");
+ user.setCity("London"); 
+ userRepository.save(user);
+ }
+
+}

src/test/java/org/springframework/data/cassandra/repository/example/User.java

@@ -0,0 +1,58 @@
+package org.springframework.data.cassandra.repository.example;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+
+@Entity
+@Table(name = "users", schema = "KunderaExamples@cassandra_pu")
+public class User {
+ @Id
+ private String userId;
+
+ @Column(name = "first_name")
+ private String firstName;
+
+ @Column(name = "last_name")
+ private String lastName;
+
+ @Column(name = "city")
+ private String city;
+
+ public User() {
+ }
+
+ public String getUserId() {
+ return userId;
+ }
+
+ public void setUserId(String userId) {
+ this.userId = userId;
+ }
+
+ public String getFirstName() {
+ return firstName;
+ }
+
+ public void setFirstName(String firstName) {
+ this.firstName = firstName;
+ }
+
+ public String getLastName() {
+ return lastName;
+ }
+
+ public void setLastName(String lastName) {
+ this.lastName = lastName;
+ }
+
+ public String getCity() {
+ return city;
+ }
+
+ public void setCity(String city) {
+ this.city = city;
+ }
+}

src/test/java/org/springframework/data/cassandra/repository/example/UserRepository.java

@@ -0,0 +1,8 @@
+package org.springframework.data.cassandra.repository.example;
+
+import org.springframework.data.cassandra.repository.support.SimpleCassandraRepository;
+import org.springframework.stereotype.Component;
+
+@Component
+public class UserRepository extends SimpleCassandraRepository<User, String> {
+}

src/test/resources/beans.xml

@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
+xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jpa="http://www.springframework.org/schema/data/jpa"
+xmlns:task="http://www.springframework.org/schema/task"
+xsi:schemaLocation="http://www.springframework.org/schema/beans
+ http://www.springframework.org/schema/beans/spring-beans.xsd
+ http://www.springframework.org/schema/context
+ http://www.springframework.org/schema/context/spring-context.xsd
+ http://www.springframework.org/schema/tx
+ http://www.springframework.org/schema/tx/spring-tx.xsd
+ http://www.springframework.org/schema/task 
+ http://www.springframework.org/schema/task/spring-task.xsd
+ http://www.springframework.org/schema/data/jpa 
+ http://www.springframework.org/schema/data/jpa/spring-jpa.xsd">
+
+<jpa:repositories base-package="org.springframework.data.cassandra" />
+
+<context:component-scan base-package="org.springframework.data.cassandra" />
+
+<bean id="cassandraExceptionTranslator"
+class="org.springframework.data.cassandra.repository.CassandraPersistenceExceptionTranslator" />
+
+<bean class="org.springframework.orm.jpa.support.PersistenceAnnotationBeanPostProcessor" />
+
+<bean id="entityManagerFactory"
+class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
+<property name="persistenceUnitName" value="cassandra_pu" />
+</bean>
+
+<bean id="userRepository"
+class="org.springframework.data.cassandra.repository.example.UserRepository" />
+
+</beans>