in serverless-workflow-examples/serverless-workflow-qas-service-showcase/query-answer-service/src/main/java/org/acme/PostgreSqlQueryRecordRepository.java [131:144]
public List<QueryRecord> getAll() {
try (Connection connection = dataSource.getConnection();
PreparedStatement st = connection.prepareStatement("SELECT " + QUERY_RECORD_COLUMNS + " FROM " + QUERY_RECORD_TABLE)) {
List<QueryRecord> result = new ArrayList<>();
try (ResultSet rs = st.executeQuery()) {
while (rs.next()) {
result.add(from(rs));
}
}
return result;
} catch (Exception e) {
throw new QueryAnswerServiceException("An error was produced during " + QUERY_RECORD_TABLE + " find all: " + e.getMessage(), e);
}
}