blob: 01158fa661a10b3638f5ed48dfdc83953d539628 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
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);
}
}
}
|
