Upstream/Jobs
1
0
Fork 0
mirror of https://github.com/Zrips/Jobs.git synced 2024-11-26 04:25:15 +01:00
Code Issues Projects Releases Wiki Activity

Only count the jobIds from database to prevent workers are set to 1 if there is no workers

Browse Source
This commit is contained in:
montlikadani 2020-04-13 14:56:12 +02:00
parent c4d0d0101a
commit e1d22533d1
1 changed files with 7 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/main/java/com/gamingmesh/jobs/dao/JobsDAO.java
View File

@ -1190,28 +1190,13 @@ public abstract class JobsDAO {
PreparedStatement prest = null;
ResultSet res = null;
try {
prest = conn.prepareStatement("SELECT COUNT(*) FROM `" + getJobsTableName() + "` WHERE `" + JobsTableFields.job + "` = ?;");
prest.setString(1, JobName);
res = prest.executeQuery();
if (res.next()) {
count += res.getInt(1);
}
if (count == 0) {
close(prest);
close(res);
prest = null;
res = null;
Job job = Jobs.getJob(JobName);
if (job != null && job.getId() != 0) {
prest = conn.prepareStatement("SELECT COUNT(*) FROM `" + getJobsTableName() + "` WHERE `" + JobsTableFields.jobid + "` = ?;");
prest.setInt(1, job.getId());
res = prest.executeQuery();
if (res.next()) {
count += res.getInt(1);
}
Job job = Jobs.getJob(JobName);
if (job != null && job.getId() != 0) {
prest = conn.prepareStatement("SELECT COUNT(*) FROM `" + getJobsTableName() + "` WHERE `" + JobsTableFields.jobid + "` = ?;");
prest.setInt(1, job.getId());
res = prest.executeQuery();
if (res.next()) {
count += res.getInt(1);
}
}
} catch (SQLException e) {