Сопоставление всех полей объекта DTO из другого набора результатов потока (разные результаты базы данных) в Java

Это объединит все частичные извлечения БД с одним и тем же ItemNumber.

• Сначала создается карта из bigq, используя номер элемента в качестве ключа.
• затем через collectingAndThen опубликуйте эту карту процессов, транслируйте dbq
• для всех предметов с одинаковым идентификатором местоположение и цена задаются из предмета dbq.

Определение класса

class ItemDTO {

    String itemNumber;
    String itemName;
    int postcode;
    String location;
    String price;

    public ItemDTO(String itemNumber, String itemName, int postcode,
            String location, String price) {
        this.itemNumber = itemNumber;
        this.itemName = itemName;
        this.postcode = postcode;
        this.location = location;
        this.price = price;
    }

    public String getItemNumber() {
        return itemNumber;
    }

    public void setItemNumber(String itemNumber) {
        this.itemNumber = itemNumber;
    }

    public String getItemName() {
        return itemName;
    }

    public void setItemName(String itemName) {
        this.itemName = itemName;
    }

    public int getPostcode() {
        return postcode;
    }

    public void setPostcode(int postcode) {
        this.postcode = postcode;
    }

    public String getLocation() {
        return location;
    }

    public void setLocation(String location) {
        this.location = location;
    }

    public String getPrice() {
        return price;
    }

    public void setPrice(String price) {
        this.price = price;
    }

    @Override
    public String toString() {
        return itemNumber + ", " + itemName + ", " + postcode + ", " + location
                + ", " + price;
    }

}

Процесс

List<ItemDTO> bigQueryResults = List.of(
        new ItemDTO("101", "chair", 4513, null, null),
        new ItemDTO("102", "Table", 2341, null, null),
        new ItemDTO("103", "Television", 5607, null, null),
        new ItemDTO("104", "Microwave", 2378, null, null),
        new ItemDTO("105", "Sofa", 1278, null, null));

List<ItemDTO> dbQueryResults = List.of(
        new ItemDTO("102", null, 0, "New York", "120"),
        new ItemDTO("106", null, 0, "Budapest", "300"),
        new ItemDTO("101", null, 0, "Amsterdam", "250)"));

// retrieving the db2 results for itemNumbers from bigQueryResults
List<ItemDTO> mergedResult = bigQueryResults.stream()
        .collect(Collectors.collectingAndThen(
           Collectors.groupingBy(ItemDTO::getItemNumber),
           mp -> dbQueryResults.stream().<ItemDTO>mapMulti((item, consumer) -> {
               List<ItemDTO> sameNumberList = mp.get(item.getItemNumber());
               if (sameNumberList != null) { // item number may not be
                                             // in map  
                  for (ItemDTO i : sameNumberList) {
                    i.setLocation(item.getLocation());
                    i.setPrice(item.getPrice());
                    consumer.accept(i); // put updated item on stream
                  }
               }
          }))).toList();

mergedResult.forEach(System.out::println);

печатает следующее для предоставленных данных

102, Table, 2341, New York, 120
101, chair, 4513, Amsterdam, 250)

Рекомендую посмотреть картуMulti , CollectingAndThen , Collectors.groupingBy

Обновлен ответ для Java-8.

• первая группаКак и раньше
• затем переберите два списка и добавьте измененный ItemDTO в объединенный список результатов.

Map<String, List<ItemDTO>> mapByItemNumber = bigQueryResults.stream()
        .collect(Collectors.groupingBy(ItemDTO::getItemNumber));

List<ItemDTO> mergedResults = new ArrayList<>();

for (ItemDTO item : dbQueryResults) {
    if (mapByItemNumber.containsKey(item.getItemNumber())) {
        for (ItemDTO i : mapByItemNumber.get(item.getItemNumber())) {
            i.setLocation(item.getLocation());
            i.setPrice(item.getPrice());
            mergedResults.add(i);
        }
    }
}

mergedResults.forEach(System.out::println);