#include "postgres.h"
#include "access/heapam.h"
#include "access/htup_details.h"
#include "catalog/dependency.h"
#include "catalog/namespace.h"
#include "catalog/objectaddress.h"
#include "catalog/pg_class.h"
#include "catalog/pg_proc.h"
#include "commands/defrem.h"
#include "miscadmin.h"
#include "nodes/makefuncs.h"
#include "parser/parse_type.h"
#include "utils/builtins.h"
#include "utils/syscache.h"

Include dependency graph for dropcmds.c:

Functions
static void	does_not_exist_skipping (ObjectType objtype, Node *object)

static bool	owningrel_does_not_exist_skipping (List object, const char msg, char *name)

static bool	schema_does_not_exist_skipping (List object, const char msg, char *name)

static bool	type_in_list_does_not_exist_skipping (List typenames, const char msg, char *name)

void	RemoveObjects (DropStmt *stmt)

Function Documentation

static void does_not_exist_skipping	(	ObjectType	objtype,
		Node *	object
	)

static

Definition at line 247 of file dropcmds.c.

References generate_unaccent_rules::args, castNode, elog, ereport, errmsg(), ERROR, gettext_noop, linitial, linitial_node, list_copy(), list_copy_tail(), list_length(), list_make1, list_truncate(), llast, lsecond, lsecond_node, name, NameListToString(), TypeName::names, NOTICE, ObjectWithArgs::objargs, OBJECT_ACCESS_METHOD, OBJECT_AGGREGATE, OBJECT_CAST, OBJECT_COLLATION, OBJECT_CONVERSION, OBJECT_DOMAIN, OBJECT_EVENT_TRIGGER, OBJECT_EXTENSION, OBJECT_FDW, OBJECT_FOREIGN_SERVER, OBJECT_FUNCTION, OBJECT_LANGUAGE, OBJECT_OPCLASS, OBJECT_OPERATOR, OBJECT_OPFAMILY, OBJECT_POLICY, OBJECT_PUBLICATION, OBJECT_RULE, OBJECT_SCHEMA, OBJECT_STATISTIC_EXT, OBJECT_TRANSFORM, OBJECT_TRIGGER, OBJECT_TSCONFIGURATION, OBJECT_TSDICTIONARY, OBJECT_TSPARSER, OBJECT_TSTEMPLATE, OBJECT_TYPE, ObjectWithArgs::objname, owningrel_does_not_exist_skipping(), schema_does_not_exist_skipping(), strVal, type_in_list_does_not_exist_skipping(), TypeNameListToString(), and TypeNameToString().

