【发布时间】:2021-04-17 10:47:19
【问题描述】:
我使用 Clickhouse 数据库。
我有分段输入的文本。我需要将所有文本分组在一行中,没有重复的段
当count(segment) = total Segment。
我创建了第一个表来插入段。 然后我创建一个 MATERIALIZED 视图来删除重复的行并对所有段进行分组。
然后将其移至第二个表,但我的问题是视图不显示值。 当我运行查询时,它工作正常
第一个表:
CREATE table test_table_1
(
id UInt16,
text String,
totalSegment UInt16,
segmentNumber UInt16,
reference UInt16,
insertTime DateTime
)
ENGINE = ReplacingMergeTree()
order by (id , text , totalSegment , segmentNumber , reference );
第二张桌子:
CREATE table test_table_2
(
message String,
reference UInt16,
totalSegment UInt16
)
ENGINE = MergeTree()
order by (reference );
实体化视图:
CREATE MATERIALIZED VIEW consumer To test_table_2
as
SELECT groupArray(text) as message ,reference ,totalSegment
from (
select *
from
(
SELECT COUNT(*) as countSegment, totalSegment, reference
from test_table_1
where (text,totalSegment,reference,insertTime) in (
select text,totalSegment,reference, max(insertTime) as insertTime
from test_table_1
group by text,totalSegment,segmentNumber,reference
)
group by totalSegment, reference
HAVING count(*) = totalSegment
)as a
left join (
select text,segmentNumber,reference, max(insertTime) as insertTime
from test_table_1
group by text,segmentNumber,reference
)as b using (reference)
order by segmentNumber
)
grousp by reference ,totalSegment
order by reference ;
插入数据:
INSERT INTO test_table_1 (id,text, totalSegment, segmentNumber, reference,insertTime) VALUES(1, 'A1 ', 3, 1, '101', now() );
INSERT INTO test_table_1 (id,text, totalSegment, segmentNumber, reference,insertTime) VALUES(2, 'B1 ', 2, 1, '202', now() );
INSERT INTO test_table_1 (id,text, totalSegment, segmentNumber, reference,insertTime) VALUES(3, 'C2 ', 3, 2, '303', now() );
INSERT INTO test_table_1 (id,text, totalSegment, segmentNumber, reference,insertTime) VALUES(4, 'A3 ', 3, 3, '101', now() );
INSERT INTO test_table_1 (id,text, totalSegment, segmentNumber, reference,insertTime) VALUES(5, 'A2 ', 3, 2, '101', now() );
INSERT INTO test_table_1 (id,text, totalSegment, segmentNumber, reference,insertTime) VALUES(6, 'C1 ', 3, 1, '303', now() );
INSERT INTO test_table_1 (id,text, totalSegment, segmentNumber, reference,insertTime) VALUES(7, 'C3 ', 3, 3, '303', now() );
INSERT INTO test_table_1 (id,text, totalSegment, segmentNumber, reference,insertTime) VALUES(8, 'B2 ', 2, 2, '202', now() );
【问题讨论】:
标签: database clickhouse materialized-views