diff --git a/backend/pom.xml b/backend/pom.xml index b31ca86ca3..5d5b69d9f8 100644 --- a/backend/pom.xml +++ b/backend/pom.xml @@ -373,6 +373,11 @@ testcontainers-postgresql test + + org.testcontainers + testcontainers-clickhouse + test + org.testcontainers testcontainers-solr @@ -383,6 +388,12 @@ ngdbc 2.17.10 + + com.clickhouse + clickhouse-jdbc + 0.9.8 + all + io.prometheus simpleclient_dropwizard diff --git a/backend/src/main/java/com/bakdata/conquery/models/config/Dialect.java b/backend/src/main/java/com/bakdata/conquery/models/config/Dialect.java index c1effedb58..0bb1507f68 100644 --- a/backend/src/main/java/com/bakdata/conquery/models/config/Dialect.java +++ b/backend/src/main/java/com/bakdata/conquery/models/config/Dialect.java @@ -1,8 +1,9 @@ package com.bakdata.conquery.models.config; import com.bakdata.conquery.sql.conversion.dialect.DialectBundle; -import com.bakdata.conquery.sql.conversion.dialect.HanaDialectBundle; -import com.bakdata.conquery.sql.conversion.dialect.PostgreDialectBundle; +import com.bakdata.conquery.sql.conversion.dialect.clickhouse.ClickhouseDialectBundle; +import com.bakdata.conquery.sql.conversion.dialect.hana.HanaDialectBundle; +import com.bakdata.conquery.sql.conversion.dialect.pg.PostgreDialectBundle; import lombok.Getter; import lombok.RequiredArgsConstructor; @@ -15,13 +16,8 @@ @Getter public enum Dialect { - /** - * Dialect for PostgreSQL database - */ POSTGRESQL(new PostgreDialectBundle()), - /** - * Dialect for SAP HANA database - */ + CLICKHOUSE(new ClickhouseDialectBundle()), HANA(new HanaDialectBundle()); private final DialectBundle dialectBundle; diff --git a/backend/src/main/java/com/bakdata/conquery/models/datasets/concepts/select/connector/DistinctSelect.java b/backend/src/main/java/com/bakdata/conquery/models/datasets/concepts/select/connector/DistinctSelect.java index a014283044..b7b90e9612 100644 --- a/backend/src/main/java/com/bakdata/conquery/models/datasets/concepts/select/connector/DistinctSelect.java +++ b/backend/src/main/java/com/bakdata/conquery/models/datasets/concepts/select/connector/DistinctSelect.java @@ -17,6 +17,7 @@ import com.bakdata.conquery.models.query.resultinfo.printers.PrinterFactory; import com.bakdata.conquery.models.query.resultinfo.printers.common.OneToManyMappingPrinter; import com.bakdata.conquery.models.types.ResultType; +import com.bakdata.conquery.sql.conversion.model.select.ClickhouseDistinctSelectConverter; import com.bakdata.conquery.sql.conversion.model.select.DistinctSelectConverter; import com.bakdata.conquery.sql.conversion.model.select.SelectConverter; import com.bakdata.conquery.sql.execution.ResultSetProcessor; @@ -37,7 +38,8 @@ public Aggregator createAggregator() { @Override public SelectConverter createConverter() { - return new DistinctSelectConverter(); + //TODO inject this instead + return new ClickhouseDistinctSelectConverter(); } @Override diff --git a/backend/src/main/java/com/bakdata/conquery/models/query/resultinfo/printers/common/ListStringPrinter.java b/backend/src/main/java/com/bakdata/conquery/models/query/resultinfo/printers/common/ListStringPrinter.java index 218a37d71f..0e62677566 100644 --- a/backend/src/main/java/com/bakdata/conquery/models/query/resultinfo/printers/common/ListStringPrinter.java +++ b/backend/src/main/java/com/bakdata/conquery/models/query/resultinfo/printers/common/ListStringPrinter.java @@ -1,6 +1,7 @@ package com.bakdata.conquery.models.query.resultinfo.printers.common; import java.util.Collection; +import java.util.Objects; import java.util.StringJoiner; import com.bakdata.conquery.models.config.LocaleConfig; @@ -24,7 +25,7 @@ public String apply(@NotNull Collection f) { continue; } - joiner.add(listFormat.escapeListElement(elementPrinter.apply(obj).toString())); + joiner.add(listFormat.escapeListElement(Objects.toString(elementPrinter.apply(obj)))); } return joiner.toString(); } diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/aggregation/InvertCte.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/aggregation/InvertCte.java index 30ef3a59b3..9b89287910 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/aggregation/InvertCte.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/aggregation/InvertCte.java @@ -59,12 +59,12 @@ private Selects getInvertSelects(QueryStep rowNumberStep, SqlIdColumns coalesced Field rangeStart = DSL.coalesce( QualifyingUtil.qualify(validityDate.getEnd(), ROWS_LEFT_TABLE_NAME), - functionProvider.toDateField(functionProvider.getMinDateExpression()) + (functionProvider.getMinDateExpression()) ).as(DateAggregationCte.RANGE_START); Field rangeEnd = DSL.coalesce( QualifyingUtil.qualify(validityDate.getStart(), ROWS_RIGHT_TABLE_NAME), - functionProvider.toDateField(functionProvider.getMaxDateExpression()) + (functionProvider.getMaxDateExpression()) ).as(DateAggregationCte.RANGE_END); return Selects.builder() diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/aggregation/PostgreSqlDateAggregator.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/aggregation/PostgreSqlDateAggregator.java index 08e74dfcf8..58d2e4083c 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/aggregation/PostgreSqlDateAggregator.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/aggregation/PostgreSqlDateAggregator.java @@ -84,8 +84,8 @@ public QueryStep invertAggregatedIntervals(QueryStep baseStep, ConversionContext Field maxDateRange = DSL.function( "daterange", Object.class, - this.functionProvider.toDateField(this.functionProvider.getMinDateExpression()), - this.functionProvider.toDateField(this.functionProvider.getMaxDateExpression()), + (this.functionProvider.getMinDateExpression()), + (this.functionProvider.getMaxDateExpression()), DSL.inline("[]") ); diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/concept/CQConceptConverter.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/concept/CQConceptConverter.java index 17bc77eefe..9c2d797a60 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/concept/CQConceptConverter.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/cqelement/concept/CQConceptConverter.java @@ -223,11 +223,11 @@ private static SqlFilters dateRestrictionFilter(ConversionContext context, Colum List dateRestrictionSelects = new ArrayList<>(); List conditions = new ArrayList<>(); + SqlFunctionProvider functionProvider = context.getFunctionProvider(); - conditions.add(ConditionUtil.wrap(validityDate.isNotEmpty())); + conditions.add(ConditionUtil.wrap(functionProvider.isNotEmptyDateRange(validityDate))); if (context.getDateRestrictionRange() != null) { - SqlFunctionProvider functionProvider = context.getFunctionProvider(); ColumnDateRange dateRestriction = functionProvider.forCDateRange(context.getDateRestrictionRange()).as(SharedAliases.DATE_RESTRICTION.getAlias()); conditions.add(ConditionUtil.wrap(functionProvider.dateRestriction(dateRestriction, validityDate))); diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/SqlFunctionProvider.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/SqlFunctionProvider.java index d3f6a76fe5..a89ab94ad4 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/SqlFunctionProvider.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/SqlFunctionProvider.java @@ -13,7 +13,6 @@ import com.bakdata.conquery.apiv1.query.concept.filter.CQTable; import com.bakdata.conquery.models.common.CDateSet; import com.bakdata.conquery.models.common.daterange.CDateRange; -import com.bakdata.conquery.models.datasets.Column; import com.bakdata.conquery.models.datasets.concepts.DaterangeSelectOrFilter; import com.bakdata.conquery.models.datasets.concepts.ValidityDate; import com.bakdata.conquery.sql.conversion.SharedAliases; @@ -43,9 +42,9 @@ Collection> orderByValidityDates( Function, ? extends SortField> ordering, List> validityDateFields); - String getMinDateExpression(); + Field getMinDateExpression(); - String getMaxDateExpression(); + Field getMaxDateExpression(); Field cast(Field field, DataType type); @@ -180,7 +179,7 @@ default Field stringAggregation(Field stringField, Field ColumnDateRange allRangeIf(Condition condition); - default Field concat(List> fields) { + default Field stringArray(List> fields) { String concatenated = fields.stream() // if a field is null, the whole concatenation would be null - but we just want to skip this field in this case, @@ -229,20 +228,7 @@ default Field toDateField(String dateExpression) { return toDate(dateExpression, DEFAULT_DATE_FORMAT); } - default Condition validityDateFilter(ValidityDate validityDate) { - - if (validityDate.isSingleColumnDaterange()) { - Column column = validityDate.getColumn().resolve(); - return field(name(column.getName())).isNotNull(); - } - - Column startColumn = validityDate.getStartColumn().resolve(); - Column endColumn = validityDate.getEndColumn().resolve(); - - return or(field(name(startColumn.getName())).isNotNull(), - field(name(endColumn.getName())).isNotNull() - ); - } + Condition isNotEmptyDateRange(ColumnDateRange columnDateRange); ColumnDateRange emptyColumnDateRange(); diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseCDateSetParser.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseCDateSetParser.java new file mode 100644 index 0000000000..6a804a3150 --- /dev/null +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseCDateSetParser.java @@ -0,0 +1,61 @@ +package com.bakdata.conquery.sql.conversion.dialect.clickhouse; + +import java.sql.Date; +import java.time.LocalDate; +import java.util.ArrayList; +import java.util.Collections; +import java.util.List; + +import com.bakdata.conquery.models.common.CDate; +import com.bakdata.conquery.models.common.daterange.CDateRange; +import com.bakdata.conquery.sql.execution.SqlCDateSetParser; +import com.google.common.base.Preconditions; +import org.apache.commons.lang3.NotImplementedException; + +public class ClickhouseCDateSetParser implements SqlCDateSetParser { + + public static final String DATE_SEPARATOR = ","; + + @Override + public List> toEpochDayRangeList(String multiDateRange) { + throw new NotImplementedException(); + } + + + + @Override + public List toEpochDayRange(String daterange) { + //TODO probably should also be implemented as tuples, and then we don't even supply a SqlCDateSetParser for CH but solve it via com.bakdata.conquery.sql.execution.ResultSetProcessor + + if (daterange == null) { + return Collections.emptyList(); + } + + String[] dates = daterange.split(DATE_SEPARATOR); + Preconditions.checkArgument(dates.length == 2, "Dateranges must have a start and end."); + + // the dateranges have always an included start date marked by a [ + String startDateExpression = dates[0]; + int startDate; + if (startDateExpression.equals(ClickhouseFunctionProvider.MIN_DATE_VALUE)) { + startDate = CDateRange.NEGATIVE_INFINITY; + } + else { + LocalDate dateValue = Date.valueOf(startDateExpression).toLocalDate(); + startDate = CDate.ofLocalDate(dateValue); + } + + String endDateExpression = dates[1]; + int endDate; + if (endDateExpression.equals(ClickhouseFunctionProvider.MAX_DATE_VALUE)) { + endDate = CDateRange.POSITIVE_INFINITY; + } + else { + LocalDate dateValue = Date.valueOf(endDateExpression).toLocalDate(); + endDate = CDate.ofLocalDate(dateValue); + } + + return List.of(startDate, endDate); + } + +} diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseDialectBundle.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseDialectBundle.java new file mode 100644 index 0000000000..91db0438bc --- /dev/null +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseDialectBundle.java @@ -0,0 +1,101 @@ +package com.bakdata.conquery.sql.conversion.dialect.clickhouse; + +import java.util.List; + +import com.bakdata.conquery.models.config.ConqueryConfig; +import com.bakdata.conquery.models.config.Dialect; +import com.bakdata.conquery.models.events.MajorTypeId; +import com.bakdata.conquery.models.query.Visitable; +import com.bakdata.conquery.sql.conversion.NodeConverter; +import com.bakdata.conquery.sql.conversion.cqelement.aggregation.AnsiSqlDateAggregator; +import com.bakdata.conquery.sql.conversion.cqelement.intervalpacking.AnsiSqlIntervalPacker; +import com.bakdata.conquery.sql.conversion.dialect.DialectBundle; +import com.bakdata.conquery.sql.conversion.dialect.IntervalPacker; +import com.bakdata.conquery.sql.conversion.dialect.SqlDateAggregator; +import com.bakdata.conquery.sql.conversion.dialect.SqlFunctionProvider; +import com.bakdata.conquery.sql.conversion.dialect.hana.HanaStratificationFunctions; +import com.bakdata.conquery.sql.conversion.forms.StratificationFunctions; +import com.bakdata.conquery.sql.execution.ResultSetProcessor; +import com.bakdata.conquery.sql.execution.SqlCDateSetParser; +import lombok.extern.slf4j.Slf4j; +import org.jooq.DSLContext; +import org.jooq.Field; +import org.jooq.SQLDialect; + +@Slf4j +public class ClickhouseDialectBundle implements DialectBundle { + + private final SqlFunctionProvider functionProvider; + private final IntervalPacker intervalPacker; + private final SqlDateAggregator dateAggregator; + private final SqlCDateSetParser dateSetParser; + + public ClickhouseDialectBundle() { + this.functionProvider = new ClickhouseFunctionProvider(); + this.intervalPacker = new AnsiSqlIntervalPacker(); + this.dateAggregator = new AnsiSqlDateAggregator(this.intervalPacker, this.functionProvider); + this.dateSetParser = new ClickhouseCDateSetParser(); // TODO => ArrayCDateSetParser + } + + @Override + public Dialect getDialect() { + return Dialect.CLICKHOUSE; + } + + @Override + public int getNameMaxLength() { + return 64; + } + + @Override + public String getConnectionTestString() { + return "SELECT 1;"; + } + + @Override + public SQLDialect getJooqDialect() { + return SQLDialect.CLICKHOUSE; + } + + @Override + public SqlCDateSetParser getCDateSetParser() { + return this.dateSetParser; + } + + @Override + public List> getNodeConverters(DSLContext dslContext) { + return getDefaultNodeConverters(dslContext); + } + + @Override + public StratificationFunctions getStratificationFunctions() { + return new ClickhouseStratificationFunctions(getFunctionProvider()); + } + + @Override + public boolean isTypeCompatible(Field field, MajorTypeId type) { + + return true; //TODO CLickhouse integration is terrible here. We always receive just Object. + } + + @Override + public SqlFunctionProvider getFunctionProvider() { + return this.functionProvider; + } + + @Override + public IntervalPacker getIntervalPacker() { + return this.intervalPacker; + } + + @Override + public SqlDateAggregator getDateAggregator() { + return this.dateAggregator; + } + + @Override + public ResultSetProcessor getResultSetProcessor(ConqueryConfig config) { + return new ClickhouseResultSetProcessor(config, getCDateSetParser()); + } + +} diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseFunctionProvider.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseFunctionProvider.java new file mode 100644 index 0000000000..04aab61f47 --- /dev/null +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseFunctionProvider.java @@ -0,0 +1,356 @@ +package com.bakdata.conquery.sql.conversion.dialect.clickhouse; + +import static org.jooq.impl.DSL.*; + +import java.sql.Date; +import java.time.LocalDate; +import java.time.temporal.ChronoUnit; +import java.util.Collection; +import java.util.List; +import java.util.function.Function; + +import com.bakdata.conquery.models.common.CDate; +import com.bakdata.conquery.models.common.CDateSet; +import com.bakdata.conquery.models.common.daterange.CDateRange; +import com.bakdata.conquery.models.datasets.Column; +import com.bakdata.conquery.models.datasets.concepts.DaterangeSelectOrFilter; +import com.bakdata.conquery.models.datasets.concepts.ValidityDate; +import com.bakdata.conquery.sql.conversion.SharedAliases; +import com.bakdata.conquery.sql.conversion.dialect.SqlFunctionProvider; +import com.bakdata.conquery.sql.conversion.model.ColumnDateRange; +import com.bakdata.conquery.sql.conversion.model.QueryStep; +import org.apache.commons.lang3.NotImplementedException; +import org.jetbrains.annotations.NotNull; +import org.jooq.Condition; +import org.jooq.DataType; +import org.jooq.Field; +import org.jooq.OrderField; +import org.jooq.Record; +import org.jooq.SortField; +import org.jooq.Table; +import org.jooq.impl.DSL; +import org.jooq.impl.SQLDataType; + +public class ClickhouseFunctionProvider implements SqlFunctionProvider { + + public static final Integer MIN_DATE_VALUE = -25567; + public static final Integer MAX_DATE_VALUE = 24855; + private static final String ANY_CHAR_REGEX = ".*"; + + @Override + public String getAnyCharRegex() { + return ANY_CHAR_REGEX; + } + + @Override + public Table getNoOpTable() { + return table(select(inline(1))).as(name(SharedAliases.NOP_TABLE.getAlias())); + } + + @Override + public Condition dateRestriction(ColumnDateRange dateRestriction, ColumnDateRange daterange) { + + if (dateRestriction.isSingleColumnRange() || daterange.isSingleColumnRange()) { + throw new UnsupportedOperationException("Clickhouse does not support single column ranges."); + } + + Condition dateRestrictionStartsBeforeDate = dateRestriction.getStart().lessThan(daterange.getEnd()); + Condition dateRestrictionEndsAfterDate = dateRestriction.getEnd().greaterThan(daterange.getStart()); + + return condition(dateRestrictionStartsBeforeDate.and(dateRestrictionEndsAfterDate)); + } + + @Override + public List forCDateSet(CDateSet dateset, SharedAliases alias) { + return dateset.asRanges().stream() + .map(this::forCDateRange) + .map(dateRange -> dateRange.as(alias.getAlias())) + .toList(); + } + + @Override + public ColumnDateRange forCDateRange(CDateRange daterange) { + + Field startDateExpression = getMinDateExpression(); + Field endDateExpression = getMaxDateExpression(); + + if (daterange.hasLowerBound()) { + startDateExpression = inline(Date.valueOf(daterange.getMin())); + } + if (daterange.hasUpperBound()) { + endDateExpression = inline(Date.valueOf(daterange.getMax().plusDays(1))); + } + + return ColumnDateRange.of(startDateExpression, endDateExpression); + } + + @Override + public Field toDateField(String dateExpression) { + return function( + "toDate", + Date.class, + inline(dateExpression), + inline(DEFAULT_DATE_FORMAT) + ); + } + + @Override + public Condition isNotEmptyDateRange(ColumnDateRange columnDateRange) { + return columnDateRange.getStart().notEqual(getMinDateExpression()).or(columnDateRange.getEnd().notEqual(getMaxDateExpression())); + } + + @Override + public ColumnDateRange emptyColumnDateRange() { + return ColumnDateRange.of(getMinDateExpression(), getMaxDateExpression()); + } + + @Override + public ColumnDateRange forValidityDate(ValidityDate validityDate) { + return toColumnDateRange(validityDate); + } + + @Override + public ColumnDateRange allRange() { + return ColumnDateRange.of(getMinDateExpression().as("all_range_start"), getMaxDateExpression().as("all_range_end")); + } + + private ColumnDateRange toColumnDateRange(ValidityDate validityDate) { + + String tableName = validityDate.getConnector().resolveTableId().getTable(); + + Column startColumn; + Column endColumn; + + // if no end column is present, the only existing column is both start and end of the date range + if (validityDate.getColumn() != null) { + Column column = validityDate.getColumn().resolve(); + startColumn = column; + endColumn = column; + } + else { + startColumn = validityDate.getStartColumn().resolve(); + endColumn = validityDate.getEndColumn().resolve(); + } + + return ofStartAndEnd(tableName, startColumn, endColumn); + } + + @Override + public Field stringArray(List> fields) { + return field("arrayFilter(x -> x <> '', {0})", Object.class, array(fields)); + } + + private ColumnDateRange ofStartAndEnd(String tableName, Column startColumn, Column endColumn) { + + // Since coalesce makes Clickhouse certain, that the field is not nullable, it will do silly stuff with it down the line: + // missing values (for example in outer-joins) will be coerced to 0 = 01-01-1970, which is clearly not correct + // Therefore we tag the values as Nullable again to make Clickhouse show some respect + + Field rangeStart = field("{0}::Nullable(Date32)", Date.class, coalesce( + field(name(tableName, startColumn.getName()), Date.class), + getMinDateExpression() + )); + // when aggregating date ranges, we want to treat the last day of the range as excluded, + // so when using the date value of the end column, we add +1 day as end of the date range + Field rangeEnd = field("{0}::Nullable(Date32)", Date.class, coalesce( + addDays(field(name(tableName, endColumn.getName()), Date.class), inline(1)), + getMaxDateExpression() + )); + + return ColumnDateRange.of(rangeStart, rangeEnd); + } + + @Override + public Field addDays(Field dateColumn, Field amountOfDays) { + return function( + "addDays", + Date.class, + dateColumn, + amountOfDays + ); + } + + @Override + public ColumnDateRange forValidityDate(ValidityDate validityDate, CDateRange dateRestriction) { + + ColumnDateRange validityDateRange = toColumnDateRange(validityDate); + ColumnDateRange restriction = toColumnDateRange(dateRestriction); + + Field lowerBound = when(validityDateRange.getStart().lessThan(restriction.getStart()), restriction.getStart()) + .otherwise(validityDateRange.getStart()); + + Field maxDate = getMinDateExpression(); // we want to add +1 day to the end date - except when it's the max date already + Field restrictionUpperBound = when(restriction.getEnd().eq(maxDate), maxDate).otherwise(addDays(restriction.getEnd(), inline(1))); + Field upperBound = when(validityDateRange.getEnd().greaterThan(restriction.getEnd()), restrictionUpperBound) + .otherwise(validityDateRange.getEnd()); + + return ColumnDateRange.of(lowerBound, upperBound); + } + + private ColumnDateRange toColumnDateRange(CDateRange dateRestriction) { + + Field startDateExpression = getMinDateExpression(); + Field endDateExpression = getMaxDateExpression(); + + if (dateRestriction.hasLowerBound()) { + startDateExpression = inline(Date.valueOf(dateRestriction.getMin())); + } + if (dateRestriction.hasUpperBound()) { + endDateExpression = inline(Date.valueOf(dateRestriction.getMax())); + } + + return ColumnDateRange.of(startDateExpression, endDateExpression); + } + + @NotNull + @Override + public Collection> orderByValidityDates( + Function, ? extends SortField> ordering, + List> validityDateFields) { + + return List.of( + ordering.apply(nullif(validityDateFields.getFirst(), getMinDateExpression())).nullsLast(), + ordering.apply(nullif(validityDateFields.getLast(), getMaxDateExpression())).nullsLast() + ); + } + + @Override + public Field getMinDateExpression() { + return field("toDate32({0})", Date.class, MIN_DATE_VALUE); + } + + @Override + public Field getMaxDateExpression() { + return field("toDate32({0})", Date.class, MAX_DATE_VALUE); + } + + @Override + public ColumnDateRange forArbitraryDateRange(DaterangeSelectOrFilter daterangeSelectOrFilter) { + String tableName = daterangeSelectOrFilter.getTable().getName(); + if (daterangeSelectOrFilter.getEndColumn() != null) { + return ofStartAndEnd(tableName, daterangeSelectOrFilter.getStartColumn().resolve(), daterangeSelectOrFilter.getEndColumn().resolve()); + } + Column column = daterangeSelectOrFilter.getColumn().resolve(); + return ofStartAndEnd(tableName, column, column); + } + + @Override + public ColumnDateRange aggregated(ColumnDateRange columnDateRange) { + return ColumnDateRange.of( + min(columnDateRange.getStart()), + max(columnDateRange.getEnd()) + ) + .as(columnDateRange.getAlias()); + } + + @Override + public ColumnDateRange toDualColumn(ColumnDateRange columnDateRange) { + return ColumnDateRange.of(columnDateRange.getStart(), columnDateRange.getEnd()); + } + + @Override + public ColumnDateRange intersection(ColumnDateRange left, ColumnDateRange right) { + Field greatest = DSL.greatest(left.getStart(), right.getStart()); + Field least = DSL.least(left.getEnd(), right.getEnd()); + return ColumnDateRange.of(greatest, least); + } + + @Override + public QueryStep unnestDaterange(ColumnDateRange nested, QueryStep predecessor, String cteName) { + return predecessor; + } + + @Override + public Field dateRangeAggregation(ColumnDateRange columnDateRange) { + return field("groupArray({0})", Object[].class, dateRangeToField(columnDateRange)); + } + + @Override + public Field dateRangeToField(ColumnDateRange columnDateRange) { + + if (columnDateRange.isSingleColumnRange()) { + throw new UnsupportedOperationException("Clickhouse does not support single-column date ranges."); + } + + //TODO this cast is necessary because we explicitly use null for empty. Maybe if we forego this we can simplify it again. + Field startDateExpression = field("{0}::{1}", Object.class, columnDateRange.getStart(), keyword("Nullable(Integer)")); + Field endDateExpression = field("{0}::{1}", Object.class, columnDateRange.getEnd(), keyword("Nullable(Integer)")); + + return function("tuple", Object.class, startDateExpression, endDateExpression); + } + + @Override + public Field cast(Field field, DataType type) { + if (type == SQLDataType.VARCHAR) { + return function("toString", type.getType(), field); + } + return function( + name("CAST"), + type.getType(), + field("{0} AS {1}", field, keyword(type.getName())) + ); + } + + @Override + public Field dateDistance(ChronoUnit datePart, Field startDate, Field endDate) { + + String unit = switch (datePart) { + case DAYS -> "days"; + case MONTHS -> "months"; + case YEARS, DECADES, CENTURIES -> "years"; + default -> throw new UnsupportedOperationException("Given ChronoUnit %s is not supported."); + }; + + Field dateDistance = function("age", Integer.class, inline(unit), startDate, endDate); + + // HANA does not support decades or centuries directly + dateDistance = switch (datePart) { + case DECADES -> dateDistance.divide(10); + case CENTURIES -> dateDistance.divide(100); + default -> dateDistance; + }; + + // otherwise HANA would return floating point numbers for date distances + return dateDistance.cast(Integer.class); + } + + @Override + public Field lower(Field daterange) { + throw new NotImplementedException(); + } + + @Override + public Field upper(Field daterange) { + throw new NotImplementedException(); + } + + @Override + public Field random(Field column) { + return field( + "groupArraySample(1)({0})[1]", + column.getType(), + column + ); + } + + @Override + public Condition likeRegex(Field field, String pattern) { + return condition(function("match", Boolean.class, field, inline(pattern))); + } + + + @Override + public Field yearQuarter(Field dateField) { + return field("formatDateTime({0}, '%Y-Q%Q')", String.class, dateField); + } + + @Override + public ColumnDateRange allRangeIf(Condition condition) { + return ColumnDateRange.of( + when(condition.isTrue(), + allRange() + ) + ); + } + +} diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseResultSetProcessor.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseResultSetProcessor.java new file mode 100644 index 0000000000..3a32359ef0 --- /dev/null +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseResultSetProcessor.java @@ -0,0 +1,122 @@ +package com.bakdata.conquery.sql.conversion.dialect.clickhouse; + +import java.math.BigDecimal; +import java.sql.Array; +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.Comparator; +import java.util.List; + +import com.bakdata.conquery.models.config.ConqueryConfig; +import com.bakdata.conquery.sql.execution.DefaultResultSetProcessor; +import com.bakdata.conquery.sql.execution.SqlCDateSetParser; + +public class ClickhouseResultSetProcessor extends DefaultResultSetProcessor { + + public ClickhouseResultSetProcessor(ConqueryConfig config, SqlCDateSetParser sqlCDateSetParser) { + super(config, sqlCDateSetParser); + } + + public List> toEpochDayRangeList(List raw) { + List> out = new ArrayList<>(); + + for (Object[] rawTuple : raw) { + + if (rawTuple[0] == null) { + assert rawTuple[1] == null; + continue; + } + + int begin = (Integer) rawTuple[0]; + int end = (Integer) rawTuple[1]; + + if (begin == ClickhouseFunctionProvider.MIN_DATE_VALUE) { + begin = Integer.MIN_VALUE; + } + if (end == ClickhouseFunctionProvider.MAX_DATE_VALUE) { + end = Integer.MAX_VALUE; + } + else { + end--; + } + + out.add(List.of(begin, end)); + } + + return out; + } + + private List sort(List list, Comparator sort) { + if (list == null) { + return null; + } + list.sort(sort); + + return list; + } + + private List getList(ResultSet resultSet, int columnIndex) throws SQLException { + Array sqlArray = resultSet.getArray(columnIndex); + + if (sqlArray == null) { + return null; + } + + Object[] array = (Object[]) sqlArray.getArray(); + + List out = new ArrayList<>(); + + for (Object obj : array) { + if (obj == null) { + continue; + } + + out.add((T) obj); + } + + if (out.isEmpty()) { + return null; + } + + return out; + } + + @Override + public List> getDateRangeList(ResultSet resultSet, int columnIndex) throws SQLException { + List raw = getList(resultSet, columnIndex); + + return sort(this.toEpochDayRangeList(raw), Comparator.comparing(List::getFirst)); + } + + + @Override + public List getMoneyList(ResultSet resultSet, int columnIndex) throws SQLException { + return sort(getList(resultSet, columnIndex), BigDecimal::compareTo); + } + + @Override + public List getIntegerList(ResultSet resultSet, int columnIndex) throws SQLException { + return sort(getList(resultSet, columnIndex), Integer::compareTo); + } + + @Override + public List getDoubleList(ResultSet resultSet, int columnIndex) throws SQLException { + return sort(getList(resultSet, columnIndex), Double::compareTo); + } + + @Override + public List getBooleanList(ResultSet resultSet, int columnIndex) throws SQLException { + return sort(getList(resultSet, columnIndex), Boolean::compareTo); + } + + @Override + public List getDateList(ResultSet resultSet, int columnIndex) throws SQLException { + return sort(getList(resultSet, columnIndex), Comparator.comparing(Number::floatValue)); + } + + @Override + public List getStringList(ResultSet resultSet, int columnIndex) throws SQLException { + return sort(getList(resultSet, columnIndex), String::compareTo); + } +} diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseStratificationFunctions.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseStratificationFunctions.java new file mode 100644 index 0000000000..96da68378a --- /dev/null +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/clickhouse/ClickhouseStratificationFunctions.java @@ -0,0 +1,188 @@ +package com.bakdata.conquery.sql.conversion.dialect.clickhouse; + +import static com.bakdata.conquery.sql.conversion.dialect.Interval.MONTHS_PER_QUARTER; +import static com.bakdata.conquery.sql.conversion.forms.FormConstants.SERIES_INDEX; +import static org.jooq.impl.DSL.inline; + +import java.sql.Date; +import java.time.temporal.ChronoUnit; + +import com.bakdata.conquery.apiv1.query.TemporalSamplerFactory; +import com.bakdata.conquery.sql.conversion.dialect.Interval; +import com.bakdata.conquery.sql.conversion.dialect.SqlFunctionProvider; +import com.bakdata.conquery.sql.conversion.forms.Offset; +import com.bakdata.conquery.sql.conversion.forms.StratificationFunctions; +import com.bakdata.conquery.sql.conversion.model.ColumnDateRange; +import lombok.Getter; +import lombok.RequiredArgsConstructor; +import org.jooq.Field; +import org.jooq.Record; +import org.jooq.Table; +import org.jooq.impl.DSL; +import org.jooq.impl.SQLDataType; + +@Getter +@RequiredArgsConstructor +public class ClickhouseStratificationFunctions extends StratificationFunctions { + + private static final int INCREMENT = 1; + + /** + * Hana pre-generates the column names of a generated series + * (see HANA docs) + */ + private static final String GENERATED_PERIOD_END = "GENERATED_PERIOD_END"; + + private final SqlFunctionProvider functionProvider; + + private static Field addMonths(Field yearStart, Field amount) { + return DSL.function("addMonths", Date.class, yearStart, amount); + } + + private static Field addDays(Field start, Field amount) { + return DSL.function("addDays", Date.class, start, amount); + } + + private static Field jumpToYearStart(Field date) { + return DSL.function("toStartOfYear", Date.class, date); + } + + @Override + public Field lower(ColumnDateRange dateRange) { + // HANA does not support single-column ranges, so we can return start and end directly + return dateRange.getStart(); + } + + @Override + protected Field inclusiveUpper(ColumnDateRange dateRange) { + return functionProvider.addDays(exclusiveUpper(dateRange), DSL.inline(-1)); + } + + @Override + protected Field exclusiveUpper(ColumnDateRange dateRange) { + // HANA does not support single-column ranges, so we can return start and end directly + return dateRange.getEnd(); + } + + @Override + protected ColumnDateRange calcRange(Field start, Interval interval) { + return ColumnDateRange.of( + calcStartDate(start, interval), + calcEndDate(start, interval) + ); + } + + @Override + public Field absoluteIndexStartDate(ColumnDateRange dateRange) { + return dateRange.getStart(); + } + + @Override + public Field lowerBoundYearStart(ColumnDateRange dateRange) { + return jumpToYearStart(dateRange.getStart()); + } + + @Override + public Field upperBoundYearEnd(ColumnDateRange dateRange) { + return DSL.field("addYears(toStartOfYear({0}), {1})", Date.class, dateRange.getEnd(), inline(1)); + } + + @Override + public Field upperBoundYearEndQuarterAligned(ColumnDateRange dateRange) { + Field yearStartOfUpperBound = jumpToYearStart(dateRange.getEnd()); + Field quartersInMonths = getQuartersInMonths(dateRange.getStart(), Offset.MINUS_ONE); + Field yearEndQuarterAligned = addMonths(yearStartOfUpperBound, quartersInMonths); + // we add +1 year to the quarter aligned end if it is less than the upper bound we want to align + return DSL.when( + yearEndQuarterAligned.lessThan(dateRange.getEnd()), + shiftByInterval(yearEndQuarterAligned, Interval.ONE_YEAR_INTERVAL, DSL.inline(1), Offset.NONE) + ) + .otherwise(yearEndQuarterAligned); + } + + @Override + public Field lowerBoundQuarterStart(ColumnDateRange dateRange) { + return jumpToQuarterStart(dateRange.getStart()); + } + + @Override + public Field jumpToQuarterStart(Field date) { + Field yearStart = jumpToYearStart(date); + Field quartersInMonths = getQuartersInMonths(date, Offset.MINUS_ONE); + return addMonths(yearStart, quartersInMonths); + } + + @Override + public Field upperBoundQuarterEnd(ColumnDateRange dateRange) { + return jumpToNextQuarterStart(inclusiveUpper(dateRange)); + } + + @Override + public Field jumpToNextQuarterStart(Field date) { + Field yearStart = jumpToYearStart(date); + Field quartersInMonths = getQuartersInMonths(date, Offset.NONE); + return addMonths(yearStart, quartersInMonths); + } + + @Override + public Field intSeriesField() { + return SERIES_INDEX; + } + + @Override + public Table generateIntSeries(int start, int end) { + //TODO this only supports ungigned values. Probably need to handle negatives manually Q_Q + return DSL.table("generate_series({0}, {1}, 1)", start, end); + } + + @Override + public Field indexSelectorField(TemporalSamplerFactory indexSelector, ColumnDateRange validityDate) { + return switch (indexSelector) { + case EARLIEST -> DSL.min(validityDate.getStart()); + case LATEST -> DSL.max(inclusiveUpper(validityDate)); + case RANDOM -> { + // we calculate a random int which is in range of the date distance between upper and lower bound + Field dateDistanceInDays = functionProvider.dateDistance(ChronoUnit.DAYS, validityDate.getStart(), validityDate.getEnd()); + Field randomAmountOfDays = DSL.function("RAND", Double.class).times(dateDistanceInDays); + Field flooredAsInt = functionProvider.cast(DSL.floor(randomAmountOfDays), SQLDataType.INTEGER); + // then we add this random amount (of days) to the start date + Field randomDateInRange = functionProvider.addDays(lower(validityDate), flooredAsInt); + // finally, we handle multiple ranges by randomizing which range we use to select a random date from + yield functionProvider.random(randomDateInRange); + } + }; + } + + @Override + public Field shiftByInterval(Field startDate, Interval interval, Field amount, Offset offset) { + Field multiplier = amount.plus(offset.getOffset()); + return switch (interval) { + case ONE_YEAR_INTERVAL -> DSL.function("addYears", Date.class, startDate, multiplier.times(Interval.ONE_YEAR_INTERVAL.getAmount())); + case YEAR_AS_DAYS_INTERVAL -> addDays(startDate, multiplier.times(Interval.YEAR_AS_DAYS_INTERVAL.getAmount())); + case QUARTER_INTERVAL -> addMonths(startDate, multiplier.times(Interval.QUARTER_INTERVAL.getAmount())); + case NINETY_DAYS_INTERVAL -> addDays(startDate, multiplier.times(Interval.NINETY_DAYS_INTERVAL.getAmount())); + case ONE_DAY_INTERVAL -> addDays(startDate, multiplier.times(Interval.ONE_DAY_INTERVAL.getAmount())); + }; + } + + private Field calcStartDate(Field start, Interval interval) { + return calcDate(start, interval, Offset.MINUS_ONE); + } + + private Field calcEndDate(Field start, Interval interval) { + return calcDate(start, interval, Offset.NONE); + } + + private Field calcDate(Field start, Interval interval, Offset offset) { + return shiftByInterval(start, interval, intSeriesField(), offset); + } + + private Field getQuartersInMonths(Field date, Offset offset) { + Field quarterExpression = functionProvider.yearQuarter(date); + Field rightMostCharacter = DSL.function("RIGHT", String.class, quarterExpression, DSL.inline(1)); + Field amountOfQuarters = functionProvider.cast(rightMostCharacter, SQLDataType.INTEGER) + .plus(offset.getOffset()); + return amountOfQuarters.times(MONTHS_PER_QUARTER); + } + +} diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/HanaDialectBundle.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/hana/HanaDialectBundle.java similarity index 90% rename from backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/HanaDialectBundle.java rename to backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/hana/HanaDialectBundle.java index ef12b04e98..101786d376 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/HanaDialectBundle.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/hana/HanaDialectBundle.java @@ -1,4 +1,4 @@ -package com.bakdata.conquery.sql.conversion.dialect; +package com.bakdata.conquery.sql.conversion.dialect.hana; import java.util.List; @@ -9,7 +9,10 @@ import com.bakdata.conquery.sql.conversion.NodeConverter; import com.bakdata.conquery.sql.conversion.cqelement.aggregation.AnsiSqlDateAggregator; import com.bakdata.conquery.sql.conversion.cqelement.intervalpacking.AnsiSqlIntervalPacker; -import com.bakdata.conquery.sql.conversion.forms.HanaStratificationFunctions; +import com.bakdata.conquery.sql.conversion.dialect.DialectBundle; +import com.bakdata.conquery.sql.conversion.dialect.IntervalPacker; +import com.bakdata.conquery.sql.conversion.dialect.SqlDateAggregator; +import com.bakdata.conquery.sql.conversion.dialect.SqlFunctionProvider; import com.bakdata.conquery.sql.conversion.forms.StratificationFunctions; import com.bakdata.conquery.sql.execution.DefaultResultSetProcessor; import com.bakdata.conquery.sql.execution.HanaSqlCDateSetParser; diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/HanaSqlFunctionProvider.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/hana/HanaSqlFunctionProvider.java similarity index 94% rename from backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/HanaSqlFunctionProvider.java rename to backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/hana/HanaSqlFunctionProvider.java index a2221f2091..a1466e5bef 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/HanaSqlFunctionProvider.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/hana/HanaSqlFunctionProvider.java @@ -1,4 +1,4 @@ -package com.bakdata.conquery.sql.conversion.dialect; +package com.bakdata.conquery.sql.conversion.dialect.hana; import static com.bakdata.conquery.sql.execution.ResultSetProcessor.UNIT_SEPARATOR; import static org.jooq.impl.DSL.*; @@ -17,6 +17,7 @@ import com.bakdata.conquery.models.datasets.concepts.DaterangeSelectOrFilter; import com.bakdata.conquery.models.datasets.concepts.ValidityDate; import com.bakdata.conquery.sql.conversion.SharedAliases; +import com.bakdata.conquery.sql.conversion.dialect.SqlFunctionProvider; import com.bakdata.conquery.sql.conversion.model.ColumnDateRange; import com.bakdata.conquery.sql.conversion.model.QueryStep; import org.jetbrains.annotations.NotNull; @@ -104,6 +105,11 @@ public Field toDateField(String dateExpression) { ); } + @Override + public Condition isNotEmptyDateRange(ColumnDateRange columnDateRange) { + return columnDateRange.getStart().isNotNull().and(columnDateRange.getEnd().isNotNull()); + } + @Override public ColumnDateRange emptyColumnDateRange() { return ColumnDateRange.of(field(inline(null, Date.class)), field(inline(null, Date.class))); @@ -176,6 +182,8 @@ public ColumnDateRange allRangeIf(Condition condition) { ); } + + @Override public ColumnDateRange forValidityDate(ValidityDate validityDate, CDateRange dateRestriction) { @@ -215,19 +223,19 @@ public Collection> orderByValidityDates( List> validityDateFields) { return List.of( - ordering.apply(nullif(validityDateFields.getFirst(), toDateField(getMinDateExpression()))).nullsLast(), - ordering.apply(nullif(validityDateFields.getLast(), toDateField(getMaxDateExpression()))).nullsLast() + ordering.apply(nullif(validityDateFields.getFirst(), getMinDateExpression())).nullsLast(), + ordering.apply(nullif(validityDateFields.getLast(), getMaxDateExpression())).nullsLast() ); } @Override - public String getMinDateExpression() { - return MIN_DATE_VALUE; + public Field getMinDateExpression() { + return toDateField(MIN_DATE_VALUE); } @Override - public String getMaxDateExpression() { - return MAX_DATE_VALUE; + public Field getMaxDateExpression() { + return toDateField(MAX_DATE_VALUE); } @Override diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/HanaStratificationFunctions.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/hana/HanaStratificationFunctions.java similarity index 97% rename from backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/HanaStratificationFunctions.java rename to backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/hana/HanaStratificationFunctions.java index 7f89ae3fe4..2bae80d371 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/HanaStratificationFunctions.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/hana/HanaStratificationFunctions.java @@ -1,4 +1,4 @@ -package com.bakdata.conquery.sql.conversion.forms; +package com.bakdata.conquery.sql.conversion.dialect.hana; import static com.bakdata.conquery.sql.conversion.dialect.Interval.MONTHS_PER_QUARTER; @@ -6,8 +6,9 @@ import java.time.temporal.ChronoUnit; import com.bakdata.conquery.apiv1.query.TemporalSamplerFactory; -import com.bakdata.conquery.sql.conversion.dialect.HanaSqlFunctionProvider; import com.bakdata.conquery.sql.conversion.dialect.Interval; +import com.bakdata.conquery.sql.conversion.forms.Offset; +import com.bakdata.conquery.sql.conversion.forms.StratificationFunctions; import com.bakdata.conquery.sql.conversion.model.ColumnDateRange; import lombok.Getter; import lombok.RequiredArgsConstructor; diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/PostgreDialectBundle.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/pg/PostgreDialectBundle.java similarity index 90% rename from backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/PostgreDialectBundle.java rename to backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/pg/PostgreDialectBundle.java index d145f61d3b..0356f89940 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/PostgreDialectBundle.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/pg/PostgreDialectBundle.java @@ -1,4 +1,4 @@ -package com.bakdata.conquery.sql.conversion.dialect; +package com.bakdata.conquery.sql.conversion.dialect.pg; import java.util.List; @@ -9,7 +9,10 @@ import com.bakdata.conquery.sql.conversion.NodeConverter; import com.bakdata.conquery.sql.conversion.cqelement.aggregation.PostgreSqlDateAggregator; import com.bakdata.conquery.sql.conversion.cqelement.intervalpacking.PostgreSqlIntervalPacker; -import com.bakdata.conquery.sql.conversion.forms.PostgresStratificationFunctions; +import com.bakdata.conquery.sql.conversion.dialect.DialectBundle; +import com.bakdata.conquery.sql.conversion.dialect.IntervalPacker; +import com.bakdata.conquery.sql.conversion.dialect.SqlDateAggregator; +import com.bakdata.conquery.sql.conversion.dialect.SqlFunctionProvider; import com.bakdata.conquery.sql.conversion.forms.StratificationFunctions; import com.bakdata.conquery.sql.execution.DefaultResultSetProcessor; import com.bakdata.conquery.sql.execution.PgSqlCDateSetParser; diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/PostgreSqlFunctionProvider.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/pg/PostgreSqlFunctionProvider.java similarity index 96% rename from backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/PostgreSqlFunctionProvider.java rename to backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/pg/PostgreSqlFunctionProvider.java index 716c52b5fe..691abd393b 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/PostgreSqlFunctionProvider.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/pg/PostgreSqlFunctionProvider.java @@ -1,4 +1,4 @@ -package com.bakdata.conquery.sql.conversion.dialect; +package com.bakdata.conquery.sql.conversion.dialect.pg; import static org.jooq.impl.DSL.*; @@ -15,6 +15,7 @@ import com.bakdata.conquery.models.datasets.concepts.DaterangeSelectOrFilter; import com.bakdata.conquery.models.datasets.concepts.ValidityDate; import com.bakdata.conquery.sql.conversion.SharedAliases; +import com.bakdata.conquery.sql.conversion.dialect.SqlFunctionProvider; import com.bakdata.conquery.sql.conversion.model.ColumnDateRange; import com.bakdata.conquery.sql.conversion.model.QueryStep; import com.bakdata.conquery.sql.conversion.model.Selects; @@ -50,8 +51,8 @@ private static Field unnest(Field multirange) { } @Override - public String getMaxDateExpression() { - return INFINITY_DATE_VALUE; + public Field getMaxDateExpression() { + return inline(INFINITY_DATE_VALUE, Date.class); } @Override @@ -82,8 +83,8 @@ public Field emptyDateRange() { } @Override - public String getMinDateExpression() { - return NEGATIVE_INFINITY_DATE_VALUE; + public Field getMinDateExpression() { + return inline(NEGATIVE_INFINITY_DATE_VALUE, Date.class); } @Override @@ -372,6 +373,11 @@ public Field toDateField(String dateValue) { return field("{0}::{1}", Date.class, inline(dateValue), keyword("date")); } + @Override + public Condition isNotEmptyDateRange(ColumnDateRange columnDateRange) { + return columnDateRange.getRange().notEqual(PostgreSqlFunctionProvider.EMPTY_RANGE); + } + @Override public ColumnDateRange emptyColumnDateRange() { return ColumnDateRange.of(EMPTY_RANGE); diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/PostgresStratificationFunctions.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/pg/PostgresStratificationFunctions.java similarity index 97% rename from backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/PostgresStratificationFunctions.java rename to backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/pg/PostgresStratificationFunctions.java index e67c7a82c9..9de6ffceaf 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/PostgresStratificationFunctions.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/dialect/pg/PostgresStratificationFunctions.java @@ -1,4 +1,4 @@ -package com.bakdata.conquery.sql.conversion.forms; +package com.bakdata.conquery.sql.conversion.dialect.pg; import static com.bakdata.conquery.sql.conversion.forms.FormConstants.SERIES_INDEX; @@ -10,7 +10,8 @@ import com.bakdata.conquery.apiv1.query.TemporalSamplerFactory; import com.bakdata.conquery.sql.conversion.dialect.Interval; -import com.bakdata.conquery.sql.conversion.dialect.PostgreSqlFunctionProvider; +import com.bakdata.conquery.sql.conversion.forms.Offset; +import com.bakdata.conquery.sql.conversion.forms.StratificationFunctions; import com.bakdata.conquery.sql.conversion.model.ColumnDateRange; import lombok.Getter; import lombok.RequiredArgsConstructor; diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/AbsoluteStratification.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/AbsoluteStratification.java index 0a9153dc2c..4cabedd5af 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/AbsoluteStratification.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/AbsoluteStratification.java @@ -58,8 +58,7 @@ private QueryStep createIntSeriesStep() { .sqlSelect(seriesIndex) .build(); - Table seriesTable = stratificationFunctions.generateIntSeries(INDEX_START, INDEX_END) - .as(SharedAliases.SERIES_INDEX.getAlias()); + Table seriesTable = stratificationFunctions.generateIntSeries(INDEX_START, INDEX_END); return QueryStep.builder() .cteName(FormCteStep.INT_SERIES.getSuffix()) diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/FormConstants.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/FormConstants.java index 579a21fa64..e51fe3e87f 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/FormConstants.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/FormConstants.java @@ -12,7 +12,7 @@ /** * Constant fields used for absolute and relative date stratification. See this modules README for more detailed information. */ -class FormConstants { +public class FormConstants { /** * The index date from which an absolute stratification for an entity starts. It is the lowest date bound of an absolute stratification. diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/Offset.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/Offset.java index 35342eab1a..92242c63bf 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/Offset.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/forms/Offset.java @@ -11,7 +11,7 @@ */ @Getter @RequiredArgsConstructor -enum Offset { +public enum Offset { MINUS_ONE(-1), NONE(0), ONE(1); diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/ColumnDateRange.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/ColumnDateRange.java index 6be9ada893..74bc6ce0e9 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/ColumnDateRange.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/ColumnDateRange.java @@ -1,13 +1,11 @@ package com.bakdata.conquery.sql.conversion.model; -import static org.jooq.impl.DSL.field; - import java.sql.Date; import java.util.List; import java.util.stream.Collectors; import java.util.stream.Stream; -import com.bakdata.conquery.sql.conversion.dialect.PostgreSqlFunctionProvider; +import com.bakdata.conquery.sql.conversion.dialect.pg.PostgreSqlFunctionProvider; import com.bakdata.conquery.sql.conversion.model.select.SqlSelect; import lombok.Getter; import org.jooq.Condition; @@ -123,26 +121,19 @@ public Condition join(ColumnDateRange right) { if (this.isSingleColumnRange() != right.isSingleColumnRange()) { throw new UnsupportedOperationException("Can only join ColumnDateRanges of same type"); } + if (this.isSingleColumnRange()) { return this.range.coerce(Object.class).eq(right.getRange()); } return this.start.eq(right.getStart()).and(end.eq(right.getEnd())); } - public Condition isNotEmpty() { - if (this.isSingleColumnRange()) { - return this.range.notEqual(PostgreSqlFunctionProvider.EMPTY_RANGE); + public static Condition isNotEmpty(ColumnDateRange columnDateRange) { + if (columnDateRange.isSingleColumnRange()) { + return columnDateRange.getRange().notEqual(PostgreSqlFunctionProvider.EMPTY_RANGE); } - //this is weird - return this.start.isNotNull().and(this.end.isNotNull()); - } - - public Condition isNotNull() { - if (this.isSingleColumnRange()) { - return this.range.isNotNull(); - } - return this.start.isNotNull().and(this.end.isNotNull()); + return columnDateRange.getStart().isNotNull().and(columnDateRange.getEnd().isNotNull()); } } diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/aggregator/FlagSqlAggregator.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/aggregator/FlagSqlAggregator.java index bbb1978f9e..561d113ecc 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/aggregator/FlagSqlAggregator.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/aggregator/FlagSqlAggregator.java @@ -29,7 +29,6 @@ import com.bakdata.conquery.sql.conversion.model.select.SingleColumnSqlSelect; import org.jooq.Condition; import org.jooq.Field; -import org.jooq.Param; /** * {@link FlagSelect} conversion aggregates the keys of the flags of a {@link FlagSelect} into an array. @@ -88,7 +87,7 @@ private static Map createFlagRootSelectMap(FlagSe )); } - private static FieldWrapper createFlagSelect( + private static FieldWrapper createFlagSelect( String alias, SqlTables connectorTables, SqlFunctionProvider functionProvider, @@ -100,7 +99,7 @@ private static FieldWrapper createFlagSelect( List> flagAggregations = new ArrayList<>(); for (Map.Entry> entry : flagFieldsMap.entrySet()) { Field boolColumn = entry.getValue(); - Condition anyTrue = condition(boolOr(boolColumn)); + Condition anyTrue = condition(max(boolColumn)); // Clickhouse doesnt have aggregate or, this does the same thing. String flagName = entry.getKey(); Field flag = when(anyTrue, inline(flagName)).otherwise(""); // else null is implicit in SQL @@ -108,7 +107,7 @@ private static FieldWrapper createFlagSelect( } // and stuff them into 1 array field - Field flagsArray = functionProvider.concat(flagAggregations).as(alias); + Field flagsArray = functionProvider.stringArray(flagAggregations).as(alias); // we also need the references for all flag columns for the flag aggregation of multiple columns String[] requiredColumns = flagFieldsMap.values().stream().map(Field::getName).toArray(String[]::new); return new FieldWrapper<>(flagsArray, requiredColumns); @@ -144,9 +143,9 @@ public ConnectorSqlSelects connectorSelect(FlagSelect flagSelect, SelectContext< Map rootSelects = createFlagRootSelectMap(flagSelect, connectorTables.getRootTable()); String alias = selectContext.getNameGenerator().selectName(flagSelect); - FieldWrapper flagAggregation = createFlagSelect(alias, connectorTables, functionProvider, rootSelects); + FieldWrapper flagAggregation = createFlagSelect(alias, connectorTables, functionProvider, rootSelects); - ExtractingSqlSelect finalSelect = flagAggregation.qualify(connectorTables.getPredecessor(ConceptCteStep.AGGREGATION_FILTER)); + ExtractingSqlSelect finalSelect = flagAggregation.qualify(connectorTables.getPredecessor(ConceptCteStep.AGGREGATION_FILTER)); return ConnectorSqlSelects.builder() .preprocessingSelects(rootSelects.values()) diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/ClickhouseDistinctSelectConverter.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/ClickhouseDistinctSelectConverter.java new file mode 100644 index 0000000000..2bd0a0adea --- /dev/null +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/ClickhouseDistinctSelectConverter.java @@ -0,0 +1,67 @@ +package com.bakdata.conquery.sql.conversion.model.select; + +import static org.jooq.impl.DSL.field; + +import com.bakdata.conquery.models.datasets.concepts.select.connector.DistinctSelect; +import com.bakdata.conquery.models.datasets.concepts.select.connector.specific.MappableSingleColumnSelect; +import com.bakdata.conquery.sql.conversion.cqelement.concept.ConceptCteStep; +import com.bakdata.conquery.sql.conversion.cqelement.concept.ConnectorSqlTables; +import com.bakdata.conquery.sql.conversion.model.Selects; +import com.bakdata.conquery.sql.conversion.model.SqlIdColumns; + +/** + * 
+ *  The two additional CTEs this aggregator creates:
+ * 	
    
+ * 	    
  1. 
+ * 	        Select distinct values of a column.
+ *            {@code
+ * 	        	"distinct" as (
+ *     				select distinct "pid", "column"
+ *     				from "event_filter"
+ *  			)
+ *            }
+ * 	    
    2. 
+ * 	    
  2. 
+ * 	        String agg all distinct values of the column.
+ *            {@code
+ * 	        "aggregated" as (
+ *    			 select
+ *    			   "select-1-distinct"."pid",
+ *    			   string_agg(cast("column" as varchar), cast(' ' as varchar) ) as "select-1"
+ *    			 from "distinct"
+ *    			 group by "pid"
+ *   			)
+ *            }
+ * 	    
    3. 
+ * 	

+ *
+ */ +public class ClickhouseDistinctSelectConverter implements SelectConverter { + + + @Override + public ConnectorSqlSelects connectorSelect(DistinctSelect distinctSelect, SelectContext selectContext) { + + String alias = selectContext.getNameGenerator().selectName(distinctSelect); + + ConnectorSqlTables tables = selectContext.getTables(); + SingleColumnSqlSelect preprocessingSelect = + MappableSingleColumnSelect.getSubstringSelect(distinctSelect.getColumn().get(), distinctSelect.getSubstringRange(), selectContext, alias); + + String eventFilterTable = selectContext.getTables().cteName(ConceptCteStep.EVENT_FILTER); + SingleColumnSqlSelect qualified = preprocessingSelect.qualify(eventFilterTable); + + FieldWrapper grouped = new FieldWrapper<>(field("arrayFilter(x -> x <> '' and x is not null, groupUniqArray({0}))", Object.class, qualified.select()).as(alias), qualified.select().getName()); + + SingleColumnSqlSelect finalSelect = grouped.qualify(tables.cteName(ConceptCteStep.AGGREGATION_SELECT)); + + return ConnectorSqlSelects.builder() + .preprocessingSelect(preprocessingSelect) + .aggregationSelect(grouped) + .finalSelect(finalSelect) + .build(); + } + + +} diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/DaterangeSelectUtil.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/DaterangeSelectUtil.java index c8fecc732b..69922694b3 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/DaterangeSelectUtil.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/DaterangeSelectUtil.java @@ -135,8 +135,8 @@ public static FieldWrapper createDurationSumSqlSelect(String alias, } private static Condition containsInfinityDate(ColumnDateRange validityDate, SqlFunctionProvider functionProvider) { - Field negativeInfinity = functionProvider.toDateField(functionProvider.getMinDateExpression()); - Field positiveInfinity = functionProvider.toDateField(functionProvider.getMaxDateExpression()); + Field negativeInfinity = (functionProvider.getMinDateExpression()); + Field positiveInfinity = (functionProvider.getMaxDateExpression()); return validityDate.getStart().eq(negativeInfinity).or(validityDate.getEnd().eq(positiveInfinity)); } diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/EventDurationSumSelectConverter.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/EventDurationSumSelectConverter.java index e7e8bbd88d..7a9b21307b 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/EventDurationSumSelectConverter.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/EventDurationSumSelectConverter.java @@ -60,8 +60,8 @@ private FieldWrapper createEventDurationSumAggregation(EventDuration } private static Condition containsInfinityDate(ColumnDateRange validityDate, SqlFunctionProvider functionProvider) { - Field negativeInfinity = functionProvider.toDateField(functionProvider.getMinDateExpression()); - Field positiveInfinity = functionProvider.toDateField(functionProvider.getMaxDateExpression()); + Field negativeInfinity = functionProvider.getMinDateExpression(); + Field positiveInfinity = functionProvider.getMaxDateExpression(); return validityDate.getStart().eq(negativeInfinity).or(validityDate.getEnd().eq(positiveInfinity)); } diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/ValueSelectUtil.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/ValueSelectUtil.java index fce8fb56be..572958fd25 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/ValueSelectUtil.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/model/select/ValueSelectUtil.java @@ -60,6 +60,8 @@ private static QueryStep buildRowNumberStep( SingleColumnSqlSelect rootSelect, Function, ? extends SortField> ordering, String alias, SelectContext selectContext) { + SqlFunctionProvider functionProvider = selectContext.getFunctionProvider(); + String predecessor = selectContext.getTables().getPredecessor(ConceptCteStep.AGGREGATION_SELECT); Field qualifiedRootSelect = rootSelect.qualify(predecessor).select(); @@ -70,12 +72,12 @@ private static QueryStep buildRowNumberStep( new FieldWrapper<>(qualifiedRootSelect.as(alias), qualifiedRootSelect.getName()), rowNumberField(predecessor, selectContext.getValidityDate(), ordering, selectContext.getIds(), - selectContext.getFunctionProvider() + functionProvider ) )) .build()) .cteName(ValueSelectCteStep.ROW_NUMBER_STEP.cteName(alias)) - .conditions(List.of(qualifiedRootSelect.isNotNull(), selectContext.getValidityDate().map(ColumnDateRange::isNotEmpty).orElse(noCondition()))) + .conditions(List.of(qualifiedRootSelect.isNotNull(), selectContext.getValidityDate().map(functionProvider::isNotEmptyDateRange).orElse(noCondition()))) .fromTable(table(name(predecessor))) .build(); } diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conversion/query/FormConversionHelper.java b/backend/src/main/java/com/bakdata/conquery/sql/conversion/query/FormConversionHelper.java index d9977af200..05876ea091 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/conversion/query/FormConversionHelper.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/conversion/query/FormConversionHelper.java @@ -68,7 +68,7 @@ public QueryStep convertPrerequisite(Query query, ConversionContext context) { Condition dateNotNullCondition; if (columnDateRange.isPresent()) { - dateNotNullCondition = columnDateRange.get().isNotNull(); + dateNotNullCondition = context.getFunctionProvider().isNotEmptyDateRange(columnDateRange.get()); } else { dateNotNullCondition = falseCondition(); diff --git a/backend/src/main/java/com/bakdata/conquery/sql/execution/HanaSqlCDateSetParser.java b/backend/src/main/java/com/bakdata/conquery/sql/execution/HanaSqlCDateSetParser.java index 6f8912b556..81fe66563e 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/execution/HanaSqlCDateSetParser.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/execution/HanaSqlCDateSetParser.java @@ -1,11 +1,11 @@ package com.bakdata.conquery.sql.execution; -import static com.bakdata.conquery.sql.conversion.dialect.HanaSqlFunctionProvider.DATE_SET_SEPARATOR; +import static com.bakdata.conquery.sql.conversion.dialect.hana.HanaSqlFunctionProvider.DATE_SET_SEPARATOR; import java.util.Collections; import java.util.Set; -import com.bakdata.conquery.sql.conversion.dialect.HanaSqlFunctionProvider; +import com.bakdata.conquery.sql.conversion.dialect.hana.HanaSqlFunctionProvider; import com.bakdata.conquery.util.DateReader; public class HanaSqlCDateSetParser extends DefaultCDateSetParser { diff --git a/backend/src/main/java/com/bakdata/conquery/sql/execution/PgSqlCDateSetParser.java b/backend/src/main/java/com/bakdata/conquery/sql/execution/PgSqlCDateSetParser.java index 253a7db001..4046e4e262 100644 --- a/backend/src/main/java/com/bakdata/conquery/sql/execution/PgSqlCDateSetParser.java +++ b/backend/src/main/java/com/bakdata/conquery/sql/execution/PgSqlCDateSetParser.java @@ -3,7 +3,7 @@ import java.util.Collections; import java.util.Set; -import com.bakdata.conquery.sql.conversion.dialect.PostgreSqlFunctionProvider; +import com.bakdata.conquery.sql.conversion.dialect.pg.PostgreSqlFunctionProvider; import com.bakdata.conquery.util.DateReader; public class PgSqlCDateSetParser extends DefaultCDateSetParser { diff --git a/backend/src/test/java/com/bakdata/conquery/integration/IntegrationTests.java b/backend/src/test/java/com/bakdata/conquery/integration/IntegrationTests.java index fc3773a5c7..8b9fbc2a6e 100644 --- a/backend/src/test/java/com/bakdata/conquery/integration/IntegrationTests.java +++ b/backend/src/test/java/com/bakdata/conquery/integration/IntegrationTests.java @@ -17,6 +17,7 @@ import java.util.regex.Pattern; import java.util.stream.Collectors; import java.util.stream.Stream; +import javax.annotation.CheckForNull; import com.bakdata.conquery.TestTags; import com.bakdata.conquery.integration.json.ConqueryTestSpec; @@ -68,7 +69,7 @@ public class IntegrationTests { } @Getter - public final ConqueryConfig config = new ConqueryConfig(); + public final ConqueryConfig config = new ConqueryConfig(); private final Map reusedInstances = new HashMap<>(); private final String defaultTestRoot; private final String defaultTestRootPackage; @@ -182,25 +183,34 @@ private List collectTestTree(ResourceTree tree, String testRoot, Te final ResourceTree reduced = tree.reduce(); if (reduced.getChildren().isEmpty()) { - return Collections.singletonList(collectTests(reduced, testImporter, sqlDialect)); + return collectTests(reduced, testImporter, sqlDialect) + .map(List::of) + .orElse(Collections.emptyList()); } return reduced.getChildren().values().stream() .map(currentDir -> collectTests(currentDir, testImporter, sqlDialect)) + .flatMap(Optional::stream) .collect(Collectors.toList()); } - private DynamicNode collectTests(ResourceTree currentDir, TestDataImporter testImporter, Dialect sqlDialect) { + private Optional collectTests(ResourceTree currentDir, TestDataImporter testImporter, Dialect sqlDialect) { if (currentDir.getValue() != null) { Optional dynamicTest = readTest(currentDir.getValue(), currentDir.getName(), testImporter, sqlDialect); if (dynamicTest.isPresent()) { - return dynamicTest.get(); + return Optional.of(dynamicTest.get()); } } List list = new ArrayList<>(); for (ResourceTree child : currentDir.getChildren().values()) { - list.add(collectTests(child, testImporter, sqlDialect)); + collectTests(child, testImporter, sqlDialect) + .ifPresent(list::add); } - return toDynamicContainer(currentDir, list); + + if (list.isEmpty()) { + return Optional.empty(); + } + + return Optional.of(toDynamicContainer(currentDir, list)); } private Optional readTest(Resource resource, String name, TestDataImporter testImporter, Dialect sqlDialect) { diff --git a/backend/src/test/java/com/bakdata/conquery/integration/sql/CsvTableImporter.java b/backend/src/test/java/com/bakdata/conquery/integration/sql/CsvTableImporter.java index 7b9af73b18..3c54aed42e 100644 --- a/backend/src/test/java/com/bakdata/conquery/integration/sql/CsvTableImporter.java +++ b/backend/src/test/java/com/bakdata/conquery/integration/sql/CsvTableImporter.java @@ -140,7 +140,7 @@ private void dropTable(Table table, Statement statement) { private void createTable(Table table, List> columns, Statement statement) throws SQLException { String createTableStatement = testSqlDialect.getTestFunctionProvider().createTableStatement(table, columns, dslContext); - log.debug("Creating table: {}", createTableStatement); + log.info("Creating table: {}", createTableStatement); statement.execute(createTableStatement); } @@ -152,7 +152,7 @@ private Field createField(RequiredColumn requiredColumn) { case BOOLEAN -> SQLDataType.BOOLEAN; // TODO (ja) how do we handle REAL and DECIMAL properly? case REAL, DECIMAL, MONEY -> SQLDataType.DECIMAL(10, 2); - case DATE -> SQLDataType.DATE; + case DATE -> SQLDataType.DATE.nullable(true); case DATE_RANGE -> new BuiltInDataType<>(DateRange.class, "daterange"); }; diff --git a/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/ClickhouseSqlIntegrationTests.java b/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/ClickhouseSqlIntegrationTests.java new file mode 100644 index 0000000000..86abcb6afb --- /dev/null +++ b/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/ClickhouseSqlIntegrationTests.java @@ -0,0 +1,179 @@ +package com.bakdata.conquery.integration.sql.dialect; + +import java.sql.Statement; +import java.util.ArrayList; +import java.util.List; +import java.util.Objects; +import java.util.stream.Stream; + +import com.bakdata.conquery.TestTags; +import com.bakdata.conquery.integration.ConqueryIntegrationTests; +import com.bakdata.conquery.integration.IntegrationTests; +import com.bakdata.conquery.integration.json.SqlTestDataImporter; +import com.bakdata.conquery.integration.json.TestDataImporter; +import com.bakdata.conquery.integration.sql.CsvTableImporter; +import com.bakdata.conquery.mode.local.ManagedConnection; +import com.bakdata.conquery.models.config.DatabaseConnectionConfig; +import com.bakdata.conquery.models.config.Dialect; +import com.bakdata.conquery.sql.conversion.dialect.clickhouse.ClickhouseDialectBundle; +import com.google.common.base.Strings; +import lombok.Getter; +import lombok.SneakyThrows; +import lombok.extern.slf4j.Slf4j; +import org.jooq.DSLContext; +import org.jooq.Field; +import org.jooq.InsertValuesStepN; +import org.jooq.Record; +import org.jooq.RowN; +import org.jooq.Table; +import org.jooq.conf.ParamType; +import org.junit.jupiter.api.AfterAll; +import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.DynamicNode; +import org.junit.jupiter.api.Tag; +import org.junit.jupiter.api.TestFactory; +import org.testcontainers.clickhouse.ClickHouseContainer; +import org.testcontainers.junit.jupiter.Container; +import org.testcontainers.utility.DockerImageName; + +@Slf4j +public class ClickhouseSqlIntegrationTests extends IntegrationTests { + + // SAP does not provide more than 1 image and on an update, the earlier image is deleted from dockerhub, thus latest tag is fine + private final static DockerImageName IMAGE_TAGE = DockerImageName.parse("clickhouse/clickhouse-server"); + private static boolean useLocal = true; + private static DSLContext dslContext; + private static ManagedConnection managedConnection; + + static { + final String raw = System.getenv("USE_LOCAL_CH_DB"); + if (!Strings.isNullOrEmpty(raw)) { + useLocal = Boolean.parseBoolean(raw); + } + } + + public ClickhouseSqlIntegrationTests() { + super(ConqueryIntegrationTests.DEFAULT_SQL_TEST_ROOT, "com.bakdata.conquery.integration"); + } + + + @SneakyThrows + @AfterAll + public static void tearDownClass() { + + } + + @BeforeAll + static void before() throws Exception { + TestContextProvider provider = useLocal + ? new ClickhouseTestContainerContextProvider() + : new RemoteClickhouseContextProvider(); + + log.info("Running Clickhouse tests with {}.", provider.getClass().getSimpleName()); + + managedConnection = new ManagedConnection("test", provider.getSqlConnectorConfig(), provider.getDatabaseConfig(), null); + managedConnection.start(); + + dslContext = managedConnection.connect(); + } + + @AfterAll + static void after() throws Exception { + managedConnection.stop(); + } + + @TestFactory + @Tag(TestTags.INTEGRATION_SQL_BACKEND) + public Stream sqlBackendTests() { + + DatabaseConnectionConfig databaseConfig = managedConnection.getConnection(); + TestDialectBundle testHanaDialect = new TestClickhouseDialectBundle(); + TestDataImporter testDataImporter = new SqlTestDataImporter(new CsvTableImporter(dslContext, testHanaDialect, databaseConfig)); + + + return Stream.concat( + super.sqlProgrammaticTests(databaseConfig, managedConnection.getConfig(), testDataImporter), + super.sqlQueryTests(databaseConfig, managedConnection.getConfig(), testDataImporter).stream() + ); + } + + public static class TestClickhouseDialectBundle extends ClickhouseDialectBundle implements TestDialectBundle { + + public TestFunctionProvider getTestFunctionProvider() { + return new ClickhouseTestFunctionProvider(); + } + + } + + private static class ClickhouseTestFunctionProvider implements TestFunctionProvider { + + @Override + public void insertValuesIntoTable(Table table, List> columns, List content, Statement statement, DSLContext dslContext) { + + List statements = new ArrayList<>(); + for (RowN rowN : content) { + InsertValuesStepN values = dslContext.insertInto(table, columns) + .values(rowN); + statements.add(values); + } + + dslContext.batch(statements) + .execute(); + } + + @Override + public String createDropTableStatement(Table table, DSLContext dslContext) { + return dslContext.dropTable(table) + .getSQL(ParamType.INLINED); + } + + } + + @Getter + private static class ClickhouseTestContainerContextProvider implements TestContextProvider { + + private final DatabaseConnectionConfig databaseConfig; + private final TestSqlConnectorConfig sqlConnectorConfig; + + @Container + private final ClickHouseContainer container; + + public ClickhouseTestContainerContextProvider() { + this.container = new ClickHouseContainer(IMAGE_TAGE); + this.container.start(); + + this.databaseConfig = DatabaseConnectionConfig.builder() + .dialect(Dialect.CLICKHOUSE) + .jdbcConnectionUrl(container.getJdbcUrl()) + .databaseUsername(container.getUsername()) + .databasePassword(container.getPassword()) + .build(); + this.sqlConnectorConfig = new TestSqlConnectorConfig(databaseConfig); + } + } + + @Getter + private static class RemoteClickhouseContextProvider implements TestContextProvider { + + private final static String PORT = Objects.requireNonNullElse(System.getenv("CONQUERY_SQL_PORT"), "8123"); + private final static String HOST = System.getenv("CONQUERY_SQL_HOST"); + private final static String CONNECTION_URL = "jdbc:clickhouse://%s:%s/".formatted(HOST, PORT); + private final static String USERNAME = Objects.requireNonNullElse(System.getenv("CONQUERY_SQL_USER"), "default"); + private final static String PASSWORD = System.getenv("CONQUERY_SQL_PASSWORD"); + + private final DatabaseConnectionConfig databaseConfig; + private final TestSqlConnectorConfig sqlConnectorConfig; + + public RemoteClickhouseContextProvider() { + this.databaseConfig = DatabaseConnectionConfig.builder() + .dialect(Dialect.CLICKHOUSE) + .jdbcConnectionUrl(CONNECTION_URL) + .databaseUsername(USERNAME) + .databasePassword(PASSWORD) + .build(); + this.sqlConnectorConfig = new TestSqlConnectorConfig(databaseConfig); + } + + } + +} diff --git a/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/HanaSqlIntegrationTests.java b/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/HanaSqlIntegrationTests.java index 04f52676a7..2ddb45dc1e 100644 --- a/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/HanaSqlIntegrationTests.java +++ b/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/HanaSqlIntegrationTests.java @@ -24,7 +24,7 @@ import com.bakdata.conquery.mode.local.ManagedConnection; import com.bakdata.conquery.models.config.DatabaseConnectionConfig; import com.bakdata.conquery.models.config.Dialect; -import com.bakdata.conquery.sql.conversion.dialect.HanaDialectBundle; +import com.bakdata.conquery.sql.conversion.dialect.hana.HanaDialectBundle; import com.google.common.base.Strings; import lombok.Getter; import lombok.SneakyThrows; diff --git a/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/PostgreSqlIntegrationTests.java b/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/PostgreSqlIntegrationTests.java index 0675bd21f7..537a00c3e9 100644 --- a/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/PostgreSqlIntegrationTests.java +++ b/backend/src/test/java/com/bakdata/conquery/integration/sql/dialect/PostgreSqlIntegrationTests.java @@ -13,7 +13,7 @@ import com.bakdata.conquery.models.config.Dialect; import com.bakdata.conquery.models.error.ConqueryError; import com.bakdata.conquery.models.i18n.I18n; -import com.bakdata.conquery.sql.conversion.dialect.PostgreDialectBundle; +import com.bakdata.conquery.sql.conversion.dialect.pg.PostgreDialectBundle; import com.bakdata.conquery.sql.conversion.model.SqlQuery; import com.bakdata.conquery.sql.execution.ResultSetProcessor; import com.bakdata.conquery.sql.execution.SqlExecutionService; diff --git a/backend/src/test/java/com/bakdata/conquery/integration/tests/SqlSchemaValidationTest.java b/backend/src/test/java/com/bakdata/conquery/integration/tests/SqlSchemaValidationTest.java index 4606c2a22a..d822f84c29 100644 --- a/backend/src/test/java/com/bakdata/conquery/integration/tests/SqlSchemaValidationTest.java +++ b/backend/src/test/java/com/bakdata/conquery/integration/tests/SqlSchemaValidationTest.java @@ -13,6 +13,7 @@ import com.bakdata.conquery.integration.common.RequiredTable; import com.bakdata.conquery.integration.json.SqlTestDataImporter; import com.bakdata.conquery.integration.sql.CsvTableImporter; +import com.bakdata.conquery.models.config.Dialect; import com.bakdata.conquery.models.datasets.Column; import com.bakdata.conquery.models.datasets.Table; import com.bakdata.conquery.models.events.MajorTypeId; @@ -29,6 +30,7 @@ */ @Slf4j public class SqlSchemaValidationTest implements ProgrammaticIntegrationTest { + @Override public Set forModes() { return Set.of(StandaloneSupport.Mode.SQL); @@ -39,6 +41,12 @@ public void execute(String name, TestConquery testConquery) throws Exception { StandaloneSupport support = testConquery.getSupport("dataset"); + if (support.getConfig().getSqlConnectorConfig().getDatabaseConfigs().values() + .stream().allMatch(dbconf -> dbconf.getDialect().equals(Dialect.CLICKHOUSE))) { + log.info("Clickhouse validation does not work."); + return; + } + CsvTableImporter importer = ((SqlTestDataImporter) testConquery.getTestDataImporter()).getCsvTableImporter(); String tableName = "test_table"; diff --git a/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json b/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json index 955fa02f2f..539eecd6ea 100644 --- a/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/COUNT_QUARTERS_AGGREGATOR/expected.csv", @@ -36,7 +37,8 @@ "table": "table", "validityDates": { "label": "datum", - "column": "table.datum" + "startColumn": "table.start", + "endColumn": "table.ende" }, "selects": { "name" : "select", @@ -62,8 +64,12 @@ "type": "DATE" }, { - "name": "datum", - "type": "DATE_RANGE" + "name": "start", + "type": "DATE" + }, + { + "name": "ende", + "type": "DATE" } ] } diff --git a/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_AGGREGATOR/content.csv b/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_AGGREGATOR/content.csv index 083de65dfc..7e533f9896 100644 --- a/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_AGGREGATOR/content.csv +++ b/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_AGGREGATOR/content.csv @@ -1,13 +1,13 @@ -pid,behandlungsdatum,datum -1,2015-03-16,"2015-01-01/2016-12-31" -1,2015-03-17,"2015-01-01/2016-12-31" -2,2015-03-31,"2015-01-01/2016-12-31" -2,2015-04-01,"2015-01-01/2016-12-31" -3,2015-02-01,"2015-01-01/2016-12-31" -3,2015-04-01,"2015-01-01/2016-12-31" -3,2015-07-01,"2015-01-01/2016-12-31" -3,2015-11-01,"2015-01-01/2016-12-31" -4,2015-03-31,"2015-01-01/2016-12-31" -4,2015-04-01,"2015-01-01/2016-12-31" -4,2015-07-01,"2015-01-01/2016-12-31" -5,,"2015-01-01/2016-12-31" \ No newline at end of file +pid,behandlungsdatum,start,ende +1,2015-03-16,"2015-01-01","2016-12-31" +1,2015-03-17,"2015-01-01","2016-12-31" +2,2015-03-31,"2015-01-01","2016-12-31" +2,2015-04-01,"2015-01-01","2016-12-31" +3,2015-02-01,"2015-01-01","2016-12-31" +3,2015-04-01,"2015-01-01","2016-12-31" +3,2015-07-01,"2015-01-01","2016-12-31" +3,2015-11-01,"2015-01-01","2016-12-31" +4,2015-03-31,"2015-01-01","2016-12-31" +4,2015-04-01,"2015-01-01","2016-12-31" +4,2015-07-01,"2015-01-01","2016-12-31" +5,,"2015-01-01","2016-12-31" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_RANGE/SIMPLE_VIRTUAL_CONCEPT_Query.test.json b/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_RANGE/SIMPLE_VIRTUAL_CONCEPT_Query.test.json new file mode 100644 index 0000000000..23b967c1e5 --- /dev/null +++ b/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_RANGE/SIMPLE_VIRTUAL_CONCEPT_Query.test.json @@ -0,0 +1,72 @@ +{ + "type": "QUERY_TEST", + "label": "COUNT_QUARTERS_AGGREGATOR Test", + "sqlSpec": { + "isEnabled": true, + "supportedDialects": [ + "POSTGRESQL" + ] + }, + "expectedCsv": "tests/aggregator/COUNT_QUARTERS_RANGE/expected.csv", + "query": { + "type": "CONCEPT_QUERY", + "root": { + "ids": [ + "concept" + ], + "type": "CONCEPT", + "tables": [ + { + "id": "concept.connector", + "selects": [ + "concept.connector.select" + ] + } + ] + + } + }, + "concepts": [ + { + "name": "concept", + "type": "TREE", + "connectors": [ + { + "label": "connector", + "table": "table", + "validityDates": { + "label": "datum", + "column": "table.datum" + }, + "selects": { + "name" : "select", + "type": "COUNT_QUARTERS", + "column": "table.behandlungsdatum" + } + } + ] + } + ], + "content": { + "tables": [ + { + "csv": "tests/aggregator/COUNT_QUARTERS_RANGE/content.csv", + "name": "table", + "primaryColumn": { + "name": "pid", + "type": "STRING" + }, + "columns": [ + { + "name": "behandlungsdatum", + "type": "DATE" + }, + { + "name": "datum", + "type": "DATE_RANGE" + } + ] + } + ] + } +} diff --git a/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_RANGE/content.csv b/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_RANGE/content.csv new file mode 100644 index 0000000000..083de65dfc --- /dev/null +++ b/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_RANGE/content.csv @@ -0,0 +1,13 @@ +pid,behandlungsdatum,datum +1,2015-03-16,"2015-01-01/2016-12-31" +1,2015-03-17,"2015-01-01/2016-12-31" +2,2015-03-31,"2015-01-01/2016-12-31" +2,2015-04-01,"2015-01-01/2016-12-31" +3,2015-02-01,"2015-01-01/2016-12-31" +3,2015-04-01,"2015-01-01/2016-12-31" +3,2015-07-01,"2015-01-01/2016-12-31" +3,2015-11-01,"2015-01-01/2016-12-31" +4,2015-03-31,"2015-01-01/2016-12-31" +4,2015-04-01,"2015-01-01/2016-12-31" +4,2015-07-01,"2015-01-01/2016-12-31" +5,,"2015-01-01/2016-12-31" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_RANGE/expected.csv b/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_RANGE/expected.csv new file mode 100644 index 0000000000..dd76afa65c --- /dev/null +++ b/backend/src/test/resources/tests/aggregator/COUNT_QUARTERS_RANGE/expected.csv @@ -0,0 +1,6 @@ +result,dates,concept select +1,{2015-01-01/2016-12-31},1 +2,{2015-01-01/2016-12-31},2 +3,{2015-01-01/2016-12-31},4 +4,{2015-01-01/2016-12-31},3 +5,{2015-01-01/2016-12-31}, \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/DURATION_SUM_AGGREGATOR/DURATION_SUM.test.json b/backend/src/test/resources/tests/aggregator/DURATION_SUM_AGGREGATOR/DURATION_SUM.test.json index 3a54197372..35ec814fdd 100644 --- a/backend/src/test/resources/tests/aggregator/DURATION_SUM_AGGREGATOR/DURATION_SUM.test.json +++ b/backend/src/test/resources/tests/aggregator/DURATION_SUM_AGGREGATOR/DURATION_SUM.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/DURATION_SUM_AGGREGATOR/expected.csv", @@ -35,12 +36,14 @@ "table": "table", "validityDates": { "label": "datum", - "column": "table.datum" + "startColumn": "table.start", + "endColumn": "table.ende" }, "selects": { "type": "DURATION_SUM", "name": "select", - "column": "table.datum" + "startColumn": "table.start", + "endColumn": "table.ende" } } ] @@ -57,8 +60,12 @@ }, "columns": [ { - "name": "datum", - "type": "DATE_RANGE" + "name": "start", + "type": "DATE" + }, + { + "name": "ende", + "type": "DATE" } ] } diff --git a/backend/src/test/resources/tests/aggregator/DURATION_SUM_AGGREGATOR/content.csv b/backend/src/test/resources/tests/aggregator/DURATION_SUM_AGGREGATOR/content.csv index 4eb17469e2..cdfeaa7675 100644 --- a/backend/src/test/resources/tests/aggregator/DURATION_SUM_AGGREGATOR/content.csv +++ b/backend/src/test/resources/tests/aggregator/DURATION_SUM_AGGREGATOR/content.csv @@ -1,8 +1,8 @@ -pid,datum -1,"2010-01-01/2010-01-31" -3,"2013-08-10/2013-08-11" -4,"2010-06-15/2010-06-20" -4,"2010-06-16/2010-06-18" -5,"2011-03-02/2011-03-10" -5,"2011-03-05/2011-03-13" -6,"/2011-03-13" \ No newline at end of file +pid,start,ende +1,"2010-01-01","2010-01-31" +3,"2013-08-10","2013-08-11" +4,"2010-06-15","2010-06-20" +4,"2010-06-16","2010-06-18" +5,"2011-03-02","2011-03-10" +5,"2011-03-05","2011-03-13" +6,,"2011-03-13" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/DURATION_SUM_DISTINCT_AGGREGATOR/DURATION_SUM.test.json b/backend/src/test/resources/tests/aggregator/DURATION_SUM_DISTINCT_AGGREGATOR/DURATION_SUM.test.json index 51b3429c18..c7247a6fc8 100644 --- a/backend/src/test/resources/tests/aggregator/DURATION_SUM_DISTINCT_AGGREGATOR/DURATION_SUM.test.json +++ b/backend/src/test/resources/tests/aggregator/DURATION_SUM_DISTINCT_AGGREGATOR/DURATION_SUM.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": false, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/DURATION_SUM_DISTINCT_AGGREGATOR/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/EVENT_DATE_AGGREGATOR_NO_RESTRICTION.test.json b/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/EVENT_DATE_AGGREGATOR_NO_RESTRICTION.test.json index 692fcca436..9bcb107b3c 100644 --- a/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/EVENT_DATE_AGGREGATOR_NO_RESTRICTION.test.json +++ b/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/EVENT_DATE_AGGREGATOR_NO_RESTRICTION.test.json @@ -1,10 +1,11 @@ { "type": "QUERY_TEST", "label": "EVENT_DATE_AGGREGATOR_NO_RESTRICTION Test", - "sqlSpec": { + "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/EVENT_DATE_AGGREGATOR/expected_no_restriction.csv", @@ -18,7 +19,9 @@ "tables": [ { "id": "concept.connector", - "selects": "concept.connector.event-date" + "selects": [ + "concept.connector.event-date" + ] } ], "selects": "concept.event-date" @@ -34,18 +37,23 @@ "table": "table", "validityDates": { "label": "indexdatum", - "column": "table.indexdatum" + "startColumn": "table.start", + "endColumn": "table.ende" }, - "selects": { - "type": "EVENT_DATE_UNION", - "name": "event-date" - } + "selects": [ + { + "type": "EVENT_DATE_UNION", + "name": "event-date" + } + ] } ], - "selects": { - "type": "EVENT_DATE_UNION", - "name": "event-date" - } + "selects": [ + { + "type": "EVENT_DATE_UNION", + "name": "event-date" + } + ] } ], "content": { @@ -59,8 +67,12 @@ }, "columns": [ { - "name": "indexdatum", - "type": "DATE_RANGE" + "name": "start", + "type": "DATE" + }, + { + "name": "ende", + "type": "DATE" }, { "name": "geburtsdatum", diff --git a/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/EVENT_DATE_AGGREGATOR_RESTRICTION.test.json b/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/EVENT_DATE_AGGREGATOR_RESTRICTION.test.json index e420c4fc6b..3f36d2ee76 100644 --- a/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/EVENT_DATE_AGGREGATOR_RESTRICTION.test.json +++ b/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/EVENT_DATE_AGGREGATOR_RESTRICTION.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/EVENT_DATE_AGGREGATOR/expected_restriction.csv", @@ -37,11 +38,12 @@ "type": "TREE", "connectors": [ { - "label": "connector", + "name": "connector", "table": "table", "validityDates": { - "label": "indexdatum", - "column": "table.indexdatum" + "name": "indexdatum", + "startColumn": "table.start", + "endColumn": "table.ende" }, "selects": { "type": "EVENT_DATE_UNION", @@ -66,8 +68,12 @@ }, "columns": [ { - "name": "indexdatum", - "type": "DATE_RANGE" + "name": "start", + "type": "DATE" + }, + { + "name": "ende", + "type": "DATE" }, { "name": "geburtsdatum", diff --git a/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/content.csv b/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/content.csv index ddfdc58317..1006a5430b 100644 --- a/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/content.csv +++ b/backend/src/test/resources/tests/aggregator/EVENT_DATE_AGGREGATOR/content.csv @@ -1,11 +1,11 @@ -pid,indexdatum,geburtsdatum -1,"2010-01-01/2010-03-31",2010-01-31 -2,"2010-01-01/2010-03-31",1998-01-01 -3,"2010-01-01/2010-03-31",1997-12-31 -4,"2010-01-01/2010-03-31", -5,"2010-01-01/2010-03-31",2011-01-01 -6,"2010-01-01/2010-03-31",1998-03-01 -7,"2010-01-01/2010-03-31",2010-01-31 -8,"2010-01-01/2010-03-31",1998-03-01 -9,"2010-01-01/2010-03-31",1998-04-01 -10,"2010-01-01/2010-03-31",2012-01-01 \ No newline at end of file +pid,start,ende,geburtsdatum +1,"2010-01-01","2010-03-31",2010-01-31 +2,"2010-01-01","2010-03-31",1998-01-01 +3,"2010-01-01","2010-03-31",1997-12-31 +4,"2010-01-01","2010-03-31", +5,"2010-01-01","2010-03-31",2011-01-01 +6,"2010-01-01","2010-03-31",1998-03-01 +7,"2010-01-01","2010-03-31",2010-01-31 +8,"2010-01-01","2010-03-31",1998-03-01 +9,"2010-01-01","2010-03-31",1998-04-01 +10,"2010-01-01","2010-03-31",2012-01-01 \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR/NUMBER.test.json b/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR/NUMBER.test.json index 85e69af173..be5d99f1f5 100644 --- a/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR/NUMBER.test.json +++ b/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR/NUMBER.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/EXISTS_AGGREGATOR/expected.csv", @@ -47,7 +48,8 @@ "table": "table", "validityDates": { "label": "datum", - "column": "table.datum" + "startColumn": "table.start", + "endColumn": "table.ende" }, "filters": { "label": "filter", @@ -73,8 +75,12 @@ "type": "REAL" }, { - "name": "datum", - "type": "DATE_RANGE" + "name": "start", + "type": "DATE" + }, + { + "name": "ende", + "type": "DATE" } ] } diff --git a/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR/content.csv b/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR/content.csv index 24556a3454..1babf7262e 100644 --- a/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR/content.csv +++ b/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR/content.csv @@ -1,8 +1,8 @@ -pid,value,datum -1,1,"2014-06-30/2015-06-30" -2,1,"2014-06-30/2015-06-30" -2,2,"2014-06-30/2015-06-30" -3,3,"2014-06-30/2015-06-30" -4,,"2014-06-30/2015-06-30" -5,1,"2014-06-30/2015-06-30" -5,,"2014-06-30/2015-06-30" +pid,value,start,ende +1,1,"2014-06-30","2015-06-30" +2,1,"2014-06-30","2015-06-30" +2,2,"2014-06-30","2015-06-30" +3,3,"2014-06-30","2015-06-30" +4,,"2014-06-30","2015-06-30" +5,1,"2014-06-30","2015-06-30" +5,,"2014-06-30","2015-06-30" diff --git a/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR_OR/NUMBER.test.json b/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR_OR/NUMBER.test.json index 28c87d6bf5..47657c0410 100644 --- a/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR_OR/NUMBER.test.json +++ b/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR_OR/NUMBER.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/EXISTS_AGGREGATOR_OR/expected.csv", @@ -74,7 +75,8 @@ "table": "table", "validityDates": { "label": "datum", - "column": "table.datum" + "startColumn": "table.start", + "endColumn": "table.ende" }, "filters": { "label": "value", @@ -101,8 +103,12 @@ "type": "REAL" }, { - "name": "datum", - "type": "DATE_RANGE" + "name": "start", + "type": "DATE" + }, + { + "name": "ende", + "type": "DATE" } ] } diff --git a/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR_OR/content.csv b/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR_OR/content.csv index 24556a3454..1babf7262e 100644 --- a/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR_OR/content.csv +++ b/backend/src/test/resources/tests/aggregator/EXISTS_AGGREGATOR_OR/content.csv @@ -1,8 +1,8 @@ -pid,value,datum -1,1,"2014-06-30/2015-06-30" -2,1,"2014-06-30/2015-06-30" -2,2,"2014-06-30/2015-06-30" -3,3,"2014-06-30/2015-06-30" -4,,"2014-06-30/2015-06-30" -5,1,"2014-06-30/2015-06-30" -5,,"2014-06-30/2015-06-30" +pid,value,start,ende +1,1,"2014-06-30","2015-06-30" +2,1,"2014-06-30","2015-06-30" +2,2,"2014-06-30","2015-06-30" +3,3,"2014-06-30","2015-06-30" +4,,"2014-06-30","2015-06-30" +5,1,"2014-06-30","2015-06-30" +5,,"2014-06-30","2015-06-30" diff --git a/backend/src/test/resources/tests/aggregator/FIRST_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json b/backend/src/test/resources/tests/aggregator/FIRST_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json index fba3354bf6..236b8c26d4 100644 --- a/backend/src/test/resources/tests/aggregator/FIRST_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/aggregator/FIRST_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/FIRST_AGGREGATOR/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/FIRST_AGGREGATOR/content.csv b/backend/src/test/resources/tests/aggregator/FIRST_AGGREGATOR/content.csv index c1de39e465..76dcc14bb1 100644 --- a/backend/src/test/resources/tests/aggregator/FIRST_AGGREGATOR/content.csv +++ b/backend/src/test/resources/tests/aggregator/FIRST_AGGREGATOR/content.csv @@ -8,4 +8,3 @@ pid,datum,value 5,2012-01-01,"m" 5,,"f" 6,2012-01-01,"m" -6,2012-01-01,"f" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/FLAGS_AGGREGATOR/FLAGS_AGGREGATOR.test.json b/backend/src/test/resources/tests/aggregator/FLAGS_AGGREGATOR/FLAGS_AGGREGATOR.test.json index 02364f081b..6834d251ff 100644 --- a/backend/src/test/resources/tests/aggregator/FLAGS_AGGREGATOR/FLAGS_AGGREGATOR.test.json +++ b/backend/src/test/resources/tests/aggregator/FLAGS_AGGREGATOR/FLAGS_AGGREGATOR.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/FLAGS_AGGREGATOR/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json b/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json index c08a548044..442b52fc33 100644 --- a/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/LAST_AGGREGATOR/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/content.csv b/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/content.csv index bb1adca9de..3a33a7f81f 100644 --- a/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/content.csv +++ b/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/content.csv @@ -9,5 +9,3 @@ pid,datum,value 4,,"f" 5,2012-01-01,"m" 5,,"f" -6,2012-01-01,"m" -6,2012-01-01,"f" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/expected.csv b/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/expected.csv index 018d2a35a4..440b512dcd 100644 --- a/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/expected.csv +++ b/backend/src/test/resources/tests/aggregator/LAST_AGGREGATOR/expected.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02},f 5,{2012-01-01/2012-01-01},m -6,{2012-01-01/2012-01-01},m \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT/SIMPLE_VIRTUAL_CONCEPT_Query.test.json b/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT/SIMPLE_VIRTUAL_CONCEPT_Query.test.json index ecc5110997..17064c082c 100644 --- a/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT/SIMPLE_VIRTUAL_CONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT/SIMPLE_VIRTUAL_CONCEPT_Query.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/MAPPED/DISTINCT/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT/expected.csv b/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT/expected.csv index c8cd2026db..b328490919 100644 --- a/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT/expected.csv +++ b/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT/expected.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02},{hello} 5,{2012-01-01/2012-01-01},{int2} -6,{2012-01-01/2012-01-01},"{int2,hello}" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT_MULTI/SIMPLE_VIRTUAL_CONCEPT_Query.test.json b/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT_MULTI/SIMPLE_VIRTUAL_CONCEPT_Query.test.json index 19bcea3b42..a1b4909aed 100644 --- a/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT_MULTI/SIMPLE_VIRTUAL_CONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT_MULTI/SIMPLE_VIRTUAL_CONCEPT_Query.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/MAPPED/DISTINCT_MULTI/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT_MULTI/expected.csv b/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT_MULTI/expected.csv index 85c148ff89..0b2f2987c2 100644 --- a/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT_MULTI/expected.csv +++ b/backend/src/test/resources/tests/aggregator/MAPPED/DISTINCT_MULTI/expected.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02},"{goodbye,hello}" 5,{2012-01-01/2012-01-01},{int2} -6,{2012-01-01/2012-01-01},"{int2,goodbye,hello}" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/MAPPED/FIRST/SIMPLE_VIRTUAL_CONCEPT_Query.test.json b/backend/src/test/resources/tests/aggregator/MAPPED/FIRST/SIMPLE_VIRTUAL_CONCEPT_Query.test.json index 86ed03ad78..2ef50af243 100644 --- a/backend/src/test/resources/tests/aggregator/MAPPED/FIRST/SIMPLE_VIRTUAL_CONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/aggregator/MAPPED/FIRST/SIMPLE_VIRTUAL_CONCEPT_Query.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/MAPPED/FIRST/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/MAPPED/FIRST/expected.csv b/backend/src/test/resources/tests/aggregator/MAPPED/FIRST/expected.csv index a391f52733..f7eba07a90 100644 --- a/backend/src/test/resources/tests/aggregator/MAPPED/FIRST/expected.csv +++ b/backend/src/test/resources/tests/aggregator/MAPPED/FIRST/expected.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02},External: hello world 5,{2012-01-01/2012-01-01},External: ext2 -6,{2012-01-01/2012-01-01},External: ext2 \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/MAPPED/FIRST_MULTI/SIMPLE_VIRTUAL_CONCEPT_Query.test.json b/backend/src/test/resources/tests/aggregator/MAPPED/FIRST_MULTI/SIMPLE_VIRTUAL_CONCEPT_Query.test.json index 9ef8481673..bfbfcb8165 100644 --- a/backend/src/test/resources/tests/aggregator/MAPPED/FIRST_MULTI/SIMPLE_VIRTUAL_CONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/aggregator/MAPPED/FIRST_MULTI/SIMPLE_VIRTUAL_CONCEPT_Query.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/MAPPED/FIRST_MULTI/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/MAPPED/FIRST_MULTI/expected.csv b/backend/src/test/resources/tests/aggregator/MAPPED/FIRST_MULTI/expected.csv index e7b1b0541d..8fb8073097 100644 --- a/backend/src/test/resources/tests/aggregator/MAPPED/FIRST_MULTI/expected.csv +++ b/backend/src/test/resources/tests/aggregator/MAPPED/FIRST_MULTI/expected.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02},"{External: hello world,External: goodbye moon}" 5,{2012-01-01/2012-01-01},{External: ext2} -6,{2012-01-01/2012-01-01},{External: ext2} \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/MAPPED/content.csv b/backend/src/test/resources/tests/aggregator/MAPPED/content.csv index 7c4c553b55..cd9314b52a 100644 --- a/backend/src/test/resources/tests/aggregator/MAPPED/content.csv +++ b/backend/src/test/resources/tests/aggregator/MAPPED/content.csv @@ -9,5 +9,3 @@ pid,datum,value 4,,int1 5,2012-01-01,int2 5,,int1 -6,2012-01-01,int2 -6,2012-01-01,int1 \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/QUARTER_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json b/backend/src/test/resources/tests/aggregator/QUARTER_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json index e1b97554f2..9e45f8c522 100644 --- a/backend/src/test/resources/tests/aggregator/QUARTER_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/aggregator/QUARTER_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": false, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/QUARTER_AGGREGATOR/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/RANDOM_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json b/backend/src/test/resources/tests/aggregator/RANDOM_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json index f7472b1d89..ea7977786f 100644 --- a/backend/src/test/resources/tests/aggregator/RANDOM_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/aggregator/RANDOM_AGGREGATOR/SIMPLE_VIRTUAL_CONCEPT_Query.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/RANDOM_AGGREGATOR/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/RANDOM_AGGREGATOR/content.csv b/backend/src/test/resources/tests/aggregator/RANDOM_AGGREGATOR/content.csv index 6d99b9f9e5..0566d5ffd9 100644 --- a/backend/src/test/resources/tests/aggregator/RANDOM_AGGREGATOR/content.csv +++ b/backend/src/test/resources/tests/aggregator/RANDOM_AGGREGATOR/content.csv @@ -5,4 +5,3 @@ pid,datum,value 5,2012-01-01,"m" 5,,"f" 6,2012-01-01,"m" -6,2012-01-01,"f" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/MAPPED.test.json b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/MAPPED.test.json index 2bc93f414f..d15c8fd121 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/MAPPED.test.json +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/MAPPED.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/SUBSTRING/DISTINCT/expected-mapped.csv", diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/SIMPLE.test.json b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/SIMPLE.test.json index 88a8bcf908..72a32bc888 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/SIMPLE.test.json +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/SIMPLE.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/SUBSTRING/DISTINCT/expected-simple.csv", diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/expected-mapped.csv b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/expected-mapped.csv index 9716ddef9d..167f4b7492 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/expected-mapped.csv +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/expected-mapped.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02}, 5,{2012-01-01/2012-01-01},{in} -6,{2012-01-01/2012-01-01},"{hello,t2}" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/expected-simple.csv b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/expected-simple.csv index e4f3864d9e..0a4e5f3af1 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/expected-simple.csv +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT/expected-simple.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02}, 5,{2012-01-01/2012-01-01},{in} -6,{2012-01-01/2012-01-01},"{t1,t2}" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT_MULTI/MAPPED.test.json b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT_MULTI/MAPPED.test.json index e04a99cee2..92f9332bbe 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT_MULTI/MAPPED.test.json +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT_MULTI/MAPPED.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/SUBSTRING/DISTINCT_MULTI/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT_MULTI/expected.csv b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT_MULTI/expected.csv index 23b2e9a8a6..e1a75a04f2 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT_MULTI/expected.csv +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/DISTINCT_MULTI/expected.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02}, 5,{2012-01-01/2012-01-01},{in} -6,{2012-01-01/2012-01-01},"{goodbye,hello,t2}" \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/MAPPED.test.json b/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/MAPPED.test.json index bd867a63b0..f9ea853755 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/MAPPED.test.json +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/MAPPED.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/SUBSTRING/FIRST/expected-mapped.csv", diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/SIMPLE.test.json b/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/SIMPLE.test.json index a1f6e3452f..be542f9b10 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/SIMPLE.test.json +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/SIMPLE.test.json @@ -4,7 +4,8 @@ "sqlSpec": { "isEnabled": true, "supportedDialects": [ - "POSTGRESQL" + "POSTGRESQL", + "CLICKHOUSE" ] }, "expectedCsv": "tests/aggregator/SUBSTRING/FIRST/expected.csv", diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected-mapped.csv b/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected-mapped.csv index bc061d9ce0..e8e2e3e547 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected-mapped.csv +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected-mapped.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02}, 5,{2012-01-01/2012-01-01},in -6,{2012-01-01/2012-01-01},External: ext2 \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected-multi.csv b/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected-multi.csv index 31a9728df9..58b6047f9e 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected-multi.csv +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected-multi.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02},{} 5,{2012-01-01/2012-01-01},{in} -6,{2012-01-01/2012-01-01},{t2} \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected.csv b/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected.csv index f3004ccea8..612667a777 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected.csv +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/FIRST/expected.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02}, 5,{2012-01-01/2012-01-01},in -6,{2012-01-01/2012-01-01},t2 \ No newline at end of file diff --git a/backend/src/test/resources/tests/aggregator/SUBSTRING/content.csv b/backend/src/test/resources/tests/aggregator/SUBSTRING/content.csv index d5cbb1b238..f72b94d6b3 100644 --- a/backend/src/test/resources/tests/aggregator/SUBSTRING/content.csv +++ b/backend/src/test/resources/tests/aggregator/SUBSTRING/content.csv @@ -9,5 +9,3 @@ pid,datum,value 4,,int1 5,2012-01-01,__int2 5,,int1__ -6,2012-01-01,int2 -6,2012-01-01,int1 \ No newline at end of file diff --git a/backend/src/test/resources/tests/filter/COUNT_QUARTERS/COUNT_QUARTERS.test.json b/backend/src/test/resources/tests/filter/COUNT_QUARTERS/COUNT_QUARTERS.test.json index 3a4589ec32..a66b6de389 100644 --- a/backend/src/test/resources/tests/filter/COUNT_QUARTERS/COUNT_QUARTERS.test.json +++ b/backend/src/test/resources/tests/filter/COUNT_QUARTERS/COUNT_QUARTERS.test.json @@ -1,10 +1,10 @@ { "type": "FILTER_TEST", "label": "COUNT_QUARTERS Test", - "expectedCsv": "tests/filter/COUNT_QUARTERS/expected_COUNT_QUARTERS_Filter.csv", + "expectedCsv": "tests/filter/COUNT_QUARTERS/expected.csv", "content": { "tables": { - "csv": "tests/filter/COUNT_QUARTERS/content_COUNT_QUARTERS_Filter.csv", + "csv": "tests/filter/COUNT_QUARTERS/content.csv", "primaryColumn": { "name": "pid", "type": "STRING" diff --git a/backend/src/test/resources/tests/filter/COUNT_QUARTERS/content_COUNT_QUARTERS_Filter.csv b/backend/src/test/resources/tests/filter/COUNT_QUARTERS/content.csv similarity index 100% rename from backend/src/test/resources/tests/filter/COUNT_QUARTERS/content_COUNT_QUARTERS_Filter.csv rename to backend/src/test/resources/tests/filter/COUNT_QUARTERS/content.csv diff --git a/backend/src/test/resources/tests/filter/COUNT_QUARTERS/expected_COUNT_QUARTERS_Filter.csv b/backend/src/test/resources/tests/filter/COUNT_QUARTERS/expected.csv similarity index 100% rename from backend/src/test/resources/tests/filter/COUNT_QUARTERS/expected_COUNT_QUARTERS_Filter.csv rename to backend/src/test/resources/tests/filter/COUNT_QUARTERS/expected.csv diff --git a/backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/COUNT_QUARTERS.test.json b/backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/COUNT_QUARTERS.test.json index 570455eaea..36f5f640f7 100644 --- a/backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/COUNT_QUARTERS.test.json +++ b/backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/COUNT_QUARTERS.test.json @@ -7,10 +7,10 @@ "POSTGRESQL" ] }, - "expectedCsv": "tests/filter/COUNT_QUARTERS_RANGE/expected_COUNT_QUARTERS_Filter.csv", + "expectedCsv": "tests/filter/COUNT_QUARTERS_RANGE/expected.csv", "content": { "tables": { - "csv": "tests/filter/COUNT_QUARTERS_RANGE/content_COUNT_QUARTERS_Filter.csv", + "csv": "tests/filter/COUNT_QUARTERS_RANGE/content.csv", "primaryColumn": { "name": "pid", "type": "STRING" diff --git a/backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/content_COUNT_QUARTERS_Filter.csv b/backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/content.csv similarity index 100% rename from backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/content_COUNT_QUARTERS_Filter.csv rename to backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/content.csv diff --git a/backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/expected_COUNT_QUARTERS_Filter.csv b/backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/expected.csv similarity index 100% rename from backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/expected_COUNT_QUARTERS_Filter.csv rename to backend/src/test/resources/tests/filter/COUNT_QUARTERS_RANGE/expected.csv diff --git a/backend/src/test/resources/tests/query/ABS_EXPORT/ABS_EXPORT_Query.test.json b/backend/src/test/resources/tests/query/ABS_EXPORT/ABS_EXPORT_Query.test.json index 9646f65b66..4a35ead38e 100644 --- a/backend/src/test/resources/tests/query/ABS_EXPORT/ABS_EXPORT_Query.test.json +++ b/backend/src/test/resources/tests/query/ABS_EXPORT/ABS_EXPORT_Query.test.json @@ -2,6 +2,14 @@ "type": "QUERY_TEST", "label": "ABS_EXPORT Test", "expectedCsv": "tests/query/ABS_EXPORT/expected.csv", + "sqlSpec": { + "isEnabled": true, + "comment": "Clickhouse does not have Lateral joins at the moment. But fix is hopefully coming.", + "supportedDialects": [ + "POSTGRESQL", + "HANA" + ] + }, "query": { "type": "ABSOLUTE_FORM_QUERY", "dateRange": { diff --git a/backend/src/test/resources/tests/query/LOGICAL/NEGATION_LOGICAL/SIMPLE_TREECONCEPT_Query.test.json b/backend/src/test/resources/tests/query/LOGICAL/NEGATION_LOGICAL/SIMPLE_TREECONCEPT_Query.test.json index 330015c9b1..687ec4efd9 100644 --- a/backend/src/test/resources/tests/query/LOGICAL/NEGATION_LOGICAL/SIMPLE_TREECONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/query/LOGICAL/NEGATION_LOGICAL/SIMPLE_TREECONCEPT_Query.test.json @@ -2,6 +2,14 @@ "type": "QUERY_TEST", "label": "AND NEGATION DATE LOGIC Test", "expectedCsv": "tests/query/LOGICAL/NEGATION_LOGICAL/expected.csv", + "sqlSpec": { + "isEnabled": true, + "comment": "Logical will hopefully be kicked.", + "supportedDialects": [ + "POSTGRESQL", + "HANA" + ] + }, "query": { "type": "CONCEPT_QUERY", "dateAggregationMode": "LOGICAL", diff --git a/backend/src/test/resources/tests/query/LOGICAL/OR/SIMPLE_TREECONCEPT_Query.test.json b/backend/src/test/resources/tests/query/LOGICAL/OR/SIMPLE_TREECONCEPT_Query.test.json index baf0352180..e306d957c6 100644 --- a/backend/src/test/resources/tests/query/LOGICAL/OR/SIMPLE_TREECONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/query/LOGICAL/OR/SIMPLE_TREECONCEPT_Query.test.json @@ -2,6 +2,14 @@ "type": "QUERY_TEST", "label": "OR Test", "expectedCsv": "tests/query/LOGICAL/OR/expected.csv", + "sqlSpec": { + "isEnabled": true, + "comment": "Logical will hopefully be kicked.", + "supportedDialects": [ + "POSTGRESQL", + "HANA" + ] + }, "query": { "type": "CONCEPT_QUERY", "root": { diff --git a/backend/src/test/resources/tests/query/LOGICAL/OR_AND/SIMPLE_TREECONCEPT_Query.test.json b/backend/src/test/resources/tests/query/LOGICAL/OR_AND/SIMPLE_TREECONCEPT_Query.test.json index 3ec600da44..e20dcbb384 100644 --- a/backend/src/test/resources/tests/query/LOGICAL/OR_AND/SIMPLE_TREECONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/query/LOGICAL/OR_AND/SIMPLE_TREECONCEPT_Query.test.json @@ -2,6 +2,14 @@ "type": "QUERY_TEST", "label": "OR_AND Select test", "expectedCsv": "tests/query/LOGICAL/OR_AND/expected.csv", + "sqlSpec": { + "isEnabled": true, + "comment": "Logical will hopefully be kicked.", + "supportedDialects": [ + "POSTGRESQL", + "HANA" + ] + }, "query": { "type": "CONCEPT_QUERY", "root": { diff --git a/backend/src/test/resources/tests/query/LOGICAL/OR_DATE_LOGICAL/SIMPLE_TREECONCEPT_Query.test.json b/backend/src/test/resources/tests/query/LOGICAL/OR_DATE_LOGICAL/SIMPLE_TREECONCEPT_Query.test.json index c4c151df1c..e17fa70e18 100644 --- a/backend/src/test/resources/tests/query/LOGICAL/OR_DATE_LOGICAL/SIMPLE_TREECONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/query/LOGICAL/OR_DATE_LOGICAL/SIMPLE_TREECONCEPT_Query.test.json @@ -2,6 +2,14 @@ "type": "QUERY_TEST", "label": "OR DATE LOGIC Test", "expectedCsv": "tests/query/LOGICAL/OR_DATE_LOGICAL/expected.csv", + "sqlSpec": { + "isEnabled": true, + "comment": "Logical will hopefully be kicked.", + "supportedDialects": [ + "POSTGRESQL", + "HANA" + ] + }, "query": { "type": "CONCEPT_QUERY", "dateAggregationMode" : "LOGICAL", diff --git a/backend/src/test/resources/tests/query/MERGE/OR_EVENT_DATE_EXCLUDED/SIMPLE_TREECONCEPT_Query.test.json b/backend/src/test/resources/tests/query/MERGE/OR_EVENT_DATE_EXCLUDED/SIMPLE_TREECONCEPT_Query.test.json index 4e62f1935c..fcd5a10ae0 100644 --- a/backend/src/test/resources/tests/query/MERGE/OR_EVENT_DATE_EXCLUDED/SIMPLE_TREECONCEPT_Query.test.json +++ b/backend/src/test/resources/tests/query/MERGE/OR_EVENT_DATE_EXCLUDED/SIMPLE_TREECONCEPT_Query.test.json @@ -4,13 +4,13 @@ "expectedCsv": "tests/query/MERGE/OR_EVENT_DATE_EXCLUDED/expected.csv", "query": { "type": "CONCEPT_QUERY", - "dateAggregationMode" : "MERGE", + "dateAggregationMode": "MERGE", "root": { "type": "OR", "children": [ { "type": "CONCEPT", - "excludeFromTimeAggregation" : true, + "excludeFromTimeAggregation": true, "ids": [ "tree.a" ], @@ -44,9 +44,9 @@ "connectors": { "name": "connector", "column": "table.column", - "selects" : { - "type" : "EVENT_DATE_UNION", - "name" : "date_union" + "selects": { + "type": "EVENT_DATE_UNION", + "name": "date_union" }, "validityDates": { "name": "datum", @@ -57,16 +57,16 @@ { "name": "a", "condition": { - "type": "PREFIX_LIST", - "prefixes": "A" + "type": "EQUAL", + "values": "A" }, "children": [] }, { "name": "b", "condition": { - "type": "PREFIX_LIST", - "prefixes": "B" + "type": "EQUAL", + "values": "B" }, "children": [] } diff --git a/backend/src/test/resources/tests/query/MULTI_SELECT_NEGATION_DATE_RESTRICTION_OR_CONCEPT_QUERY2/MULTI_SELECT_DATE_RESTRICTION_OR_CONCEPT_QUERY.test.json b/backend/src/test/resources/tests/query/MULTI_SELECT_NEGATION_DATE_RESTRICTION_OR_CONCEPT_QUERY2/MULTI_SELECT_DATE_RESTRICTION_OR_CONCEPT_QUERY.test.json index 1fabb7fd07..f0dbfd0f5f 100644 --- a/backend/src/test/resources/tests/query/MULTI_SELECT_NEGATION_DATE_RESTRICTION_OR_CONCEPT_QUERY2/MULTI_SELECT_DATE_RESTRICTION_OR_CONCEPT_QUERY.test.json +++ b/backend/src/test/resources/tests/query/MULTI_SELECT_NEGATION_DATE_RESTRICTION_OR_CONCEPT_QUERY2/MULTI_SELECT_DATE_RESTRICTION_OR_CONCEPT_QUERY.test.json @@ -13,24 +13,19 @@ "max": "2012-11-11" }, "child": { - "type": "OR", - "children": [ + "ids": [ + "geschlecht_select" + ], + "type": "CONCEPT", + "tables": [ { - "ids": [ - "geschlecht_select" - ], - "type": "CONCEPT", - "tables": [ + "id": "geschlecht_select.geschlecht_connector", + "filters": [ { - "id": "geschlecht_select.geschlecht_connector", - "filters": [ - { - "filter": "geschlecht_select.geschlecht_connector.geschlecht", - "type": "MULTI_SELECT", - "value": [ - "f" - ] - } + "filter": "geschlecht_select.geschlecht_connector.geschlecht", + "type": "MULTI_SELECT", + "value": [ + "f" ] } ] diff --git a/backend/src/test/resources/tests/query/REL_EXPORT/PREREQUISITE_WITH_DATES/REL_EXPORT_Query.test.json b/backend/src/test/resources/tests/query/REL_EXPORT/PREREQUISITE_WITH_DATES/REL_EXPORT_Query.test.json index e6893f6ab8..6ef36b7970 100644 --- a/backend/src/test/resources/tests/query/REL_EXPORT/PREREQUISITE_WITH_DATES/REL_EXPORT_Query.test.json +++ b/backend/src/test/resources/tests/query/REL_EXPORT/PREREQUISITE_WITH_DATES/REL_EXPORT_Query.test.json @@ -1,122 +1,130 @@ { - "type": "QUERY_TEST", - "label": "REL_EXPORT WITH DATES Test", - "expectedCsv": "tests/query/REL_EXPORT/PREREQUISITE_WITH_DATES/expected.csv", + "type": "QUERY_TEST", + "label": "REL_EXPORT WITH DATES Test", + "sqlSpec": { + "isEnabled": true, + "comment": "Lateral JOINS are not possible with Clickhouse yet.", + "supportedDialects": [ + "POSTGRESQL", + "HANA" + ] + }, + "expectedCsv": "tests/query/REL_EXPORT/PREREQUISITE_WITH_DATES/expected.csv", + "query": { + "type": "RELATIVE_FORM_QUERY", + "resolutionsAndAlignmentMap": [ + { + "resolution": "COMPLETE", + "alignment": "NO_ALIGN" + }, + { + "resolution": "QUARTERS", + "alignment": "QUARTER" + } + ], "query": { - "type": "RELATIVE_FORM_QUERY", - "resolutionsAndAlignmentMap": [ - { - "resolution": "COMPLETE", - "alignment": "NO_ALIGN" - }, - { - "resolution": "QUARTERS", - "alignment": "QUARTER" - } + "type": "CONCEPT_QUERY", + "root": { + "type": "CONCEPT", + "ids": [ + "test_tree.test_child1" ], - "query": { - "type": "CONCEPT_QUERY", - "root": { - "type": "CONCEPT", - "ids": [ - "test_tree.test_child1" - ], - "tables": [ - { - "id": "test_tree.test_column", - "filters": [] - } - ] - } - }, - "features": { - "type": "ARRAY_CONCEPT_QUERY", - "childQueries": { - "type": "CONCEPT_QUERY", - "root": { - "type": "CONCEPT", - "ids": [ - "test_tree.test_child1" - ], - "selects": [ - "test_tree.exists" - ], - "tables": [ - { - "id": "test_tree.test_column", - "filters": [] - } - ] - } + "tables": [ + { + "id": "test_tree.test_column", + "filters": [] + } + ] + } + }, + "features": { + "type": "ARRAY_CONCEPT_QUERY", + "childQueries": { + "type": "CONCEPT_QUERY", + "root": { + "type": "CONCEPT", + "ids": [ + "test_tree.test_child1" + ], + "selects": [ + "test_tree.exists" + ], + "tables": [ + { + "id": "test_tree.test_column", + "filters": [] } - }, - "indexSelector": "EARLIEST", - "indexPlacement": "BEFORE", - "timeCountBefore": 4, - "timeCountAfter": 4, - "timeUnit": "QUARTERS" + ] + } + } }, - "concepts": [ + "indexSelector": "EARLIEST", + "indexPlacement": "BEFORE", + "timeCountBefore": 4, + "timeCountAfter": 4, + "timeUnit": "QUARTERS" + }, + "concepts": [ + { + "label": "test_tree", + "type": "TREE", + "connectors": { + "label": "tree_label", + "name": "test_column", + "column": "test_table.test_column", + "validityDates": { + "label": "datum", + "column": "test_table.datum" + } + }, + "selects": [ { - "label": "test_tree", - "type": "TREE", - "connectors": { - "label": "tree_label", - "name": "test_column", - "column": "test_table.test_column", - "validityDates": { - "label": "datum", - "column": "test_table.datum" - } - }, - "selects": [ - { - "type": "EXISTS", - "name": "exists" - } - ], - "children": [ - { - "label": "test_child1", - "description": " ", - "condition": { - "type": "PREFIX_LIST", - "prefixes": "A1" - }, - "children": [] - }, - { - "label": "test_child2", - "description": " ", - "condition": { - "type": "PREFIX_LIST", - "prefixes": "B2" - }, - "children": [] - } - ] + "type": "EXISTS", + "name": "exists" } - ], - "content": { - "tables": [ - { - "csv": "tests/query/REL_EXPORT/PREREQUISITE_WITH_DATES/content.csv", - "name": "test_table", - "primaryColumn": { - "name": "pid", - "type": "STRING" - }, - "columns": [ - { - "name": "datum", - "type": "DATE" - }, - { - "name": "test_column", - "type": "STRING" - } - ] - } - ] + ], + "children": [ + { + "label": "test_child1", + "description": " ", + "condition": { + "type": "PREFIX_LIST", + "prefixes": "A1" + }, + "children": [] + }, + { + "label": "test_child2", + "description": " ", + "condition": { + "type": "PREFIX_LIST", + "prefixes": "B2" + }, + "children": [] + } + ] } + ], + "content": { + "tables": [ + { + "csv": "tests/query/REL_EXPORT/PREREQUISITE_WITH_DATES/content.csv", + "name": "test_table", + "primaryColumn": { + "name": "pid", + "type": "STRING" + }, + "columns": [ + { + "name": "datum", + "type": "DATE" + }, + { + "name": "test_column", + "type": "STRING" + } + ] + } + ] + } } \ No newline at end of file diff --git a/backend/src/test/resources/tests/sql/selects/first/LAST_AGGREGATOR/content.csv b/backend/src/test/resources/tests/sql/selects/first/LAST_AGGREGATOR/content.csv index bb1adca9de..3a33a7f81f 100644 --- a/backend/src/test/resources/tests/sql/selects/first/LAST_AGGREGATOR/content.csv +++ b/backend/src/test/resources/tests/sql/selects/first/LAST_AGGREGATOR/content.csv @@ -9,5 +9,3 @@ pid,datum,value 4,,"f" 5,2012-01-01,"m" 5,,"f" -6,2012-01-01,"m" -6,2012-01-01,"f" \ No newline at end of file diff --git a/backend/src/test/resources/tests/sql/selects/first/LAST_AGGREGATOR/expected.csv b/backend/src/test/resources/tests/sql/selects/first/LAST_AGGREGATOR/expected.csv index 018d2a35a4..440b512dcd 100644 --- a/backend/src/test/resources/tests/sql/selects/first/LAST_AGGREGATOR/expected.csv +++ b/backend/src/test/resources/tests/sql/selects/first/LAST_AGGREGATOR/expected.csv @@ -3,4 +3,3 @@ result,dates,concept select 2,{2010-07-15/2010-07-15}, 3,{2012-01-01/2012-01-02},f 5,{2012-01-01/2012-01-01},m -6,{2012-01-01/2012-01-01},m \ No newline at end of file