public QueryRecord get()

in serverless-workflow-examples/serverless-workflow-qas-service-showcase/query-answer-service/src/main/java/org/acme/PostgreSqlQueryRecordRepository.java [103:117]

• 15 lines of code
• 3 McCabe index (conditional complexity)

    public QueryRecord get(String id) {
        try (Connection connection = dataSource.getConnection();
                PreparedStatement st = connection.prepareStatement("SELECT " + QUERY_RECORD_COLUMNS + " FROM " + QUERY_RECORD_TABLE + " WHERE processinstanceid = ?")) {
            st.setString(1, id);
            try (ResultSet rs = st.executeQuery()) {
                if (rs.next()) {
                    return from(rs);
                } else {
                    return null;
                }
            }
        } catch (Exception e) {
            throw new QueryAnswerServiceException("An error was produced during " + QUERY_RECORD_TABLE + " find: " + e.getMessage(), e);
        }
    }