no message
This commit is contained in:
210
src/TestingSystem/Common/TasksDatabase.java
Normal file
210
src/TestingSystem/Common/TasksDatabase.java
Normal file
@@ -0,0 +1,210 @@
|
||||
package TestingSystem.Common;
|
||||
import Common.Constants;
|
||||
import Common.Database.SQLITE.SQLiteDatabase;
|
||||
import Common.Global;
|
||||
import GlobalData.Settings.SettingName;
|
||||
import TestingSystem.SAPFOR.SapforTask.SapforTasksDBTable;
|
||||
import TestingSystem.SAPFOR.SapforTasksPackage.SapforTasksPackage;
|
||||
import TestingSystem.SAPFOR.SapforTasksPackage.SapforTasksPackagesDBTable;
|
||||
import TestingSystem.Common.TSetting.TSetting;
|
||||
import TestingSystem.Common.TSetting.TSettingsDBTable;
|
||||
import TestingSystem.DVM.Tasks.TestCompilationTask;
|
||||
import TestingSystem.DVM.Tasks.TestCompilationTasksDBTable;
|
||||
import TestingSystem.DVM.Tasks.TestRunTask;
|
||||
import TestingSystem.DVM.Tasks.TestRunTasksDBTable;
|
||||
import TestingSystem.DVM.TasksPackage.TasksPackage;
|
||||
import TestingSystem.DVM.TasksPackage.TasksPackageDBTable;
|
||||
import TestingSystem.DVM.TasksPackage.TasksPackageState;
|
||||
import TestingSystem.Common.TasksPackageToKill.TasksPackageToKillDBTable;
|
||||
import Visual_DVM_2021.Passes.PassCode_2021;
|
||||
import javafx.util.Pair;
|
||||
|
||||
import java.io.File;
|
||||
import java.nio.file.Paths;
|
||||
import java.sql.PreparedStatement;
|
||||
import java.util.LinkedHashMap;
|
||||
import java.util.Vector;
|
||||
public class TasksDatabase extends SQLiteDatabase {
|
||||
public TSettingsDBTable settings;
|
||||
public TasksPackageDBTable packages;
|
||||
public TasksPackageToKillDBTable packagesToKill;
|
||||
public TestCompilationTasksDBTable testCompilationTasks;
|
||||
public TestRunTasksDBTable testRunTasks;
|
||||
PreparedStatement selectPackageRunTasks = null;
|
||||
//----------
|
||||
public SapforTasksPackagesDBTable sapforTasksPackages;
|
||||
public SapforTasksDBTable sapforTasks;
|
||||
//---------
|
||||
public TasksDatabase(String email) {
|
||||
super(Paths.get(Global.DataDirectory.getAbsolutePath(), email + "_" + Constants.tests_db_name + ".sqlite").toFile());
|
||||
}
|
||||
public TasksDatabase(File file_in) {
|
||||
super(file_in);
|
||||
}
|
||||
public void setFile(String email) {
|
||||
file = Paths.get(Global.DataDirectory.getAbsolutePath(), email + "_" + Constants.tests_db_name + ".sqlite").toFile();
|
||||
}
|
||||
@Override
|
||||
protected void initAllTables() throws Exception {
|
||||
addTable(settings = new TSettingsDBTable());
|
||||
addTable(packages = new TasksPackageDBTable());
|
||||
addTable(testCompilationTasks = new TestCompilationTasksDBTable());
|
||||
addTable(testRunTasks = new TestRunTasksDBTable());
|
||||
addTable(packagesToKill = new TasksPackageToKillDBTable());
|
||||
//-----------
|
||||
addTable(sapforTasksPackages = new SapforTasksPackagesDBTable());
|
||||
addTable(sapforTasks = new SapforTasksDBTable());
|
||||
}
|
||||
@Override
|
||||
public void Init() throws Exception {
|
||||
if (!settings.containsKey(SettingName.Email))
|
||||
Insert(new TSetting(SettingName.Email, 0));
|
||||
if (!settings.containsKey(SettingName.Pause))
|
||||
Insert(new TSetting(SettingName.Pause, 0));
|
||||
if (!settings.containsKey(SettingName.Queue))
|
||||
Insert(new TSetting(SettingName.Queue, 0));
|
||||
}
|
||||
@Override
|
||||
public PassCode_2021 getSynchronizePassCode() {
|
||||
return PassCode_2021.SynchronizeTestsTasks;
|
||||
}
|
||||
@Override
|
||||
public void prepareTablesStatements() throws Exception {
|
||||
super.prepareTablesStatements();
|
||||
selectPackageRunTasks = conn.prepareStatement("SELECT * FROM TestRunTask WHERE taskspackage_id = ?");
|
||||
}
|
||||
@Override
|
||||
protected void disconnect() throws Exception {
|
||||
if (selectPackageRunTasks != null) {
|
||||
selectPackageRunTasks.close();
|
||||
selectPackageRunTasks = null;
|
||||
}
|
||||
super.disconnect();
|
||||
}
|
||||
public LinkedHashMap<Long, TestRunTask> getPackageRunTasks(String package_id) throws Exception {
|
||||
LinkedHashMap<Long, TestRunTask> res = new LinkedHashMap<>();
|
||||
selectPackageRunTasks.setString(1, package_id);
|
||||
resSet = selectPackageRunTasks.executeQuery();
|
||||
while (resSet.next()) {
|
||||
Pair<Long, TestRunTask> record = readRecord(testRunTasks);
|
||||
res.put(record.getKey(), record.getValue());
|
||||
}
|
||||
return res;
|
||||
}
|
||||
//------
|
||||
public TasksPackage getFirstActivePackage() {
|
||||
TasksPackage first_active = null;
|
||||
TasksPackage first_queued = null;
|
||||
if (!packages.Data.isEmpty()) {
|
||||
for (TasksPackage p : packages.Data.values()) {
|
||||
switch (p.state) {
|
||||
case Done:
|
||||
case Aborted:
|
||||
break;
|
||||
case Queued:
|
||||
if (first_queued == null) first_queued = p;
|
||||
break;
|
||||
default:
|
||||
if (first_active == null) first_active = p; //это и будет первый активный.
|
||||
break;
|
||||
}
|
||||
}
|
||||
if (first_active != null) return first_active;
|
||||
if (first_queued != null) {
|
||||
first_queued.state = TasksPackageState.TestsSynchronize;
|
||||
try {
|
||||
Update(first_queued);
|
||||
} catch (Exception ex) {
|
||||
ex.printStackTrace();
|
||||
}
|
||||
}
|
||||
return first_queued;
|
||||
}
|
||||
return null;
|
||||
}
|
||||
public LinkedHashMap<Long, TestCompilationTask> getPackageCompilationTasks(TasksPackage tasksPackage) {
|
||||
if (tasksPackage == null) return null;
|
||||
LinkedHashMap<Long, TestCompilationTask> res = new LinkedHashMap<>();
|
||||
for (TestCompilationTask srcCompilationTask : testCompilationTasks.Data.values()) {
|
||||
if (srcCompilationTask.taskspackage_id.equals(tasksPackage.id)) {
|
||||
TestCompilationTask dstCompilationTask = new TestCompilationTask(srcCompilationTask);
|
||||
dstCompilationTask.runTasks = new Vector<>();
|
||||
for (TestRunTask testRunTask : testRunTasks.Data.values())
|
||||
if (testRunTask.testcompilationtask_id == srcCompilationTask.id)
|
||||
dstCompilationTask.runTasks.add(new TestRunTask(testRunTask));
|
||||
res.put(dstCompilationTask.id, dstCompilationTask);
|
||||
}
|
||||
}
|
||||
return res;
|
||||
}
|
||||
public long getQueueSize(long date) throws Exception {
|
||||
long sum = 0L;
|
||||
for (TasksPackage tasksPackage : packages.Data.values()) {
|
||||
if (tasksPackage.StartDate < date) {
|
||||
Vector<TestRunTask> tasks = new Vector<>(getPackageRunTasks(tasksPackage.id).values());
|
||||
for (TestRunTask testRunTask : tasks)
|
||||
if (testRunTask.compilation_state.isActive() || testRunTask.state.isActive())
|
||||
sum++;
|
||||
}
|
||||
}
|
||||
return sum;
|
||||
}
|
||||
//--
|
||||
/*
|
||||
public Vector<TasksPackage> getActivePackages() {
|
||||
Vector<TasksPackage> res = new Vector<>();
|
||||
for (TasksPackage p : packages.Data.values())
|
||||
if (!p.state.equals(TasksPackageState.Done))
|
||||
res.add(p);
|
||||
return res;
|
||||
}
|
||||
public Vector<SapforTasksPackage> getActiveSapforPackages() {
|
||||
Vector<SapforTasksPackage> res = new Vector<>();
|
||||
for (SapforTasksPackage p : sapforTasksPackages.Data.values())
|
||||
if (!p.state.equals(TasksPackageState.Done))
|
||||
res.add(p);
|
||||
return res;
|
||||
}
|
||||
*/
|
||||
public SapforTasksPackage getFirstActiveSapforPackage() {
|
||||
SapforTasksPackage first_active = null;
|
||||
SapforTasksPackage first_queued = null;
|
||||
if (!sapforTasksPackages.Data.isEmpty()) {
|
||||
for (SapforTasksPackage p : sapforTasksPackages.Data.values()) {
|
||||
switch (p.state) {
|
||||
case Done:
|
||||
case Aborted:
|
||||
break;
|
||||
case Queued:
|
||||
if (first_queued == null) first_queued = p;
|
||||
break;
|
||||
default:
|
||||
if (first_active == null) first_active = p; //это и будет первый активный.
|
||||
break;
|
||||
}
|
||||
}
|
||||
if (first_active != null) return first_active;
|
||||
if (first_queued != null) {
|
||||
first_queued.state = TasksPackageState.TestsSynchronize;
|
||||
try {
|
||||
Update(first_queued);
|
||||
} catch (Exception ex) {
|
||||
ex.printStackTrace();
|
||||
}
|
||||
}
|
||||
return first_queued;
|
||||
}
|
||||
return null;
|
||||
}
|
||||
public boolean hasActivePackages() {
|
||||
for (TasksPackage tasksPackage : packages.Data.values()) {
|
||||
if (tasksPackage.state.isActive())
|
||||
return true;
|
||||
}
|
||||
for (SapforTasksPackage sapforTasksPackage : sapforTasksPackages.Data.values()) {
|
||||
if (sapforTasksPackage.state.isActive())
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user