mirror of https://github.com/citusdata/citus.git
Merge pull request #3393 from citusdata/order_by_multirow_insert
Add ORDER BY to multi_row_insert.sqlpull/3478/head
commit
a53b844939
|
@ -11,7 +11,7 @@ SELECT create_distributed_table('source_table_xyz', 'key', 'range');
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
CALL public.create_range_partitioned_shards('source_table_xyz', '{"(0,a)","(25,z)"}','{"(24,a)","(49,z)"}');
|
CALL public.create_range_partitioned_shards('source_table_xyz', '{"(0,a)","(25,z)"}','{"(24,a)","(49,z)"}');
|
||||||
SELECT * FROM pg_dist_shard WHERE logicalrelid='source_table_xyz'::regclass::oid;
|
SELECT * FROM pg_dist_shard WHERE logicalrelid='source_table_xyz'::regclass::oid ORDER BY shardid;
|
||||||
logicalrelid | shardid | shardstorage | shardminvalue | shardmaxvalue
|
logicalrelid | shardid | shardstorage | shardminvalue | shardmaxvalue
|
||||||
---------------------------------------------------------------------
|
---------------------------------------------------------------------
|
||||||
source_table_xyz | 4213581 | t | (0,a) | (24,a)
|
source_table_xyz | 4213581 | t | (0,a) | (24,a)
|
||||||
|
|
|
@ -9,7 +9,7 @@ CREATE TABLE source_table_xyz(key composite_key_type, value int, mapped_key comp
|
||||||
SELECT create_distributed_table('source_table_xyz', 'key', 'range');
|
SELECT create_distributed_table('source_table_xyz', 'key', 'range');
|
||||||
CALL public.create_range_partitioned_shards('source_table_xyz', '{"(0,a)","(25,z)"}','{"(24,a)","(49,z)"}');
|
CALL public.create_range_partitioned_shards('source_table_xyz', '{"(0,a)","(25,z)"}','{"(24,a)","(49,z)"}');
|
||||||
|
|
||||||
SELECT * FROM pg_dist_shard WHERE logicalrelid='source_table_xyz'::regclass::oid;
|
SELECT * FROM pg_dist_shard WHERE logicalrelid='source_table_xyz'::regclass::oid ORDER BY shardid;
|
||||||
SELECT shardid, nodename, nodeport FROM pg_dist_shard_placement WHERE EXISTS(SELECT shardid FROM pg_dist_shard WHERE shardid=pg_dist_shard_placement.shardid AND logicalrelid='source_table_xyz'::regclass::oid);
|
SELECT shardid, nodename, nodeport FROM pg_dist_shard_placement WHERE EXISTS(SELECT shardid FROM pg_dist_shard WHERE shardid=pg_dist_shard_placement.shardid AND logicalrelid='source_table_xyz'::regclass::oid);
|
||||||
|
|
||||||
INSERT INTO source_table_xyz VALUES ((0, 'a'), 1, (0, 'a')),
|
INSERT INTO source_table_xyz VALUES ((0, 'a'), 1, (0, 'a')),
|
||||||
|
|
Loading…
Reference in New Issue