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

Style

talha_tes1
Ahmet Gedemenli 2021-10-19 15:39:47 +03:00
parent c29c2d0263
commit 5611915300
4 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/backend/distributed/commands/citus_add_local_table_to_metadata.c
View File

@ -79,7 +79,8 @@ static void DropDefaultExpressionsAndMoveOwnedSequenceOwnerships(Oid sourceRelat
static void DropDefaultColumnDefinition(Oid relationId, char *columnName); static void DropDefaultColumnDefinition(Oid relationId, char *columnName);
static void TransferSequenceOwnership(Oid ownedSequenceId, Oid targetRelationId, static void TransferSequenceOwnership(Oid ownedSequenceId, Oid targetRelationId,
char *columnName); char *columnName);
static void InsertMetadataForCitusLocalTable(Oid citusLocalTableId, uint64 shardId, bool autoConverted); static void InsertMetadataForCitusLocalTable(Oid citusLocalTableId, uint64 shardId,
bool autoConverted);
static void FinalizeCitusLocalTableCreation(Oid relationId, List *dependentSequenceList); static void FinalizeCitusLocalTableCreation(Oid relationId, List *dependentSequenceList);
@ -1099,7 +1100,8 @@ TransferSequenceOwnership(Oid sequenceId, Oid targetRelationId, char *targetColu
* pg_dist_partition, pg_dist_shard & pg_dist_placement. * pg_dist_partition, pg_dist_shard & pg_dist_placement.
*/ */
static void static void
InsertMetadataForCitusLocalTable(Oid citusLocalTableId, uint64 shardId, bool autoConverted) InsertMetadataForCitusLocalTable(Oid citusLocalTableId, uint64 shardId,
bool autoConverted)
{ {
Assert(OidIsValid(citusLocalTableId)); Assert(OidIsValid(citusLocalTableId));
Assert(shardId != INVALID_SHARD_ID); Assert(shardId != INVALID_SHARD_ID);

2
src/backend/distributed/sql/citus--10.2-3--11.0-1.sql
View File

@ -6,6 +6,6 @@
#include "udfs/fix_all_partition_shard_index_names/11.0-1.sql" #include "udfs/fix_all_partition_shard_index_names/11.0-1.sql"
#include "udfs/worker_fix_partition_shard_index_names/11.0-1.sql" #include "udfs/worker_fix_partition_shard_index_names/11.0-1.sql"
ALTER TABLE pg_catalog.pg_dist_partition ADD COLUMN autoconverted boolean;
DROP FUNCTION IF EXISTS pg_catalog.master_apply_delete_command(text); DROP FUNCTION IF EXISTS pg_catalog.master_apply_delete_command(text);
DROP FUNCTION pg_catalog.master_get_table_metadata(text); DROP FUNCTION pg_catalog.master_get_table_metadata(text);
ALTER TABLE pg_catalog.pg_dist_partition ADD COLUMN autoconverted boolean;

3
src/backend/distributed/sql/downgrades/citus--11.0-1--10.2-3.sql
View File

@ -4,8 +4,6 @@ DROP FUNCTION pg_catalog.fix_all_partition_shard_index_names();
DROP FUNCTION pg_catalog.fix_partition_shard_index_names(regclass); DROP FUNCTION pg_catalog.fix_partition_shard_index_names(regclass);
DROP FUNCTION pg_catalog.worker_fix_partition_shard_index_names(regclass, text, text); DROP FUNCTION pg_catalog.worker_fix_partition_shard_index_names(regclass, text, text);
ALTER TABLE pg_catalog.pg_dist_partition DROP COLUMN autoconverted;
CREATE FUNCTION pg_catalog.master_apply_delete_command(text) CREATE FUNCTION pg_catalog.master_apply_delete_command(text)
RETURNS integer RETURNS integer
LANGUAGE C STRICT LANGUAGE C STRICT
@ -26,3 +24,4 @@ CREATE FUNCTION pg_catalog.master_get_table_metadata(
AS 'MODULE_PATHNAME', $$master_get_table_metadata$$; AS 'MODULE_PATHNAME', $$master_get_table_metadata$$;
COMMENT ON FUNCTION master_get_table_metadata(relation_name text) COMMENT ON FUNCTION master_get_table_metadata(relation_name text)
IS 'fetch metadata values for the table'; IS 'fetch metadata values for the table';
ALTER TABLE pg_catalog.pg_dist_partition DROP COLUMN autoconverted;

4
src/include/distributed/commands.h
View File

@ -533,8 +533,8 @@ extern void ExecuteForeignKeyCreateCommandList(List *ddlCommandList,
bool skip_validation); bool skip_validation);
/* create_citus_local_table.c */ /* create_citus_local_table.c */
extern void SetAutoConverted(bool autoConvertedValue); extern void CreateCitusLocalTable(Oid relationId, bool cascadeViaForeignKeys,
extern void CreateCitusLocalTable(Oid relationId, bool cascadeViaForeignKeys, bool autoConverted); bool autoConverted);
extern List * GetExplicitIndexOidList(Oid relationId); extern List * GetExplicitIndexOidList(Oid relationId);
extern bool ShouldPropagateSetCommand(VariableSetStmt *setStmt); extern bool ShouldPropagateSetCommand(VariableSetStmt *setStmt);