thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 10:02:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Adding 00979_live_view_watch_continuous_aggregates.py test.

Browse Source
This commit is contained in:
Vitaliy Zakaznikov 2020-04-27 17:34:12 +02:00
parent 26532f4617
commit 9d28066539
2 changed files with 66 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
tests/queries/0_stateless/00979_live_view_watch_continuous_aggregates.py Executable file
View File

@ -0,0 +1,66 @@
#!/usr/bin/env python
import os
import sys
import signal
CURDIR = os.path.dirname(os.path.realpath(__file__))
sys.path.insert(0, os.path.join(CURDIR, 'helpers'))
from client import client, prompt, end_of_block
log = None
# uncomment the line below for debugging
#log=sys.stdout
with client(name='client1>', log=log) as client1, client(name='client2>', log=log) as client2:
client1.expect(prompt)
client2.expect(prompt)
client1.send('SET allow_experimental_live_view = 1')
client1.expect(prompt)
client2.send('SET allow_experimental_live_view = 1')
client2.expect(prompt)
client1.send('DROP TABLE IF EXISTS test.lv')
client1.expect(prompt)
client1.send('DROP TABLE IF EXISTS test.mt')
client1.expect(prompt)
client1.send('CREATE TABLE test.mt (time DateTime, location String, temperature UInt32) Engine=MergeTree order by tuple()')
client1.expect(prompt)
client1.send('CREATE LIVE VIEW test.lv AS SELECT toStartOfDay(time) AS day, location, avg(temperature) FROM test.mt GROUP BY day, location ORDER BY day, location')
client1.expect(prompt)
client1.send('WATCH test.lv FORMAT CSV')
client2.send("INSERT INTO test.mt VALUES ('2019-01-01 00:00:00','New York',60),('2019-01-01 00:10:00','New York',70)")
client2.expect(prompt)
client1.expect(r'"2019-01-01 00:00:00","New York",65,2')
client2.send("INSERT INTO test.mt VALUES ('2019-01-01 00:00:00','Moscow',30),('2019-01-01 00:10:00', 'Moscow', 40)")
client2.expect(prompt)
client1.expect(r'"2019-01-01 00:00:00","Moscow",35,3')
client1.expect(r'"2019-01-01 00:00:00","New York",65,3')
client2.send("INSERT INTO test.mt VALUES ('2019-01-02 00:00:00','New York',50),('2019-01-02 00:10:00','New York',60)")
client2.expect(prompt)
client1.expect(r'"2019-01-01 00:00:00","Moscow",35,4')
client1.expect(r'"2019-01-01 00:00:00","New York",65,4')
client1.expect(r'"2019-01-02 00:00:00","New York",55,4')
client2.send("INSERT INTO test.mt VALUES ('2019-01-02 00:00:00','Moscow',20),('2019-01-02 00:10:00', 'Moscow', 30)")
client2.expect(prompt)
client1.expect(r'"2019-01-01 00:00:00","Moscow",35,5')
client1.expect(r'"2019-01-01 00:00:00","New York",65,5')
client1.expect(r'"2019-01-02 00:00:00","Moscow",25,5')
client1.expect(r'"2019-01-02 00:00:00","New York",55,5')
client2.send("INSERT INTO test.mt VALUES ('2019-01-02 00:03:00','New York',40),('2019-01-02 00:06:00','New York',30)")
client2.expect(prompt)
client1.expect(r'"2019-01-01 00:00:00","Moscow",35,6')
client1.expect(r'"2019-01-01 00:00:00","New York",65,6')
client1.expect(r'"2019-01-02 00:00:00","Moscow",25,6')
client1.expect(r'"2019-01-02 00:00:00","New York",45,6')
# send Ctrl-C
client1.send('\x03', eol='')
match = client1.expect('(%s)|([#\$] )' % prompt)
if match.groups()[1]:
client1.send(client1.command)
client1.expect(prompt)
client1.send('DROP TABLE test.lv')
client1.expect(prompt)
client1.send('DROP TABLE test.mt')
client1.expect(prompt)

0
tests/queries/0_stateless/00979_live_view_watch_continuous_aggregates.reference Normal file
View File