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

Rename function

pull/4480/head
Onder Kalaci 2021-01-14 20:44:54 +03:00
parent 30d0a65f40
commit ae0b92233d
3 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/backend/distributed/commands/table.c
View File

@ -1098,13 +1098,12 @@ PreprocessAlterTableSchemaStmt(Node *node, const char *queryString,
/* /*
* WorkerProcessAlterTableStmt checks and processes the alter table statement to be * SkipForeignKeyValidationIfConstraintIsFkey checks and processes the alter table
* worked on the distributed table of the worker node. Currently, it only processes * statement to be worked on the distributed table. Currently, it only processes
* ALTER TABLE ... ADD FOREIGN KEY command to skip the validation step. * ALTER TABLE ... ADD FOREIGN KEY command to skip the validation step.
*/ */
Node * Node *
WorkerProcessAlterTableStmt(AlterTableStmt *alterTableStatement, SkipForeignKeyValidationIfConstraintIsFkey(AlterTableStmt *alterTableStatement)
const char *alterTableCommand)
{ {
/* first check whether a distributed relation is affected */ /* first check whether a distributed relation is affected */
if (alterTableStatement->relation == NULL) if (alterTableStatement->relation == NULL)

2
src/backend/distributed/commands/utility_hook.c
View File

@ -416,7 +416,7 @@ multi_ProcessUtility(PlannedStmt *pstmt,
* Note validation is done on the shard level when DDL propagation * Note validation is done on the shard level when DDL propagation
* is enabled. The following eagerly executes some tasks on workers. * is enabled. The following eagerly executes some tasks on workers.
*/ */
parsetree = WorkerProcessAlterTableStmt(alterTableStmt, queryString); parsetree = SkipForeignKeyValidationIfConstraintIsFkey(alterTableStmt);
} }
} }
} }

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

@ -368,8 +368,7 @@ extern List * PreprocessAlterTableMoveAllStmt(Node *node, const char *queryStrin
ProcessUtilityContext processUtilityContext); ProcessUtilityContext processUtilityContext);
extern List * PreprocessAlterTableSchemaStmt(Node *node, const char *queryString, extern List * PreprocessAlterTableSchemaStmt(Node *node, const char *queryString,
ProcessUtilityContext processUtilityContext); ProcessUtilityContext processUtilityContext);
extern Node * WorkerProcessAlterTableStmt(AlterTableStmt *alterTableStatement, extern Node * SkipForeignKeyValidationIfConstraintIsFkey(AlterTableStmt *alterTableStmt);
const char *alterTableCommand);
extern bool IsAlterTableRenameStmt(RenameStmt *renameStmt); extern bool IsAlterTableRenameStmt(RenameStmt *renameStmt);
extern void ErrorIfAlterDropsPartitionColumn(AlterTableStmt *alterTableStatement); extern void ErrorIfAlterDropsPartitionColumn(AlterTableStmt *alterTableStatement);
extern void PostprocessAlterTableStmt(AlterTableStmt *pStmt); extern void PostprocessAlterTableStmt(AlterTableStmt *pStmt);