Skip to content

Commit

Permalink
CB-5838 check all row identifiers fix (#3014)
Browse files Browse the repository at this point in the history
Co-authored-by: DenisSinelnikov <142215442+DenisSinelnikov@users.noreply.github.com>
  • Loading branch information
yagudin10 and DenisSinelnikov authored Oct 23, 2024
1 parent 5282175 commit 383952c
Showing 1 changed file with 4 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -35,10 +35,7 @@
import org.jkiss.utils.CommonUtils;

import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.*;
import java.util.stream.Collectors;

class WebSQLQueryDataReceiver implements DBDDataReceiver {
Expand Down Expand Up @@ -170,8 +167,9 @@ public void fetchEnd(@NotNull DBCSession session, @NotNull DBCResultSet resultSe

webResultSet.setSingleEntity(isSingleEntity);

DBDRowIdentifier rowIdentifier = resultsInfo.getDefaultRowIdentifier();
webResultSet.setHasRowIdentifier(rowIdentifier != null && rowIdentifier.isValidIdentifier());
Set<DBDRowIdentifier> rowIdentifiers = resultsInfo.getRowIdentifiers();
boolean hasRowIdentifier = rowIdentifiers.stream().allMatch(DBDRowIdentifier::isValidIdentifier);
webResultSet.setHasRowIdentifier(!rowIdentifiers.isEmpty() && hasRowIdentifier);
}

private void convertComplexValuesToRelationalView(DBCSession session) {
Expand Down

0 comments on commit 383952c

Please sign in to comment.