external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update downgrade script and quote schema/table in COPY statement

pull/6029/head
Nitish Upreti 2022-07-01 13:35:27 -07:00
parent 4fcdff53ae
commit e29222458c
2 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/backend/distributed/operations/worker_shard_copy.c
View File

@ -368,7 +368,8 @@ ConstructCopyStatement(List *destinationShardFullyQualifiedName, bool useBinaryF
StringInfo command = makeStringInfo(); StringInfo command = makeStringInfo();
appendStringInfo(command, "COPY %s.%s FROM STDIN", appendStringInfo(command, "COPY %s.%s FROM STDIN",
destinationShardSchemaName, destinationShardRelationName); quote_identifier(destinationShardSchemaName), quote_identifier(
destinationShardRelationName));
if (useBinaryFormat) if (useBinaryFormat)
{ {

11
src/backend/distributed/sql/downgrades/citus--11.1-1--11.0-2.sql
View File

@ -46,4 +46,15 @@ CREATE FUNCTION pg_catalog.worker_repartition_cleanup(bigint)
STRICT STRICT
AS 'MODULE_PATHNAME', $function$worker_repartition_cleanup$function$; AS 'MODULE_PATHNAME', $function$worker_repartition_cleanup$function$;
DROP TYPE IF EXISTS citus.split_mode;
DROP TYPE IF EXISTS citus.split_copy_info;
DROP FUNCTION pg_catalog.citus_split_shard_by_split_points(
shard_id bigint,
split_points text[],
node_ids integer[],
split_mode citus.split_mode);
DROP FUNCTION pg_catalog.worker_split_copy(
source_shard_id bigint,
splitCopyInfos citus.split_copy_info[]);
#include "../../../columnar/sql/downgrades/columnar--11.1-1--11.0-2.sql" #include "../../../columnar/sql/downgrades/columnar--11.1-1--11.0-2.sql"