Referenced by RemoveObjects().

 {
     const char *msg = NULL;
     char       *name = NULL;
     char       *args = NULL;
 
     switch (objtype)
     {
         case OBJECT_ACCESS_METHOD:
             msg = gettext_noop("access method \"%s\" does not exist, skipping");
             name = strVal((Value *) object);
             break;
         case OBJECT_TYPE:
         case OBJECT_DOMAIN:
             {
                 TypeName   *typ = castNode(TypeName, object);
 
                 if (!schema_does_not_exist_skipping(typ->names, &msg, &name))
                 {
                     msg = gettext_noop("type \"%s\" does not exist, skipping");
                     name = TypeNameToString(typ);
                 }
             }
             break;
         case OBJECT_COLLATION:
             if (!schema_does_not_exist_skipping(castNode(List, object), &msg, &name))
             {
                 msg = gettext_noop("collation \"%s\" does not exist, skipping");
                 name = NameListToString(castNode(List, object));
             }
             break;
         case OBJECT_CONVERSION:
             if (!schema_does_not_exist_skipping(castNode(List, object), &msg, &name))
             {
                 msg = gettext_noop("conversion \"%s\" does not exist, skipping");
                 name = NameListToString(castNode(List, object));
             }
             break;
         case OBJECT_SCHEMA:
             msg = gettext_noop("schema \"%s\" does not exist, skipping");
             name = strVal((Value *) object);
             break;
         case OBJECT_STATISTIC_EXT:
             if (!schema_does_not_exist_skipping(castNode(List, object), &msg, &name))
             {
                 msg = gettext_noop("statistics object \"%s\" does not exist, skipping");
                 name = NameListToString(castNode(List, object));
             }
             break;
         case OBJECT_TSPARSER:
             if (!schema_does_not_exist_skipping(castNode(List, object), &msg, &name))
             {
                 msg = gettext_noop("text search parser \"%s\" does not exist, skipping");
                 name = NameListToString(castNode(List, object));
             }
             break;
         case OBJECT_TSDICTIONARY:
             if (!schema_does_not_exist_skipping(castNode(List, object), &msg, &name))
             {
                 msg = gettext_noop("text search dictionary \"%s\" does not exist, skipping");
                 name = NameListToString(castNode(List, object));
             }
             break;
         case OBJECT_TSTEMPLATE:
             if (!schema_does_not_exist_skipping(castNode(List, object), &msg, &name))
             {
                 msg = gettext_noop("text search template \"%s\" does not exist, skipping");
                 name = NameListToString(castNode(List, object));
             }
             break;
         case OBJECT_TSCONFIGURATION:
             if (!schema_does_not_exist_skipping(castNode(List, object), &msg, &name))
             {
                 msg = gettext_noop("text search configuration \"%s\" does not exist, skipping");
                 name = NameListToString(castNode(List, object));
             }
             break;
         case OBJECT_EXTENSION:
             msg = gettext_noop("extension \"%s\" does not exist, skipping");
             name = strVal((Value *) object);
             break;
         case OBJECT_FUNCTION:
             {
                 ObjectWithArgs *owa = castNode(ObjectWithArgs, object);
 
                 if (!schema_does_not_exist_skipping(owa->objname, &msg, &name) &&
                     !type_in_list_does_not_exist_skipping(owa->objargs, &msg, &name))
                 {
                     msg = gettext_noop("function %s(%s) does not exist, skipping");
                     name = NameListToString(owa->objname);
                     args = TypeNameListToString(owa->objargs);
                 }
                 break;
             }
         case OBJECT_AGGREGATE:
             {
                 ObjectWithArgs *owa = castNode(ObjectWithArgs, object);
 
                 if (!schema_does_not_exist_skipping(owa->objname, &msg, &name) &&
                     !type_in_list_does_not_exist_skipping(owa->objargs, &msg, &name))
                 {
                     msg = gettext_noop("aggregate %s(%s) does not exist, skipping");
                     name = NameListToString(owa->objname);
                     args = TypeNameListToString(owa->objargs);
                 }
                 break;
             }
         case OBJECT_OPERATOR:
             {
                 ObjectWithArgs *owa = castNode(ObjectWithArgs, object);
 
                 if (!schema_does_not_exist_skipping(owa->objname, &msg, &name) &&
                     !type_in_list_does_not_exist_skipping(owa->objargs, &msg, &name))
                 {
                     msg = gettext_noop("operator %s does not exist, skipping");
                     name = NameListToString(owa->objname);
                 }
                 break;
             }
         case OBJECT_LANGUAGE:
             msg = gettext_noop("language \"%s\" does not exist, skipping");
             name = strVal((Value *) object);
             break;
         case OBJECT_CAST:
             {
                 if (!type_in_list_does_not_exist_skipping(list_make1(linitial(castNode(List, object))), &msg, &name) &&
                     !type_in_list_does_not_exist_skipping(list_make1(lsecond(castNode(List, object))), &msg, &name))
                 {
                     /* XXX quote or no quote? */
                     msg = gettext_noop("cast from type %s to type %s does not exist, skipping");
                     name = TypeNameToString(linitial_node(TypeName, castNode(List, object)));
                     args = TypeNameToString(lsecond_node(TypeName, castNode(List, object)));
                 }
             }
             break;
         case OBJECT_TRANSFORM:
             if (!type_in_list_does_not_exist_skipping(list_make1(linitial(castNode(List, object))), &msg, &name))
             {
                 msg = gettext_noop("transform for type %s language \"%s\" does not exist, skipping");
                 name = TypeNameToString(linitial_node(TypeName, castNode(List, object)));
                 args = strVal(lsecond(castNode(List, object)));
             }
             break;
         case OBJECT_TRIGGER:
             if (!owningrel_does_not_exist_skipping(castNode(List, object), &msg, &name))
             {
                 msg = gettext_noop("trigger \"%s\" for relation \"%s\" does not exist, skipping");
                 name = strVal(llast(castNode(List, object)));
                 args = NameListToString(list_truncate(list_copy(castNode(List, object)),
                                                       list_length(castNode(List, object)) - 1));
             }
             break;
         case OBJECT_POLICY:
             if (!owningrel_does_not_exist_skipping(castNode(List, object), &msg, &name))
             {
                 msg = gettext_noop("policy \"%s\" for relation \"%s\" does not exist, skipping");
                 name = strVal(llast(castNode(List, object)));
                 args = NameListToString(list_truncate(list_copy(castNode(List, object)),
                                                       list_length(castNode(List, object)) - 1));
             }
             break;
         case OBJECT_EVENT_TRIGGER:
             msg = gettext_noop("event trigger \"%s\" does not exist, skipping");
             name = strVal((Value *) object);
             break;
         case OBJECT_RULE:
             if (!owningrel_does_not_exist_skipping(castNode(List, object), &msg, &name))
             {
                 msg = gettext_noop("rule \"%s\" for relation \"%s\" does not exist, skipping");
                 name = strVal(llast(castNode(List, object)));
                 args = NameListToString(list_truncate(list_copy(castNode(List, object)),
                                                       list_length(castNode(List, object)) - 1));
             }
             break;
         case OBJECT_FDW:
             msg = gettext_noop("foreign-data wrapper \"%s\" does not exist, skipping");
             name = strVal((Value *) object);
             break;
         case OBJECT_FOREIGN_SERVER:
             msg = gettext_noop("server \"%s\" does not exist, skipping");
             name = strVal((Value *) object);
             break;
         case OBJECT_OPCLASS:
             {
                 List       *opcname = list_copy_tail(castNode(List, object), 1);
 
                 if (!schema_does_not_exist_skipping(opcname, &msg, &name))
                 {
                     msg = gettext_noop("operator class \"%s\" does not exist for access method \"%s\", skipping");
                     name = NameListToString(opcname);
                     args = strVal(linitial(castNode(List, object)));
                 }
             }
             break;
         case OBJECT_OPFAMILY:
             {
                 List       *opfname = list_copy_tail(castNode(List, object), 1);
 
                 if (!schema_does_not_exist_skipping(opfname, &msg, &name))
                 {
                     msg = gettext_noop("operator family \"%s\" does not exist for access method \"%s\", skipping");
                     name = NameListToString(opfname);
                     args = strVal(linitial(castNode(List, object)));
                 }
             }
             break;
         case OBJECT_PUBLICATION:
             msg = gettext_noop("publication \"%s\" does not exist, skipping");
             name = strVal((Value *) object);
             break;
         default:
             elog(ERROR, "unrecognized object type: %d", (int) objtype);
             break;
     }
 
     if (!args)
         ereport(NOTICE, (errmsg(msg, name)));
     else
         ereport(NOTICE, (errmsg(msg, name, args)));
 }

