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

wip

fix_procedure_out
Onder Kalaci 2022-03-22 16:50:24 +01:00
parent 9c7fde92b6
commit 43c3c5eded
1 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/backend/distributed/commands/function.c
View File

@ -894,11 +894,25 @@ GetFunctionAlterOwnerCommand(const RegProcedure funcOid)
* If the function exists we want to use format_procedure_qualified to * If the function exists we want to use format_procedure_qualified to
* serialize its canonical arguments * serialize its canonical arguments
*/ */
char *functionSignature = format_procedure_qualified(funcOid); char *schemaName = get_namespace_name(get_func_namespace(funcOid));
char *functionName = get_func_name(funcOid);
char *qualifiedName = quote_qualified_identifier(schemaName, functionName);
char *functionOwner = GetUserNameFromId(procOwner, false); char *functionOwner = GetUserNameFromId(procOwner, false);
appendStringInfo(alterCommand, "ALTER ROUTINE %s OWNER TO %s;", Datum sqlTextDatum = (Datum) 0;
functionSignature,
PushOverrideEmptySearchPath(CurrentMemoryContext);
sqlTextDatum = DirectFunctionCall1(pg_get_function_arguments,
ObjectIdGetDatum(funcOid));
char *functionParams = TextDatumGetCString(sqlTextDatum);
/* revert back to original search_path */
PopOverrideSearchPath();
appendStringInfo(alterCommand, "ALTER ROUTINE %s(%s) OWNER TO %s;",
qualifiedName, functionParams,
quote_identifier(functionOwner)); quote_identifier(functionOwner));
return alterCommand->data; return alterCommand->data;