mirror of https://github.com/citusdata/citus.git
fixup! Adds AlterTableStmtObjType macro
parent
95aae43a9c
commit
32c2d138fc
|
@ -773,7 +773,7 @@ GetDistributeObjectOps(Node *node)
|
||||||
case T_AlterTableStmt:
|
case T_AlterTableStmt:
|
||||||
{
|
{
|
||||||
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
||||||
switch (AlterTableStmtObjType(stmt))
|
switch (AlterTableStmtObjType_compat(stmt))
|
||||||
{
|
{
|
||||||
case OBJECT_TYPE:
|
case OBJECT_TYPE:
|
||||||
{
|
{
|
||||||
|
|
|
@ -595,7 +595,7 @@ PreprocessAlterSequenceOwnerStmt(Node *node, const char *queryString,
|
||||||
ProcessUtilityContext processUtilityContext)
|
ProcessUtilityContext processUtilityContext)
|
||||||
{
|
{
|
||||||
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_SEQUENCE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_SEQUENCE);
|
||||||
|
|
||||||
ObjectAddress sequenceAddress = GetObjectAddressFromParseTree((Node *) stmt, false);
|
ObjectAddress sequenceAddress = GetObjectAddressFromParseTree((Node *) stmt, false);
|
||||||
if (!ShouldPropagateObject(&sequenceAddress))
|
if (!ShouldPropagateObject(&sequenceAddress))
|
||||||
|
@ -623,7 +623,7 @@ ObjectAddress
|
||||||
AlterSequenceOwnerStmtObjectAddress(Node *node, bool missing_ok)
|
AlterSequenceOwnerStmtObjectAddress(Node *node, bool missing_ok)
|
||||||
{
|
{
|
||||||
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_SEQUENCE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_SEQUENCE);
|
||||||
|
|
||||||
RangeVar *sequence = stmt->relation;
|
RangeVar *sequence = stmt->relation;
|
||||||
Oid seqOid = RangeVarGetRelid(sequence, NoLock, missing_ok);
|
Oid seqOid = RangeVarGetRelid(sequence, NoLock, missing_ok);
|
||||||
|
@ -643,7 +643,7 @@ List *
|
||||||
PostprocessAlterSequenceOwnerStmt(Node *node, const char *queryString)
|
PostprocessAlterSequenceOwnerStmt(Node *node, const char *queryString)
|
||||||
{
|
{
|
||||||
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_SEQUENCE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_SEQUENCE);
|
||||||
|
|
||||||
ObjectAddress sequenceAddress = GetObjectAddressFromParseTree((Node *) stmt, false);
|
ObjectAddress sequenceAddress = GetObjectAddressFromParseTree((Node *) stmt, false);
|
||||||
if (!ShouldPropagateObject(&sequenceAddress))
|
if (!ShouldPropagateObject(&sequenceAddress))
|
||||||
|
|
|
@ -524,7 +524,7 @@ PreprocessAlterTableStmt(Node *node, const char *alterTableCommand,
|
||||||
if (get_rel_relkind(leftRelationId) == RELKIND_SEQUENCE)
|
if (get_rel_relkind(leftRelationId) == RELKIND_SEQUENCE)
|
||||||
{
|
{
|
||||||
AlterTableStmt *stmtCopy = copyObject(alterTableStatement);
|
AlterTableStmt *stmtCopy = copyObject(alterTableStatement);
|
||||||
AlterTableStmtObjType(stmtCopy) = OBJECT_SEQUENCE;
|
AlterTableStmtObjType_compat(stmtCopy) = OBJECT_SEQUENCE;
|
||||||
return PreprocessAlterSequenceOwnerStmt((Node *) stmtCopy, alterTableCommand,
|
return PreprocessAlterSequenceOwnerStmt((Node *) stmtCopy, alterTableCommand,
|
||||||
processUtilityContext);
|
processUtilityContext);
|
||||||
}
|
}
|
||||||
|
@ -1617,7 +1617,7 @@ PostprocessAlterTableStmt(AlterTableStmt *alterTableStatement)
|
||||||
*/
|
*/
|
||||||
if (get_rel_relkind(relationId) == RELKIND_SEQUENCE)
|
if (get_rel_relkind(relationId) == RELKIND_SEQUENCE)
|
||||||
{
|
{
|
||||||
AlterTableStmtObjType(alterTableStatement) = OBJECT_SEQUENCE;
|
AlterTableStmtObjType_compat(alterTableStatement) = OBJECT_SEQUENCE;
|
||||||
PostprocessAlterSequenceOwnerStmt((Node *) alterTableStatement, NULL);
|
PostprocessAlterSequenceOwnerStmt((Node *) alterTableStatement, NULL);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
|
@ -206,7 +206,7 @@ PreprocessAlterTypeStmt(Node *node, const char *queryString,
|
||||||
ProcessUtilityContext processUtilityContext)
|
ProcessUtilityContext processUtilityContext)
|
||||||
{
|
{
|
||||||
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_TYPE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_TYPE);
|
||||||
|
|
||||||
ObjectAddress typeAddress = GetObjectAddressFromParseTree((Node *) stmt, false);
|
ObjectAddress typeAddress = GetObjectAddressFromParseTree((Node *) stmt, false);
|
||||||
if (!ShouldPropagateObject(&typeAddress))
|
if (!ShouldPropagateObject(&typeAddress))
|
||||||
|
@ -789,7 +789,7 @@ ObjectAddress
|
||||||
AlterTypeStmtObjectAddress(Node *node, bool missing_ok)
|
AlterTypeStmtObjectAddress(Node *node, bool missing_ok)
|
||||||
{
|
{
|
||||||
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_TYPE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_TYPE);
|
||||||
|
|
||||||
TypeName *typeName = MakeTypeNameFromRangeVar(stmt->relation);
|
TypeName *typeName = MakeTypeNameFromRangeVar(stmt->relation);
|
||||||
Oid typeOid = LookupTypeNameOid(NULL, typeName, missing_ok);
|
Oid typeOid = LookupTypeNameOid(NULL, typeName, missing_ok);
|
||||||
|
|
|
@ -485,8 +485,8 @@ ProcessUtilityInternal(PlannedStmt *pstmt,
|
||||||
if (IsA(parsetree, AlterTableStmt))
|
if (IsA(parsetree, AlterTableStmt))
|
||||||
{
|
{
|
||||||
AlterTableStmt *alterTableStmt = (AlterTableStmt *) parsetree;
|
AlterTableStmt *alterTableStmt = (AlterTableStmt *) parsetree;
|
||||||
if (AlterTableStmtObjType(alterTableStmt) == OBJECT_TABLE ||
|
if (AlterTableStmtObjType_compat(alterTableStmt) == OBJECT_TABLE ||
|
||||||
AlterTableStmtObjType(alterTableStmt) == OBJECT_FOREIGN_TABLE)
|
AlterTableStmtObjType_compat(alterTableStmt) == OBJECT_FOREIGN_TABLE)
|
||||||
{
|
{
|
||||||
ErrorIfAlterDropsPartitionColumn(alterTableStmt);
|
ErrorIfAlterDropsPartitionColumn(alterTableStmt);
|
||||||
|
|
||||||
|
|
|
@ -194,7 +194,7 @@ DeparseAlterSequenceOwnerStmt(Node *node)
|
||||||
StringInfoData str = { 0 };
|
StringInfoData str = { 0 };
|
||||||
initStringInfo(&str);
|
initStringInfo(&str);
|
||||||
|
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_SEQUENCE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_SEQUENCE);
|
||||||
|
|
||||||
AppendAlterSequenceOwnerStmt(&str, stmt);
|
AppendAlterSequenceOwnerStmt(&str, stmt);
|
||||||
|
|
||||||
|
@ -209,7 +209,7 @@ DeparseAlterSequenceOwnerStmt(Node *node)
|
||||||
static void
|
static void
|
||||||
AppendAlterSequenceOwnerStmt(StringInfo buf, AlterTableStmt *stmt)
|
AppendAlterSequenceOwnerStmt(StringInfo buf, AlterTableStmt *stmt)
|
||||||
{
|
{
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_SEQUENCE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_SEQUENCE);
|
||||||
RangeVar *seq = stmt->relation;
|
RangeVar *seq = stmt->relation;
|
||||||
char *qualifiedSequenceName = quote_qualified_identifier(seq->schemaname,
|
char *qualifiedSequenceName = quote_qualified_identifier(seq->schemaname,
|
||||||
seq->relname);
|
seq->relname);
|
||||||
|
|
|
@ -64,7 +64,7 @@ DeparseAlterTableStmt(Node *node)
|
||||||
StringInfoData str = { 0 };
|
StringInfoData str = { 0 };
|
||||||
initStringInfo(&str);
|
initStringInfo(&str);
|
||||||
|
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_TABLE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_TABLE);
|
||||||
|
|
||||||
AppendAlterTableStmt(&str, stmt);
|
AppendAlterTableStmt(&str, stmt);
|
||||||
return str.data;
|
return str.data;
|
||||||
|
@ -83,7 +83,7 @@ AppendAlterTableStmt(StringInfo buf, AlterTableStmt *stmt)
|
||||||
stmt->relation->relname);
|
stmt->relation->relname);
|
||||||
ListCell *cmdCell = NULL;
|
ListCell *cmdCell = NULL;
|
||||||
|
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_TABLE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_TABLE);
|
||||||
|
|
||||||
appendStringInfo(buf, "ALTER TABLE %s", identifier);
|
appendStringInfo(buf, "ALTER TABLE %s", identifier);
|
||||||
foreach(cmdCell, stmt->cmds)
|
foreach(cmdCell, stmt->cmds)
|
||||||
|
|
|
@ -122,7 +122,7 @@ DeparseAlterTypeStmt(Node *node)
|
||||||
StringInfoData str = { 0 };
|
StringInfoData str = { 0 };
|
||||||
initStringInfo(&str);
|
initStringInfo(&str);
|
||||||
|
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_TYPE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_TYPE);
|
||||||
|
|
||||||
AppendAlterTypeStmt(&str, stmt);
|
AppendAlterTypeStmt(&str, stmt);
|
||||||
|
|
||||||
|
@ -137,7 +137,7 @@ AppendAlterTypeStmt(StringInfo buf, AlterTableStmt *stmt)
|
||||||
stmt->relation->relname);
|
stmt->relation->relname);
|
||||||
ListCell *cmdCell = NULL;
|
ListCell *cmdCell = NULL;
|
||||||
|
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_TYPE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_TYPE);
|
||||||
|
|
||||||
appendStringInfo(buf, "ALTER TYPE %s", identifier);
|
appendStringInfo(buf, "ALTER TYPE %s", identifier);
|
||||||
foreach(cmdCell, stmt->cmds)
|
foreach(cmdCell, stmt->cmds)
|
||||||
|
|
|
@ -32,7 +32,7 @@ void
|
||||||
QualifyAlterSequenceOwnerStmt(Node *node)
|
QualifyAlterSequenceOwnerStmt(Node *node)
|
||||||
{
|
{
|
||||||
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_SEQUENCE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_SEQUENCE);
|
||||||
|
|
||||||
RangeVar *seq = stmt->relation;
|
RangeVar *seq = stmt->relation;
|
||||||
|
|
||||||
|
|
|
@ -126,7 +126,7 @@ void
|
||||||
QualifyAlterTypeStmt(Node *node)
|
QualifyAlterTypeStmt(Node *node)
|
||||||
{
|
{
|
||||||
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
AlterTableStmt *stmt = castNode(AlterTableStmt, node);
|
||||||
Assert(AlterTableStmtObjType(stmt) == OBJECT_TYPE);
|
Assert(AlterTableStmtObjType_compat(stmt) == OBJECT_TYPE);
|
||||||
|
|
||||||
if (stmt->relation->schemaname == NULL)
|
if (stmt->relation->schemaname == NULL)
|
||||||
{
|
{
|
||||||
|
|
|
@ -31,7 +31,7 @@
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#if PG_VERSION_NUM >= PG_VERSION_14
|
#if PG_VERSION_NUM >= PG_VERSION_14
|
||||||
#define AlterTableStmtObjType(a) ((a)->objtype)
|
#define AlterTableStmtObjType_compat(a) ((a)->objtype)
|
||||||
#define getObjectTypeDescription_compat(a, b) getObjectTypeDescription(a, b)
|
#define getObjectTypeDescription_compat(a, b) getObjectTypeDescription(a, b)
|
||||||
#define getObjectIdentity_compat(a, b) getObjectIdentity(a, b)
|
#define getObjectIdentity_compat(a, b) getObjectIdentity(a, b)
|
||||||
|
|
||||||
|
@ -57,7 +57,7 @@
|
||||||
#define pull_varnos_compat(a, b) pull_varnos(a, b)
|
#define pull_varnos_compat(a, b) pull_varnos(a, b)
|
||||||
#define pg_get_statisticsobj_worker_compat(a, b, c) pg_get_statisticsobj_worker(a, b, c)
|
#define pg_get_statisticsobj_worker_compat(a, b, c) pg_get_statisticsobj_worker(a, b, c)
|
||||||
#else
|
#else
|
||||||
#define AlterTableStmtObjType(a) ((a)->relkind)
|
#define AlterTableStmtObjType_compat(a) ((a)->relkind)
|
||||||
#define F_NEXTVAL F_NEXTVAL_OID
|
#define F_NEXTVAL F_NEXTVAL_OID
|
||||||
#define ROLE_PG_MONITOR DEFAULT_ROLE_MONITOR
|
#define ROLE_PG_MONITOR DEFAULT_ROLE_MONITOR
|
||||||
#define PROC_WAIT_STATUS_WAITING STATUS_WAITING
|
#define PROC_WAIT_STATUS_WAITING STATUS_WAITING
|
||||||
|
|
Loading…
Reference in New Issue