Run all tests with SQL Mode

backend/src/main/java/com/bakdata/conquery/apiv1/query/ArrayConceptQuery.java

@@ -26,6 +26,7 @@
 import lombok.NoArgsConstructor;
 import lombok.NonNull;
 import lombok.Setter;
+import lombok.ToString;
 import lombok.extern.slf4j.Slf4j;
 
 /**
@@ -38,6 +39,7 @@
 @CPSType(id = "ARRAY_CONCEPT_QUERY", base = QueryDescription.class)
 @Slf4j
 @NoArgsConstructor(access = AccessLevel.PRIVATE, onConstructor_ = {@JsonCreator})
+@ToString
 public class ArrayConceptQuery extends Query {
 
 	@NotEmpty

backend/src/main/java/com/bakdata/conquery/apiv1/query/ResultHeaders.java

@@ -14,6 +14,7 @@
 import com.bakdata.conquery.models.query.resultinfo.printers.common.LocalizedEnumPrinter;
 import com.bakdata.conquery.models.types.ResultType;
 import com.bakdata.conquery.models.types.SemanticType;
+import com.bakdata.conquery.sql.execution.ResultSetProcessor;
 import lombok.experimental.UtilityClass;
 
 @UtilityClass
@@ -27,6 +28,11 @@ public static ResultInfo datesInfo() {
 			public String userColumnName(PrintSettings printSettings) {
 				return C10nCache.getLocalized(ResultHeadersC10n.class, printSettings.getLocale()).dates();
 			}
+
+			@Override
+			public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+				return resultSetProcessor::getDateRangeList;
+			}
 		};
 	}
 
@@ -39,6 +45,11 @@ public static ResultInfo historyDatesInfo() {
 			public String userColumnName(PrintSettings printSettings) {
 				return C10nCache.getLocalized(ResultHeadersC10n.class, printSettings.getLocale()).dates();
 			}
+
+			@Override
+			public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+				return resultSetProcessor::getDateRangeList;
+			}
 		};
 	}
 
@@ -48,6 +59,11 @@ public static ResultInfo sourceInfo() {
 			public String userColumnName(PrintSettings printSettings) {
 				return C10nCache.getLocalized(ResultHeadersC10n.class, printSettings.getLocale()).source();
 			}
+
+			@Override
+			public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+				return resultSetProcessor::getString;
+			}
 		};
 	}
 
@@ -58,6 +74,11 @@ public static ResultInfo formContextInfo() {
 			public String userColumnName(PrintSettings printSettings) {
 				return C10nCache.getLocalized(ResultHeadersC10n.class, printSettings.getLocale()).index();
 			}
+
+			@Override
+			public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+				return resultSetProcessor::getInteger;
+			}
 		};
 	}
 
@@ -68,6 +89,11 @@ public static ResultInfo formDateRangeInfo() {
 			public String userColumnName(PrintSettings printSettings) {
 				return C10nCache.getLocalized(ResultHeadersC10n.class, printSettings.getLocale()).dateRange();
 			}
+
+			@Override
+			public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+				return resultSetProcessor::getDateRange;
+			}
 		};
 	}
 
@@ -83,6 +109,11 @@ public Printer createPrinter(PrinterFactory printerFactory, PrintSettings printS
 			public String userColumnName(PrintSettings printSettings) {
 				return C10nCache.getLocalized(ResultHeadersC10n.class, printSettings.getLocale()).resolution();
 			}
+
+			@Override
+			public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+				return resultSetProcessor::getString;
+			}
 		};
 	}
 
@@ -93,6 +124,11 @@ public static ResultInfo formEventDateInfo() {
 			public String userColumnName(PrintSettings printSettings) {
 				return C10nCache.getLocalized(ResultHeadersC10n.class, printSettings.getLocale()).eventDate();
 			}
+
+			@Override
+			public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+				return resultSetProcessor::getDate;
+			}
 		};
 	}
 
@@ -108,6 +144,11 @@ public Printer createPrinter(PrinterFactory printerFactory, PrintSettings printS
 			public String userColumnName(PrintSettings printSettings) {
 				return C10nCache.getLocalized(ResultHeadersC10n.class, printSettings.getLocale()).observationScope();
 			}
+
+			@Override
+			public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+				return resultSetProcessor::getString;
+			}
 		};
 	}
 }

backend/src/main/java/com/bakdata/conquery/apiv1/query/concept/filter/FilterValue.java

@@ -68,9 +68,6 @@ public SqlFilters convertToSqlFilter(SqlIdColumns ids, ConversionContext context
 		FilterContext<VALUE> filterContext = FilterContext.forConceptConversion(ids, readValue(), context, tables);
 		final Filter<VALUE> resolve = (Filter<VALUE>) filter.resolve();
 		SqlFilters sqlFilters = resolve.createConverter().convertToSqlFilter(resolve, filterContext);
-		if (context.isNegation()) {
-			return new SqlFilters(sqlFilters.getSelects(), sqlFilters.getWhereClauses().negated());
-		}
 		return sqlFilters;
 	}
 

backend/src/main/java/com/bakdata/conquery/apiv1/query/concept/specific/CQAnd.java

@@ -31,6 +31,7 @@
 import com.bakdata.conquery.models.query.resultinfo.FixedLabelResultInfo;
 import com.bakdata.conquery.models.query.resultinfo.ResultInfo;
 import com.bakdata.conquery.models.types.ResultType;
+import com.bakdata.conquery.sql.execution.ResultSetProcessor;
 import com.bakdata.conquery.util.QueryUtils;
 import com.fasterxml.jackson.annotation.JsonView;
 import com.google.common.base.Preconditions;
@@ -129,6 +130,11 @@ public String userColumnName(PrintSettings printSettings) {
 				public String defaultColumnName(PrintSettings printSettings) {
 					return defaultLabel(printSettings.getLocale());
 				}
+
+				@Override
+				public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+					return resultSetProcessor::getBoolean;
+				}
 			});
 		}
 		return resultInfos;

backend/src/main/java/com/bakdata/conquery/apiv1/query/concept/specific/CQOr.java

@@ -31,6 +31,7 @@
 import com.bakdata.conquery.models.query.resultinfo.FixedLabelResultInfo;
 import com.bakdata.conquery.models.query.resultinfo.ResultInfo;
 import com.bakdata.conquery.models.types.ResultType;
+import com.bakdata.conquery.sql.execution.ResultSetProcessor;
 import com.bakdata.conquery.util.QueryUtils;
 import com.fasterxml.jackson.annotation.JsonView;
 import com.google.common.base.Preconditions;
@@ -134,6 +135,11 @@ public String userColumnName(PrintSettings printSettings) {
 				public String defaultColumnName(PrintSettings printSettings) {
 					return defaultLabel(printSettings.getLocale());
 				}
+
+				@Override
+				public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+					return resultSetProcessor::getBoolean;
+				}
 			});
 		}
 

backend/src/main/java/com/bakdata/conquery/apiv1/query/concept/specific/CQTemporal.java

@@ -32,6 +32,7 @@
 import com.bakdata.conquery.models.query.resultinfo.ResultInfo;
 import com.bakdata.conquery.models.query.resultinfo.printers.common.ListResultInfo;
 import com.bakdata.conquery.models.types.ResultType;
+import com.bakdata.conquery.sql.execution.ResultSetProcessor;
 import com.fasterxml.jackson.annotation.JsonView;
 import lombok.Data;
 import lombok.Setter;
@@ -188,6 +189,11 @@ public List<ResultInfo> getResultInfos() {
 				public String userColumnName(PrintSettings printSettings) {
 					return C10N.get(ResultHeadersC10n.class, printSettings.getLocale()).temporalCompareLabel(compare.userLabel(printSettings.getLocale()));
 				}
+
+				@Override
+				public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+					return resultSetProcessor::getDateRangeList;
+				}
 			});
 		}
 

backend/src/main/java/com/bakdata/conquery/io/result/csv/CsvRenderer.java

@@ -36,8 +36,9 @@ public void toCSV(List<ResultInfo> idHeaders, List<ResultInfo> infos, Stream<Ent
 		createCSVBody(cfg, infos, resultStream, printSettings, StringResultPrinters.forCharset(charset));
 	}
 
-	private void createCSVBody(PrintSettings cfg, List<ResultInfo> infos, Stream<EntityResult> results, PrintSettings printSettings,
-							   PrinterFactory printerFactory) {
+	private void createCSVBody(
+			PrintSettings cfg, List<ResultInfo> infos, Stream<EntityResult> results, PrintSettings printSettings,
+			PrinterFactory printerFactory) {
 		final Printer[] printers = infos.stream().map(info -> info.createPrinter(printerFactory, printSettings)).toArray(Printer[]::new);
 
 		results.map(result -> Pair.of(cfg.getIdMapper().map(result), result))
@@ -52,20 +53,19 @@ private void createCSVBody(PrintSettings cfg, List<ResultInfo> infos, Stream<Ent
 	public void printLine(EntityPrintId entity, Printer[] printers, Object[] values) {
 		// Cast here to Object[] so it is clear to intellij that the varargs call is intended
 		writer.addValues((Object[]) entity.getExternalId());
-		try {
-			for (int i = 0; i < printers.length; i++) {
-				final Object value = values[i];
-
-				if (value == null) {
-					writer.addValue("");
-					continue;
-				}
+		for (int i = 0; i < printers.length; i++) {
+			final Object value = values[i];
 
+			if (value == null) {
+				writer.addValue("");
+				continue;
+			}
+			try {
 				writer.addValue(printers[i].apply(value));
 			}
-		}
-		catch (Exception e) {
-			throw new IllegalStateException("Unable to print line " + Arrays.deepToString(values), e);
+			catch (Exception e) {
+				throw new IllegalStateException("Failed to print column %s of line %s".formatted(i, Arrays.deepToString(values)), e);
+			}
 		}
 
 		writer.writeValuesToRow();

backend/src/main/java/com/bakdata/conquery/models/config/IdColumnConfig.java

@@ -17,6 +17,7 @@
 import com.bakdata.conquery.models.query.resultinfo.ResultInfo;
 import com.bakdata.conquery.models.types.ResultType;
 import com.bakdata.conquery.models.types.SemanticType;
+import com.bakdata.conquery.sql.execution.ResultSetProcessor;
 import com.fasterxml.jackson.annotation.JsonIgnore;
 import com.google.common.base.Functions;
 import com.google.common.collect.MoreCollectors;
@@ -139,6 +140,11 @@ public String userColumnName(PrintSettings printSettings) {
 							labels.size() == 1 ? labels.values().stream().collect(MoreCollectors.onlyElement()) : col.getField()
 					), col.getField());
 				}
+
+				@Override
+				public ResultSetProcessor.Reader<?> createReader(ResultSetProcessor resultSetProcessor) {
+					return resultSetProcessor::getString;
+				}
 			};
 		}).collect(Collectors.toUnmodifiableList());
 	}