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

Needs more attention, PG commit 858e776c84f48841e7e16fba7b690b76e54f3675

pg16_kickoff
onderkalaci 2023-04-26 20:41:42 +03:00
parent 70554b3a7b
commit c56c564e80
5 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -64,7 +64,7 @@ CreateDomainStmt *
RecreateDomainStmt(Oid domainOid) RecreateDomainStmt(Oid domainOid)
{ {
CreateDomainStmt *stmt = makeNode(CreateDomainStmt); CreateDomainStmt *stmt = makeNode(CreateDomainStmt);
stmt->domainname = stringToQualifiedNameList(format_type_be_qualified(domainOid)); stmt->domainname = stringToQualifiedNameList(format_type_be_qualified(domainOid), NULL);
HeapTuple tup = SearchSysCache1(TYPEOID, ObjectIdGetDatum(domainOid)); HeapTuple tup = SearchSysCache1(TYPEOID, ObjectIdGetDatum(domainOid));
if (!HeapTupleIsValid(tup)) if (!HeapTupleIsValid(tup))

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

@ -182,7 +182,7 @@ truncate_local_data_after_distributing_table(PG_FUNCTION_ARGS)
TruncateStmt *truncateStmt = makeNode(TruncateStmt); TruncateStmt *truncateStmt = makeNode(TruncateStmt);
char *relationName = generate_qualified_relation_name(relationId); char *relationName = generate_qualified_relation_name(relationId);
List *names = stringToQualifiedNameList(relationName); List *names = stringToQualifiedNameList(relationName, NULL);
truncateStmt->relations = list_make1(makeRangeVarFromNameList(names)); truncateStmt->relations = list_make1(makeRangeVarFromNameList(names));
truncateStmt->restart_seqs = false; truncateStmt->restart_seqs = false;
truncateStmt->behavior = DROP_CASCADE; truncateStmt->behavior = DROP_CASCADE;

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

@ -187,7 +187,7 @@ RecreateCompositeTypeStmt(Oid typeOid)
Assert(get_typtype(typeOid) == TYPTYPE_COMPOSITE); Assert(get_typtype(typeOid) == TYPTYPE_COMPOSITE);
CompositeTypeStmt *stmt = makeNode(CompositeTypeStmt); CompositeTypeStmt *stmt = makeNode(CompositeTypeStmt);
List *names = stringToQualifiedNameList(format_type_be_qualified(typeOid)); List *names = stringToQualifiedNameList(format_type_be_qualified(typeOid), NULL);
stmt->typevar = makeRangeVarFromNameList(names); stmt->typevar = makeRangeVarFromNameList(names);
stmt->coldeflist = CompositeTypeColumnDefList(typeOid); stmt->coldeflist = CompositeTypeColumnDefList(typeOid);
@ -252,7 +252,7 @@ RecreateEnumStmt(Oid typeOid)
Assert(get_typtype(typeOid) == TYPTYPE_ENUM); Assert(get_typtype(typeOid) == TYPTYPE_ENUM);
CreateEnumStmt *stmt = makeNode(CreateEnumStmt); CreateEnumStmt *stmt = makeNode(CreateEnumStmt);
stmt->typeName = stringToQualifiedNameList(format_type_be_qualified(typeOid)); stmt->typeName = stringToQualifiedNameList(format_type_be_qualified(typeOid), NULL);
stmt->vals = EnumValsList(typeOid); stmt->vals = EnumValsList(typeOid);
return stmt; return stmt;
@ -565,7 +565,7 @@ CreateTypeDDLCommandsIdempotent(const ObjectAddress *typeAddress)
char * char *
GenerateBackupNameForTypeCollision(const ObjectAddress *address) GenerateBackupNameForTypeCollision(const ObjectAddress *address)
{ {
List *names = stringToQualifiedNameList(format_type_be_qualified(address->objectId)); List *names = stringToQualifiedNameList(format_type_be_qualified(address->objectId), NULL);
RangeVar *rel = makeRangeVarFromNameList(names); RangeVar *rel = makeRangeVarFromNameList(names);
char *newName = palloc0(NAMEDATALEN); char *newName = palloc0(NAMEDATALEN);

2
src/backend/distributed/utils/function_utils.c
View File

@ -41,7 +41,7 @@ FunctionOidExtended(const char *schemaName, const char *functionName, int argume
bool missingOK) bool missingOK)
{ {
char *qualifiedFunctionName = quote_qualified_identifier(schemaName, functionName); char *qualifiedFunctionName = quote_qualified_identifier(schemaName, functionName);
List *qualifiedFunctionNameList = stringToQualifiedNameList(qualifiedFunctionName); List *qualifiedFunctionNameList = stringToQualifiedNameList(qualifiedFunctionName, NULL);
List *argumentList = NIL; List *argumentList = NIL;
const bool findVariadics = false; const bool findVariadics = false;
const bool findDefaults = false; const bool findDefaults = false;

2
src/backend/distributed/worker/worker_create_or_replace.c
View File

@ -526,7 +526,7 @@ CreateRenameTypeStmt(const ObjectAddress *address, char *newName)
stmt->renameType = OBJECT_TYPE; stmt->renameType = OBJECT_TYPE;
stmt->object = (Node *) stringToQualifiedNameList(format_type_be_qualified( stmt->object = (Node *) stringToQualifiedNameList(format_type_be_qualified(
address->objectId)); address->objectId), NULL);
stmt->newname = newName; stmt->newname = newName;