开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > 查看源码
utility.c
资源名称：postgresql-6.5.2.tar.gz　[点击查看]
上传用户：blenddy
上传日期：2007-01-07
资源大小：6495k
文件大小：18k
源码类别：

数据库系统

开发平台：

Unix_Linux

utility.c：源码内容
  1. /*-------------------------------------------------------------------------
  2.  *
  3.  * utility.c
  4.  *   Contains functions which control the execution of the POSTGRES utility
  5.  *   commands.  At one time acted as an interface between the Lisp and C
  6.  *   systems.
  7.  *
  8.  * Copyright (c) 1994, Regents of the University of California
  9.  *
  10.  *
  11.  * IDENTIFICATION
  12.  *   $Header: /usr/local/cvsroot/pgsql/src/backend/tcop/utility.c,v 1.61 1999/05/25 16:11:43 momjian Exp $
  13.  *
  14.  *-------------------------------------------------------------------------
  15.  */
  16. #include "postgres.h"
  17. #include "access/xact.h"
  18. #include "access/heapam.h"
  19. #include "catalog/catalog.h"
  20. #include "catalog/pg_type.h"
  22. #include "commands/async.h"
  23. #include "commands/cluster.h"
  24. #include "commands/command.h"
  25. #include "commands/copy.h"
  26. #include "commands/creatinh.h"
  27. #include "commands/dbcommands.h"
  28. #include "commands/sequence.h"
  29. #include "commands/defrem.h"
  30. #include "commands/rename.h"
  31. #include "commands/view.h"
  32. #include "commands/version.h"
  33. #include "commands/vacuum.h"
  34. #include "commands/explain.h"
  35. #include "commands/trigger.h"
  36. #include "commands/proclang.h"
  37. #include "commands/variable.h"
  39. #include "nodes/parsenodes.h"
  40. #include "../backend/parser/parse.h"
  41. #include "utils/builtins.h"
  42. #include "utils/acl.h"
  43. #include "utils/palloc.h"
  44. #include "rewrite/rewriteRemove.h"
  45. #include "rewrite/rewriteDefine.h"
  46. #include "tcop/tcopdebug.h"
  47. #include "tcop/dest.h"
  48. #include "tcop/utility.h"
  49. #include "fmgr.h" /* For load_file() */
  50. #include "storage/fd.h"
  51. #include "utils/ps_status.h"
  53. #ifndef NO_SECURITY
  54. #include "miscadmin.h"
  55. #include "utils/acl.h"
  56. #include "utils/syscache.h"
  57. #endif
  59. void DefineUser(CreateUserStmt *stmt, CommandDest);
  60. void AlterUser(AlterUserStmt *stmt, CommandDest);
  61. void RemoveUser(char *username, CommandDest);
  63. /* ----------------
  64.  * CHECK_IF_ABORTED() is used to avoid doing unnecessary
  65.  * processing within an aborted transaction block.
  66.  * ----------------
  67.  */
  68.  /* we have to use IF because of the 'break' */
  69. #define CHECK_IF_ABORTED() 
  70. if (1) 
  71. { 
  72. if (IsAbortedTransactionBlockState()) 
  73. { 
  74. elog(NOTICE, "(transaction aborted): %s", 
  75.  "all queries ignored until end of transaction block"); 
  76. commandTag = "*ABORT STATE*"; 
  77. break; 
  78. } 
  79. } else
  81. /* ----------------
  82.  * general utility function invoker
  83.  * ----------------
  84.  */
  85. void
  86. ProcessUtility(Node *parsetree,
  87.    CommandDest dest)
  88. {
  89. char    *commandTag = NULL;
  90. char    *relname;
  91. char    *relationName;
  92. char    *userName;
  94. userName = GetPgUserName();
  96. switch (nodeTag(parsetree))
  97. {
  99. /*
  100.  * ******************************** transactions ********************************
  101.  *
  102.  */
  103. case T_TransactionStmt:
  104. {
  105. TransactionStmt *stmt = (TransactionStmt *) parsetree;
  107. switch (stmt->command)
  108. {
  109. case BEGIN_TRANS:
  110. PS_SET_STATUS(commandTag = "BEGIN");
  111. CHECK_IF_ABORTED();
  112. BeginTransactionBlock();
  113. break;
  115. case END_TRANS:
  116. PS_SET_STATUS(commandTag = "END");
  117. EndTransactionBlock();
  118. break;
  120. case ABORT_TRANS:
  121. PS_SET_STATUS(commandTag = "ABORT");
  122. UserAbortTransactionBlock();
  123. break;
  124. }
  125. }
  126. break;
  128. /*
  129.  * ******************************** portal manipulation ********************************
  130.  *
  131.  */
  132. case T_ClosePortalStmt:
  133. {
  134. ClosePortalStmt *stmt = (ClosePortalStmt *) parsetree;
  136. PS_SET_STATUS(commandTag = "CLOSE");
  137. CHECK_IF_ABORTED();
  139. PerformPortalClose(stmt->portalname, dest);
  140. }
  141. break;
  143. case T_FetchStmt:
  144. {
  145. FetchStmt  *stmt = (FetchStmt *) parsetree;
  146. char    *portalName = stmt->portalname;
  147. bool forward;
  148. int count;
  150. PS_SET_STATUS(commandTag = (stmt->ismove) ? "MOVE" : "FETCH");
  151. CHECK_IF_ABORTED();
  153. forward = (bool) (stmt->direction == FORWARD);
  155. /*
  156.  * parser ensures that count is >= 0 and 'fetch ALL' -> 0
  157.  */
  159. count = stmt->howMany;
  160. PerformPortalFetch(portalName, forward, count, commandTag,
  161.    (stmt->ismove) ? None : dest); /* /dev/null for MOVE */
  162. }
  163. break;
  165. /*
  166.  * ******************************** relation and attribute
  167.  * manipulation ********************************
  168.  *
  169.  */
  170. case T_CreateStmt:
  171. PS_SET_STATUS(commandTag = "CREATE");
  172. CHECK_IF_ABORTED();
  174. DefineRelation((CreateStmt *) parsetree, RELKIND_RELATION);
  175. break;
  177. case T_DestroyStmt:
  178. {
  179. DestroyStmt *stmt = (DestroyStmt *) parsetree;
  180. List    *arg;
  181. List    *args = stmt->relNames;
  182. Relation rel;
  184. PS_SET_STATUS(commandTag = "DROP");
  185. CHECK_IF_ABORTED();
  187. foreach(arg, args)
  188. {
  189. relname = strVal(lfirst(arg));
  190. if (!allowSystemTableMods && IsSystemRelationName(relname))
  191. elog(ERROR, "class "%s" is a system catalog",
  192.  relname);
  193. rel = heap_openr(relname);
  194. if (RelationIsValid(rel))
  195. {
  196. if (stmt->sequence &&
  197. rel->rd_rel->relkind != RELKIND_SEQUENCE)
  198. elog(ERROR, "Use DROP TABLE to drop table '%s'",
  199.  relname);
  200. if (!(stmt->sequence) &&
  201. rel->rd_rel->relkind == RELKIND_SEQUENCE)
  202. elog(ERROR, "Use DROP SEQUENCE to drop sequence '%s'",
  203.  relname);
  204. heap_close(rel);
  205. }
  206. #ifndef NO_SECURITY
  207. if (!pg_ownercheck(userName, relname, RELNAME))
  208. elog(ERROR, "you do not own class "%s"",
  209.  relname);
  210. #endif
  211. }
  212. foreach(arg, args)
  213. {
  214. relname = strVal(lfirst(arg));
  215. RemoveRelation(relname);
  216. }
  217. }
  218. break;
  220. case T_CopyStmt:
  221. {
  222. CopyStmt   *stmt = (CopyStmt *) parsetree;
  224. PS_SET_STATUS(commandTag = "COPY");
  225. CHECK_IF_ABORTED();
  227. DoCopy(stmt->relname,
  228.    stmt->binary,
  229.    stmt->oids,
  230.    (bool) (stmt->direction == FROM),
  231.    (bool) (stmt->filename == NULL),
  233. /*
  234.  * null filename means copy to/from stdout/stdin, rather
  235.  * than to/from a file.
  236.  */
  237.    stmt->filename,
  238.    stmt->delimiter);
  239. }
  240. break;
  242. case T_AddAttrStmt:
  243. {
  244. AddAttrStmt *stmt = (AddAttrStmt *) parsetree;
  246. PS_SET_STATUS(commandTag = "ADD");
  247. CHECK_IF_ABORTED();
  249. /*
  250.  * owner checking done in PerformAddAttribute (now
  251.  * recursive)
  252.  */
  253. PerformAddAttribute(stmt->relname,
  254. userName,
  255. stmt->inh,
  256. (ColumnDef *) stmt->colDef);
  257. }
  258. break;
  260. /*
  261.  * schema
  262.  */
  263. case T_RenameStmt:
  264. {
  265. RenameStmt *stmt = (RenameStmt *) parsetree;
  267. PS_SET_STATUS(commandTag = "RENAME");
  268. CHECK_IF_ABORTED();
  270. relname = stmt->relname;
  271. if (!allowSystemTableMods && IsSystemRelationName(relname))
  272. elog(ERROR, "class "%s" is a system catalog",
  273.  relname);
  274. #ifndef NO_SECURITY
  275. if (!pg_ownercheck(userName, relname, RELNAME))
  276. elog(ERROR, "you do not own class "%s"",
  277.  relname);
  278. #endif
  280. /* ----------------
  281.  * XXX using len == 3 to tell the difference
  282.  * between "rename rel to newrel" and
  283.  * "rename att in rel to newatt" will not
  284.  * work soon because "rename type/operator/rule"
  285.  * stuff is being added. - cim 10/24/90
  286.  * ----------------
  287.  * [another piece of amuzing but useless anecdote -- ay]
  288.  */
  289. if (stmt->column == NULL)
  290. {
  291. /* ----------------
  292.  * rename relation
  293.  *
  294.  * Note: we also rename the "type" tuple
  295.  * corresponding to the relation.
  296.  * ----------------
  297.  */
  298. renamerel(relname, /* old name */
  299.   stmt->newname); /* new name */
  300. TypeRename(relname, /* old name */
  301.    stmt->newname); /* new name */
  302. }
  303. else
  304. {
  305. /* ----------------
  306.  * rename attribute
  307.  * ----------------
  308.  */
  309. renameatt(relname, /* relname */
  310.   stmt->column, /* old att name */
  311.   stmt->newname, /* new att name */
  312.   userName,
  313.   stmt->inh); /* recursive? */
  314. }
  315. }
  316. break;
  318. case T_ChangeACLStmt:
  319. {
  320. ChangeACLStmt *stmt = (ChangeACLStmt *) parsetree;
  321. List    *i;
  322. AclItem    *aip;
  323. unsigned modechg;
  325. PS_SET_STATUS(commandTag = "CHANGE");
  326. CHECK_IF_ABORTED();
  328. aip = stmt->aclitem;
  330. modechg = stmt->modechg;
  331. #ifndef NO_SECURITY
  332. foreach(i, stmt->relNames)
  333. {
  334. relname = strVal(lfirst(i));
  335. if (!pg_ownercheck(userName, relname, RELNAME))
  336. elog(ERROR, "you do not own class "%s"",
  337.  relname);
  338. }
  339. #endif
  340. foreach(i, stmt->relNames)
  341. {
  342. relname = strVal(lfirst(i));
  343. ChangeAcl(relname, aip, modechg);
  344. }
  346. }
  347. break;
  349. /*
  350.  * ******************************** object creation /
  351.  * destruction ********************************
  352.  *
  353.  */
  354. case T_DefineStmt:
  355. {
  356. DefineStmt *stmt = (DefineStmt *) parsetree;
  358. PS_SET_STATUS(commandTag = "CREATE");
  359. CHECK_IF_ABORTED();
  361. switch (stmt->defType)
  362. {
  363. case OPERATOR:
  364. DefineOperator(stmt->defname, /* operator name */
  365.    stmt->definition); /* rest */
  366. break;
  367. case TYPE_P:
  368. DefineType(stmt->defname, stmt->definition);
  369. break;
  370. case AGGREGATE:
  371. DefineAggregate(stmt->defname, /* aggregate name */
  372. stmt->definition); /* rest */
  373. break;
  374. }
  375. }
  376. break;
  378. case T_ViewStmt: /* CREATE VIEW */
  379. {
  380. ViewStmt   *stmt = (ViewStmt *) parsetree;
  382. PS_SET_STATUS(commandTag = "CREATE");
  383. CHECK_IF_ABORTED();
  384. DefineView(stmt->viewname, stmt->query); /* retrieve parsetree */
  385. }
  386. break;
  388. case T_ProcedureStmt: /* CREATE FUNCTION */
  389. PS_SET_STATUS(commandTag = "CREATE");
  390. CHECK_IF_ABORTED();
  391. CreateFunction((ProcedureStmt *) parsetree, dest); /* everything */
  392. break;
  394. case T_IndexStmt: /* CREATE INDEX */
  395. {
  396. IndexStmt  *stmt = (IndexStmt *) parsetree;
  398. PS_SET_STATUS(commandTag = "CREATE");
  399. CHECK_IF_ABORTED();
  400. DefineIndex(stmt->relname, /* relation name */
  401. stmt->idxname, /* index name */
  402. stmt->accessMethod, /* am name */
  403. stmt->indexParams, /* parameters */
  404. stmt->withClause,
  405. stmt->unique,
  406. stmt->primary,
  407. (Expr *) stmt->whereClause,
  408. stmt->rangetable);
  409. }
  410. break;
  412. case T_RuleStmt: /* CREATE RULE */
  413. {
  414. RuleStmt   *stmt = (RuleStmt *) parsetree;
  415. int aclcheck_result;
  417. #ifndef NO_SECURITY
  418. relname = stmt->object->relname;
  419. aclcheck_result = pg_aclcheck(relname, userName, ACL_RU);
  420. if (aclcheck_result != ACLCHECK_OK)
  421. elog(ERROR, "%s: %s", relname, aclcheck_error_strings[aclcheck_result]);
  422. #endif
  423. PS_SET_STATUS(commandTag = "CREATE");
  424. CHECK_IF_ABORTED();
  425. DefineQueryRewrite(stmt);
  426. }
  427. break;
  429. case T_CreateSeqStmt:
  430. PS_SET_STATUS(commandTag = "CREATE");
  431. CHECK_IF_ABORTED();
  433. DefineSequence((CreateSeqStmt *) parsetree);
  434. break;
  436. case T_ExtendStmt:
  437. {
  438. ExtendStmt *stmt = (ExtendStmt *) parsetree;
  440. PS_SET_STATUS(commandTag = "EXTEND");
  441. CHECK_IF_ABORTED();
  443. ExtendIndex(stmt->idxname, /* index name */
  444. (Expr *) stmt->whereClause, /* where */
  445. stmt->rangetable);
  446. }
  447. break;
  449. case T_RemoveStmt:
  450. {
  451. RemoveStmt *stmt = (RemoveStmt *) parsetree;
  453. PS_SET_STATUS(commandTag = "DROP");
  454. CHECK_IF_ABORTED();
  456. switch (stmt->removeType)
  457. {
  458. case INDEX:
  459. relname = stmt->name;
  460. if (!allowSystemTableMods && IsSystemRelationName(relname))
  461. elog(ERROR, "class "%s" is a system catalog index",
  462.  relname);
  463. #ifndef NO_SECURITY
  464. if (!pg_ownercheck(userName, relname, RELNAME))
  465. elog(ERROR, "%s: %s", relname, aclcheck_error_strings[ACLCHECK_NOT_OWNER]);
  466. #endif
  467. RemoveIndex(relname);
  468. break;
  469. case RULE:
  470. {
  471. char    *rulename = stmt->name;
  472. int aclcheck_result;
  474. #ifndef NO_SECURITY
  476. relationName = RewriteGetRuleEventRel(rulename);
  477. aclcheck_result = pg_aclcheck(relationName, userName, ACL_RU);
  478. if (aclcheck_result != ACLCHECK_OK)
  479. elog(ERROR, "%s: %s", relationName, aclcheck_error_strings[aclcheck_result]);
  480. #endif
  481. RemoveRewriteRule(rulename);
  482. }
  483. break;
  484. case TYPE_P:
  485. #ifndef NO_SECURITY
  486. /* XXX moved to remove.c */
  487. #endif
  488. RemoveType(stmt->name);
  489. break;
  490. case VIEW:
  491. {
  492. char    *viewName = stmt->name;
  493. char    *ruleName;
  495. #ifndef NO_SECURITY
  497. ruleName = MakeRetrieveViewRuleName(viewName);
  498. relationName = RewriteGetRuleEventRel(ruleName);
  499. if (!pg_ownercheck(userName, relationName, RELNAME))
  500. elog(ERROR, "%s: %s", relationName, aclcheck_error_strings[ACLCHECK_NOT_OWNER]);
  501. pfree(ruleName);
  502. #endif
  503. RemoveView(viewName);
  504. }
  505. break;
  506. }
  507. break;
  508. }
  509. break;
  511. case T_RemoveAggrStmt:
  512. {
  513. RemoveAggrStmt *stmt = (RemoveAggrStmt *) parsetree;
  515. PS_SET_STATUS(commandTag = "DROP");
  516. CHECK_IF_ABORTED();
  517. RemoveAggregate(stmt->aggname, stmt->aggtype);
  518. }
  519. break;
  521. case T_RemoveFuncStmt:
  522. {
  523. RemoveFuncStmt *stmt = (RemoveFuncStmt *) parsetree;
  525. PS_SET_STATUS(commandTag = "DROP");
  526. CHECK_IF_ABORTED();
  527. RemoveFunction(stmt->funcname,
  528.    length(stmt->args),
  529.    stmt->args);
  530. }
  531. break;
  533. case T_RemoveOperStmt:
  534. {
  535. RemoveOperStmt *stmt = (RemoveOperStmt *) parsetree;
  536. char    *type1 = (char *) NULL;
  537. char    *type2 = (char *) NULL;
  539. PS_SET_STATUS(commandTag = "DROP");
  540. CHECK_IF_ABORTED();
  542. if (lfirst(stmt->args) != NULL)
  543. type1 = strVal(lfirst(stmt->args));
  544. if (lsecond(stmt->args) != NULL)
  545. type2 = strVal(lsecond(stmt->args));
  546. RemoveOperator(stmt->opname, type1, type2);
  547. }
  548. break;
  550. case T_VersionStmt:
  551. elog(ERROR, "CREATE VERSION is not currently implemented");
  552. break;
  554. case T_CreatedbStmt:
  555. {
  556. CreatedbStmt *stmt = (CreatedbStmt *) parsetree;
  558. PS_SET_STATUS(commandTag = "CREATEDB");
  559. CHECK_IF_ABORTED();
  560. createdb(stmt->dbname, stmt->dbpath, stmt->encoding, dest);
  561. }
  562. break;
  564. case T_DestroydbStmt:
  565. {
  566. DestroydbStmt *stmt = (DestroydbStmt *) parsetree;
  568. PS_SET_STATUS(commandTag = "DESTROYDB");
  569. CHECK_IF_ABORTED();
  570. destroydb(stmt->dbname, dest);
  571. }
  572. break;
  574. /* Query-level asynchronous notification */
  575. case T_NotifyStmt:
  576. {
  577. NotifyStmt *stmt = (NotifyStmt *) parsetree;
  579. PS_SET_STATUS(commandTag = "NOTIFY");
  580. CHECK_IF_ABORTED();
  582. Async_Notify(stmt->relname);
  583. }
  584. break;
  586. case T_ListenStmt:
  587. {
  588. ListenStmt *stmt = (ListenStmt *) parsetree;
  590. PS_SET_STATUS(commandTag = "LISTEN");
  591. CHECK_IF_ABORTED();
  593. Async_Listen(stmt->relname, MyProcPid);
  594. }
  595. break;
  597. case T_UnlistenStmt:
  598. {
  599. UnlistenStmt *stmt = (UnlistenStmt *) parsetree;
  601. PS_SET_STATUS(commandTag = "UNLISTEN");
  602. CHECK_IF_ABORTED();
  604. Async_Unlisten(stmt->relname, MyProcPid);
  605. }
  606. break;
  608. /*
  609.  * ******************************** dynamic loader ********************************
  610.  *
  611.  */
  612. case T_LoadStmt:
  613. {
  614. LoadStmt   *stmt = (LoadStmt *) parsetree;
  616. PS_SET_STATUS(commandTag = "LOAD");
  617. CHECK_IF_ABORTED();
  619. closeAllVfds(); /* probably not necessary... */
  620. load_file(stmt->filename);
  621. }
  622. break;
  624. case T_ClusterStmt:
  625. {
  626. ClusterStmt *stmt = (ClusterStmt *) parsetree;
  628. PS_SET_STATUS(commandTag = "CLUSTER");
  629. CHECK_IF_ABORTED();
  631. cluster(stmt->relname, stmt->indexname);
  632. }
  633. break;
  635. case T_VacuumStmt:
  636. PS_SET_STATUS(commandTag = "VACUUM");
  637. CHECK_IF_ABORTED();
  638. vacuum(((VacuumStmt *) parsetree)->vacrel,
  639.    ((VacuumStmt *) parsetree)->verbose,
  640.    ((VacuumStmt *) parsetree)->analyze,
  641.    ((VacuumStmt *) parsetree)->va_spec);
  642. break;
  644. case T_ExplainStmt:
  645. {
  646. ExplainStmt *stmt = (ExplainStmt *) parsetree;
  648. PS_SET_STATUS(commandTag = "EXPLAIN");
  649. CHECK_IF_ABORTED();
  651. ExplainQuery(stmt->query, stmt->verbose, dest);
  652. }
  653. break;
  655. #ifdef NOT_USED
  657. /*
  658.  * ******************************** Tioga-related statements *******************************
  659.  */
  660. case T_RecipeStmt:
  661. {
  662. RecipeStmt *stmt = (RecipeStmt *) parsetree;
  664. PS_SET_STATUS(commandTag = "EXECUTE RECIPE");
  665. CHECK_IF_ABORTED();
  666. beginRecipe(stmt);
  667. }
  668. break;
  669. #endif
  671. /*
  672.  * ******************************** set variable statements *******************************
  673.  */
  674. case T_VariableSetStmt:
  675. {
  676. VariableSetStmt *n = (VariableSetStmt *) parsetree;
  678. SetPGVariable(n->name, n->value);
  679. PS_SET_STATUS(commandTag = "SET VARIABLE");
  680. }
  681. break;
  683. case T_VariableShowStmt:
  684. {
  685. VariableShowStmt *n = (VariableShowStmt *) parsetree;
  687. GetPGVariable(n->name);
  688. PS_SET_STATUS(commandTag = "SHOW VARIABLE");
  689. }
  690. break;
  692. case T_VariableResetStmt:
  693. {
  694. VariableResetStmt *n = (VariableResetStmt *) parsetree;
  696. ResetPGVariable(n->name);
  697. PS_SET_STATUS(commandTag = "RESET VARIABLE");
  698. }
  699. break;
  701. /*
  702.  * ******************************** TRIGGER statements *******************************
  703.  */
  704. case T_CreateTrigStmt:
  705. PS_SET_STATUS(commandTag = "CREATE");
  706. CHECK_IF_ABORTED();
  708. CreateTrigger((CreateTrigStmt *) parsetree);
  709. break;
  711. case T_DropTrigStmt:
  712. PS_SET_STATUS(commandTag = "DROP");
  713. CHECK_IF_ABORTED();
  715. DropTrigger((DropTrigStmt *) parsetree);
  716. break;
  718. /*
  719.  * ************* PROCEDURAL LANGUAGE statements *****************
  720.  */
  721. case T_CreatePLangStmt:
  722. PS_SET_STATUS(commandTag = "CREATE");
  723. CHECK_IF_ABORTED();
  725. CreateProceduralLanguage((CreatePLangStmt *) parsetree);
  726. break;
  728. case T_DropPLangStmt:
  729. PS_SET_STATUS(commandTag = "DROP");
  730. CHECK_IF_ABORTED();
  732. DropProceduralLanguage((DropPLangStmt *) parsetree);
  733. break;
  735. /*
  736.  * ******************************** USER statements ****
  737.  *
  738.  */
  739. case T_CreateUserStmt:
  740. PS_SET_STATUS(commandTag = "CREATE USER");
  741. CHECK_IF_ABORTED();
  743. DefineUser((CreateUserStmt *) parsetree, dest);
  744. break;
  746. case T_AlterUserStmt:
  747. PS_SET_STATUS(commandTag = "ALTER USER");
  748. CHECK_IF_ABORTED();
  750. AlterUser((AlterUserStmt *) parsetree, dest);
  751. break;
  753. case T_DropUserStmt:
  754. PS_SET_STATUS(commandTag = "DROP USER");
  755. CHECK_IF_ABORTED();
  757. RemoveUser(((DropUserStmt *) parsetree)->user, dest);
  758. break;
  760. case T_LockStmt:
  761. PS_SET_STATUS(commandTag = "LOCK TABLE");
  762. CHECK_IF_ABORTED();
  764. LockTableCommand((LockStmt *) parsetree);
  765. break;
  768. /*
  769.  * ******************************** default ********************************
  770.  *
  771.  */
  772. default:
  773. elog(ERROR, "ProcessUtility: command #%d unsupported",
  774.  nodeTag(parsetree));
  775. break;
  776. }
  778. /* ----------------
  779.  * tell fe/be or whatever that we're done.
  780.  * ----------------
  781.  */
  782. EndCommand(commandTag, dest);
  783. }