public void update()

in src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/util/DmlOperationHandler.java [78:95]

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

  public void update(DmlOperationArgs args) {
    log.info("Updating table {}", args.getTableName());

    var connection = DataSourceUtils.getConnection(dataSource);
    try (CallableStatement statement = connection.prepareCall(DmlOperation.U.getSqlString())) {
      Array rolesDbArray = connection
          .createArrayOf("text", JwtClaimsUtils.getRoles(args.getUserClaims()).toArray());
      statement.setString(1, args.getTableName()); //NOSONAR
      statement.setString(2, args.getEntityId());
      statement.setString(3, HStoreConverter.toString(args.getSysValues()));
      statement.setString(4, HStoreConverter.toString(args.getBusinessValues()));
      statement.setArray(5, rolesDbArray);

      statement.execute();
    } catch (SQLException e) {
      throw SQLExceptionResolverUtil.getDetailedExceptionFromSql(e);
    }
  }