static bool owningrel_does_not_exist_skipping	(	List *	object,
		const char **	msg,
		char **	name
	)

static

Definition at line 142 of file dropcmds.c.

References gettext_noop, list_copy(), list_length(), list_truncate(), makeRangeVarFromNameList(), NameListToString(), NoLock, OidIsValid, RangeVarGetRelid, and schema_does_not_exist_skipping().

Referenced by does_not_exist_skipping().

 {
     List       *parent_object;
     RangeVar   *parent_rel;
 
     parent_object = list_truncate(list_copy(object),
                                   list_length(object) - 1);
 
     if (schema_does_not_exist_skipping(parent_object, msg, name))
         return true;
 
     parent_rel = makeRangeVarFromNameList(parent_object);
 
     if (!OidIsValid(RangeVarGetRelid(parent_rel, NoLock, true)))
     {
         *msg = gettext_noop("relation \"%s\" does not exist, skipping");
         *name = NameListToString(parent_object);
 
         return true;
     }
 
     return false;
 }

void RemoveObjects ( DropStmt * stmt )

Definition at line 54 of file dropcmds.c.

References AccessExclusiveLock, add_exact_object_address(), Assert, DropStmt::behavior, castNode, check_object_ownership(), does_not_exist_skipping(), elog, ereport, errcode(), errhint(), errmsg(), ERROR, free_object_addresses(), get_object_address(), get_object_namespace(), GETSTRUCT, GetUserId(), heap_close, HeapTupleIsValid, lfirst, DropStmt::missing_ok, NameListToString(), new_object_addresses(), NoLock, OBJECT_FUNCTION, ObjectAddress::objectId, ObjectIdGetDatum, DropStmt::objects, OidIsValid, performMultipleDeletions(), pg_namespace_ownercheck(), PROCOID, ReleaseSysCache(), DropStmt::removeType, and SearchSysCache1.

