public void update()

in src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/AbstractUpdateCommandHandler.java [52:67]

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

  public void update(Request<T> input) {
    JwtClaimsDto userClaims = jwtInfoProvider.getUserClaims(input);
    Map<String, Object> entityMap = entityConverter.entityToMap(input.getPayload());
    Object entityId = entityMap.remove(tableDataProvider.pkColumnName());

    if (entityId == null) {
      log.error("No entity ID for update");
      throw new ConstraintViolationException("No entity ID for update", "not null");
    }

    Map<String, String> sysValues = entityConverter.buildSysValues(userClaims.getDrfo(), input);
    dmlOperationHandler.update(
        DmlOperationArgs.builder(tableDataProvider.tableName(), userClaims, sysValues)
            .updateOperationArgs(entityId.toString(), entityMap)
            .build());
  }