51 int stmt_location,
int stmt_len)
72 owner_uid = saved_uid;
81 elog(
ERROR,
"cache lookup failed for role %u", owner_uid);
104 (
errcode(ERRCODE_RESERVED_NAME),
105 errmsg(
"unacceptable schema name \"%s\"", schemaName),
106 errdetail(
"The prefix \"pg_\" is reserved for system schemas.")));
119 (
errcode(ERRCODE_DUPLICATE_SCHEMA),
120 errmsg(
"schema \"%s\" already exists, skipping",
133 if (saved_uid != owner_uid)
178 foreach(parsetree_item, parsetree_list)
232 (
errcode(ERRCODE_UNDEFINED_SCHEMA),
233 errmsg(
"schema \"%s\" does not exist", oldname)));
236 nspOid = nspform->oid;
241 (
errcode(ERRCODE_DUPLICATE_SCHEMA),
242 errmsg(
"schema \"%s\" already exists", newname)));
257 (
errcode(ERRCODE_RESERVED_NAME),
258 errmsg(
"unacceptable schema name \"%s\"", newname),
259 errdetail(
"The prefix \"pg_\" is reserved for system schemas.")));
285 elog(
ERROR,
"cache lookup failed for schema %u", oid);
312 (
errcode(ERRCODE_UNDEFINED_SCHEMA),
313 errmsg(
"schema \"%s\" does not exist", name)));
316 nspOid = nspform->oid;
343 if (nspForm->nspowner != newOwnerId)
345 Datum repl_val[Natts_pg_namespace];
346 bool repl_null[Natts_pg_namespace];
347 bool repl_repl[Natts_pg_namespace];
377 memset(repl_null,
false,
sizeof(repl_null));
378 memset(repl_repl,
false,
sizeof(repl_repl));
380 repl_repl[Anum_pg_namespace_nspowner - 1] =
true;
388 Anum_pg_namespace_nspacl,
393 nspForm->nspowner, newOwnerId);
394 repl_repl[Anum_pg_namespace_nspacl - 1] =
true;
ObjectAddress RenameSchema(const char *oldname, const char *newname)
static void AlterSchemaOwner_internal(HeapTuple tup, Relation rel, Oid newOwnerId)
Oid get_namespace_oid(const char *nspname, bool missing_ok)
void table_close(Relation relation, LOCKMODE lockmode)
FormData_pg_namespace * Form_pg_namespace
void SetUserIdAndSecContext(Oid userid, int sec_context)
#define RelationGetDescr(relation)
void namestrcpy(Name name, const char *str)
#define PointerGetDatum(X)
void AlterSchemaOwner_oid(Oid oid, Oid newOwnerId)
char * pstrdup(const char *in)
void PushOverrideSearchPath(OverrideSearchPath *newpath)
int errcode(int sqlerrcode)
bool pg_namespace_ownercheck(Oid nsp_oid, Oid roleid)
List * lcons_oid(Oid datum, List *list)
void heap_freetuple(HeapTuple htup)
bool IsReservedName(const char *name)
DestReceiver * None_Receiver
#define OidIsValid(objectId)
FormData_pg_authid * Form_pg_authid
void changeDependencyOnOwner(Oid classId, Oid objectId, Oid newOwnerId)
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
#define SearchSysCacheExists1(cacheId, key1)
#define ObjectIdGetDatum(X)
OverrideSearchPath * GetOverrideSearchPath(MemoryContext context)
char * get_database_name(Oid dbid)
void GetUserIdAndSecContext(Oid *userid, int *sec_context)
int errdetail(const char *fmt,...)
#define CStringGetDatum(X)
Oid CreateSchemaCommand(CreateSchemaStmt *stmt, const char *queryString, int stmt_location, int stmt_len)
MemoryContext CurrentMemoryContext
void check_is_member_of_role(Oid member, Oid role)
#define InvokeObjectPostAlterHook(classId, objectId, subId)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
void PopOverrideSearchPath(void)
void CommandCounterIncrement(void)
void ReleaseSysCache(HeapTuple tuple)
Datum SysCacheGetAttr(int cacheId, HeapTuple tup, AttrNumber attributeNumber, bool *isNull)
Oid get_rolespec_oid(const RoleSpec *role, bool missing_ok)
#define SECURITY_LOCAL_USERID_CHANGE
bool allowSystemTableMods
#define ereport(elevel,...)
#define HeapTupleIsValid(tuple)
AclResult pg_database_aclcheck(Oid db_oid, Oid roleid, AclMode mode)
ObjectAddress AlterSchemaOwner(const char *name, Oid newOwnerId)
#define Assert(condition)
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
#define ObjectAddressSet(addr, class_id, object_id)
List * transformCreateSchemaStmt(CreateSchemaStmt *stmt)
#define SearchSysCacheCopy1(cacheId, key1)
const ObjectAddress InvalidObjectAddress
int errmsg(const char *fmt,...)
void EventTriggerCollectSimpleCommand(ObjectAddress address, ObjectAddress secondaryObject, Node *parsetree)
Relation table_open(Oid relationId, LOCKMODE lockmode)
HeapTuple heap_modify_tuple(HeapTuple tuple, TupleDesc tupleDesc, Datum *replValues, bool *replIsnull, bool *doReplace)
Acl * aclnewowner(const Acl *old_acl, Oid oldOwnerId, Oid newOwnerId)
#define RelationGetRelid(relation)
void ProcessUtility(PlannedStmt *pstmt, const char *queryString, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
Oid NamespaceCreate(const char *nspName, Oid ownerId, bool isTemp)