private ColumnConfig findTableColumn()

in src/main/java/com/epam/digital/data/platform/liquibase/extension/change/core/DdmTableReadParametersChange.java [69:89]


    private ColumnConfig findTableColumn(DdmTableReadParametersConfig readParametersConfig,
                                         List<DdmCreateTableChange> createTableChanges,
                                         List<AddColumnChange> columnChanges) {

        Optional<ColumnConfig> columnFromCreateTable =
                createTableChanges
                        .stream()
                        .flatMap(tableChange -> tableChange.getColumns().stream())
                        .filter(column -> column.getName().equals(readParametersConfig.getName()))
                        .findFirst();
        if (columnFromCreateTable.isPresent()) {
            return columnFromCreateTable.get();
        }
        Optional<AddColumnConfig> columnFromAddColumn =
                columnChanges
                        .stream()
                        .flatMap(tableChange -> tableChange.getColumns().stream())
                        .filter(column -> column.getName().equals(readParametersConfig.getName()))
                        .findFirst();
        return columnFromAddColumn.orElse(null);
    }