public Optional findById()

in src/main/java/com/epam/digital/data/platform/kafkaapi/core/queryhandler/AbstractQueryHandler.java [58:78]

• 19 lines of code
• 2 McCabe index (conditional complexity)

  public Optional<O> findById(Request<I> input) {
    var tableName = tableDataProvider.tableName();
    log.info("Reading from table {}", tableName);

    validateAccess(input);

    I id = input.getPayload();
    try {
      final O dto =
          context
              .select(selectFields())
              .from(DSL.table(tableName))
              .where(DSL.field(tableDataProvider.pkColumnName()).eq(id))
              .and(getCommonCondition(input))
              .fetchOneInto(entityType());
      return Optional.ofNullable(dto);
    } catch (Exception e) {
      var message = String.format("Couldn't read from table '%s': %s", tableName, e.getMessage());
      throw new SqlErrorException(message, e);
    }
  }