diff options
| author | Peter Eisentraut <peter_e@gmx.net> | 2017-03-03 10:47:04 -0500 |
|---|---|---|
| committer | Peter Eisentraut <peter_e@gmx.net> | 2017-03-03 10:47:04 -0500 |
| commit | 6da9759a03d6d985c3b95a3177bbda7bcffd0ae6 (patch) | |
| tree | c519af3041ba6af4d54b15689351fa798d167676 /src/backend/commands/alter.c | |
| parent | 713f7c47d9c38654adbc36c47fd9e439f0d1f715 (diff) | |
Add RENAME support for PUBLICATIONs and SUBSCRIPTIONs
From: Petr Jelinek <petr.jelinek@2ndquadrant.com>
Diffstat (limited to 'src/backend/commands/alter.c')
| -rw-r--r-- | src/backend/commands/alter.c | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/src/backend/commands/alter.c b/src/backend/commands/alter.c index d6195e49f5e..8ff5dd5aaf2 100644 --- a/src/backend/commands/alter.c +++ b/src/backend/commands/alter.c @@ -32,6 +32,7 @@ #include "catalog/pg_opclass.h" #include "catalog/pg_opfamily.h" #include "catalog/pg_proc.h" +#include "catalog/pg_subscription.h" #include "catalog/pg_ts_config.h" #include "catalog/pg_ts_dict.h" #include "catalog/pg_ts_parser.h" @@ -90,6 +91,12 @@ report_name_conflict(Oid classId, const char *name) case LanguageRelationId: msgfmt = gettext_noop("language \"%s\" already exists"); break; + case PublicationRelationId: + msgfmt = gettext_noop("publication \"%s\" already exists"); + break; + case SubscriptionRelationId: + msgfmt = gettext_noop("subscription \"%s\" already exists"); + break; default: elog(ERROR, "unsupported object class %u", classId); break; @@ -256,6 +263,12 @@ AlterObjectRename_internal(Relation rel, Oid objectId, const char *new_name) IsThereOpFamilyInNamespace(new_name, opf->opfmethod, opf->opfnamespace); } + else if (classId == SubscriptionRelationId) + { + if (SearchSysCacheExists2(SUBSCRIPTIONNAME, MyDatabaseId, + CStringGetDatum(new_name))) + report_name_conflict(classId, new_name); + } else if (nameCacheId >= 0) { if (OidIsValid(namespaceId)) @@ -364,6 +377,8 @@ ExecRenameStmt(RenameStmt *stmt) case OBJECT_TSDICTIONARY: case OBJECT_TSPARSER: case OBJECT_TSTEMPLATE: + case OBJECT_PUBLICATION: + case OBJECT_SUBSCRIPTION: { ObjectAddress address; Relation catalog; |