thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-03 13:02:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix non joined rows from nullable column

Browse Source
This commit is contained in:
vdimir 2021-08-30 14:05:47 +03:00
parent bb1d22aa19
commit 943b71e4ff
No known key found for this signature in database
GPG Key ID: F57B3E10A21DBB31
5 changed files with 68 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/Interpreters/join_common.cpp
View File

@ -9,7 +9,6 @@
#include <DataTypes/DataTypeLowCardinality.h>
#include <DataTypes/DataTypeNullable.h>
#include <DataTypes/DataTypesNumber.h>
#include <DataTypes/getLeastSupertype.h>
#include <IO/WriteHelpers.h>
@ -30,12 +29,42 @@ namespace ErrorCodes
namespace
{
void insertFromNullableOrDefault(MutableColumnPtr & dst, const ColumnNullable * nullable_col)
{
const auto & nested = nullable_col->getNestedColumn();
const auto & nullmap = nullable_col->getNullMapColumn().getData();
if (auto * lc = typeid_cast<ColumnLowCardinality *>(dst.get()); lc && !nested.lowCardinality())
{
for (size_t i = 0; i < nullable_col->size(); ++i)
{
if (nullmap[i])
lc->insertDefault();
else
lc->insertRangeFromFullColumn(nested, i, 1);
}
}
else
{
for (size_t i = 0; i < nullable_col->size(); ++i)
{
if (nullmap[i])
dst->insertDefault();
else
dst->insertFrom(nested, i);
}
}
}
ColumnPtr changeLowCardinality(const ColumnPtr & column, const ColumnPtr & dst_sample)
{
if (dst_sample->lowCardinality())
{
MutableColumnPtr lc = dst_sample->cloneEmpty();
typeid_cast<ColumnLowCardinality &>(*lc).insertRangeFromFullColumn(*column, 0, column->size());
if (const auto * nullable_col = typeid_cast<const ColumnNullable *>(column.get()))
insertFromNullableOrDefault(lc, nullable_col);
else
typeid_cast<ColumnLowCardinality &>(*lc).insertRangeFromFullColumn(*column, 0, column->size());
return lc;
}
@ -190,9 +219,9 @@ void removeColumnNullability(ColumnWithTypeAndName & column)
if (column.column && column.column->isNullable())
{
const auto * nullable_column = checkAndGetColumn<ColumnNullable>(*column.column);
ColumnPtr nested_column = nullable_column->getNestedColumnPtr();
MutableColumnPtr mutable_column = IColumn::mutate(std::move(nested_column));
const auto * nullable_col = checkAndGetColumn<ColumnNullable>(*column.column);
MutableColumnPtr mutable_column = nullable_col->getNestedColumn().cloneEmpty();
insertFromNullableOrDefault(mutable_column, nullable_col);
column.column = std::move(mutable_column);
}
}

10
tests/queries/0_stateless/00445_join_nullable_keys.reference
View File

@ -22,3 +22,13 @@
13 13
14 14
\N 8
0 0
0 2
0 4
0 6
0 8
1 1
3 3
5 5
7 7
9 9

10
tests/queries/0_stateless/00445_join_nullable_keys.sql
View File

@ -30,3 +30,13 @@ ANY RIGHT JOIN
(
SELECT nullIf(number, 8) AS k, toString(number) AS b FROM system.numbers LIMIT 5, 10
) js2 USING (k) ORDER BY k;
SELECT k, b
FROM
(
SELECT number + 1 AS k FROM numbers(10)
) js1
RIGHT JOIN
(
SELECT nullIf(number, if(number % 2 == 0, number, 0)) AS k, number AS b FROM numbers(10)
) js2 USING (k) ORDER BY k, b;

5
tests/queries/0_stateless/01142_join_lc_and_nullable_in_key.reference
View File

@ -13,6 +13,8 @@
0 \N Nullable(String)
1 l \N Nullable(String)
-
0
-
1 l \N Nullable(String)
2 \N \N Nullable(String)
1 l \N Nullable(String)
@ -27,3 +29,6 @@
\N \N \N Nullable(String)
1 l \N Nullable(String)
\N \N \N Nullable(String)
-
\N \N
-

9
tests/queries/0_stateless/01142_join_lc_and_nullable_in_key.sql
View File

@ -27,6 +27,10 @@ SELECT x, lc, materialize(r.lc) y, toTypeName(y) FROM t AS l FULL JOIN nr AS r U
SELECT '-';
SELECT x, lc FROM t AS l RIGHT JOIN nr AS r USING (lc);
SELECT '-';
SET join_use_nulls = 1;
SELECT x, lc, r.lc, toTypeName(r.lc) FROM t AS l LEFT JOIN nr AS r USING (x) ORDER BY x;
@ -45,6 +49,11 @@ SELECT x, lc, materialize(r.lc) y, toTypeName(y) FROM t AS l LEFT JOIN nr AS r U
SELECT x, lc, materialize(r.lc) y, toTypeName(y) FROM t AS l RIGHT JOIN nr AS r USING (lc) ORDER BY x;
SELECT x, lc, materialize(r.lc) y, toTypeName(y) FROM t AS l FULL JOIN nr AS r USING (lc) ORDER BY x;
SELECT '-';
SELECT x, lc FROM t AS l RIGHT JOIN nr AS r USING (lc);
SELECT '-';
DROP TABLE t;
DROP TABLE nr;