mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 16:50:48 +00:00
29 lines
2.1 KiB
SQL
29 lines
2.1 KiB
SQL
DROP TABLE IF EXISTS rows_events_test;
|
|
CREATE TABLE rows_events_test (k UInt32, v UInt32) ENGINE = MergeTree ORDER BY k;
|
|
|
|
INSERT INTO /* test 01413, query 1 */ rows_events_test VALUES (1,1);
|
|
SYSTEM FLUSH LOGS;
|
|
|
|
SELECT written_rows FROM system.query_log WHERE current_database = currentDatabase() AND query LIKE 'INSERT INTO /* test 01413, query 1 */ rows_events_test%' AND type = 2 AND event_date >= yesterday() ORDER BY event_time DESC LIMIT 1;
|
|
|
|
SELECT ProfileEvents.Values as value FROM system.query_log ARRAY JOIN ProfileEvents
|
|
WHERE current_database = currentDatabase() AND ProfileEvents.Names = 'InsertedRows' AND query LIKE 'INSERT INTO /* test 01413, query 1 */ rows_events_test%' AND type = 2 AND event_date >= yesterday() ORDER BY event_time DESC LIMIT 1;
|
|
|
|
INSERT INTO /* test 01413, query 2 */ rows_events_test VALUES (2,2), (3,3);
|
|
SYSTEM FLUSH LOGS;
|
|
|
|
SELECT written_rows FROM system.query_log WHERE current_database = currentDatabase() AND query LIKE 'INSERT INTO /* test 01413, query 2 */ rows_events_test%' AND type = 2 AND event_date >= yesterday() ORDER BY event_time DESC LIMIT 1;
|
|
|
|
SELECT ProfileEvents.Values as value FROM system.query_log ARRAY JOIN ProfileEvents
|
|
WHERE current_database = currentDatabase() AND ProfileEvents.Names = 'InsertedRows' AND query LIKE 'INSERT INTO /* test 01413, query 2 */ rows_events_test%' AND type = 2 AND event_date >= yesterday() ORDER BY event_time DESC LIMIT 1;
|
|
|
|
SELECT * FROM /* test 01413, query 3 */ rows_events_test WHERE v = 2;
|
|
SYSTEM FLUSH LOGS;
|
|
|
|
SELECT read_rows FROM system.query_log WHERE current_database = currentDatabase() AND query LIKE 'SELECT * FROM /* test 01413, query 3 */ rows_events_test%' AND type = 2 AND event_date >= yesterday() ORDER BY event_time DESC LIMIT 1;
|
|
|
|
SELECT ProfileEvents.Values as value FROM system.query_log ARRAY JOIN ProfileEvents
|
|
WHERE current_database = currentDatabase() AND ProfileEvents.Names = 'SelectedRows' AND query LIKE 'SELECT * FROM /* test 01413, query 3 */ rows_events_test%' AND type = 2 AND event_date >= yesterday() ORDER BY event_time DESC LIMIT 1;
|
|
|
|
DROP TABLE rows_events_test;
|