Referenced by ExecDropStmt().

 {
     ObjectAddresses *objects;
     ListCell   *cell1;
 
     objects = new_object_addresses();
 
     foreach(cell1, stmt->objects)
     {
         ObjectAddress address;
         Node       *object = lfirst(cell1);
         Relation    relation = NULL;
         Oid         namespaceId;
 
         /* Get an ObjectAddress for the object. */
         address = get_object_address(stmt->removeType,
                                      object,
                                      &relation,
                                      AccessExclusiveLock,
                                      stmt->missing_ok);
 
         /*
          * Issue NOTICE if supplied object was not found.  Note this is only
          * relevant in the missing_ok case, because otherwise
          * get_object_address would have thrown an error.
          */
         if (!OidIsValid(address.objectId))
         {
             Assert(stmt->missing_ok);
             does_not_exist_skipping(stmt->removeType, object);
             continue;
         }
 
         /*
          * Although COMMENT ON FUNCTION, SECURITY LABEL ON FUNCTION, etc. are
          * happy to operate on an aggregate as on any other function, we have
          * historically not allowed this for DROP FUNCTION.
          */
         if (stmt->removeType == OBJECT_FUNCTION)
         {
             Oid         funcOid = address.objectId;
             HeapTuple   tup;
 
             tup = SearchSysCache1(PROCOID, ObjectIdGetDatum(funcOid));
             if (!HeapTupleIsValid(tup)) /* should not happen */
                 elog(ERROR, "cache lookup failed for function %u", funcOid);
 
             if (((Form_pg_proc) GETSTRUCT(tup))->proisagg)
                 ereport(ERROR,
                         (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                          errmsg("\"%s\" is an aggregate function",
                                 NameListToString(castNode(ObjectWithArgs, object)->objname)),
                          errhint("Use DROP AGGREGATE to drop aggregate functions.")));
 
             ReleaseSysCache(tup);
         }
 
         /* Check permissions. */
         namespaceId = get_object_namespace(&address);
         if (!OidIsValid(namespaceId) ||
             !pg_namespace_ownercheck(namespaceId, GetUserId()))
             check_object_ownership(GetUserId(), stmt->removeType, address,
                                    object, relation);
 
         /* Release any relcache reference count, but keep lock until commit. */
         if (relation)
             heap_close(relation, NoLock);
 
         add_exact_object_address(&address, objects);
     }
 
     /* Here we really delete them. */
     performMultipleDeletions(objects, stmt->behavior, 0);
 
     free_object_addresses(objects);
 }

static bool schema_does_not_exist_skipping	(	List *	object,
		const char **	msg,
		char **	name
	)

static

Definition at line 178 of file dropcmds.c.

References gettext_noop, LookupNamespaceNoError(), makeRangeVarFromNameList(), OidIsValid, and RangeVar::schemaname.

Referenced by does_not_exist_skipping(), owningrel_does_not_exist_skipping(), and type_in_list_does_not_exist_skipping().

 {
     RangeVar   *rel;
 
     rel = makeRangeVarFromNameList(object);
 
     if (rel->schemaname != NULL &&
         !OidIsValid(LookupNamespaceNoError(rel->schemaname)))
     {
         *msg = gettext_noop("schema \"%s\" does not exist, skipping");
         *name = rel->schemaname;
 
         return true;
     }
 
     return false;
 }

static bool type_in_list_does_not_exist_skipping	(	List *	typenames,
		const char **	msg,
		char **	name
	)

static

Definition at line 210 of file dropcmds.c.

References gettext_noop, lfirst_node, LookupTypeNameOid(), TypeName::names, OidIsValid, schema_does_not_exist_skipping(), and TypeNameToString().

Referenced by does_not_exist_skipping().

 {
     ListCell   *l;
 
     foreach(l, typenames)
     {
         TypeName   *typeName = lfirst_node(TypeName, l);
 
         if (typeName != NULL)
         {
             if (!OidIsValid(LookupTypeNameOid(NULL, typeName, true)))
             {
                 /* type doesn't exist, try to find why */
                 if (schema_does_not_exist_skipping(typeName->names, msg, name))
                     return true;
 
                 *msg = gettext_noop("type \"%s\" does not exist, skipping");
                 *name = TypeNameToString(typeName);
 
                 return true;
             }
         }
     }
 
     return false;
 }

Functions

Function Documentation