Add waiting jobs to counters

Author: lukfor

src/main/java/cloudgene/mapred/api/v2/server/GetCounter.java

@@ -2,6 +2,7 @@
 
 import java.util.Map;
 
+import cloudgene.mapred.database.JobDao;
 import org.restlet.representation.Representation;
 import org.restlet.representation.StringRepresentation;
 import org.restlet.resource.Get;
@@ -41,10 +42,13 @@ public Representation get() {
 		for (String key : counters.keySet()) {
 			jsonWaiting.put(key, counters.get(key));
 		}
+		JobDao jobDao = new JobDao(getDatabase());
+		int waitingJobs = jobDao.findAllByState(AbstractJob.STATE_WAITING).size();
+		jsonWaiting.put("runs", waitingJobs);
 		jsonCounters.put("waiting", jsonWaiting);
 
-		UserDao dao = new UserDao(getDatabase());		
-		jsonCounters.put("users", dao.findAll().size());
+		UserDao dao = new UserDao(getDatabase());
+		jsonCounters.put("users", dao.countAll());
 
 
 		return new StringRepresentation(jsonCounters.toString());

src/main/java/cloudgene/mapred/database/JobDao.java

@@ -412,6 +412,31 @@ public List<AbstractJob> findAllByState(int state) {
 		}
 	}
 
+	@SuppressWarnings("unchecked")
+	public int countAllByState(int state) {
+
+		StringBuilder sql = new StringBuilder();
+		sql.append("select count(*) ");
+		sql.append("from job ");
+		sql.append("where state = ? ");
+
+		Object[] params = new Object[1];
+		params[0] = state;
+
+		int result = 0;
+
+		try {
+			result = (Integer) queryForObject(sql.toString(), params, new IntegerMapper());
+			log.debug("count all old jobs successful. results: " + result);
+
+			return result;
+		} catch (SQLException e) {
+			log.error("count all old jobs failed", e);
+			return 0;
+		}
+	}
+
+
 	public AbstractJob findById(String id) {
 
 		return findById(id, true);

src/main/java/cloudgene/mapred/database/UserDao.java

@@ -208,7 +208,28 @@ public List<User> findAll() {
 		}
 		return result;
 	}
-	
+
+	@SuppressWarnings("unchecked")
+	public int countAll() {
+
+		StringBuilder sql = new StringBuilder();
+		sql.append("select count(*) ");
+		sql.append("from `user` ");
+
+		int result = 0;
+
+		try {
+			result = (Integer) queryForObject(sql.toString(), new IntegerMapper());
+			log.debug("count all users successful. results: " + result);
+
+			return result;
+		} catch (SQLException e) {
+			log.error("count all users failed", e);
+			return 0;
+		}
+	}
+
+
 	@SuppressWarnings("unchecked")
 	public List<User> findByQuery(String query) {