diff options
Diffstat (limited to 'src/backend/tcop/utility.c')
| -rw-r--r-- | src/backend/tcop/utility.c | 840 |
1 files changed, 0 insertions, 840 deletions
diff --git a/src/backend/tcop/utility.c b/src/backend/tcop/utility.c deleted file mode 100644 index 8277a165791..00000000000 --- a/src/backend/tcop/utility.c +++ /dev/null @@ -1,840 +0,0 @@ -/*------------------------------------------------------------------------- - * - * utility.c - * Contains functions which control the execution of the POSTGRES utility - * commands. At one time acted as an interface between the Lisp and C - * systems. - * - * Portions Copyright (c) 1996-2002, PostgreSQL Global Development Group - * Portions Copyright (c) 1994, Regents of the University of California - * - * - * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/tcop/utility.c,v 1.159 2002/06/20 20:29:36 momjian Exp $ - * - *------------------------------------------------------------------------- - */ -#include "postgres.h" - -#include "access/heapam.h" -#include "catalog/catalog.h" -#include "catalog/namespace.h" -#include "catalog/pg_shadow.h" -#include "commands/async.h" -#include "commands/cluster.h" -#include "commands/comment.h" -#include "commands/copy.h" -#include "commands/dbcommands.h" -#include "commands/defrem.h" -#include "commands/explain.h" -#include "commands/lockcmds.h" -#include "commands/portalcmds.h" -#include "commands/proclang.h" -#include "commands/schemacmds.h" -#include "commands/sequence.h" -#include "commands/tablecmds.h" -#include "commands/trigger.h" -#include "commands/user.h" -#include "commands/vacuum.h" -#include "commands/view.h" -#include "miscadmin.h" -#include "nodes/makefuncs.h" -#include "parser/parse.h" -#include "parser/parse_clause.h" -#include "parser/parse_expr.h" -#include "parser/parse_type.h" -#include "rewrite/rewriteDefine.h" -#include "rewrite/rewriteRemove.h" -#include "tcop/utility.h" -#include "utils/acl.h" -#include "utils/guc.h" -#include "utils/lsyscache.h" -#include "utils/syscache.h" -#include "access/xlog.h" - -/* - * Error-checking support for DROP commands - */ - -struct kindstrings -{ - char kind; - char *indef_article; - char *name; - char *command; -}; - -static struct kindstrings kindstringarray[] = { - {RELKIND_RELATION, "a", "table", "TABLE"}, - {RELKIND_SEQUENCE, "a", "sequence", "SEQUENCE"}, - {RELKIND_VIEW, "a", "view", "VIEW"}, - {RELKIND_INDEX, "an", "index", "INDEX"}, - {'\0', "a", "???", "???"} -}; - - -static void -DropErrorMsg(char *relname, char wrongkind, char rightkind) -{ - struct kindstrings *rentry; - struct kindstrings *wentry; - - for (rentry = kindstringarray; rentry->kind != '\0'; rentry++) - if (rentry->kind == rightkind) - break; - Assert(rentry->kind != '\0'); - - for (wentry = kindstringarray; wentry->kind != '\0'; wentry++) - if (wentry->kind == wrongkind) - break; - /* wrongkind could be something we don't have in our table... */ - if (wentry->kind != '\0') - elog(ERROR, "\"%s\" is not %s %s. Use DROP %s to remove %s %s", - relname, rentry->indef_article, rentry->name, - wentry->command, wentry->indef_article, wentry->name); - else - elog(ERROR, "\"%s\" is not %s %s", - relname, rentry->indef_article, rentry->name); -} - -static void -CheckDropPermissions(RangeVar *rel, char rightkind) -{ - struct kindstrings *rentry; - Oid relOid; - HeapTuple tuple; - Form_pg_class classform; - - for (rentry = kindstringarray; rentry->kind != '\0'; rentry++) - if (rentry->kind == rightkind) - break; - Assert(rentry->kind != '\0'); - - relOid = RangeVarGetRelid(rel, true); - if (!OidIsValid(relOid)) - elog(ERROR, "%s \"%s\" does not exist", rentry->name, rel->relname); - tuple = SearchSysCache(RELOID, - ObjectIdGetDatum(relOid), - 0, 0, 0); - if (!HeapTupleIsValid(tuple)) - elog(ERROR, "%s \"%s\" does not exist", rentry->name, rel->relname); - - classform = (Form_pg_class) GETSTRUCT(tuple); - - if (classform->relkind != rightkind) - DropErrorMsg(rel->relname, classform->relkind, rightkind); - - /* Allow DROP to either table owner or schema owner */ - if (!pg_class_ownercheck(relOid, GetUserId()) && - !pg_namespace_ownercheck(classform->relnamespace, GetUserId())) - aclcheck_error(ACLCHECK_NOT_OWNER, rel->relname); - - if (!allowSystemTableMods && IsSystemClass(classform)) - elog(ERROR, "%s \"%s\" is a system %s", - rentry->name, rel->relname, rentry->name); - - ReleaseSysCache(tuple); -} - -static void -CheckOwnership(RangeVar *rel, bool noCatalogs) -{ - Oid relOid; - HeapTuple tuple; - - relOid = RangeVarGetRelid(rel, false); - tuple = SearchSysCache(RELOID, - ObjectIdGetDatum(relOid), - 0, 0, 0); - if (!HeapTupleIsValid(tuple)) - elog(ERROR, "Relation \"%s\" does not exist", rel->relname); - - if (!pg_class_ownercheck(relOid, GetUserId())) - aclcheck_error(ACLCHECK_NOT_OWNER, rel->relname); - - if (noCatalogs) - { - if (!allowSystemTableMods && - IsSystemClass((Form_pg_class) GETSTRUCT(tuple))) - elog(ERROR, "relation \"%s\" is a system catalog", - rel->relname); - } - - ReleaseSysCache(tuple); -} - - -/* - * ProcessUtility - * general utility function invoker - * - * parsetree: the parse tree for the utility statement - * dest: where to send results - * completionTag: points to a buffer of size COMPLETION_TAG_BUFSIZE - * in which to store a command completion status string. - * - * completionTag is only set nonempty if we want to return a nondefault - * status (currently, only used for MOVE/FETCH). - * - * completionTag may be NULL if caller doesn't want a status string. - */ -void -ProcessUtility(Node *parsetree, - CommandDest dest, - char *completionTag) -{ - char *relname; - - if (completionTag) - completionTag[0] = '\0'; - - switch (nodeTag(parsetree)) - { - /* - * ******************************** transactions ******************************** - * - */ - case T_TransactionStmt: - { - TransactionStmt *stmt = (TransactionStmt *) parsetree; - - switch (stmt->command) - { - case BEGIN_TRANS: - BeginTransactionBlock(); - break; - - case COMMIT: - EndTransactionBlock(); - break; - - case ROLLBACK: - UserAbortTransactionBlock(); - break; - } - } - break; - - /* - * ******************************** portal manipulation ******************************** - * - */ - case T_ClosePortalStmt: - { - ClosePortalStmt *stmt = (ClosePortalStmt *) parsetree; - - PerformPortalClose(stmt->portalname, dest); - } - break; - - case T_FetchStmt: - { - FetchStmt *stmt = (FetchStmt *) parsetree; - char *portalName = stmt->portalname; - bool forward; - int count; - - forward = (bool) (stmt->direction == FORWARD); - - /* - * parser ensures that count is >= 0 and 'fetch ALL' -> 0 - */ - - count = stmt->howMany; - PerformPortalFetch(portalName, forward, count, - (stmt->ismove) ? None : dest, - completionTag); - } - break; - - /* - * relation and attribute manipulation - */ - case T_CreateSchemaStmt: - { - CreateSchemaStmt *stmt = (CreateSchemaStmt *) parsetree; - - CreateSchemaCommand(stmt); - } - break; - - case T_CreateStmt: - { - Oid relOid; - - relOid = DefineRelation((CreateStmt *) parsetree, - RELKIND_RELATION); - - /* - * Let AlterTableCreateToastTable decide if this one needs a - * secondary relation too. - */ - CommandCounterIncrement(); - AlterTableCreateToastTable(relOid, true); - } - break; - - case T_DropStmt: - { - DropStmt *stmt = (DropStmt *) parsetree; - List *arg; - - foreach(arg, stmt->objects) - { - List *names = (List *) lfirst(arg); - RangeVar *rel; - - switch (stmt->removeType) - { - case DROP_TABLE: - rel = makeRangeVarFromNameList(names); - CheckDropPermissions(rel, RELKIND_RELATION); - RemoveRelation(rel); - break; - - case DROP_SEQUENCE: - rel = makeRangeVarFromNameList(names); - CheckDropPermissions(rel, RELKIND_SEQUENCE); - RemoveRelation(rel); - break; - - case DROP_VIEW: - rel = makeRangeVarFromNameList(names); - CheckDropPermissions(rel, RELKIND_VIEW); - RemoveView(rel); - break; - - case DROP_INDEX: - rel = makeRangeVarFromNameList(names); - CheckDropPermissions(rel, RELKIND_INDEX); - RemoveIndex(rel); - break; - - case DROP_TYPE: - /* RemoveType does its own permissions checks */ - RemoveType(names); - break; - - case DROP_DOMAIN: - /* RemoveDomain does its own permissions checks */ - RemoveDomain(names, stmt->behavior); - break; - } - - /* - * Make sure subsequent loop iterations will see - * results of this one; needed if removing multiple - * rules for same table, for example. - */ - CommandCounterIncrement(); - } - } - break; - - case T_TruncateStmt: - { - TruncateStmt *stmt = (TruncateStmt *) parsetree; - - TruncateRelation(stmt->relation); - } - break; - - case T_CommentStmt: - CommentObject((CommentStmt *) parsetree); - break; - - case T_CopyStmt: - { - CopyStmt *stmt = (CopyStmt *) parsetree; - - if (!stmt->is_from) - SetQuerySnapshot(); - - DoCopy(stmt); - } - break; - - /* - * schema - */ - case T_RenameStmt: - { - RenameStmt *stmt = (RenameStmt *) parsetree; - Oid relid; - - CheckOwnership(stmt->relation, true); - - relid = RangeVarGetRelid(stmt->relation, false); - - switch (stmt->renameType) - { - case RENAME_TABLE: - { - /* - * RENAME TABLE requires that we (still) hold CREATE - * rights on the containing namespace, as well as - * ownership of the table. But skip check for - * temp tables. - */ - Oid namespaceId = get_rel_namespace(relid); - - if (!isTempNamespace(namespaceId)) - { - AclResult aclresult; - - aclresult = pg_namespace_aclcheck(namespaceId, - GetUserId(), - ACL_CREATE); - if (aclresult != ACLCHECK_OK) - aclcheck_error(aclresult, - get_namespace_name(namespaceId)); - } - - renamerel(relid, stmt->newname); - break; - } - case RENAME_COLUMN: - renameatt(relid, - stmt->oldname, /* old att name */ - stmt->newname, /* new att name */ - interpretInhOption(stmt->relation->inhOpt)); /* recursive? */ - break; - case RENAME_TRIGGER: - renametrig(relid, - stmt->oldname, /* old att name */ - stmt->newname); /* new att name */ - break; - case RENAME_RULE: - elog(ERROR, "ProcessUtility: Invalid target for RENAME: %d", - stmt->renameType); - break; - default: - elog(ERROR, "ProcessUtility: Invalid target for RENAME: %d", - stmt->renameType); - } - } - break; - - /* various Alter Table forms */ - - case T_AlterTableStmt: - { - AlterTableStmt *stmt = (AlterTableStmt *) parsetree; - Oid relid; - - relid = RangeVarGetRelid(stmt->relation, false); - - /* - * Some or all of these functions are recursive to cover - * inherited things, so permission checks are done there. - */ - switch (stmt->subtype) - { - case 'A': /* ADD COLUMN */ - /* - * Recursively add column to table and, - * if requested, to descendants - */ - AlterTableAddColumn(relid, - interpretInhOption(stmt->relation->inhOpt), - (ColumnDef *) stmt->def); - break; - case 'T': /* ALTER COLUMN DEFAULT */ - /* - * Recursively alter column default for table and, - * if requested, for descendants - */ - AlterTableAlterColumnDefault(relid, - interpretInhOption(stmt->relation->inhOpt), - stmt->name, - stmt->def); - break; - case 'N': /* ALTER COLUMN DROP NOT NULL */ - AlterTableAlterColumnDropNotNull(relid, - interpretInhOption(stmt->relation->inhOpt), - stmt->name); - break; - case 'O': /* ALTER COLUMN SET NOT NULL */ - AlterTableAlterColumnSetNotNull(relid, - interpretInhOption(stmt->relation->inhOpt), - stmt->name); - break; - case 'S': /* ALTER COLUMN STATISTICS */ - case 'M': /* ALTER COLUMN STORAGE */ - /* - * Recursively alter column statistics for table and, - * if requested, for descendants - */ - AlterTableAlterColumnFlags(relid, - interpretInhOption(stmt->relation->inhOpt), - stmt->name, - stmt->def, - &(stmt->subtype)); - break; - case 'D': /* DROP COLUMN */ - /* - * XXX We don't actually recurse yet, but what we should do would be: - * Recursively drop column from table and, - * if requested, from descendants - */ - AlterTableDropColumn(relid, - interpretInhOption(stmt->relation->inhOpt), - stmt->name, - stmt->behavior); - break; - case 'C': /* ADD CONSTRAINT */ - /* - * Recursively add constraint to table and, - * if requested, to descendants - */ - AlterTableAddConstraint(relid, - interpretInhOption(stmt->relation->inhOpt), - (List *) stmt->def); - break; - case 'X': /* DROP CONSTRAINT */ - /* - * Recursively drop constraint from table and, - * if requested, from descendants - */ - AlterTableDropConstraint(relid, - interpretInhOption(stmt->relation->inhOpt), - stmt->name, - stmt->behavior); - break; - case 'E': /* CREATE TOAST TABLE */ - AlterTableCreateToastTable(relid, false); - break; - case 'U': /* ALTER OWNER */ - /* check that we are the superuser */ - if (!superuser()) - elog(ERROR, "ALTER TABLE: permission denied"); - /* get_usesysid raises an error if no such user */ - AlterTableOwner(relid, - get_usesysid(stmt->name)); - break; - default: /* oops */ - elog(ERROR, "T_AlterTableStmt: unknown subtype"); - break; - } - } - break; - - - case T_GrantStmt: - { - GrantStmt *stmt = (GrantStmt *) parsetree; - - ExecuteGrantStmt(stmt); - } - break; - - /* - * ******************************** object creation / - * destruction ******************************** - * - */ - case T_DefineStmt: - { - DefineStmt *stmt = (DefineStmt *) parsetree; - - switch (stmt->defType) - { - case OPERATOR: - DefineOperator(stmt->defnames, stmt->definition); - break; - case TYPE_P: - DefineType(stmt->defnames, stmt->definition); - break; - case AGGREGATE: - DefineAggregate(stmt->defnames, stmt->definition); - break; - } - } - break; - - case T_ViewStmt: /* CREATE VIEW */ - { - ViewStmt *stmt = (ViewStmt *) parsetree; - - DefineView(stmt->view, stmt->query); - } - break; - - case T_CreateFunctionStmt: /* CREATE FUNCTION */ - CreateFunction((CreateFunctionStmt *) parsetree); - break; - - case T_IndexStmt: /* CREATE INDEX */ - { - IndexStmt *stmt = (IndexStmt *) parsetree; - - CheckOwnership(stmt->relation, true); - - DefineIndex(stmt->relation, /* relation */ - stmt->idxname, /* index name */ - stmt->accessMethod, /* am name */ - stmt->indexParams, /* parameters */ - stmt->unique, - stmt->primary, - (Expr *) stmt->whereClause, - stmt->rangetable); - } - break; - - case T_RuleStmt: /* CREATE RULE */ - DefineQueryRewrite((RuleStmt *) parsetree); - break; - - case T_CreateSeqStmt: - DefineSequence((CreateSeqStmt *) parsetree); - break; - - case T_RemoveAggrStmt: - { - RemoveAggrStmt *stmt = (RemoveAggrStmt *) parsetree; - - RemoveAggregate(stmt->aggname, stmt->aggtype); - } - break; - - case T_RemoveFuncStmt: - { - RemoveFuncStmt *stmt = (RemoveFuncStmt *) parsetree; - - RemoveFunction(stmt->funcname, stmt->args); - } - break; - - case T_RemoveOperStmt: - { - RemoveOperStmt *stmt = (RemoveOperStmt *) parsetree; - TypeName *typenode1 = (TypeName *) lfirst(stmt->args); - TypeName *typenode2 = (TypeName *) lsecond(stmt->args); - - RemoveOperator(stmt->opname, typenode1, typenode2); - } - break; - - case T_CreatedbStmt: - { - CreatedbStmt *stmt = (CreatedbStmt *) parsetree; - createdb(stmt); - } - break; - - case T_AlterDatabaseSetStmt: - AlterDatabaseSet((AlterDatabaseSetStmt *)parsetree); - break; - - case T_DropdbStmt: - { - DropdbStmt *stmt = (DropdbStmt *) parsetree; - - dropdb(stmt->dbname); - } - break; - - /* Query-level asynchronous notification */ - case T_NotifyStmt: - { - NotifyStmt *stmt = (NotifyStmt *) parsetree; - - Async_Notify(stmt->relation->relname); - } - break; - - case T_ListenStmt: - { - ListenStmt *stmt = (ListenStmt *) parsetree; - - Async_Listen(stmt->relation->relname, MyProcPid); - } - break; - - case T_UnlistenStmt: - { - UnlistenStmt *stmt = (UnlistenStmt *) parsetree; - - Async_Unlisten(stmt->relation->relname, MyProcPid); - } - break; - - case T_LoadStmt: - { - LoadStmt *stmt = (LoadStmt *) parsetree; - - closeAllVfds(); /* probably not necessary... */ - load_file(stmt->filename); - } - break; - - case T_ClusterStmt: - { - ClusterStmt *stmt = (ClusterStmt *) parsetree; - - CheckOwnership(stmt->relation, true); - - cluster(stmt->relation, stmt->indexname); - } - break; - - case T_VacuumStmt: - vacuum((VacuumStmt *) parsetree); - break; - - case T_ExplainStmt: - ExplainQuery((ExplainStmt *) parsetree, dest); - break; - -#ifdef NOT_USED - - case T_RecipeStmt: - { - RecipeStmt *stmt = (RecipeStmt *) parsetree; - - beginRecipe(stmt); - } - break; -#endif - - case T_VariableSetStmt: - { - VariableSetStmt *n = (VariableSetStmt *) parsetree; - - SetPGVariable(n->name, n->args, n->is_local); - } - break; - - case T_VariableShowStmt: - { - VariableShowStmt *n = (VariableShowStmt *) parsetree; - - GetPGVariable(n->name); - } - break; - - case T_VariableResetStmt: - { - VariableResetStmt *n = (VariableResetStmt *) parsetree; - - ResetPGVariable(n->name); - } - break; - - case T_CreateTrigStmt: - CreateTrigger((CreateTrigStmt *) parsetree); - break; - - case T_DropPropertyStmt: - { - DropPropertyStmt *stmt = (DropPropertyStmt *) parsetree; - Oid relId; - - relId = RangeVarGetRelid(stmt->relation, false); - - switch (stmt->removeType) - { - case DROP_RULE: - /* RemoveRewriteRule checks permissions */ - RemoveRewriteRule(relId, stmt->property); - break; - case DROP_TRIGGER: - /* DropTrigger checks permissions */ - DropTrigger(relId, stmt->property); - break; - } - } - break; - - case T_CreatePLangStmt: - CreateProceduralLanguage((CreatePLangStmt *) parsetree); - break; - - case T_DropPLangStmt: - DropProceduralLanguage((DropPLangStmt *) parsetree); - break; - - /* - * ******************************** DOMAIN statements **** - */ - case T_CreateDomainStmt: - DefineDomain((CreateDomainStmt *) parsetree); - break; - - /* - * ******************************** USER statements **** - */ - case T_CreateUserStmt: - CreateUser((CreateUserStmt *) parsetree); - break; - - case T_AlterUserStmt: - AlterUser((AlterUserStmt *) parsetree); - break; - - case T_AlterUserSetStmt: - AlterUserSet((AlterUserSetStmt *) parsetree); - break; - - case T_DropUserStmt: - DropUser((DropUserStmt *) parsetree); - break; - - case T_LockStmt: - LockTableCommand((LockStmt *) parsetree); - break; - - case T_ConstraintsSetStmt: - DeferredTriggerSetState((ConstraintsSetStmt *) parsetree); - break; - - case T_CreateGroupStmt: - CreateGroup((CreateGroupStmt *) parsetree); - break; - - case T_AlterGroupStmt: - AlterGroup((AlterGroupStmt *) parsetree, "ALTER GROUP"); - break; - - case T_DropGroupStmt: - DropGroup((DropGroupStmt *) parsetree); - break; - - case T_CheckPointStmt: - { - if (!superuser()) - elog(ERROR, "permission denied"); - CreateCheckPoint(false); - } - break; - - case T_ReindexStmt: - { - ReindexStmt *stmt = (ReindexStmt *) parsetree; - - switch (stmt->reindexType) - { - case INDEX: - relname = (char *) stmt->relation->relname; - CheckOwnership(stmt->relation, false); - ReindexIndex(stmt->relation, stmt->force); - break; - case TABLE: - CheckOwnership(stmt->relation, false); - ReindexTable(stmt->relation, stmt->force); - break; - case DATABASE: - relname = (char *) stmt->name; - ReindexDatabase(relname, stmt->force, false); - break; - } - break; - } - break; - - default: - elog(ERROR, "ProcessUtility: command #%d unsupported", - nodeTag(parsetree)); - break; - } -} |