added successvotes

apavlo · Aug 31, 2014 · 3912c44 · 3912c44
1 parent adbc728
commit 3912c44
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 4 deletions.
diff --git a/...s/edu/brown/benchmark/voterexperiments/demohstorecorrect/procedures/DeleteContestant.java b/...s/edu/brown/benchmark/voterexperiments/demohstorecorrect/procedures/DeleteContestant.java
@@ -118,6 +118,7 @@ public class DeleteContestant extends VoltProcedure {
 			  + "        , contestant_number ASC");
 
 	public final SQLStmt getVoteCountStmt = new SQLStmt( "SELECT totalcnt FROM proc_one_count WHERE row_id=1;");
+	public final SQLStmt getSuccessCountStmt = new SQLStmt( "SELECT successcnt FROM proc_one_count WHERE row_id=1;");
 	public final SQLStmt getActualVoteCountStmt = new SQLStmt( "SELECT totalcnt, successcnt FROM proc_one_count WHERE row_id = 1;");
 	public final SQLStmt getTrendingCountStmt = new SQLStmt("SELECT count(*) FROM w_rows;");
 	public final SQLStmt getRemainingContestants = new SQLStmt("SELECT count(*) FROM contestants;");
@@ -148,9 +149,11 @@ private void printResults() throws IOException
 			voltQueueSQL(getTrendingCountStmt);
 			tableNames.add("TrendingCount");
 			voltQueueSQL(getRemainingContestants);
-	        tableNames.add("RemainingContestants");
+			tableNames.add("remainingContestants");
 	        voltQueueSQL(getVotesTilNextDeleteStmt);
 	        tableNames.add("VotesTilNextDelete");
+	        voltQueueSQL(getSuccessCountStmt);
+	        tableNames.add("SuccessCount");
 	        //voltQueueSQL(getRemovedContestant);
 	        //tableNames.add("RemovedContestant");
 		}

diff --git a/src/benchmarks/edu/brown/benchmark/voterexperiments/demohstorecorrect/procedures/Vote.java b/src/benchmarks/edu/brown/benchmark/voterexperiments/demohstorecorrect/procedures/Vote.java
@@ -137,6 +137,7 @@ public class Vote extends VoltProcedure {
 	+ "        , contestant_number ASC");
 
 	public final SQLStmt getVoteCountStmt = new SQLStmt( "SELECT totalcnt FROM proc_one_count WHERE row_id=1;");
+	public final SQLStmt getSuccessCountStmt = new SQLStmt( "SELECT successcnt FROM proc_one_count WHERE row_id=1;");
 	public final SQLStmt getActualVoteCountStmt = new SQLStmt( "SELECT totalcnt, successcnt FROM proc_one_count WHERE row_id = 1;");
 	public final SQLStmt getTrendingCountStmt = new SQLStmt("SELECT count(*) FROM w_rows;");
 	public final SQLStmt getRemainingContestants = new SQLStmt("SELECT count(*) FROM contestants;");
@@ -166,9 +167,11 @@ private void printResults(int numVotes) throws IOException
             voltQueueSQL(getTrendingCountStmt);
             tableNames.add("TrendingCount");
             voltQueueSQL(getRemainingContestants);
-	        tableNames.add("RemainingContestants");
+			tableNames.add("remainingContestants");
 	        voltQueueSQL(getVotesTilNextDeleteStmt);
 	        tableNames.add("VotesTilNextDelete");
+	        voltQueueSQL(getSuccessCountStmt);
+	        tableNames.add("SuccessCount");
 	        //voltQueueSQL(getRemovedContestant);
 	        //tableNames.add("RemovedContestant");
         }

diff --git a/...s/edu/brown/benchmark/voterexperiments/demosstorecorrect/procedures/DeleteContestant.java b/...s/edu/brown/benchmark/voterexperiments/demosstorecorrect/procedures/DeleteContestant.java
@@ -129,6 +129,7 @@ protected void toSetTriggerTableName()
 			  + "        , contestant_number ASC");
 
 	public final SQLStmt getVoteCountStmt = new SQLStmt( "SELECT totalcnt FROM proc_one_count WHERE row_id=1;");
+	public final SQLStmt getSuccessCountStmt = new SQLStmt( "SELECT successcnt FROM proc_one_count WHERE row_id=1;");
 	public final SQLStmt getActualVoteCountStmt = new SQLStmt( "SELECT totalcnt, successcnt FROM proc_one_count WHERE row_id = 1;");
 	public final SQLStmt getTrendingCountStmt = new SQLStmt("SELECT count(*) FROM trending_leaderboard;");
 	public final SQLStmt getRemainingContestants = new SQLStmt("SELECT count(*) FROM contestants;");
@@ -159,9 +160,11 @@ private void printResults() throws IOException
 			voltQueueSQL(getTrendingCountStmt);
 			tableNames.add("TrendingCount");
 			voltQueueSQL(getRemainingContestants);
-	        tableNames.add("RemainingContestants");
+			tableNames.add("remainingContestants");
 	        voltQueueSQL(getVotesTilNextDeleteStmt);
 	        tableNames.add("VotesTilNextDelete");
+	        voltQueueSQL(getSuccessCountStmt);
+	        tableNames.add("SuccessCount");
 	        //voltQueueSQL(getRemovedContestant);
 	        //tableNames.add("RemovedContestant");
 		}

diff --git a/src/benchmarks/edu/brown/benchmark/voterexperiments/demosstorecorrect/procedures/Vote.java b/src/benchmarks/edu/brown/benchmark/voterexperiments/demosstorecorrect/procedures/Vote.java
@@ -137,6 +137,7 @@ public class Vote extends VoltProcedure {
 	+ "        , contestant_number ASC");
 
 	public final SQLStmt getVoteCountStmt = new SQLStmt( "SELECT totalcnt FROM proc_one_count WHERE row_id=1;");
+	public final SQLStmt getSuccessCountStmt = new SQLStmt( "SELECT successcnt FROM proc_one_count WHERE row_id=1;");
 	public final SQLStmt getActualVoteCountStmt = new SQLStmt( "SELECT totalcnt, successcnt FROM proc_one_count WHERE row_id = 1;");
 	public final SQLStmt getTrendingCountStmt = new SQLStmt("SELECT count(*) FROM trending_leaderboard;");
 	public final SQLStmt getRemainingContestants = new SQLStmt("SELECT count(*) FROM contestants;");
@@ -166,9 +167,11 @@ private void printResults(int numVotes) throws IOException
             voltQueueSQL(getTrendingCountStmt);
             tableNames.add("TrendingCount");
             voltQueueSQL(getRemainingContestants);
-	        tableNames.add("RemainingContestants");
+			tableNames.add("remainingContestants");
 	        voltQueueSQL(getVotesTilNextDeleteStmt);
 	        tableNames.add("VotesTilNextDelete");
+	        voltQueueSQL(getSuccessCountStmt);
+	        tableNames.add("SuccessCount");
 	        //voltQueueSQL(getRemovedContestant);
 	        //tableNames.add("RemovedContestant");
         }