Skip to content

Commit

Permalink
adding spring and cql example
Browse files Browse the repository at this point in the history
  • Loading branch information
jsevellec committed Jun 21, 2013
1 parent 1a7e743 commit c62f646
Show file tree
Hide file tree
Showing 6 changed files with 104 additions and 4 deletions.
22 changes: 19 additions & 3 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -27,11 +27,27 @@
</dependency>
<dependency>
<groupId>org.cassandraunit</groupId>
<artifactId>cassandra-unit</artifactId>
<version>1.1.1.3-SNAPSHOT</version>
<artifactId>cassandra-unit-spring</artifactId>
<version>1.2.0.1</version>
<scope>test</scope>
</dependency>
</dependencies>
<dependency>
<groupId>org.hectorclient</groupId>
<artifactId>hector-core</artifactId>
<version>1.1-4</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
<exclusion>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
</exclusion>
</exclusions>
</dependency>

</dependencies>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
import me.prettyprint.hector.api.ddl.KeyspaceDefinition;
import me.prettyprint.hector.api.factory.HFactory;

import org.apache.cassandra.config.ConfigurationException;
import org.apache.cassandra.exceptions.ConfigurationException;
import org.apache.thrift.transport.TTransportException;
import org.cassandraunit.utils.EmbeddedCassandraServerHelper;
import org.junit.Before;
Expand Down
24 changes: 24 additions & 0 deletions src/test/java/org/cassandraunit/test/cql/CQLScriptLoadTest.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
package org.cassandraunit.test.cql;

import com.datastax.driver.core.ResultSet;
import org.cassandraunit.CassandraCQLUnit;
import org.cassandraunit.dataset.cql.ClassPathCQLDataSet;
import org.junit.Rule;
import org.junit.Test;

import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.is;

public class CQLScriptLoadTest {

@Rule
public CassandraCQLUnit cassandraCQLUnit = new CassandraCQLUnit(new ClassPathCQLDataSet("simple.cql","keyspaceNameToCreate"));

@Test
public void should_have_started_and_execute_cql_script() throws Exception {
ResultSet result = cassandraCQLUnit.session.execute("select * from mytable WHERE id='myKey01'");
assertThat(result.iterator().next().getString("value"), is("myValue01"));


}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,41 @@
package org.cassandraunit.test.spring.cql;

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Session;
import org.cassandraunit.CassandraCQLUnit;
import org.cassandraunit.dataset.cql.ClassPathCQLDataSet;
import org.cassandraunit.spring.CassandraDataSet;
import org.cassandraunit.spring.CassandraUnitTestExecutionListener;
import org.cassandraunit.spring.EmbeddedCassandra;
import org.junit.Rule;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.TestExecutionListeners;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.is;
import static org.junit.Assert.assertEquals;

@RunWith(SpringJUnit4ClassRunner.class)
@TestExecutionListeners({ CassandraUnitTestExecutionListener.class })
@CassandraDataSet(value = { "simple.cql" })
@EmbeddedCassandra
public class SpringCQLScriptLoadTest {

@Test
public void should_have_started_and_execute_cql_script() throws Exception {
Cluster cluster = Cluster.builder()
.addContactPoints("127.0.0.1")
.withPort(9142)
.build();
Session session = cluster.connect("cassandra_unit_keyspace");

ResultSet result = session.execute("select * from mytable WHERE id='myKey01'");
assertThat(result.iterator().next().getString("value"), is("myValue01"));


}
}
8 changes: 8 additions & 0 deletions src/test/resources/simple.cql
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
CREATE TABLE myTable(
id varchar,
value varchar,
PRIMARY KEY(id));

INSERT INTO myTable(id, value) values('myKey01','myValue01');

INSERT INTO myTable(id, value) values('myKey02','myValue02');
11 changes: 11 additions & 0 deletions src/test/resources/simpleWithCreateKeyspace.cql
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
CREATE KEYSPACE mykeyspace WITH replication={'class' : 'SimpleStrategy', 'replication_factor':1};
USE mykeyspace;

CREATE TABLE myTable(
id varchar,
value varchar,
PRIMARY KEY(id));

INSERT INTO myTable(id, value) values('myKey01','myValue01');

INSERT INTO myTable(id, value) values('myKey02','myValue02');

0 comments on commit c62f646

Please sign in to comment.