public void delete()

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

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

  public void delete(DmlOperationArgs args) {
    log.info("Deleting from  table {}", args.getTableName());

    var connection = DataSourceUtils.getConnection(dataSource);
    try (CallableStatement statement = connection.prepareCall(DmlOperation.D.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.setArray(4, rolesDbArray);

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