public class DatabaseManager {
private Connection connection;
public void initDatabase() {
connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "user", "password");
}
public void closeDatabase() {
connection.close();
}
public List<String> queryDataFromDatabase() {
List<String> result = new ArrayList<>();
try (Statement stmt = connection.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM example")) {
while(rs.next()) {
result.add(rs.getString("data"));
}
} catch (SQLException e) {
e.printStackTrace();
}
return result;
}
}
public class DatabaseManager {
private Connection connection;
public void initDatabase() {
Awaitility.await().atMost(TIMEOUT, TIME_UNIT).until(() -> {
try {
connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "user", "password");
return true;
} catch (SQLException e) {
return false;
}
});
}
public void closeDatabase() {
connection.close();
}
public List<String> queryDataFromDatabase() {
List<String> result = new ArrayList<>();
Awaitility.await().atMost(TIMEOUT, TIME_UNIT).until(() -> {
try (Statement stmt = connection.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM example")) {
while(rs.next()) {
result.add(rs.getString("data"));
}
return true;
} catch (SQLException e) {
return false;
}
});
return result;
}
}
