D-Net

import eu.dnetlib.domain.functionality.validator.JobResultEntry;

	List<StoredJob> getJobSummary(List<String> baseUrls, int size) throws DaoException;

import java.util.stream.Collectors;

	@Override

	public List<StoredJob> getJobSummary(List<String> baseUrls, int size) throws DaoException {

		ResultSet rs = null;

		Connection con = null;

		PreparedStatement stmt = null;

		List<JobResultEntry> resultEntries = new ArrayList<JobResultEntry>();

		StringBuilder builder = new StringBuilder();

		List<StoredJob> storedJobs = new ArrayList<>();

		for(int i = 0; i < baseUrls.size(); i++ ) {

			builder.append("?,");

		}

		Map<Integer, List<JobResultEntry>> results = new HashMap<>();

		try {

			con = getConnection();

			String query="select rules.name, rules.description, rules.weight, rules.mandatory, total, successes, rules.id, rules.job_type, job_results.job_id from job_results join rules on job_results.rule_id = rules.id join jobs on jobs.id = job_results.job_id where jobs.repo in ("+ builder.deleteCharAt( builder.length() -1 ).toString() +") order by job_results.job_id limit " + size;

			stmt = con.prepareStatement(query);

			int index = 1;

			for( String o : baseUrls) {

				stmt.setString(  index++, o ); // or whatever it applies

			}

			rs = stmt.executeQuery();

			JobResultEntry retEntry = new JobResultEntry();

			if (rs!=null){

				int oldId = 0;

				while (rs.next()) {

					if(oldId!=rs.getInt("job_id")){

						results.put(oldId,resultEntries);

						logger.debug("Old id:"+oldId + " new id:"+rs.getInt("job_id") + " size:"+resultEntries.size());

						System.out.println("Old id:"+oldId + " new id:"+rs.getInt("job_id") + " size:"+resultEntries.size());

						oldId=rs.getInt("job_id");

						resultEntries = new ArrayList<>();

					}

					retEntry.setName(rs.getString(1));

					retEntry.setDescription(rs.getString(2));

					retEntry.setWeight(rs.getInt(3));

					retEntry.setMandatory(rs.getBoolean(4));

					retEntry.setRuleId(rs.getInt(7));

					retEntry.setType(rs.getString("job_type"));

					retEntry.setErrors(this.getValidationErrors(rs.getInt("job_id"), retEntry.getRuleId()));

					int total = rs.getInt(5);

					int successes = rs.getInt(6);

					if (rs.getInt(5) > 0)

						retEntry.setSuccesses(successes + "/" + total);

					else

						retEntry.setSuccesses("--");

					if (successes < total)

						retEntry.setHasErrors(true);

					else

						retEntry.setHasErrors(false);

					resultEntries.add(retEntry);

				}

				if(oldId!=0)

					results.put(oldId,resultEntries);

				if(results.get(0)!=null)

					results.remove(0);

				for(Map.Entry<Integer,List<JobResultEntry>> entry : results.entrySet()){

					StoredJob storedJob = this.get(entry.getKey());

					storedJob.setResultEntries(entry.getValue());

					storedJob.setFilteredScores(this.getScoresPerGroupBy(entry.getKey()));

					storedJob.getFilteredScores().put("all", storedJob.getContentJobScore());

					storedJobs.add(storedJob);

				}

			}

		} catch (Exception e) {

			logger.error("Error while Accessing DB to get all Jobs entries.", e);

			throw new DaoException(e);

		} finally {

			if (stmt != null) {

				try {

					stmt.close();

				} catch (SQLException e) {

					logger.error("Error while Accessing DB to get all Jobs entries.", e);

					throw new DaoException(e);

				}

			}

			closeConnection(con);

		}

		return storedJobs;

	}