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

Use database in path to support parallel

Browse Source
This commit is contained in:
Antonio Andelic 2022-09-02 07:24:46 +00:00
parent dbf67f26d8
commit c91369ec5a
3 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/queries/0_stateless/02416_keeper_map.sql
View File

@ -2,13 +2,13 @@
DROP TABLE IF EXISTS 02416_test SYNC; DROP TABLE IF EXISTS 02416_test SYNC;
CREATE TABLE 02416_test (key String, value UInt32) Engine=KeeperMap('/test2381'); -- { serverError 36 } CREATE TABLE 02416_test (key String, value UInt32) Engine=KeeperMap('/' || currentDatabase() || '/test2416'); -- { serverError 36 }
CREATE TABLE 02416_test (key String, value UInt32) Engine=KeeperMap('/test2381') PRIMARY KEY(key2); -- { serverError 47 } CREATE TABLE 02416_test (key String, value UInt32) Engine=KeeperMap('/' || currentDatabase() || '/test2416') PRIMARY KEY(key2); -- { serverError 47 }
CREATE TABLE 02416_test (key String, value UInt32) Engine=KeeperMap('/test2381') PRIMARY KEY(key, value); -- { serverError 36 } CREATE TABLE 02416_test (key String, value UInt32) Engine=KeeperMap('/' || currentDatabase() || '/test2416') PRIMARY KEY(key, value); -- { serverError 36 }
CREATE TABLE 02416_test (key Tuple(String, UInt32), value UInt64) Engine=KeeperMap('/test2381') PRIMARY KEY(key); CREATE TABLE 02416_test (key Tuple(String, UInt32), value UInt64) Engine=KeeperMap('/' || currentDatabase() || '/test2416') PRIMARY KEY(key);
DROP TABLE IF EXISTS 02416_test SYNC; DROP TABLE IF EXISTS 02416_test SYNC;
CREATE TABLE 02416_test (key String, value UInt32) Engine=KeeperMap('/test2381') PRIMARY KEY(key); CREATE TABLE 02416_test (key String, value UInt32) Engine=KeeperMap('/' || currentDatabase() || '/test2416') PRIMARY KEY(key);
INSERT INTO 02416_test SELECT '1_1', number FROM numbers(10000); INSERT INTO 02416_test SELECT '1_1', number FROM numbers(10000);
SELECT COUNT(1) == 1 FROM 02416_test; SELECT COUNT(1) == 1 FROM 02416_test;
@ -21,7 +21,7 @@ SELECT SUM(value) == 1 + 99 + 900 FROM 02416_test WHERE key IN ('1_1', '99_1', '
DROP TABLE IF EXISTS 02416_test SYNC; DROP TABLE IF EXISTS 02416_test SYNC;
DROP TABLE IF EXISTS 02416_test_memory; DROP TABLE IF EXISTS 02416_test_memory;
CREATE TABLE 02416_test (k UInt32, value UInt64, dummy Tuple(UInt32, Float64), bm AggregateFunction(groupBitmap, UInt64)) Engine=KeeperMap('/test2381') PRIMARY KEY(k); CREATE TABLE 02416_test (k UInt32, value UInt64, dummy Tuple(UInt32, Float64), bm AggregateFunction(groupBitmap, UInt64)) Engine=KeeperMap('/' || currentDatabase() || '/test2416') PRIMARY KEY(k);
CREATE TABLE 02416_test_memory AS 02416_test Engine = Memory; CREATE TABLE 02416_test_memory AS 02416_test Engine = Memory;
INSERT INTO 02416_test SELECT number % 77 AS k, SUM(number) AS value, (1, 1.2), bitmapBuild(groupArray(number)) FROM numbers(10000000) group by k; INSERT INTO 02416_test SELECT number % 77 AS k, SUM(number) AS value, (1, 1.2), bitmapBuild(groupArray(number)) FROM numbers(10000000) group by k;

4
tests/queries/0_stateless/02417_keeper_map_create_drop.sql
View File

@ -2,12 +2,12 @@
DROP TABLE IF EXISTS 02417_test SYNC; DROP TABLE IF EXISTS 02417_test SYNC;
CREATE TABLE 02417_test (key UInt64, value UInt64) Engine=KeeperMap('/test2417') PRIMARY KEY(key); CREATE TABLE 02417_test (key UInt64, value UInt64) Engine=KeeperMap('/' || currentDatabase() || '/test2417') PRIMARY KEY(key);
INSERT INTO 02417_test VALUES (1, 11); INSERT INTO 02417_test VALUES (1, 11);
SELECT * FROM 02417_test ORDER BY key; SELECT * FROM 02417_test ORDER BY key;
SELECT '------'; SELECT '------';
CREATE TABLE 02417_test_another (key UInt64, value UInt64) Engine=KeeperMap('/test2417') PRIMARY KEY(key); CREATE TABLE 02417_test_another (key UInt64, value UInt64) Engine=KeeperMap('/' || currentDatabase() || '/test2417') PRIMARY KEY(key);
INSERT INTO 02417_test_another VALUES (2, 22); INSERT INTO 02417_test_another VALUES (2, 22);
SELECT * FROM 02417_test_another ORDER BY key; SELECT * FROM 02417_test_another ORDER BY key;
SELECT '------'; SELECT '------';

4
tests/queries/0_stateless/02418_keeper_map_keys_limit.sql
View File

@ -2,7 +2,7 @@
DROP TABLE IF EXISTS 02418_test SYNC; DROP TABLE IF EXISTS 02418_test SYNC;
CREATE TABLE 02418_test (key UInt64, value Float64) Engine=KeeperMap('/test2418', 1, 3) PRIMARY KEY(key); CREATE TABLE 02418_test (key UInt64, value Float64) Engine=KeeperMap('/' || currentDatabase() || '/test2418', 1, 3) PRIMARY KEY(key);
INSERT INTO 02418_test VALUES (1, 1.1), (2, 2.2); INSERT INTO 02418_test VALUES (1, 1.1), (2, 2.2);
SELECT count() FROM 02418_test; SELECT count() FROM 02418_test;
@ -12,7 +12,7 @@ INSERT INTO 02418_test VALUES (3, 3.3), (4, 4.4); -- { serverError 290 }
INSERT INTO 02418_test VALUES (1, 2.1), (2, 3.2), (3, 3.3); INSERT INTO 02418_test VALUES (1, 2.1), (2, 3.2), (3, 3.3);
SELECT count() FROM 02418_test; SELECT count() FROM 02418_test;
CREATE TABLE 02418_test_another (key UInt64, value Float64) Engine=KeeperMap('/test2418', 1, 4) PRIMARY KEY(key); CREATE TABLE 02418_test_another (key UInt64, value Float64) Engine=KeeperMap('/' || currentDatabase() || '/test2418', 1, 4) PRIMARY KEY(key);
INSERT INTO 02418_test VALUES (4, 4.4); -- { serverError 290 } INSERT INTO 02418_test VALUES (4, 4.4); -- { serverError 290 }
INSERT INTO 02418_test_another VALUES (4, 4.4); INSERT INTO 02418_test_another VALUES (4, 4.4);