diff options
Diffstat (limited to 'vid-automation/src/main/java/vid/automation/test/services/AsyncJobsService.java')
-rw-r--r-- | vid-automation/src/main/java/vid/automation/test/services/AsyncJobsService.java | 44 |
1 files changed, 44 insertions, 0 deletions
diff --git a/vid-automation/src/main/java/vid/automation/test/services/AsyncJobsService.java b/vid-automation/src/main/java/vid/automation/test/services/AsyncJobsService.java new file mode 100644 index 000000000..01158fa66 --- /dev/null +++ b/vid-automation/src/main/java/vid/automation/test/services/AsyncJobsService.java @@ -0,0 +1,44 @@ +package vid.automation.test.services; + +import vid.automation.test.utils.DB_CONFIG; + +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.SQLException; +import java.sql.Statement; + +public class AsyncJobsService { + + public void dropAllAsyncJobs() { + System.out.println("Connecting database..."); + + try (Connection connection = DriverManager.getConnection(DB_CONFIG.url, DB_CONFIG.username, DB_CONFIG.password)) { + System.out.println("Database connected!"); + + Statement stmt = connection.createStatement(); + stmt.addBatch("DELETE FROM `vid_service_info`"); + stmt.addBatch("DELETE FROM `vid_job`"); + stmt.addBatch("DELETE FROM `vid_job_audit_status`"); + int[] executeBatch = stmt.executeBatch(); + + } catch (SQLException e) { + throw new IllegalStateException("Cannot connect the database!", e); + } + } + + public void muteAllAsyncJobs() { + System.out.println("Connecting database..."); + + try (Connection connection = DriverManager.getConnection(DB_CONFIG.url, DB_CONFIG.username, DB_CONFIG.password)) { + System.out.println("Database connected!"); + + Statement stmt = connection.createStatement(); + stmt.addBatch("UPDATE `vid_job` set `TAKEN_BY`='muteAllAsyncJobs', `AGE`=`AGE`+5"); + int[] executeBatch = stmt.executeBatch(); + + } catch (SQLException e) { + throw new IllegalStateException("Cannot connect the database!", e); + } + } + +} |