/ - Diff - D-Net - D-Net project tracking tool

« Previous | Next »

Revision 35378

Added by Nikon Gasparis over 9 years ago

updated jobsDao to support pagination while getting StoredJobs

     	public List<StoredJob> getUncompletedJobs();
     	public List<StoredJob> getJobsOfUser(String userName);
     	public List<StoredJob> getJobs(String userName, String jobType, Integer offset, Integer limit);
     	public int getJobsTotalNumber(String userName, String jobType);
     	public StoredJob getJobSummary(int jobId, String groupby);
     	/*
     	public Map<String, List<StoredJob>> getJobsOfUserSplitted(String userName);
     	public boolean getJobError(int jobId);
     	public void deleteOldCompatibilityTestsOnly(String date);
     	public void deleteJobForRegistration(String activationId);
     	public void deleteSemiCompletedRegistrationJobs(String activationId);

+    	}
     	@Override
     	public List<StoredJob> getJobsOfUser(String userName) {
     	public List<StoredJob> getJobs(String userName, String jobType, Integer offset, Integer limit) {
     		ResultSet rs = null;
     		Connection con = null;
     		PreparedStatement stmt = null;
     		List<StoredJob> retList = new ArrayList<StoredJob>();
     		logger.debug("Accessing DB to get Submitted Jobs of user: "+userName);
     		logger.debug("Accessing DB to get Submitted Jobs of user: "+userName + " and type: " + jobType);
     		try {
     			con = getConnection();
     			String query;
     			String beginQuery="SELECT j.validation_type, j.content_job_status, j.usage_job_status, j.content_job_score, j.usage_job_score, j.started, j.ended, j.user_email, j.repo, j.duration, r.short_name, j.guidelines, j.id, j.error_information, j.job_type, j.records_tested FROM jobs j, rulesets r WHERE j.guidelines = r.guidelines_acronym";
     			String endQuery=" ORDER BY j.id DESC";
     			if (userName != null) {
     				query="SELECT j.validation_type, j.content_job_status, j.usage_job_status, j.content_job_score, j.usage_job_score, j.started, j.ended, j.user_email, j.repo, j.duration, r.short_name, j.guidelines, j.id, j.error_information, j.job_type, j.records_tested FROM jobs j, rulesets r WHERE user_email=? AND j.guidelines = r.guidelines_acronym  ORDER BY j.started DESC";
     				stmt = con.prepareStatement(query);
     				stmt.setString(1, userName);
     			} else {
     				query="SELECT j.validation_type, j.content_job_status, j.usage_job_status, j.content_job_score, j.usage_job_score, j.started, j.ended, j.user_email, j.repo, j.duration, r.short_name, j.guidelines, j.id, j.error_information, j.job_type, j.records_tested FROM jobs j, rulesets r WHERE j.guidelines = r.guidelines_acronym  ORDER BY j.started DESC";
     				stmt = con.prepareStatement(query);
     				beginQuery += " AND j.user_email=?";
+    			}
     			if (jobType != null) {
     				beginQuery += " AND j.job_type=?";
+    			}
     			if (offset != null) {
     				endQuery += " OFFSET ?";
+    			}
     			if (limit != null) {
     				endQuery += " LIMIT ?";
+    			}
     			String finalQuery = beginQuery + endQuery;
     			logger.debug("finalQuery" + finalQuery);
     			stmt = con.prepareStatement(finalQuery);
     			int index = 1;
     			if (userName != null) {
     				stmt.setString(index++, userName);
+    			}
     			if (jobType != null) {
     				stmt.setString(index++, jobType);
+    			}
     			if (offset != null) {
     				stmt.setInt(index++, offset);
+    			}
     			if (limit != null) {
     				stmt.setInt(index++, limit);
+    			}
     			rs = stmt.executeQuery();
     			if (rs!=null){
     				while (rs.next()) {
-...
     						retJob.setCris(true);
     						this.getJobForCris(retJob);
+    					}
     //					else if (retJob.getJobType().equals("Compatibility Test"))
     //						compList.add(retJob);
     //					else if (retJob.getJobType().equals("Workflow Request"))
     //						workflowList.add(retJob);
     					retList.add(retJob);
+    				}
+    			}
-...
     		return retList;
+    	}
     	@Override
     	public int getJobsTotalNumber(String userName, String jobType) {
     		ResultSet rs = null;
     		Connection con = null;
     		PreparedStatement stmt = null;
     		int sum = 0;
     		logger.debug("Accessing DB to get total number of Jobs of user: "+userName + " and type: " + jobType);
     		try {
     			con = getConnection();
     			String query="SELECT count(*) as count FROM jobs WHERE";
     			if (userName != null) {
     				query += " user_email=? AND";
+    			}
     			if (jobType != null) {
     				query += " job_type=?";
+    			}
     			logger.debug(query);
     			stmt = con.prepareStatement(query);
     			int index = 1;
     			if (userName != null) {
     				stmt.setString(index++, userName);
+    			}
     			if (jobType != null) {
     				stmt.setString(index++, jobType);
+    			}
     			rs = stmt.executeQuery();
     			if (rs!=null){
     				if (rs.next()) {
     					sum = rs.getInt("count");
+    				}
+    			}
     		} catch (SQLException e) {
     			logger.error("Error while accessing DB to get total number of Jobs of user: "+e);
     		} finally {
     			if (stmt != null) {
     				try {
     					stmt.close();
     				} catch (SQLException e) {
     					logger.error("Error while accessing DB to get total number of Jobs of user: "+e);
+    				}
+    			}
+    		}
     		return sum;
+    	}
     	@Deprecated
     	public Date setJobFinished(int jobId, String error, Boolean failed) {
     		Date date_ended = null;
-...
     		Connection con = null;
     		PreparedStatement stmt = null;
     		logger.debug("Accessing DB to delete old Jobs");
     		String interval = "<=";
     		String interval = "<";
     		if (period.equalsIgnoreCase("older"))
     			interval = "<=";
     			interval = "<";
     		else if (period.equalsIgnoreCase("newer"))
     			interval = ">=";
     			interval = ">";
     		if (period.equalsIgnoreCase("exact"))
     			interval = "=";

Also available in: Unified diff

Project

General

Profile

D-Net

Revision 35378

Added by Nikon Gasparis over 9 years ago