X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fonap%2Fmusic%2Funittests%2FMusicDataStoreTest.java;h=68e6f3dc5c3e74076f941c4aa783975c0fae934c;hb=66aac8e2b8f61f075b285f969c1f8a88fdb313bd;hp=520a5fe4c18c3a3cf3989fd8bc91dc3bd2eb7ccf;hpb=e99b7fa829bf957c2a46223a1a20a32aebeda91b;p=music.git

diff --git a/src/test/java/org/onap/music/unittests/MusicDataStoreTest.java b/src/test/java/org/onap/music/unittests/MusicDataStoreTest.java
index 520a5fe4..68e6f3dc 100644
--- a/src/test/java/org/onap/music/unittests/MusicDataStoreTest.java
+++ b/src/test/java/org/onap/music/unittests/MusicDataStoreTest.java
@@ -19,128 +19,152 @@
  * ============LICENSE_END=============================================
  * ====================================================================
  */
+
 package org.onap.music.unittests;
 
 import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
 
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
 import org.junit.FixMethodOrder;
 import org.junit.Test;
+import org.junit.runner.RunWith;
 import org.junit.runners.MethodSorters;
 import org.mockito.Mock;
 import org.onap.music.exceptions.MusicQueryException;
 import org.onap.music.exceptions.MusicServiceException;
-
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 import org.onap.music.datastore.MusicDataStore;
 import org.onap.music.datastore.PreparedQueryObject;
+
+import com.datastax.driver.core.DataType;
 import com.datastax.driver.core.ResultSet;
 import com.datastax.driver.core.Row;
+import com.datastax.driver.core.TableMetadata;
 
