thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 00:30:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixing Not-ready set in constraint.

Browse Source
This commit is contained in:
Nikolai Kochetov 2024-07-09 11:54:21 +00:00
parent 5943d60f26
commit 0174a43d17
8 changed files with 34 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Processors/Transforms/CheckConstraintsTransform.cpp
View File

@ -10,6 +10,7 @@
#include <Common/FieldVisitorToString.h>
#include <Common/assert_cast.h>
#include <Common/quoteString.h>
#include <Storages/VirtualColumnUtils.h>
namespace DB
@ -31,6 +32,7 @@ CheckConstraintsTransform::CheckConstraintsTransform(
, table_id(table_id_)
, constraints_to_check(constraints_.filterConstraints(ConstraintsDescription::ConstraintType::CHECK))
, expressions(constraints_.getExpressions(context_, header.getNamesAndTypesList()))
, context(std::move(context_))
{
}
@ -39,6 +41,10 @@ void CheckConstraintsTransform::onConsume(Chunk chunk)
{
if (chunk.getNumRows() > 0)
{
if (rows_written == 0)
for (const auto & expression : expressions)
VirtualColumnUtils::buildSetsForDAG(expression->getActionsDAG(), context);
Block block_to_calculate = getInputPort().getHeader().cloneWithColumns(chunk.getColumns());
for (size_t i = 0; i < expressions.size(); ++i)
{

1
src/Processors/Transforms/CheckConstraintsTransform.h
View File

@ -35,6 +35,7 @@ private:
StorageID table_id;
const ASTs constraints_to_check;
const ConstraintsExpressions expressions;
ContextPtr context;
size_t rows_written = 0;
Chunk cur_chunk;
};

2
src/Storages/System/StorageSystemDetachedParts.cpp
View File

@ -328,7 +328,7 @@ void ReadFromSystemDetachedParts::applyFilters(ActionDAGNodes added_filter_nodes
filter = VirtualColumnUtils::splitFilterDagForAllowedInputs(predicate, &block);
if (filter)
VirtualColumnUtils::buildSetsForDAG(filter, context);
VirtualColumnUtils::buildSetsForDAG(*filter, context);
}
}

4
src/Storages/System/StorageSystemPartsBase.cpp
View File

@ -274,7 +274,7 @@ void ReadFromSystemPartsBase::applyFilters(ActionDAGNodes added_filter_nodes)
filter_by_database = VirtualColumnUtils::splitFilterDagForAllowedInputs(predicate, &block);
if (filter_by_database)
VirtualColumnUtils::buildSetsForDAG(filter_by_database, context);
VirtualColumnUtils::buildSetsForDAG(*filter_by_database, context);
block.insert(ColumnWithTypeAndName({}, std::make_shared<DataTypeString>(), table_column_name));
block.insert(ColumnWithTypeAndName({}, std::make_shared<DataTypeString>(), engine_column_name));
@ -283,7 +283,7 @@ void ReadFromSystemPartsBase::applyFilters(ActionDAGNodes added_filter_nodes)
filter_by_other_columns = VirtualColumnUtils::splitFilterDagForAllowedInputs(predicate, &block);
if (filter_by_other_columns)
VirtualColumnUtils::buildSetsForDAG(filter_by_other_columns, context);
VirtualColumnUtils::buildSetsForDAG(*filter_by_other_columns, context);
}
}

6
src/Storages/VirtualColumnUtils.cpp
View File

@ -54,9 +54,9 @@ namespace DB
namespace VirtualColumnUtils
{
void buildSetsForDAG(const ActionsDAGPtr & dag, const ContextPtr & context)
void buildSetsForDAG(const ActionsDAG & dag, const ContextPtr & context)
{
for (const auto & node : dag->getNodes())
for (const auto & node : dag.getNodes())
{
if (node.type == ActionsDAG::ActionType::COLUMN)
{
@ -79,7 +79,7 @@ void buildSetsForDAG(const ActionsDAGPtr & dag, const ContextPtr & context)
void filterBlockWithDAG(ActionsDAGPtr dag, Block & block, ContextPtr context)
{
buildSetsForDAG(dag, context);
buildSetsForDAG(*dag, context);
auto actions = std::make_shared<ExpressionActions>(dag);
Block block_with_filter = block;
actions->execute(block_with_filter, /*dry_run=*/ false, /*allow_duplicates_in_input=*/ true);

2
src/Storages/VirtualColumnUtils.h
View File

@ -26,7 +26,7 @@ void filterBlockWithPredicate(const ActionsDAG::Node * predicate, Block & block,
void filterBlockWithDAG(ActionsDAGPtr dag, Block & block, ContextPtr context);
/// Builds sets used by ActionsDAG inplace.
void buildSetsForDAG(const ActionsDAGPtr & dag, const ContextPtr & context);
void buildSetsForDAG(const ActionsDAG & dag, const ContextPtr & context);
/// Recursively checks if all functions used in DAG are deterministic in scope of query.
bool isDeterministicInScopeOfQuery(const ActionsDAG::Node * node);

1
tests/queries/0_stateless/02841_not_ready_set_constraints.reference Normal file
View File

@ -0,0 +1 @@
42

19
tests/queries/0_stateless/02841_not_ready_set_constraints.sql Normal file
View File

@ -0,0 +1,19 @@
DROP TABLE IF EXISTS t1;
DROP TABLE IF EXISTS t2;
CREATE TABLE t1 (
`id` UInt64
)
ENGINE = MergeTree ORDER BY id;
INSERT INTO t1(id) VALUES (42);
CREATE TABLE t2 (
`conversation` UInt64,
CONSTRAINT constraint_conversation CHECK conversation IN (SELECT id FROM t1)
)
ENGINE = MergeTree ORDER BY conversation;
INSERT INTO t2(conversation) VALUES (42);
select * from t2;