aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/org/onap/music/main/VotingAppJar.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/onap/music/main/VotingAppJar.java')
-rw-r--r--src/main/java/org/onap/music/main/VotingAppJar.java115
1 files changed, 0 insertions, 115 deletions
diff --git a/src/main/java/org/onap/music/main/VotingAppJar.java b/src/main/java/org/onap/music/main/VotingAppJar.java
deleted file mode 100644
index 1c475639..00000000
--- a/src/main/java/org/onap/music/main/VotingAppJar.java
+++ /dev/null
@@ -1,115 +0,0 @@
-package org.onap.music.main;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import org.onap.music.datastore.PreparedQueryObject;
-import org.onap.music.exceptions.MusicLockingException;
-import org.onap.music.exceptions.MusicQueryException;
-import org.onap.music.exceptions.MusicServiceException;
-import org.onap.music.main.MusicCore;
-
-import com.datastax.driver.core.ResultSet;
-import com.datastax.driver.core.Row;
-
-/**
- *
- */
-public class VotingAppJar
-{
- String keyspaceName;
- String tableName;
-
- public VotingAppJar() throws MusicServiceException {
- keyspaceName = "VotingAppForMusic";
- tableName = "votevount";
-
- createVotingKeyspace();
- System.out.println("Created keyspaces");
- createVotingTable();
- System.out.println("Created tables");
-
- createEntryForCandidate("Popeye");
- createEntryForCandidate("Judy");
- createEntryForCandidate("Flash");
- createEntryForCandidate("Mickey");
- System.out.println("Created candidates");
- }
-
- private void createVotingKeyspace() throws MusicServiceException {
-
- Map<String,Object> replicationInfo = new HashMap<String, Object>();
- replicationInfo.put("'class'", "'SimpleStrategy'");
- replicationInfo.put("'replication_factor'", 1);
-
- PreparedQueryObject queryObject = new PreparedQueryObject();
- queryObject.appendQueryString(
- "CREATE KEYSPACE " + keyspaceName + " WITH REPLICATION = " + replicationInfo.toString().replaceAll("=", ":"));
-
- try {
- MusicCore.nonKeyRelatedPut(queryObject, "eventual");
- } catch (MusicServiceException e) {
- if (e.getMessage().equals("Keyspace votingappformusic already exists")) {
- // ignore
- } else {
- throw(e);
- }
- }
- }
-
- private void createVotingTable() throws MusicServiceException {
- PreparedQueryObject queryObject = new PreparedQueryObject();
- queryObject.appendQueryString(
- "CREATE TABLE " + keyspaceName + "." + tableName + " (name text PRIMARY KEY, count varint);");
-
- try {
- MusicCore.createTable(keyspaceName, tableName, queryObject, "eventual");
- } catch (MusicServiceException e) {
- if (e.getMessage().equals("Table votingappformusic.votevount already exists")) {
- //ignore
- } else {
- throw(e);
- }
- }
- }
-
- private void createEntryForCandidate(String candidateName) throws MusicServiceException {
- PreparedQueryObject queryObject = new PreparedQueryObject();
- queryObject.appendQueryString(
- "INSERT INTO " + keyspaceName + "." + tableName + " (name, count) "
- + "VALUES ('"+candidateName+"', 0);");
-
- MusicCore.nonKeyRelatedPut(queryObject, "eventual");
- }
-
- public void vote() throws MusicLockingException, MusicQueryException, MusicServiceException {
- updateVoteCount("Popeye",5);
- updateVoteCount("Judy",7);
- updateVoteCount("Mickey",8);
- updateVoteCount("Flash",2);
- }
-
- private void updateVoteCount(String candidateName, int numVotes) throws MusicLockingException, MusicQueryException, MusicServiceException {
- PreparedQueryObject queryObject = new PreparedQueryObject();
- queryObject.appendQueryString(
- "INSERT INTO " + keyspaceName + "." + tableName + " (name, count) "
- + "VALUES ('"+candidateName+"', "+numVotes+");");
- MusicCore.atomicPut(keyspaceName, tableName, candidateName, queryObject, null);
- }
-
- private void readAllVotes() throws MusicServiceException {
- PreparedQueryObject queryObject = new PreparedQueryObject();
- queryObject.appendQueryString("SELECT * FROM " + keyspaceName + "." + tableName);
- ResultSet rs = MusicCore.get(queryObject);
- for(Row candidate : rs.all()) {
- System.out.println(candidate.getString("name") + " - " + candidate.getVarint("count"));
- }
- }
-
- public static void main( String[] args ) throws Exception {
- VotingAppJar vHandle = new VotingAppJar();
- vHandle.vote();
- vHandle.readAllVotes();
- }
-
-}