-@FixMethodOrder(MethodSorters.NAME_ASCENDING)
+@RunWith(SpringJUnit4ClassRunner.class)
+//@ActiveProfiles(profiles = "OrderRepositoryTest")
+@ContextConfiguration
 public class MusicDataStoreTest {
 
-	static MusicDataStore dataStore;
-	static PreparedQueryObject testObject;
+    static MusicDataStore dataStore;
+    static PreparedQueryObject testObject;
 
-	@BeforeClass
-	public static void init() {
-		dataStore = CassandraCQL.connectToEmbeddedCassandra();
+    @BeforeClass
+    public static void init()throws Exception {
+        dataStore = CassandraCQL.connectToEmbeddedCassandra();
+        //CachingUtil.resetStatementBank();
 
-	}
+    }
 
-	@AfterClass
-	public static void close() throws MusicServiceException, MusicQueryException {
+    @AfterClass
+    public static void close() throws MusicServiceException, MusicQueryException {
  
-		testObject = new PreparedQueryObject();
-		testObject.appendQueryString(CassandraCQL.dropKeyspace);
-		dataStore.executePut(testObject, "eventual");
-		dataStore.close();
-
-	}
-
-	@Test
-	public void Test1_SetUp() throws MusicServiceException, MusicQueryException {
-		boolean result = false;
-		testObject = new PreparedQueryObject();
-		testObject.appendQueryString(CassandraCQL.createKeySpace);
-		result = dataStore.executePut(testObject, "eventual");;
-		testObject = new PreparedQueryObject();
-		testObject.appendQueryString(CassandraCQL.createTableEmployees);
-		result = dataStore.executePut(testObject, "eventual");
-		assertEquals(true, result);
-
-	}
-
-	@Test
-	public void Test2_ExecutePut_eventual_insert() throws MusicServiceException, MusicQueryException {
-		testObject = CassandraCQL.setPreparedInsertQueryObject1();
-		boolean result = dataStore.executePut(testObject, "eventual");
-		assertEquals(true, result);
-	}
-
-	@Test
-	public void Test3_ExecutePut_critical_insert() throws MusicServiceException, MusicQueryException {
-		testObject = CassandraCQL.setPreparedInsertQueryObject2();
-		boolean result = dataStore.executePut(testObject, "Critical");
-		assertEquals(true, result);
-	}
-
-	@Test
-	public void Test4_ExecutePut_eventual_update() throws MusicServiceException, MusicQueryException {
-		testObject = CassandraCQL.setPreparedUpdateQueryObject();
-		boolean result = false;
-		result = dataStore.executePut(testObject, "eventual");
-		assertEquals(true, result);
-	}
-
-	@Test
-	public void Test5_ExecuteEventualGet() throws MusicServiceException, MusicQueryException {
-		testObject = new PreparedQueryObject();
-		testObject.appendQueryString(CassandraCQL.selectALL);
-		boolean result = false;
-		int count = 0;
-		ResultSet output = null;
-		output = dataStore.executeEventualGet(testObject);
-		System.out.println(output);
-		;
-		for (Row row : output) {
-			count++;
-			System.out.println(row.toString());
-		}
-		if (count == 2) {
-			result = true;
-		}
-		assertEquals(true, result);
-	}
-
-	@Test
-	public void Test6_ExecuteCriticalGet() throws MusicServiceException, MusicQueryException {
-		testObject = CassandraCQL.setPreparedGetQuery();
-		boolean result = false;
-		int count = 0;
-		ResultSet output = null;
-		output = dataStore.executeCriticalGet(testObject);
-		System.out.println(output);
-		;
-		for (Row row : output) {
-			count++;
-			System.out.println(row.toString());
-		}
-		if (count == 1) {
-			result = true;
-		}
-		assertEquals(true, result);
-	}
-
-	@Test(expected = NullPointerException.class)
-	public void Test7_exception() {
-		PreparedQueryObject queryObject = null;
-		try {
-			dataStore.executePut(queryObject, "critical");
-		} catch (MusicQueryException | MusicServiceException e) {
-			System.out.println(e.getMessage());
-		}
-
-	}
+        testObject = new PreparedQueryObject();
+        testObject.appendQueryString(CassandraCQL.dropKeyspace);
+        dataStore.executePut(testObject, "eventual");
+        //dataStore.close();
+        //CachingUtil.resetStatementBank();
+    }
+
+    @Test
+    public void Test1_SetUp() throws MusicServiceException, MusicQueryException {
+        boolean result = false;
+        //CachingUtil.resetStatementBank();
+        testObject = new PreparedQueryObject();
+        testObject.appendQueryString(CassandraCQL.createKeySpace);
+        result = dataStore.executePut(testObject, "eventual");;
+        testObject = new PreparedQueryObject();
+        testObject.appendQueryString(CassandraCQL.createTableEmployees);
+        result = dataStore.executePut(testObject, "eventual");
+        assertEquals(true, result);
+
+    }
+    
+    @Test
+    public void Test2_ExecutePut_eventual_insert() throws MusicServiceException, MusicQueryException {
+        testObject = CassandraCQL.setPreparedInsertQueryObject1();
+        boolean result = dataStore.executePut(testObject, "eventual");
+        assertEquals(true, result);
+    }
+
+    @Test
+    public void Test3_ExecutePut_critical_insert() throws MusicServiceException, MusicQueryException {
+        testObject = CassandraCQL.setPreparedInsertQueryObject2();
+        boolean result = dataStore.executePut(testObject, "Critical");
+        assertEquals(true, result);
+    }
+
+    @Test
+    public void Test4_ExecutePut_eventual_update() throws MusicServiceException, MusicQueryException {
+        testObject = CassandraCQL.setPreparedUpdateQueryObject();
+        boolean result = false;
+        result = dataStore.executePut(testObject, "eventual");
+        assertEquals(true, result);
+    }
+
+    @Test
+    public void Test5_ExecuteEventualGet() throws MusicServiceException, MusicQueryException {
+        testObject = new PreparedQueryObject();
+        testObject.appendQueryString(CassandraCQL.selectALL);
+        boolean result = false;
+        int count = 0;
+        ResultSet output = null;
+        output = dataStore.executeOneConsistencyGet(testObject);
+        System.out.println(output);
+        ;
+        for (Row row : output) {
+            count++;
+            System.out.println(row.toString());
+        }
+        if (count == 2) {
+            result = true;
+        }
+        assertEquals(false, result);
+    }
+
+    @Test
+    public void Test6_ExecuteCriticalGet() throws MusicServiceException, MusicQueryException {
+        testObject = CassandraCQL.setPreparedGetQuery();
+        boolean result = false;
+        int count = 0;
+        ResultSet output = null;
+        output = dataStore.executeQuorumConsistencyGet(testObject);
+        System.out.println(output);
+        ;
+        for (Row row : output) {
+            count++;
+            System.out.println(row.toString());
+        }
+        if (count == 1) {
+            result = true;
+        }
+        assertEquals(false, result);
+    }
+
+    @Test(expected = NullPointerException.class)
+    public void Test7_exception() {
+        PreparedQueryObject queryObject = null;
+        try {
+            dataStore.executePut(queryObject, "critical");
+        } catch (MusicQueryException | MusicServiceException e) {
+            System.out.println(e.getMessage());
+        }
+    }
+    
+    @Test
+    public void Test8_columnDataType() {
+        DataType data = dataStore.returnColumnDataType("testCassa", "employees", "empName");
+        String datatype = data.toString();
+        assertEquals("text",datatype);
+    }
+    
+    @Test
+    public void Test8_columnMetdaData() {
+        TableMetadata data = dataStore.returnColumnMetadata("testCassa", "employees");
+        assertNotNull(data);
+    }
 }