summaryrefslogtreecommitdiffstats
path: root/collaboration/GSoC-2011-Eranda/cassandra/src/test/java
diff options
context:
space:
mode:
authoreranda <eranda@13f79535-47bb-0310-9956-ffa450edef68>2011-07-09 09:02:32 +0000
committereranda <eranda@13f79535-47bb-0310-9956-ffa450edef68>2011-07-09 09:02:32 +0000
commit611747a6fea6b03c16d955af639d101319cf0b7f (patch)
tree314c6e820ba60d23fe00e9e44fad7cd5bf7c3fa9 /collaboration/GSoC-2011-Eranda/cassandra/src/test/java
parent800d0da7d863cc75004b9e034646d457156edf97 (diff)
1. Remove static variable in SessionFactory
2. Set spaces to 4 3. Exception handling 4. Rename *Test to *TestCase 5. Convert test cases in to JUnit 6. Rename addValue() method in Group.java to addEntry() 7. Updated the addEntry method signature to accept String type only git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1144620 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'collaboration/GSoC-2011-Eranda/cassandra/src/test/java')
-rw-r--r--collaboration/GSoC-2011-Eranda/cassandra/src/test/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraTest.java68
-rw-r--r--collaboration/GSoC-2011-Eranda/cassandra/src/test/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraTestCase.java96
2 files changed, 96 insertions, 68 deletions
diff --git a/collaboration/GSoC-2011-Eranda/cassandra/src/test/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraTest.java b/collaboration/GSoC-2011-Eranda/cassandra/src/test/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraTest.java
deleted file mode 100644
index 8ca38d2f9f..0000000000
--- a/collaboration/GSoC-2011-Eranda/cassandra/src/test/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraTest.java
+++ /dev/null
@@ -1,68 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you 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.apache.tuscany.nosqldatastore.cassandra;
-
-import org.apache.tuscany.nosqldatastore.Database;
-import org.apache.tuscany.nosqldatastore.Group;
-import org.apache.tuscany.nosqldatastore.Session;
-import org.apache.tuscany.nosqldatastore.SessionFactory;
-
-
-public class CassandraTest {
-
- Session session;
-
- public CassandraTest(){
- session = SessionFactory.getCassandraSession();
- }
-
- public static void main(String[] args){
- CassandraTest test = new CassandraTest();
- test.create();
- test.delete();
- }
-
- public void create(){
- Database db = session.createDatabase("TwitApp");
- Group group1 = db.createGroup("twits");
-
- group1.addEntry("twitName1", "Here I am");
- group1.addEntry("twitName2", "I am not here");
- group1.addEntry("twitName3", "Sometimes");
-
- Group group2 = db.createGroup("users");
-
- group2.addEntry("userName1", "eranda");
- group2.addEntry("userName2", "ishara");
- group2.addEntry("userName3", "ravi");
-
- group2.deleteEntry("userName3");
- group2.updateEntry("userName2", "eranda");
-
- System.out.println(group2.getValue("userName1"));
- }
-
- public void delete(){
- Database db = session.getDatabase("TwitApp");
- db.deleteGroup("twits");
- db.deleteGroup("users");
- session.deleteDatabase("TwitApp");
- }
-
-}
diff --git a/collaboration/GSoC-2011-Eranda/cassandra/src/test/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraTestCase.java b/collaboration/GSoC-2011-Eranda/cassandra/src/test/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraTestCase.java
new file mode 100644
index 0000000000..267808dfa1
--- /dev/null
+++ b/collaboration/GSoC-2011-Eranda/cassandra/src/test/java/org/apache/tuscany/nosqldatastore/cassandra/CassandraTestCase.java
@@ -0,0 +1,96 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you 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.apache.tuscany.nosqldatastore.cassandra;
+
+import org.apache.tuscany.nosqldatastore.Database;
+import org.apache.tuscany.nosqldatastore.Group;
+import org.apache.tuscany.nosqldatastore.Session;
+import org.apache.tuscany.nosqldatastore.SessionFactory;
+import org.apache.tuscany.nosqldatastore.exception.*;
+import org.junit.Before;
+import org.junit.Test;
+
+import org.junit.Assert;
+
+
+public class CassandraTestCase {
+
+ private Session session;
+
+ @Before
+ public void init(){
+ SessionFactory factory = new SessionFactory();
+ session = factory.getCassandraSession();
+ }
+
+ @Test
+ public void testAddEntry() throws Exception {
+ Database db = session.createDatabase("TwitApp");
+ Group group = db.createGroup("twits");
+
+ group.addEntry("twitName1", "Here I am");
+ group.addEntry("twitName2", "I am not here");
+ group.addEntry("twitName3", "Sometimes");
+
+ Assert.assertEquals(group.getEntry("twitName1"), "Here I am");
+ Assert.assertEquals(group.getEntry("twitName2"), "I am not here");
+ Assert.assertEquals(group.getEntry("twitName3"), "Sometimes");
+
+ db.deleteGroup("twits");
+ session.deleteDatabase("TwitApp");
+ }
+
+ @Test
+ public void testDeleteEntry() throws Exception {
+ Database db = session.createDatabase("TwitApp");
+ Group group = db.createGroup("twits");
+
+ group.addEntry("twitName1", "Here I am");
+ group.addEntry("twitName2", "I am not here");
+ group.addEntry("twitName3", "Sometimes");
+
+ group.deleteEntry("twitName1");
+
+ try {
+ Assert.assertNull(group.getEntry("twitName1"));
+ Assert.fail("Deleted entry exists");
+ } catch(EntryNotFoundException e) {
+ //Expected
+ }
+
+ db.deleteGroup("twits");
+ session.deleteDatabase("TwitApp");
+ }
+
+ @Test
+ public void testUpdateEntry() throws Exception {
+ Database db = session.createDatabase("TwitApp");
+ Group group = db.createGroup("twits");
+
+ group.addEntry("twitName1", "Here I am");
+ group.addEntry("twitName2", "I am not here");
+ group.addEntry("twitName3", "Sometimes");
+
+ group.updateEntry("twitName3", "Never");
+ Assert.assertEquals(group.getEntry("twitName3"), "Never");
+
+ db.deleteGroup("twits");
+ session.deleteDatabase("TwitApp");
+ }
+}