PostgreSQL Source Code git master
Data Structures | Macros | Typedefs | Enumerations | Functions | Variables
utility.h File Reference
#include "tcop/cmdtag.h"
#include "tcop/tcopprot.h"
Include dependency graph for utility.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  AlterTableUtilityContext
 

Macros

#define COMMAND_OK_IN_READ_ONLY_TXN   0x0001
 
#define COMMAND_OK_IN_PARALLEL_MODE   0x0002
 
#define COMMAND_OK_IN_RECOVERY   0x0004
 
#define COMMAND_IS_STRICTLY_READ_ONLY
 
#define COMMAND_IS_NOT_READ_ONLY   0
 

Typedefs

typedef struct AlterTableUtilityContext AlterTableUtilityContext
 
typedef void(* ProcessUtility_hook_type) (PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
 

Enumerations

enum  ProcessUtilityContext { PROCESS_UTILITY_TOPLEVEL , PROCESS_UTILITY_QUERY , PROCESS_UTILITY_QUERY_NONATOMIC , PROCESS_UTILITY_SUBCOMMAND }
 

Functions

void ProcessUtility (PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
 
void standard_ProcessUtility (PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
 
void ProcessUtilityForAlterTable (Node *stmt, AlterTableUtilityContext *context)
 
bool UtilityReturnsTuples (Node *parsetree)
 
TupleDesc UtilityTupleDescriptor (Node *parsetree)
 
Query * UtilityContainsQuery (Node *parsetree)
 
CommandTag CreateCommandTag (Node *parsetree)
 
static const char * CreateCommandName (Node *parsetree)
 
LogStmtLevel GetCommandLogLevel (Node *parsetree)
 
bool CommandIsReadOnly (PlannedStmt *pstmt)
 

Variables

PGDLLIMPORT ProcessUtility_hook_type ProcessUtility_hook
 

Macro Definition Documentation

◆ COMMAND_IS_NOT_READ_ONLY

#define COMMAND_IS_NOT_READ_ONLY   0

Definition at line 68 of file utility.h.

◆ COMMAND_IS_STRICTLY_READ_ONLY

#define COMMAND_IS_STRICTLY_READ_ONLY
Value:
(COMMAND_OK_IN_READ_ONLY_TXN | COMMAND_OK_IN_RECOVERY | \
COMMAND_OK_IN_PARALLEL_MODE)
COMMAND_OK_IN_RECOVERY
#define COMMAND_OK_IN_RECOVERY
Definition: utility.h:58
COMMAND_OK_IN_READ_ONLY_TXN
#define COMMAND_OK_IN_READ_ONLY_TXN
Definition: utility.h:56

Definition at line 65 of file utility.h.

◆ COMMAND_OK_IN_PARALLEL_MODE

#define COMMAND_OK_IN_PARALLEL_MODE   0x0002

Definition at line 57 of file utility.h.

◆ COMMAND_OK_IN_READ_ONLY_TXN

#define COMMAND_OK_IN_READ_ONLY_TXN   0x0001

Definition at line 56 of file utility.h.

◆ COMMAND_OK_IN_RECOVERY

#define COMMAND_OK_IN_RECOVERY   0x0004

Definition at line 58 of file utility.h.

Typedef Documentation

◆ AlterTableUtilityContext

typedef struct AlterTableUtilityContext AlterTableUtilityContext

◆ ProcessUtility_hook_type

typedef void(* ProcessUtility_hook_type) (PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)

Definition at line 71 of file utility.h.

Enumeration Type Documentation

◆ ProcessUtilityContext

enum ProcessUtilityContext
Enumerator
PROCESS_UTILITY_TOPLEVEL 
PROCESS_UTILITY_QUERY 
PROCESS_UTILITY_QUERY_NONATOMIC 
PROCESS_UTILITY_SUBCOMMAND 

Definition at line 20 of file utility.h.

21{
22 PROCESS_UTILITY_TOPLEVEL, /* toplevel interactive command */
23 PROCESS_UTILITY_QUERY, /* a complete query, but not toplevel */
24 PROCESS_UTILITY_QUERY_NONATOMIC, /* a complete query, nonatomic
25 * execution context */
26 PROCESS_UTILITY_SUBCOMMAND, /* a portion of a query */
27} ProcessUtilityContext;
ProcessUtilityContext
ProcessUtilityContext
Definition: utility.h:21
PROCESS_UTILITY_SUBCOMMAND
@ PROCESS_UTILITY_SUBCOMMAND
Definition: utility.h:26
PROCESS_UTILITY_TOPLEVEL
@ PROCESS_UTILITY_TOPLEVEL
Definition: utility.h:22
PROCESS_UTILITY_QUERY_NONATOMIC
@ PROCESS_UTILITY_QUERY_NONATOMIC
Definition: utility.h:24
PROCESS_UTILITY_QUERY
@ PROCESS_UTILITY_QUERY
Definition: utility.h:23

Function Documentation

◆ CommandIsReadOnly()

bool CommandIsReadOnly ( PlannedStmt *  pstmt)

Definition at line 94 of file utility.c.

95{
96 Assert(IsA(pstmt, PlannedStmt));
97 switch (pstmt->commandType)
98 {
99 case CMD_SELECT:
100 if (pstmt->rowMarks != NIL)
101 return false; /* SELECT FOR [KEY] UPDATE/SHARE */
102 else if (pstmt->hasModifyingCTE)
103 return false; /* data-modifying CTE */
104 else
105 return true;
106 case CMD_UPDATE:
107 case CMD_INSERT:
108 case CMD_DELETE:
109 case CMD_MERGE:
110 return false;
111 case CMD_UTILITY:
112 /* For now, treat all utility commands as read/write */
113 return false;
114 default:
115 elog(WARNING, "unrecognized commandType: %d",
116 (int) pstmt->commandType);
117 break;
118 }
119 return false;
120}
WARNING
#define WARNING
Definition: elog.h:36
elog
#define elog(elevel,...)
Definition: elog.h:226
Assert
Assert(PointerIsAligned(start, uint64))
IsA
#define IsA(nodeptr, _type_)
Definition: nodes.h:164
CMD_MERGE
@ CMD_MERGE
Definition: nodes.h:275
CMD_UTILITY
@ CMD_UTILITY
Definition: nodes.h:276
CMD_INSERT
@ CMD_INSERT
Definition: nodes.h:273
CMD_DELETE
@ CMD_DELETE
Definition: nodes.h:274
CMD_UPDATE
@ CMD_UPDATE
Definition: nodes.h:272
CMD_SELECT
@ CMD_SELECT
Definition: nodes.h:271
NIL
#define NIL
Definition: pg_list.h:68
PlannedStmt::hasModifyingCTE
bool hasModifyingCTE
Definition: plannodes.h:65
PlannedStmt::rowMarks
List * rowMarks
Definition: plannodes.h:127
PlannedStmt::commandType
CmdType commandType
Definition: plannodes.h:53

References Assert(), CMD_DELETE, CMD_INSERT, CMD_MERGE, CMD_SELECT, CMD_UPDATE, CMD_UTILITY, PlannedStmt::commandType, elog, PlannedStmt::hasModifyingCTE, IsA, NIL, PlannedStmt::rowMarks, and WARNING.

Referenced by _SPI_execute_plan(), init_execution_state(), and SPI_cursor_open_internal().

◆ CreateCommandName()

static const char * CreateCommandName ( Node *  parsetree)
inlinestatic

Definition at line 103 of file utility.h.

104{
105 return GetCommandTagName(CreateCommandTag(parsetree));
106}
GetCommandTagName
const char * GetCommandTagName(CommandTag commandTag)
Definition: cmdtag.c:47
CreateCommandTag
CommandTag CreateCommandTag(Node *parsetree)
Definition: utility.c:2362

References CreateCommandTag(), and GetCommandTagName().

Referenced by _SPI_execute_plan(), ExecCheckXactReadOnly(), get_command_tag(), init_execution_state(), pg_event_trigger_ddl_commands(), and SPI_cursor_open_internal().

◆ CreateCommandTag()

CommandTag CreateCommandTag ( Node *  parsetree)

Definition at line 2362 of file utility.c.

2363{
2364 CommandTag tag;
2365
2366 switch (nodeTag(parsetree))
2367 {
2368 /* recurse if we're given a RawStmt */
2369 case T_RawStmt:
2370 tag = CreateCommandTag(((RawStmt *) parsetree)->stmt);
2371 break;
2372
2373 /* raw plannable queries */
2374 case T_InsertStmt:
2375 tag = CMDTAG_INSERT;
2376 break;
2377
2378 case T_DeleteStmt:
2379 tag = CMDTAG_DELETE;
2380 break;
2381
2382 case T_UpdateStmt:
2383 tag = CMDTAG_UPDATE;
2384 break;
2385
2386 case T_MergeStmt:
2387 tag = CMDTAG_MERGE;
2388 break;
2389
2390 case T_SelectStmt:
2391 tag = CMDTAG_SELECT;
2392 break;
2393
2394 case T_PLAssignStmt:
2395 tag = CMDTAG_SELECT;
2396 break;
2397
2398 /* utility statements --- same whether raw or cooked */
2399 case T_TransactionStmt:
2400 {
2401 TransactionStmt *stmt = (TransactionStmt *) parsetree;
2402
2403 switch (stmt->kind)
2404 {
2405 case TRANS_STMT_BEGIN:
2406 tag = CMDTAG_BEGIN;
2407 break;
2408
2409 case TRANS_STMT_START:
2410 tag = CMDTAG_START_TRANSACTION;
2411 break;
2412
2413 case TRANS_STMT_COMMIT:
2414 tag = CMDTAG_COMMIT;
2415 break;
2416
2417 case TRANS_STMT_ROLLBACK:
2418 case TRANS_STMT_ROLLBACK_TO:
2419 tag = CMDTAG_ROLLBACK;
2420 break;
2421
2422 case TRANS_STMT_SAVEPOINT:
2423 tag = CMDTAG_SAVEPOINT;
2424 break;
2425
2426 case TRANS_STMT_RELEASE:
2427 tag = CMDTAG_RELEASE;
2428 break;
2429
2430 case TRANS_STMT_PREPARE:
2431 tag = CMDTAG_PREPARE_TRANSACTION;
2432 break;
2433
2434 case TRANS_STMT_COMMIT_PREPARED:
2435 tag = CMDTAG_COMMIT_PREPARED;
2436 break;
2437
2438 case TRANS_STMT_ROLLBACK_PREPARED:
2439 tag = CMDTAG_ROLLBACK_PREPARED;
2440 break;
2441
2442 default:
2443 tag = CMDTAG_UNKNOWN;
2444 break;
2445 }
2446 }
2447 break;
2448
2449 case T_DeclareCursorStmt:
2450 tag = CMDTAG_DECLARE_CURSOR;
2451 break;
2452
2453 case T_ClosePortalStmt:
2454 {
2455 ClosePortalStmt *stmt = (ClosePortalStmt *) parsetree;
2456
2457 if (stmt->portalname == NULL)
2458 tag = CMDTAG_CLOSE_CURSOR_ALL;
2459 else
2460 tag = CMDTAG_CLOSE_CURSOR;
2461 }
2462 break;
2463
2464 case T_FetchStmt:
2465 {
2466 FetchStmt *stmt = (FetchStmt *) parsetree;
2467
2468 tag = (stmt->ismove) ? CMDTAG_MOVE : CMDTAG_FETCH;
2469 }
2470 break;
2471
2472 case T_CreateDomainStmt:
2473 tag = CMDTAG_CREATE_DOMAIN;
2474 break;
2475
2476 case T_CreateSchemaStmt:
2477 tag = CMDTAG_CREATE_SCHEMA;
2478 break;
2479
2480 case T_CreateStmt:
2481 tag = CMDTAG_CREATE_TABLE;
2482 break;
2483
2484 case T_CreateTableSpaceStmt:
2485 tag = CMDTAG_CREATE_TABLESPACE;
2486 break;
2487
2488 case T_DropTableSpaceStmt:
2489 tag = CMDTAG_DROP_TABLESPACE;
2490 break;
2491
2492 case T_AlterTableSpaceOptionsStmt:
2493 tag = CMDTAG_ALTER_TABLESPACE;
2494 break;
2495
2496 case T_CreateExtensionStmt:
2497 tag = CMDTAG_CREATE_EXTENSION;
2498 break;
2499
2500 case T_AlterExtensionStmt:
2501 tag = CMDTAG_ALTER_EXTENSION;
2502 break;
2503
2504 case T_AlterExtensionContentsStmt:
2505 tag = CMDTAG_ALTER_EXTENSION;
2506 break;
2507
2508 case T_CreateFdwStmt:
2509 tag = CMDTAG_CREATE_FOREIGN_DATA_WRAPPER;
2510 break;
2511
2512 case T_AlterFdwStmt:
2513 tag = CMDTAG_ALTER_FOREIGN_DATA_WRAPPER;
2514 break;
2515
2516 case T_CreateForeignServerStmt:
2517 tag = CMDTAG_CREATE_SERVER;
2518 break;
2519
2520 case T_AlterForeignServerStmt:
2521 tag = CMDTAG_ALTER_SERVER;
2522 break;
2523
2524 case T_CreateUserMappingStmt:
2525 tag = CMDTAG_CREATE_USER_MAPPING;
2526 break;
2527
2528 case T_AlterUserMappingStmt:
2529 tag = CMDTAG_ALTER_USER_MAPPING;
2530 break;
2531
2532 case T_DropUserMappingStmt:
2533 tag = CMDTAG_DROP_USER_MAPPING;
2534 break;
2535
2536 case T_CreateForeignTableStmt:
2537 tag = CMDTAG_CREATE_FOREIGN_TABLE;
2538 break;
2539
2540 case T_ImportForeignSchemaStmt:
2541 tag = CMDTAG_IMPORT_FOREIGN_SCHEMA;
2542 break;
2543
2544 case T_DropStmt:
2545 switch (((DropStmt *) parsetree)->removeType)
2546 {
2547 case OBJECT_TABLE:
2548 tag = CMDTAG_DROP_TABLE;
2549 break;
2550 case OBJECT_SEQUENCE:
2551 tag = CMDTAG_DROP_SEQUENCE;
2552 break;
2553 case OBJECT_VIEW:
2554 tag = CMDTAG_DROP_VIEW;
2555 break;
2556 case OBJECT_MATVIEW:
2557 tag = CMDTAG_DROP_MATERIALIZED_VIEW;
2558 break;
2559 case OBJECT_INDEX:
2560 tag = CMDTAG_DROP_INDEX;
2561 break;
2562 case OBJECT_TYPE:
2563 tag = CMDTAG_DROP_TYPE;
2564 break;
2565 case OBJECT_DOMAIN:
2566 tag = CMDTAG_DROP_DOMAIN;
2567 break;
2568 case OBJECT_COLLATION:
2569 tag = CMDTAG_DROP_COLLATION;
2570 break;
2571 case OBJECT_CONVERSION:
2572 tag = CMDTAG_DROP_CONVERSION;
2573 break;
2574 case OBJECT_SCHEMA:
2575 tag = CMDTAG_DROP_SCHEMA;
2576 break;
2577 case OBJECT_TSPARSER:
2578 tag = CMDTAG_DROP_TEXT_SEARCH_PARSER;
2579 break;
2580 case OBJECT_TSDICTIONARY:
2581 tag = CMDTAG_DROP_TEXT_SEARCH_DICTIONARY;
2582 break;
2583 case OBJECT_TSTEMPLATE:
2584 tag = CMDTAG_DROP_TEXT_SEARCH_TEMPLATE;
2585 break;
2586 case OBJECT_TSCONFIGURATION:
2587 tag = CMDTAG_DROP_TEXT_SEARCH_CONFIGURATION;
2588 break;
2589 case OBJECT_FOREIGN_TABLE:
2590 tag = CMDTAG_DROP_FOREIGN_TABLE;
2591 break;
2592 case OBJECT_EXTENSION:
2593 tag = CMDTAG_DROP_EXTENSION;
2594 break;
2595 case OBJECT_FUNCTION:
2596 tag = CMDTAG_DROP_FUNCTION;
2597 break;
2598 case OBJECT_PROCEDURE:
2599 tag = CMDTAG_DROP_PROCEDURE;
2600 break;
2601 case OBJECT_ROUTINE:
2602 tag = CMDTAG_DROP_ROUTINE;
2603 break;
2604 case OBJECT_AGGREGATE:
2605 tag = CMDTAG_DROP_AGGREGATE;
2606 break;
2607 case OBJECT_OPERATOR:
2608 tag = CMDTAG_DROP_OPERATOR;
2609 break;
2610 case OBJECT_LANGUAGE:
2611 tag = CMDTAG_DROP_LANGUAGE;
2612 break;
2613 case OBJECT_CAST:
2614 tag = CMDTAG_DROP_CAST;
2615 break;
2616 case OBJECT_TRIGGER:
2617 tag = CMDTAG_DROP_TRIGGER;
2618 break;
2619 case OBJECT_EVENT_TRIGGER:
2620 tag = CMDTAG_DROP_EVENT_TRIGGER;
2621 break;
2622 case OBJECT_RULE:
2623 tag = CMDTAG_DROP_RULE;
2624 break;
2625 case OBJECT_FDW:
2626 tag = CMDTAG_DROP_FOREIGN_DATA_WRAPPER;
2627 break;
2628 case OBJECT_FOREIGN_SERVER:
2629 tag = CMDTAG_DROP_SERVER;
2630 break;
2631 case OBJECT_OPCLASS:
2632 tag = CMDTAG_DROP_OPERATOR_CLASS;
2633 break;
2634 case OBJECT_OPFAMILY:
2635 tag = CMDTAG_DROP_OPERATOR_FAMILY;
2636 break;
2637 case OBJECT_POLICY:
2638 tag = CMDTAG_DROP_POLICY;
2639 break;
2640 case OBJECT_TRANSFORM:
2641 tag = CMDTAG_DROP_TRANSFORM;
2642 break;
2643 case OBJECT_ACCESS_METHOD:
2644 tag = CMDTAG_DROP_ACCESS_METHOD;
2645 break;
2646 case OBJECT_PUBLICATION:
2647 tag = CMDTAG_DROP_PUBLICATION;
2648 break;
2649 case OBJECT_STATISTIC_EXT:
2650 tag = CMDTAG_DROP_STATISTICS;
2651 break;
2652 default:
2653 tag = CMDTAG_UNKNOWN;
2654 }
2655 break;
2656
2657 case T_TruncateStmt:
2658 tag = CMDTAG_TRUNCATE_TABLE;
2659 break;
2660
2661 case T_CommentStmt:
2662 tag = CMDTAG_COMMENT;
2663 break;
2664
2665 case T_SecLabelStmt:
2666 tag = CMDTAG_SECURITY_LABEL;
2667 break;
2668
2669 case T_CopyStmt:
2670 tag = CMDTAG_COPY;
2671 break;
2672
2673 case T_RenameStmt:
2674
2675 /*
2676 * When the column is renamed, the command tag is created from its
2677 * relation type
2678 */
2679 tag = AlterObjectTypeCommandTag(((RenameStmt *) parsetree)->renameType == OBJECT_COLUMN ?
2680 ((RenameStmt *) parsetree)->relationType :
2681 ((RenameStmt *) parsetree)->renameType);
2682 break;
2683
2684 case T_AlterObjectDependsStmt:
2685 tag = AlterObjectTypeCommandTag(((AlterObjectDependsStmt *) parsetree)->objectType);
2686 break;
2687
2688 case T_AlterObjectSchemaStmt:
2689 tag = AlterObjectTypeCommandTag(((AlterObjectSchemaStmt *) parsetree)->objectType);
2690 break;
2691
2692 case T_AlterOwnerStmt:
2693 tag = AlterObjectTypeCommandTag(((AlterOwnerStmt *) parsetree)->objectType);
2694 break;
2695
2696 case T_AlterTableMoveAllStmt:
2697 tag = AlterObjectTypeCommandTag(((AlterTableMoveAllStmt *) parsetree)->objtype);
2698 break;
2699
2700 case T_AlterTableStmt:
2701 tag = AlterObjectTypeCommandTag(((AlterTableStmt *) parsetree)->objtype);
2702 break;
2703
2704 case T_AlterDomainStmt:
2705 tag = CMDTAG_ALTER_DOMAIN;
2706 break;
2707
2708 case T_AlterFunctionStmt:
2709 switch (((AlterFunctionStmt *) parsetree)->objtype)
2710 {
2711 case OBJECT_FUNCTION:
2712 tag = CMDTAG_ALTER_FUNCTION;
2713 break;
2714 case OBJECT_PROCEDURE:
2715 tag = CMDTAG_ALTER_PROCEDURE;
2716 break;
2717 case OBJECT_ROUTINE:
2718 tag = CMDTAG_ALTER_ROUTINE;
2719 break;
2720 default:
2721 tag = CMDTAG_UNKNOWN;
2722 }
2723 break;
2724
2725 case T_GrantStmt:
2726 {
2727 GrantStmt *stmt = (GrantStmt *) parsetree;
2728
2729 tag = (stmt->is_grant) ? CMDTAG_GRANT : CMDTAG_REVOKE;
2730 }
2731 break;
2732
2733 case T_GrantRoleStmt:
2734 {
2735 GrantRoleStmt *stmt = (GrantRoleStmt *) parsetree;
2736
2737 tag = (stmt->is_grant) ? CMDTAG_GRANT_ROLE : CMDTAG_REVOKE_ROLE;
2738 }
2739 break;
2740
2741 case T_AlterDefaultPrivilegesStmt:
2742 tag = CMDTAG_ALTER_DEFAULT_PRIVILEGES;
2743 break;
2744
2745 case T_DefineStmt:
2746 switch (((DefineStmt *) parsetree)->kind)
2747 {
2748 case OBJECT_AGGREGATE:
2749 tag = CMDTAG_CREATE_AGGREGATE;
2750 break;
2751 case OBJECT_OPERATOR:
2752 tag = CMDTAG_CREATE_OPERATOR;
2753 break;
2754 case OBJECT_TYPE:
2755 tag = CMDTAG_CREATE_TYPE;
2756 break;
2757 case OBJECT_TSPARSER:
2758 tag = CMDTAG_CREATE_TEXT_SEARCH_PARSER;
2759 break;
2760 case OBJECT_TSDICTIONARY:
2761 tag = CMDTAG_CREATE_TEXT_SEARCH_DICTIONARY;
2762 break;
2763 case OBJECT_TSTEMPLATE:
2764 tag = CMDTAG_CREATE_TEXT_SEARCH_TEMPLATE;
2765 break;
2766 case OBJECT_TSCONFIGURATION:
2767 tag = CMDTAG_CREATE_TEXT_SEARCH_CONFIGURATION;
2768 break;
2769 case OBJECT_COLLATION:
2770 tag = CMDTAG_CREATE_COLLATION;
2771 break;
2772 case OBJECT_ACCESS_METHOD:
2773 tag = CMDTAG_CREATE_ACCESS_METHOD;
2774 break;
2775 default:
2776 tag = CMDTAG_UNKNOWN;
2777 }
2778 break;
2779
2780 case T_CompositeTypeStmt:
2781 tag = CMDTAG_CREATE_TYPE;
2782 break;
2783
2784 case T_CreateEnumStmt:
2785 tag = CMDTAG_CREATE_TYPE;
2786 break;
2787
2788 case T_CreateRangeStmt:
2789 tag = CMDTAG_CREATE_TYPE;
2790 break;
2791
2792 case T_AlterEnumStmt:
2793 tag = CMDTAG_ALTER_TYPE;
2794 break;
2795
2796 case T_ViewStmt:
2797 tag = CMDTAG_CREATE_VIEW;
2798 break;
2799
2800 case T_CreateFunctionStmt:
2801 if (((CreateFunctionStmt *) parsetree)->is_procedure)
2802 tag = CMDTAG_CREATE_PROCEDURE;
2803 else
2804 tag = CMDTAG_CREATE_FUNCTION;
2805 break;
2806
2807 case T_IndexStmt:
2808 tag = CMDTAG_CREATE_INDEX;
2809 break;
2810
2811 case T_RuleStmt:
2812 tag = CMDTAG_CREATE_RULE;
2813 break;
2814
2815 case T_CreateSeqStmt:
2816 tag = CMDTAG_CREATE_SEQUENCE;
2817 break;
2818
2819 case T_AlterSeqStmt:
2820 tag = CMDTAG_ALTER_SEQUENCE;
2821 break;
2822
2823 case T_DoStmt:
2824 tag = CMDTAG_DO;
2825 break;
2826
2827 case T_CreatedbStmt:
2828 tag = CMDTAG_CREATE_DATABASE;
2829 break;
2830
2831 case T_AlterDatabaseStmt:
2832 case T_AlterDatabaseRefreshCollStmt:
2833 case T_AlterDatabaseSetStmt:
2834 tag = CMDTAG_ALTER_DATABASE;
2835 break;
2836
2837 case T_DropdbStmt:
2838 tag = CMDTAG_DROP_DATABASE;
2839 break;
2840
2841 case T_NotifyStmt:
2842 tag = CMDTAG_NOTIFY;
2843 break;
2844
2845 case T_ListenStmt:
2846 tag = CMDTAG_LISTEN;
2847 break;
2848
2849 case T_UnlistenStmt:
2850 tag = CMDTAG_UNLISTEN;
2851 break;
2852
2853 case T_LoadStmt:
2854 tag = CMDTAG_LOAD;
2855 break;
2856
2857 case T_CallStmt:
2858 tag = CMDTAG_CALL;
2859 break;
2860
2861 case T_ClusterStmt:
2862 tag = CMDTAG_CLUSTER;
2863 break;
2864
2865 case T_VacuumStmt:
2866 if (((VacuumStmt *) parsetree)->is_vacuumcmd)
2867 tag = CMDTAG_VACUUM;
2868 else
2869 tag = CMDTAG_ANALYZE;
2870 break;
2871
2872 case T_ExplainStmt:
2873 tag = CMDTAG_EXPLAIN;
2874 break;
2875
2876 case T_CreateTableAsStmt:
2877 switch (((CreateTableAsStmt *) parsetree)->objtype)
2878 {
2879 case OBJECT_TABLE:
2880 if (((CreateTableAsStmt *) parsetree)->is_select_into)
2881 tag = CMDTAG_SELECT_INTO;
2882 else
2883 tag = CMDTAG_CREATE_TABLE_AS;
2884 break;
2885 case OBJECT_MATVIEW:
2886 tag = CMDTAG_CREATE_MATERIALIZED_VIEW;
2887 break;
2888 default:
2889 tag = CMDTAG_UNKNOWN;
2890 }
2891 break;
2892
2893 case T_RefreshMatViewStmt:
2894 tag = CMDTAG_REFRESH_MATERIALIZED_VIEW;
2895 break;
2896
2897 case T_AlterSystemStmt:
2898 tag = CMDTAG_ALTER_SYSTEM;
2899 break;
2900
2901 case T_VariableSetStmt:
2902 switch (((VariableSetStmt *) parsetree)->kind)
2903 {
2904 case VAR_SET_VALUE:
2905 case VAR_SET_CURRENT:
2906 case VAR_SET_DEFAULT:
2907 case VAR_SET_MULTI:
2908 tag = CMDTAG_SET;
2909 break;
2910 case VAR_RESET:
2911 case VAR_RESET_ALL:
2912 tag = CMDTAG_RESET;
2913 break;
2914 default:
2915 tag = CMDTAG_UNKNOWN;
2916 }
2917 break;
2918
2919 case T_VariableShowStmt:
2920 tag = CMDTAG_SHOW;
2921 break;
2922
2923 case T_DiscardStmt:
2924 switch (((DiscardStmt *) parsetree)->target)
2925 {
2926 case DISCARD_ALL:
2927 tag = CMDTAG_DISCARD_ALL;
2928 break;
2929 case DISCARD_PLANS:
2930 tag = CMDTAG_DISCARD_PLANS;
2931 break;
2932 case DISCARD_TEMP:
2933 tag = CMDTAG_DISCARD_TEMP;
2934 break;
2935 case DISCARD_SEQUENCES:
2936 tag = CMDTAG_DISCARD_SEQUENCES;
2937 break;
2938 default:
2939 tag = CMDTAG_UNKNOWN;
2940 }
2941 break;
2942
2943 case T_CreateTransformStmt:
2944 tag = CMDTAG_CREATE_TRANSFORM;
2945 break;
2946
2947 case T_CreateTrigStmt:
2948 tag = CMDTAG_CREATE_TRIGGER;
2949 break;
2950
2951 case T_CreateEventTrigStmt:
2952 tag = CMDTAG_CREATE_EVENT_TRIGGER;
2953 break;
2954
2955 case T_AlterEventTrigStmt:
2956 tag = CMDTAG_ALTER_EVENT_TRIGGER;
2957 break;
2958
2959 case T_CreatePLangStmt:
2960 tag = CMDTAG_CREATE_LANGUAGE;
2961 break;
2962
2963 case T_CreateRoleStmt:
2964 tag = CMDTAG_CREATE_ROLE;
2965 break;
2966
2967 case T_AlterRoleStmt:
2968 tag = CMDTAG_ALTER_ROLE;
2969 break;
2970
2971 case T_AlterRoleSetStmt:
2972 tag = CMDTAG_ALTER_ROLE;
2973 break;
2974
2975 case T_DropRoleStmt:
2976 tag = CMDTAG_DROP_ROLE;
2977 break;
2978
2979 case T_DropOwnedStmt:
2980 tag = CMDTAG_DROP_OWNED;
2981 break;
2982
2983 case T_ReassignOwnedStmt:
2984 tag = CMDTAG_REASSIGN_OWNED;
2985 break;
2986
2987 case T_LockStmt:
2988 tag = CMDTAG_LOCK_TABLE;
2989 break;
2990
2991 case T_ConstraintsSetStmt:
2992 tag = CMDTAG_SET_CONSTRAINTS;
2993 break;
2994
2995 case T_CheckPointStmt:
2996 tag = CMDTAG_CHECKPOINT;
2997 break;
2998
2999 case T_ReindexStmt:
3000 tag = CMDTAG_REINDEX;
3001 break;
3002
3003 case T_CreateConversionStmt:
3004 tag = CMDTAG_CREATE_CONVERSION;
3005 break;
3006
3007 case T_CreateCastStmt:
3008 tag = CMDTAG_CREATE_CAST;
3009 break;
3010
3011 case T_CreateOpClassStmt:
3012 tag = CMDTAG_CREATE_OPERATOR_CLASS;
3013 break;
3014
3015 case T_CreateOpFamilyStmt:
3016 tag = CMDTAG_CREATE_OPERATOR_FAMILY;
3017 break;
3018
3019 case T_AlterOpFamilyStmt:
3020 tag = CMDTAG_ALTER_OPERATOR_FAMILY;
3021 break;
3022
3023 case T_AlterOperatorStmt:
3024 tag = CMDTAG_ALTER_OPERATOR;
3025 break;
3026
3027 case T_AlterTypeStmt:
3028 tag = CMDTAG_ALTER_TYPE;
3029 break;
3030
3031 case T_AlterTSDictionaryStmt:
3032 tag = CMDTAG_ALTER_TEXT_SEARCH_DICTIONARY;
3033 break;
3034
3035 case T_AlterTSConfigurationStmt:
3036 tag = CMDTAG_ALTER_TEXT_SEARCH_CONFIGURATION;
3037 break;
3038
3039 case T_CreatePolicyStmt:
3040 tag = CMDTAG_CREATE_POLICY;
3041 break;
3042
3043 case T_AlterPolicyStmt:
3044 tag = CMDTAG_ALTER_POLICY;
3045 break;
3046
3047 case T_CreateAmStmt:
3048 tag = CMDTAG_CREATE_ACCESS_METHOD;
3049 break;
3050
3051 case T_CreatePublicationStmt:
3052 tag = CMDTAG_CREATE_PUBLICATION;
3053 break;
3054
3055 case T_AlterPublicationStmt:
3056 tag = CMDTAG_ALTER_PUBLICATION;
3057 break;
3058
3059 case T_CreateSubscriptionStmt:
3060 tag = CMDTAG_CREATE_SUBSCRIPTION;
3061 break;
3062
3063 case T_AlterSubscriptionStmt:
3064 tag = CMDTAG_ALTER_SUBSCRIPTION;
3065 break;
3066
3067 case T_DropSubscriptionStmt:
3068 tag = CMDTAG_DROP_SUBSCRIPTION;
3069 break;
3070
3071 case T_AlterCollationStmt:
3072 tag = CMDTAG_ALTER_COLLATION;
3073 break;
3074
3075 case T_PrepareStmt:
3076 tag = CMDTAG_PREPARE;
3077 break;
3078
3079 case T_ExecuteStmt:
3080 tag = CMDTAG_EXECUTE;
3081 break;
3082
3083 case T_CreateStatsStmt:
3084 tag = CMDTAG_CREATE_STATISTICS;
3085 break;
3086
3087 case T_AlterStatsStmt:
3088 tag = CMDTAG_ALTER_STATISTICS;
3089 break;
3090
3091 case T_DeallocateStmt:
3092 {
3093 DeallocateStmt *stmt = (DeallocateStmt *) parsetree;
3094
3095 if (stmt->name == NULL)
3096 tag = CMDTAG_DEALLOCATE_ALL;
3097 else
3098 tag = CMDTAG_DEALLOCATE;
3099 }
3100 break;
3101
3102 /* already-planned queries */
3103 case T_PlannedStmt:
3104 {
3105 PlannedStmt *stmt = (PlannedStmt *) parsetree;
3106
3107 switch (stmt->commandType)
3108 {
3109 case CMD_SELECT:
3110
3111 /*
3112 * We take a little extra care here so that the result
3113 * will be useful for complaints about read-only
3114 * statements
3115 */
3116 if (stmt->rowMarks != NIL)
3117 {
3118 /* not 100% but probably close enough */
3119 switch (((PlanRowMark *) linitial(stmt->rowMarks))->strength)
3120 {
3121 case LCS_FORKEYSHARE:
3122 tag = CMDTAG_SELECT_FOR_KEY_SHARE;
3123 break;
3124 case LCS_FORSHARE:
3125 tag = CMDTAG_SELECT_FOR_SHARE;
3126 break;
3127 case LCS_FORNOKEYUPDATE:
3128 tag = CMDTAG_SELECT_FOR_NO_KEY_UPDATE;
3129 break;
3130 case LCS_FORUPDATE:
3131 tag = CMDTAG_SELECT_FOR_UPDATE;
3132 break;
3133 default:
3134 tag = CMDTAG_SELECT;
3135 break;
3136 }
3137 }
3138 else
3139 tag = CMDTAG_SELECT;
3140 break;
3141 case CMD_UPDATE:
3142 tag = CMDTAG_UPDATE;
3143 break;
3144 case CMD_INSERT:
3145 tag = CMDTAG_INSERT;
3146 break;
3147 case CMD_DELETE:
3148 tag = CMDTAG_DELETE;
3149 break;
3150 case CMD_MERGE:
3151 tag = CMDTAG_MERGE;
3152 break;
3153 case CMD_UTILITY:
3154 tag = CreateCommandTag(stmt->utilityStmt);
3155 break;
3156 default:
3157 elog(WARNING, "unrecognized commandType: %d",
3158 (int) stmt->commandType);
3159 tag = CMDTAG_UNKNOWN;
3160 break;
3161 }
3162 }
3163 break;
3164
3165 /* parsed-and-rewritten-but-not-planned queries */
3166 case T_Query:
3167 {
3168 Query *stmt = (Query *) parsetree;
3169
3170 switch (stmt->commandType)
3171 {
3172 case CMD_SELECT:
3173
3174 /*
3175 * We take a little extra care here so that the result
3176 * will be useful for complaints about read-only
3177 * statements
3178 */
3179 if (stmt->rowMarks != NIL)
3180 {
3181 /* not 100% but probably close enough */
3182 switch (((RowMarkClause *) linitial(stmt->rowMarks))->strength)
3183 {
3184 case LCS_FORKEYSHARE:
3185 tag = CMDTAG_SELECT_FOR_KEY_SHARE;
3186 break;
3187 case LCS_FORSHARE:
3188 tag = CMDTAG_SELECT_FOR_SHARE;
3189 break;
3190 case LCS_FORNOKEYUPDATE:
3191 tag = CMDTAG_SELECT_FOR_NO_KEY_UPDATE;
3192 break;
3193 case LCS_FORUPDATE:
3194 tag = CMDTAG_SELECT_FOR_UPDATE;
3195 break;
3196 default:
3197 tag = CMDTAG_UNKNOWN;
3198 break;
3199 }
3200 }
3201 else
3202 tag = CMDTAG_SELECT;
3203 break;
3204 case CMD_UPDATE:
3205 tag = CMDTAG_UPDATE;
3206 break;
3207 case CMD_INSERT:
3208 tag = CMDTAG_INSERT;
3209 break;
3210 case CMD_DELETE:
3211 tag = CMDTAG_DELETE;
3212 break;
3213 case CMD_MERGE:
3214 tag = CMDTAG_MERGE;
3215 break;
3216 case CMD_UTILITY:
3217 tag = CreateCommandTag(stmt->utilityStmt);
3218 break;
3219 default:
3220 elog(WARNING, "unrecognized commandType: %d",
3221 (int) stmt->commandType);
3222 tag = CMDTAG_UNKNOWN;
3223 break;
3224 }
3225 }
3226 break;
3227
3228 default:
3229 elog(WARNING, "unrecognized node type: %d",
3230 (int) nodeTag(parsetree));
3231 tag = CMDTAG_UNKNOWN;
3232 break;
3233 }
3234
3235 return tag;
3236}
CommandTag
CommandTag
Definition: cmdtag.h:23
stmt
#define stmt
Definition: indent_codes.h:59
LCS_FORUPDATE
@ LCS_FORUPDATE
Definition: lockoptions.h:27
LCS_FORSHARE
@ LCS_FORSHARE
Definition: lockoptions.h:25
LCS_FORKEYSHARE
@ LCS_FORKEYSHARE
Definition: lockoptions.h:24
LCS_FORNOKEYUPDATE
@ LCS_FORNOKEYUPDATE
Definition: lockoptions.h:26
nodeTag
#define nodeTag(nodeptr)
Definition: nodes.h:139
TRANS_STMT_ROLLBACK_TO
@ TRANS_STMT_ROLLBACK_TO
Definition: parsenodes.h:3757
TRANS_STMT_START
@ TRANS_STMT_START
Definition: parsenodes.h:3752
TRANS_STMT_SAVEPOINT
@ TRANS_STMT_SAVEPOINT
Definition: parsenodes.h:3755
TRANS_STMT_BEGIN
@ TRANS_STMT_BEGIN
Definition: parsenodes.h:3751
TRANS_STMT_ROLLBACK
@ TRANS_STMT_ROLLBACK
Definition: parsenodes.h:3754
TRANS_STMT_COMMIT_PREPARED
@ TRANS_STMT_COMMIT_PREPARED
Definition: parsenodes.h:3759
TRANS_STMT_COMMIT
@ TRANS_STMT_COMMIT
Definition: parsenodes.h:3753
TRANS_STMT_ROLLBACK_PREPARED
@ TRANS_STMT_ROLLBACK_PREPARED
Definition: parsenodes.h:3760
TRANS_STMT_PREPARE
@ TRANS_STMT_PREPARE
Definition: parsenodes.h:3758
TRANS_STMT_RELEASE
@ TRANS_STMT_RELEASE
Definition: parsenodes.h:3756
VAR_SET_DEFAULT
@ VAR_SET_DEFAULT
Definition: parsenodes.h:2684
VAR_RESET
@ VAR_RESET
Definition: parsenodes.h:2687
VAR_SET_MULTI
@ VAR_SET_MULTI
Definition: parsenodes.h:2686
VAR_SET_VALUE
@ VAR_SET_VALUE
Definition: parsenodes.h:2683
VAR_SET_CURRENT
@ VAR_SET_CURRENT
Definition: parsenodes.h:2685
VAR_RESET_ALL
@ VAR_RESET_ALL
Definition: parsenodes.h:2688
OBJECT_EVENT_TRIGGER
@ OBJECT_EVENT_TRIGGER
Definition: parsenodes.h:2331
OBJECT_FDW
@ OBJECT_FDW
Definition: parsenodes.h:2333
OBJECT_TSPARSER
@ OBJECT_TSPARSER
Definition: parsenodes.h:2364
OBJECT_COLLATION
@ OBJECT_COLLATION
Definition: parsenodes.h:2324
OBJECT_ACCESS_METHOD
@ OBJECT_ACCESS_METHOD
Definition: parsenodes.h:2317
OBJECT_OPCLASS
@ OBJECT_OPCLASS
Definition: parsenodes.h:2341
OBJECT_AGGREGATE
@ OBJECT_AGGREGATE
Definition: parsenodes.h:2318
OBJECT_MATVIEW
@ OBJECT_MATVIEW
Definition: parsenodes.h:2340
OBJECT_SCHEMA
@ OBJECT_SCHEMA
Definition: parsenodes.h:2353
OBJECT_POLICY
@ OBJECT_POLICY
Definition: parsenodes.h:2345
OBJECT_OPERATOR
@ OBJECT_OPERATOR
Definition: parsenodes.h:2342
OBJECT_FOREIGN_TABLE
@ OBJECT_FOREIGN_TABLE
Definition: parsenodes.h:2335
OBJECT_TSCONFIGURATION
@ OBJECT_TSCONFIGURATION
Definition: parsenodes.h:2362
OBJECT_OPFAMILY
@ OBJECT_OPFAMILY
Definition: parsenodes.h:2343
OBJECT_DOMAIN
@ OBJECT_DOMAIN
Definition: parsenodes.h:2329
OBJECT_COLUMN
@ OBJECT_COLUMN
Definition: parsenodes.h:2323
OBJECT_ROUTINE
@ OBJECT_ROUTINE
Definition: parsenodes.h:2351
OBJECT_PROCEDURE
@ OBJECT_PROCEDURE
Definition: parsenodes.h:2346
OBJECT_EXTENSION
@ OBJECT_EXTENSION
Definition: parsenodes.h:2332
OBJECT_INDEX
@ OBJECT_INDEX
Definition: parsenodes.h:2337
OBJECT_SEQUENCE
@ OBJECT_SEQUENCE
Definition: parsenodes.h:2354
OBJECT_TSTEMPLATE
@ OBJECT_TSTEMPLATE
Definition: parsenodes.h:2365
OBJECT_LANGUAGE
@ OBJECT_LANGUAGE
Definition: parsenodes.h:2338
OBJECT_FOREIGN_SERVER
@ OBJECT_FOREIGN_SERVER
Definition: parsenodes.h:2334
OBJECT_TSDICTIONARY
@ OBJECT_TSDICTIONARY
Definition: parsenodes.h:2363
OBJECT_PUBLICATION
@ OBJECT_PUBLICATION
Definition: parsenodes.h:2347
OBJECT_RULE
@ OBJECT_RULE
Definition: parsenodes.h:2352
OBJECT_CONVERSION
@ OBJECT_CONVERSION
Definition: parsenodes.h:2325
OBJECT_TABLE
@ OBJECT_TABLE
Definition: parsenodes.h:2358
OBJECT_VIEW
@ OBJECT_VIEW
Definition: parsenodes.h:2368
OBJECT_TYPE
@ OBJECT_TYPE
Definition: parsenodes.h:2366
OBJECT_FUNCTION
@ OBJECT_FUNCTION
Definition: parsenodes.h:2336
OBJECT_STATISTIC_EXT
@ OBJECT_STATISTIC_EXT
Definition: parsenodes.h:2356
OBJECT_CAST
@ OBJECT_CAST
Definition: parsenodes.h:2322
OBJECT_TRIGGER
@ OBJECT_TRIGGER
Definition: parsenodes.h:2361
OBJECT_TRANSFORM
@ OBJECT_TRANSFORM
Definition: parsenodes.h:2360
DISCARD_ALL
@ DISCARD_ALL
Definition: parsenodes.h:4022
DISCARD_PLANS
@ DISCARD_PLANS
Definition: parsenodes.h:4023
DISCARD_SEQUENCES
@ DISCARD_SEQUENCES
Definition: parsenodes.h:4024
DISCARD_TEMP
@ DISCARD_TEMP
Definition: parsenodes.h:4025
linitial
#define linitial(l)
Definition: pg_list.h:178
CreateCommandTag
CommandTag CreateCommandTag(Node *parsetree)
Definition: utility.c:2362
AlterObjectTypeCommandTag
static CommandTag AlterObjectTypeCommandTag(ObjectType objtype)
Definition: utility.c:2216

References AlterObjectTypeCommandTag(), CMD_DELETE, CMD_INSERT, CMD_MERGE, CMD_SELECT, CMD_UPDATE, CMD_UTILITY, CreateCommandTag(), DISCARD_ALL, DISCARD_PLANS, DISCARD_SEQUENCES, DISCARD_TEMP, elog, LCS_FORKEYSHARE, LCS_FORNOKEYUPDATE, LCS_FORSHARE, LCS_FORUPDATE, linitial, NIL, nodeTag, OBJECT_ACCESS_METHOD, OBJECT_AGGREGATE, OBJECT_CAST, OBJECT_COLLATION, OBJECT_COLUMN, OBJECT_CONVERSION, OBJECT_DOMAIN, OBJECT_EVENT_TRIGGER, OBJECT_EXTENSION, OBJECT_FDW, OBJECT_FOREIGN_SERVER, OBJECT_FOREIGN_TABLE, OBJECT_FUNCTION, OBJECT_INDEX, OBJECT_LANGUAGE, OBJECT_MATVIEW, OBJECT_OPCLASS, OBJECT_OPERATOR, OBJECT_OPFAMILY, OBJECT_POLICY, OBJECT_PROCEDURE, OBJECT_PUBLICATION, OBJECT_ROUTINE, OBJECT_RULE, OBJECT_SCHEMA, OBJECT_SEQUENCE, OBJECT_STATISTIC_EXT, OBJECT_TABLE, OBJECT_TRANSFORM, OBJECT_TRIGGER, OBJECT_TSCONFIGURATION, OBJECT_TSDICTIONARY, OBJECT_TSPARSER, OBJECT_TSTEMPLATE, OBJECT_TYPE, OBJECT_VIEW, stmt, TRANS_STMT_BEGIN, TRANS_STMT_COMMIT, TRANS_STMT_COMMIT_PREPARED, TRANS_STMT_PREPARE, TRANS_STMT_RELEASE, TRANS_STMT_ROLLBACK, TRANS_STMT_ROLLBACK_PREPARED, TRANS_STMT_ROLLBACK_TO, TRANS_STMT_SAVEPOINT, TRANS_STMT_START, VAR_RESET, VAR_RESET_ALL, VAR_SET_CURRENT, VAR_SET_DEFAULT, VAR_SET_MULTI, VAR_SET_VALUE, and WARNING.

Referenced by _SPI_prepare_oneshot_plan(), _SPI_prepare_plan(), CreateCommandName(), CreateCommandTag(), EventTriggerGetTag(), exec_parse_message(), exec_simple_query(), interpret_AS_clause(), prepare_next_query(), PrepareQuery(), REGRESS_utility_command(), and standard_ProcessUtility().

◆ GetCommandLogLevel()

LogStmtLevel GetCommandLogLevel ( Node *  parsetree)

Definition at line 3249 of file utility.c.

3250{
3251 LogStmtLevel lev;
3252
3253 switch (nodeTag(parsetree))
3254 {
3255 /* recurse if we're given a RawStmt */
3256 case T_RawStmt:
3257 lev = GetCommandLogLevel(((RawStmt *) parsetree)->stmt);
3258 break;
3259
3260 /* raw plannable queries */
3261 case T_InsertStmt:
3262 case T_DeleteStmt:
3263 case T_UpdateStmt:
3264 case T_MergeStmt:
3265 lev = LOGSTMT_MOD;
3266 break;
3267
3268 case T_SelectStmt:
3269 if (((SelectStmt *) parsetree)->intoClause)
3270 lev = LOGSTMT_DDL; /* SELECT INTO */
3271 else
3272 lev = LOGSTMT_ALL;
3273 break;
3274
3275 case T_PLAssignStmt:
3276 lev = LOGSTMT_ALL;
3277 break;
3278
3279 /* utility statements --- same whether raw or cooked */
3280 case T_TransactionStmt:
3281 lev = LOGSTMT_ALL;
3282 break;
3283
3284 case T_DeclareCursorStmt:
3285 lev = LOGSTMT_ALL;
3286 break;
3287
3288 case T_ClosePortalStmt:
3289 lev = LOGSTMT_ALL;
3290 break;
3291
3292 case T_FetchStmt:
3293 lev = LOGSTMT_ALL;
3294 break;
3295
3296 case T_CreateSchemaStmt:
3297 lev = LOGSTMT_DDL;
3298 break;
3299
3300 case T_CreateStmt:
3301 case T_CreateForeignTableStmt:
3302 lev = LOGSTMT_DDL;
3303 break;
3304
3305 case T_CreateTableSpaceStmt:
3306 case T_DropTableSpaceStmt:
3307 case T_AlterTableSpaceOptionsStmt:
3308 lev = LOGSTMT_DDL;
3309 break;
3310
3311 case T_CreateExtensionStmt:
3312 case T_AlterExtensionStmt:
3313 case T_AlterExtensionContentsStmt:
3314 lev = LOGSTMT_DDL;
3315 break;
3316
3317 case T_CreateFdwStmt:
3318 case T_AlterFdwStmt:
3319 case T_CreateForeignServerStmt:
3320 case T_AlterForeignServerStmt:
3321 case T_CreateUserMappingStmt:
3322 case T_AlterUserMappingStmt:
3323 case T_DropUserMappingStmt:
3324 case T_ImportForeignSchemaStmt:
3325 lev = LOGSTMT_DDL;
3326 break;
3327
3328 case T_DropStmt:
3329 lev = LOGSTMT_DDL;
3330 break;
3331
3332 case T_TruncateStmt:
3333 lev = LOGSTMT_MOD;
3334 break;
3335
3336 case T_CommentStmt:
3337 lev = LOGSTMT_DDL;
3338 break;
3339
3340 case T_SecLabelStmt:
3341 lev = LOGSTMT_DDL;
3342 break;
3343
3344 case T_CopyStmt:
3345 if (((CopyStmt *) parsetree)->is_from)
3346 lev = LOGSTMT_MOD;
3347 else
3348 lev = LOGSTMT_ALL;
3349 break;
3350
3351 case T_PrepareStmt:
3352 {
3353 PrepareStmt *stmt = (PrepareStmt *) parsetree;
3354
3355 /* Look through a PREPARE to the contained stmt */
3356 lev = GetCommandLogLevel(stmt->query);
3357 }
3358 break;
3359
3360 case T_ExecuteStmt:
3361 {
3362 ExecuteStmt *stmt = (ExecuteStmt *) parsetree;
3363 PreparedStatement *ps;
3364
3365 /* Look through an EXECUTE to the referenced stmt */
3366 ps = FetchPreparedStatement(stmt->name, false);
3367 if (ps && ps->plansource->raw_parse_tree)
3368 lev = GetCommandLogLevel(ps->plansource->raw_parse_tree->stmt);
3369 else
3370 lev = LOGSTMT_ALL;
3371 }
3372 break;
3373
3374 case T_DeallocateStmt:
3375 lev = LOGSTMT_ALL;
3376 break;
3377
3378 case T_RenameStmt:
3379 lev = LOGSTMT_DDL;
3380 break;
3381
3382 case T_AlterObjectDependsStmt:
3383 lev = LOGSTMT_DDL;
3384 break;
3385
3386 case T_AlterObjectSchemaStmt:
3387 lev = LOGSTMT_DDL;
3388 break;
3389
3390 case T_AlterOwnerStmt:
3391 lev = LOGSTMT_DDL;
3392 break;
3393
3394 case T_AlterOperatorStmt:
3395 lev = LOGSTMT_DDL;
3396 break;
3397
3398 case T_AlterTypeStmt:
3399 lev = LOGSTMT_DDL;
3400 break;
3401
3402 case T_AlterTableMoveAllStmt:
3403 case T_AlterTableStmt:
3404 lev = LOGSTMT_DDL;
3405 break;
3406
3407 case T_AlterDomainStmt:
3408 lev = LOGSTMT_DDL;
3409 break;
3410
3411 case T_GrantStmt:
3412 lev = LOGSTMT_DDL;
3413 break;
3414
3415 case T_GrantRoleStmt:
3416 lev = LOGSTMT_DDL;
3417 break;
3418
3419 case T_AlterDefaultPrivilegesStmt:
3420 lev = LOGSTMT_DDL;
3421 break;
3422
3423 case T_DefineStmt:
3424 lev = LOGSTMT_DDL;
3425 break;
3426
3427 case T_CompositeTypeStmt:
3428 lev = LOGSTMT_DDL;
3429 break;
3430
3431 case T_CreateEnumStmt:
3432 lev = LOGSTMT_DDL;
3433 break;
3434
3435 case T_CreateRangeStmt:
3436 lev = LOGSTMT_DDL;
3437 break;
3438
3439 case T_AlterEnumStmt:
3440 lev = LOGSTMT_DDL;
3441 break;
3442
3443 case T_ViewStmt:
3444 lev = LOGSTMT_DDL;
3445 break;
3446
3447 case T_CreateFunctionStmt:
3448 lev = LOGSTMT_DDL;
3449 break;
3450
3451 case T_AlterFunctionStmt:
3452 lev = LOGSTMT_DDL;
3453 break;
3454
3455 case T_IndexStmt:
3456 lev = LOGSTMT_DDL;
3457 break;
3458
3459 case T_RuleStmt:
3460 lev = LOGSTMT_DDL;
3461 break;
3462
3463 case T_CreateSeqStmt:
3464 lev = LOGSTMT_DDL;
3465 break;
3466
3467 case T_AlterSeqStmt:
3468 lev = LOGSTMT_DDL;
3469 break;
3470
3471 case T_DoStmt:
3472 lev = LOGSTMT_ALL;
3473 break;
3474
3475 case T_CreatedbStmt:
3476 lev = LOGSTMT_DDL;
3477 break;
3478
3479 case T_AlterDatabaseStmt:
3480 case T_AlterDatabaseRefreshCollStmt:
3481 case T_AlterDatabaseSetStmt:
3482 lev = LOGSTMT_DDL;
3483 break;
3484
3485 case T_DropdbStmt:
3486 lev = LOGSTMT_DDL;
3487 break;
3488
3489 case T_NotifyStmt:
3490 lev = LOGSTMT_ALL;
3491 break;
3492
3493 case T_ListenStmt:
3494 lev = LOGSTMT_ALL;
3495 break;
3496
3497 case T_UnlistenStmt:
3498 lev = LOGSTMT_ALL;
3499 break;
3500
3501 case T_LoadStmt:
3502 lev = LOGSTMT_ALL;
3503 break;
3504
3505 case T_CallStmt:
3506 lev = LOGSTMT_ALL;
3507 break;
3508
3509 case T_ClusterStmt:
3510 lev = LOGSTMT_DDL;
3511 break;
3512
3513 case T_VacuumStmt:
3514 lev = LOGSTMT_ALL;
3515 break;
3516
3517 case T_ExplainStmt:
3518 {
3519 ExplainStmt *stmt = (ExplainStmt *) parsetree;
3520 bool analyze = false;
3521 ListCell *lc;
3522
3523 /* Look through an EXPLAIN ANALYZE to the contained stmt */
3524 foreach(lc, stmt->options)
3525 {
3526 DefElem *opt = (DefElem *) lfirst(lc);
3527
3528 if (strcmp(opt->defname, "analyze") == 0)
3529 analyze = defGetBoolean(opt);
3530 /* don't "break", as explain.c will use the last value */
3531 }
3532 if (analyze)
3533 return GetCommandLogLevel(stmt->query);
3534
3535 /* Plain EXPLAIN isn't so interesting */
3536 lev = LOGSTMT_ALL;
3537 }
3538 break;
3539
3540 case T_CreateTableAsStmt:
3541 lev = LOGSTMT_DDL;
3542 break;
3543
3544 case T_RefreshMatViewStmt:
3545 lev = LOGSTMT_DDL;
3546 break;
3547
3548 case T_AlterSystemStmt:
3549 lev = LOGSTMT_DDL;
3550 break;
3551
3552 case T_VariableSetStmt:
3553 lev = LOGSTMT_ALL;
3554 break;
3555
3556 case T_VariableShowStmt:
3557 lev = LOGSTMT_ALL;
3558 break;
3559
3560 case T_DiscardStmt:
3561 lev = LOGSTMT_ALL;
3562 break;
3563
3564 case T_CreateTrigStmt:
3565 lev = LOGSTMT_DDL;
3566 break;
3567
3568 case T_CreateEventTrigStmt:
3569 lev = LOGSTMT_DDL;
3570 break;
3571
3572 case T_AlterEventTrigStmt:
3573 lev = LOGSTMT_DDL;
3574 break;
3575
3576 case T_CreatePLangStmt:
3577 lev = LOGSTMT_DDL;
3578 break;
3579
3580 case T_CreateDomainStmt:
3581 lev = LOGSTMT_DDL;
3582 break;
3583
3584 case T_CreateRoleStmt:
3585 lev = LOGSTMT_DDL;
3586 break;
3587
3588 case T_AlterRoleStmt:
3589 lev = LOGSTMT_DDL;
3590 break;
3591
3592 case T_AlterRoleSetStmt:
3593 lev = LOGSTMT_DDL;
3594 break;
3595
3596 case T_DropRoleStmt:
3597 lev = LOGSTMT_DDL;
3598 break;
3599
3600 case T_DropOwnedStmt:
3601 lev = LOGSTMT_DDL;
3602 break;
3603
3604 case T_ReassignOwnedStmt:
3605 lev = LOGSTMT_DDL;
3606 break;
3607
3608 case T_LockStmt:
3609 lev = LOGSTMT_ALL;
3610 break;
3611
3612 case T_ConstraintsSetStmt:
3613 lev = LOGSTMT_ALL;
3614 break;
3615
3616 case T_CheckPointStmt:
3617 lev = LOGSTMT_ALL;
3618 break;
3619
3620 case T_ReindexStmt:
3621 lev = LOGSTMT_ALL; /* should this be DDL? */
3622 break;
3623
3624 case T_CreateConversionStmt:
3625 lev = LOGSTMT_DDL;
3626 break;
3627
3628 case T_CreateCastStmt:
3629 lev = LOGSTMT_DDL;
3630 break;
3631
3632 case T_CreateOpClassStmt:
3633 lev = LOGSTMT_DDL;
3634 break;
3635
3636 case T_CreateOpFamilyStmt:
3637 lev = LOGSTMT_DDL;
3638 break;
3639
3640 case T_CreateTransformStmt:
3641 lev = LOGSTMT_DDL;
3642 break;
3643
3644 case T_AlterOpFamilyStmt:
3645 lev = LOGSTMT_DDL;
3646 break;
3647
3648 case T_CreatePolicyStmt:
3649 lev = LOGSTMT_DDL;
3650 break;
3651
3652 case T_AlterPolicyStmt:
3653 lev = LOGSTMT_DDL;
3654 break;
3655
3656 case T_AlterTSDictionaryStmt:
3657 lev = LOGSTMT_DDL;
3658 break;
3659
3660 case T_AlterTSConfigurationStmt:
3661 lev = LOGSTMT_DDL;
3662 break;
3663
3664 case T_CreateAmStmt:
3665 lev = LOGSTMT_DDL;
3666 break;
3667
3668 case T_CreatePublicationStmt:
3669 lev = LOGSTMT_DDL;
3670 break;
3671
3672 case T_AlterPublicationStmt:
3673 lev = LOGSTMT_DDL;
3674 break;
3675
3676 case T_CreateSubscriptionStmt:
3677 lev = LOGSTMT_DDL;
3678 break;
3679
3680 case T_AlterSubscriptionStmt:
3681 lev = LOGSTMT_DDL;
3682 break;
3683
3684 case T_DropSubscriptionStmt:
3685 lev = LOGSTMT_DDL;
3686 break;
3687
3688 case T_CreateStatsStmt:
3689 lev = LOGSTMT_DDL;
3690 break;
3691
3692 case T_AlterStatsStmt:
3693 lev = LOGSTMT_DDL;
3694 break;
3695
3696 case T_AlterCollationStmt:
3697 lev = LOGSTMT_DDL;
3698 break;
3699
3700 /* already-planned queries */
3701 case T_PlannedStmt:
3702 {
3703 PlannedStmt *stmt = (PlannedStmt *) parsetree;
3704
3705 switch (stmt->commandType)
3706 {
3707 case CMD_SELECT:
3708 lev = LOGSTMT_ALL;
3709 break;
3710
3711 case CMD_UPDATE:
3712 case CMD_INSERT:
3713 case CMD_DELETE:
3714 case CMD_MERGE:
3715 lev = LOGSTMT_MOD;
3716 break;
3717
3718 case CMD_UTILITY:
3719 lev = GetCommandLogLevel(stmt->utilityStmt);
3720 break;
3721
3722 default:
3723 elog(WARNING, "unrecognized commandType: %d",
3724 (int) stmt->commandType);
3725 lev = LOGSTMT_ALL;
3726 break;
3727 }
3728 }
3729 break;
3730
3731 /* parsed-and-rewritten-but-not-planned queries */
3732 case T_Query:
3733 {
3734 Query *stmt = (Query *) parsetree;
3735
3736 switch (stmt->commandType)
3737 {
3738 case CMD_SELECT:
3739 lev = LOGSTMT_ALL;
3740 break;
3741
3742 case CMD_UPDATE:
3743 case CMD_INSERT:
3744 case CMD_DELETE:
3745 case CMD_MERGE:
3746 lev = LOGSTMT_MOD;
3747 break;
3748
3749 case CMD_UTILITY:
3750 lev = GetCommandLogLevel(stmt->utilityStmt);
3751 break;
3752
3753 default:
3754 elog(WARNING, "unrecognized commandType: %d",
3755 (int) stmt->commandType);
3756 lev = LOGSTMT_ALL;
3757 break;
3758 }
3759 }
3760 break;
3761
3762 default:
3763 elog(WARNING, "unrecognized node type: %d",
3764 (int) nodeTag(parsetree));
3765 lev = LOGSTMT_ALL;
3766 break;
3767 }
3768
3769 return lev;
3770}
FetchPreparedStatement
PreparedStatement * FetchPreparedStatement(const char *stmt_name, bool throwError)
Definition: prepare.c:435
defGetBoolean
bool defGetBoolean(DefElem *def)
Definition: define.c:94
ps
struct parser_state ps
lfirst
#define lfirst(lc)
Definition: pg_list.h:172
analyze
static long analyze(struct nfa *nfa)
Definition: regc_nfa.c:3051
DefElem::defname
char * defname
Definition: parsenodes.h:826
LogStmtLevel
LogStmtLevel
Definition: tcopprot.h:32
LOGSTMT_MOD
@ LOGSTMT_MOD
Definition: tcopprot.h:35
LOGSTMT_DDL
@ LOGSTMT_DDL
Definition: tcopprot.h:34
LOGSTMT_ALL
@ LOGSTMT_ALL
Definition: tcopprot.h:36
GetCommandLogLevel
LogStmtLevel GetCommandLogLevel(Node *parsetree)
Definition: utility.c:3249

References analyze(), CMD_DELETE, CMD_INSERT, CMD_MERGE, CMD_SELECT, CMD_UPDATE, CMD_UTILITY, defGetBoolean(), DefElem::defname, elog, FetchPreparedStatement(), GetCommandLogLevel(), lfirst, LOGSTMT_ALL, LOGSTMT_DDL, LOGSTMT_MOD, nodeTag, ps, stmt, and WARNING.

Referenced by check_log_statement(), and GetCommandLogLevel().

◆ ProcessUtility()

void ProcessUtility ( PlannedStmt *  pstmt,
const char *  queryString,
bool  readOnlyTree,
ProcessUtilityContext  context,
ParamListInfo  params,
QueryEnvironment *  queryEnv,
DestReceiver *  dest,
QueryCompletion *  qc 
)

Definition at line 499 of file utility.c.

507{
508 Assert(IsA(pstmt, PlannedStmt));
509 Assert(pstmt->commandType == CMD_UTILITY);
510 Assert(queryString != NULL); /* required as of 8.4 */
511 Assert(qc == NULL || qc->commandTag == CMDTAG_UNKNOWN);
512
513 /*
514 * We provide a function hook variable that lets loadable plugins get
515 * control when ProcessUtility is called. Such a plugin would normally
516 * call standard_ProcessUtility().
517 */
518 if (ProcessUtility_hook)
519 (*ProcessUtility_hook) (pstmt, queryString, readOnlyTree,
520 context, params, queryEnv,
521 dest, qc);
522 else
523 standard_ProcessUtility(pstmt, queryString, readOnlyTree,
524 context, params, queryEnv,
525 dest, qc);
526}
generate_unaccent_rules.dest
dest
Definition: generate_unaccent_rules.py:285
QueryCompletion::commandTag
CommandTag commandTag
Definition: cmdtag.h:31
standard_ProcessUtility
void standard_ProcessUtility(PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
Definition: utility.c:543
ProcessUtility_hook
ProcessUtility_hook_type ProcessUtility_hook
Definition: utility.c:70

References Assert(), CMD_UTILITY, QueryCompletion::commandTag, PlannedStmt::commandType, generate_unaccent_rules::dest, IsA, ProcessUtility_hook, and standard_ProcessUtility().

Referenced by _SPI_execute_plan(), CreateSchemaCommand(), execute_sql_string(), ImportForeignSchema(), PortalRunUtility(), postquel_getnext(), ProcessUtilityForAlterTable(), and ProcessUtilitySlow().

◆ ProcessUtilityForAlterTable()

void ProcessUtilityForAlterTable ( Node *  stmt,
AlterTableUtilityContext *  context 
)

Definition at line 1959 of file utility.c.

1960{
1961 PlannedStmt *wrapper;
1962
1963 /*
1964 * For event triggers, we must "close" the current complex-command set,
1965 * and start a new one afterwards; this is needed to ensure the ordering
1966 * of command events is consistent with the way they were executed.
1967 */
1968 EventTriggerAlterTableEnd();
1969
1970 /* Create a suitable wrapper */
1971 wrapper = makeNode(PlannedStmt);
1972 wrapper->commandType = CMD_UTILITY;
1973 wrapper->canSetTag = false;
1974 wrapper->utilityStmt = stmt;
1975 wrapper->stmt_location = context->pstmt->stmt_location;
1976 wrapper->stmt_len = context->pstmt->stmt_len;
1977
1978 ProcessUtility(wrapper,
1979 context->queryString,
1980 false,
1981 PROCESS_UTILITY_SUBCOMMAND,
1982 context->params,
1983 context->queryEnv,
1984 None_Receiver,
1985 NULL);
1986
1987 EventTriggerAlterTableStart(context->pstmt->utilityStmt);
1988 EventTriggerAlterTableRelid(context->relid);
1989}
None_Receiver
DestReceiver * None_Receiver
Definition: dest.c:96
EventTriggerAlterTableStart
void EventTriggerAlterTableStart(Node *parsetree)
Definition: event_trigger.c:1621
EventTriggerAlterTableRelid
void EventTriggerAlterTableRelid(Oid objectId)
Definition: event_trigger.c:1655
EventTriggerAlterTableEnd
void EventTriggerAlterTableEnd(void)
Definition: event_trigger.c:1708
makeNode
#define makeNode(_type_)
Definition: nodes.h:161
AlterTableUtilityContext::params
ParamListInfo params
Definition: utility.h:35
AlterTableUtilityContext::queryEnv
QueryEnvironment * queryEnv
Definition: utility.h:36
AlterTableUtilityContext::pstmt
PlannedStmt * pstmt
Definition: utility.h:32
AlterTableUtilityContext::queryString
const char * queryString
Definition: utility.h:33
PlannedStmt::canSetTag
bool canSetTag
Definition: plannodes.h:68
PlannedStmt::stmt_len
ParseLoc stmt_len
Definition: plannodes.h:145
PlannedStmt::stmt_location
ParseLoc stmt_location
Definition: plannodes.h:143
PlannedStmt::utilityStmt
Node * utilityStmt
Definition: plannodes.h:139
ProcessUtility
void ProcessUtility(PlannedStmt *pstmt, const char *queryString, bool readOnlyTree, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
Definition: utility.c:499

References PlannedStmt::canSetTag, CMD_UTILITY, PlannedStmt::commandType, EventTriggerAlterTableEnd(), EventTriggerAlterTableRelid(), EventTriggerAlterTableStart(), makeNode, None_Receiver, AlterTableUtilityContext::params, PROCESS_UTILITY_SUBCOMMAND, ProcessUtility(), AlterTableUtilityContext::pstmt, AlterTableUtilityContext::queryEnv, AlterTableUtilityContext::queryString, AlterTableUtilityContext::relid, stmt, PlannedStmt::stmt_len, PlannedStmt::stmt_location, and PlannedStmt::utilityStmt.

Referenced by ATParseTransformCmd(), and ATRewriteTables().

◆ standard_ProcessUtility()

void standard_ProcessUtility ( PlannedStmt *  pstmt,
const char *  queryString,
bool  readOnlyTree,
ProcessUtilityContext  context,
ParamListInfo  params,
QueryEnvironment *  queryEnv,
DestReceiver *  dest,
QueryCompletion *  qc 
)

Definition at line 543 of file utility.c.

551{
552 Node *parsetree;
553 bool isTopLevel = (context == PROCESS_UTILITY_TOPLEVEL);
554 bool isAtomicContext = (!(context == PROCESS_UTILITY_TOPLEVEL || context == PROCESS_UTILITY_QUERY_NONATOMIC) || IsTransactionBlock());
555 ParseState *pstate;
556 int readonly_flags;
557
558 /* This can recurse, so check for excessive recursion */
559 check_stack_depth();
560
561 /*
562 * If the given node tree is read-only, make a copy to ensure that parse
563 * transformations don't damage the original tree. This could be
564 * refactored to avoid making unnecessary copies in more cases, but it's
565 * not clear that it's worth a great deal of trouble over. Statements
566 * that are complex enough to be expensive to copy are exactly the ones
567 * we'd need to copy, so that only marginal savings seem possible.
568 */
569 if (readOnlyTree)
570 pstmt = copyObject(pstmt);
571 parsetree = pstmt->utilityStmt;
572
573 /* Prohibit read/write commands in read-only states. */
574 readonly_flags = ClassifyUtilityCommandAsReadOnly(parsetree);
575 if (readonly_flags != COMMAND_IS_STRICTLY_READ_ONLY &&
576 (XactReadOnly || IsInParallelMode()))
577 {
578 CommandTag commandtag = CreateCommandTag(parsetree);
579
580 if ((readonly_flags & COMMAND_OK_IN_READ_ONLY_TXN) == 0)
581 PreventCommandIfReadOnly(GetCommandTagName(commandtag));
582 if ((readonly_flags & COMMAND_OK_IN_PARALLEL_MODE) == 0)
583 PreventCommandIfParallelMode(GetCommandTagName(commandtag));
584 if ((readonly_flags & COMMAND_OK_IN_RECOVERY) == 0)
585 PreventCommandDuringRecovery(GetCommandTagName(commandtag));
586 }
587
588 pstate = make_parsestate(NULL);
589 pstate->p_sourcetext = queryString;
590 pstate->p_queryEnv = queryEnv;
591
592 switch (nodeTag(parsetree))
593 {
594 /*
595 * ******************** transactions ********************
596 */
597 case T_TransactionStmt:
598 {
599 TransactionStmt *stmt = (TransactionStmt *) parsetree;
600
601 switch (stmt->kind)
602 {
603 /*
604 * START TRANSACTION, as defined by SQL99: Identical
605 * to BEGIN. Same code for both.
606 */
607 case TRANS_STMT_BEGIN:
608 case TRANS_STMT_START:
609 {
610 ListCell *lc;
611
612 BeginTransactionBlock();
613 foreach(lc, stmt->options)
614 {
615 DefElem *item = (DefElem *) lfirst(lc);
616
617 if (strcmp(item->defname, "transaction_isolation") == 0)
618 SetPGVariable("transaction_isolation",
619 list_make1(item->arg),
620 true);
621 else if (strcmp(item->defname, "transaction_read_only") == 0)
622 SetPGVariable("transaction_read_only",
623 list_make1(item->arg),
624 true);
625 else if (strcmp(item->defname, "transaction_deferrable") == 0)
626 SetPGVariable("transaction_deferrable",
627 list_make1(item->arg),
628 true);
629 }
630 }
631 break;
632
633 case TRANS_STMT_COMMIT:
634 if (!EndTransactionBlock(stmt->chain))
635 {
636 /* report unsuccessful commit in qc */
637 if (qc)
638 SetQueryCompletion(qc, CMDTAG_ROLLBACK, 0);
639 }
640 break;
641
642 case TRANS_STMT_PREPARE:
643 if (!PrepareTransactionBlock(stmt->gid))
644 {
645 /* report unsuccessful commit in qc */
646 if (qc)
647 SetQueryCompletion(qc, CMDTAG_ROLLBACK, 0);
648 }
649 break;
650
651 case TRANS_STMT_COMMIT_PREPARED:
652 PreventInTransactionBlock(isTopLevel, "COMMIT PREPARED");
653 FinishPreparedTransaction(stmt->gid, true);
654 break;
655
656 case TRANS_STMT_ROLLBACK_PREPARED:
657 PreventInTransactionBlock(isTopLevel, "ROLLBACK PREPARED");
658 FinishPreparedTransaction(stmt->gid, false);
659 break;
660
661 case TRANS_STMT_ROLLBACK:
662 UserAbortTransactionBlock(stmt->chain);
663 break;
664
665 case TRANS_STMT_SAVEPOINT:
666 RequireTransactionBlock(isTopLevel, "SAVEPOINT");
667 DefineSavepoint(stmt->savepoint_name);
668 break;
669
670 case TRANS_STMT_RELEASE:
671 RequireTransactionBlock(isTopLevel, "RELEASE SAVEPOINT");
672 ReleaseSavepoint(stmt->savepoint_name);
673 break;
674
675 case TRANS_STMT_ROLLBACK_TO:
676 RequireTransactionBlock(isTopLevel, "ROLLBACK TO SAVEPOINT");
677 RollbackToSavepoint(stmt->savepoint_name);
678
679 /*
680 * CommitTransactionCommand is in charge of
681 * re-defining the savepoint again
682 */
683 break;
684 }
685 }
686 break;
687
688 /*
689 * Portal (cursor) manipulation
690 */
691 case T_DeclareCursorStmt:
692 PerformCursorOpen(pstate, (DeclareCursorStmt *) parsetree, params,
693 isTopLevel);
694 break;
695
696 case T_ClosePortalStmt:
697 {
698 ClosePortalStmt *stmt = (ClosePortalStmt *) parsetree;
699
700 CheckRestrictedOperation("CLOSE");
701 PerformPortalClose(stmt->portalname);
702 }
703 break;
704
705 case T_FetchStmt:
706 PerformPortalFetch((FetchStmt *) parsetree, dest, qc);
707 break;
708
709 case T_DoStmt:
710 ExecuteDoStmt(pstate, (DoStmt *) parsetree, isAtomicContext);
711 break;
712
713 case T_CreateTableSpaceStmt:
714 /* no event triggers for global objects */
715 PreventInTransactionBlock(isTopLevel, "CREATE TABLESPACE");
716 CreateTableSpace((CreateTableSpaceStmt *) parsetree);
717 break;
718
719 case T_DropTableSpaceStmt:
720 /* no event triggers for global objects */
721 PreventInTransactionBlock(isTopLevel, "DROP TABLESPACE");
722 DropTableSpace((DropTableSpaceStmt *) parsetree);
723 break;
724
725 case T_AlterTableSpaceOptionsStmt:
726 /* no event triggers for global objects */
727 AlterTableSpaceOptions((AlterTableSpaceOptionsStmt *) parsetree);
728 break;
729
730 case T_TruncateStmt:
731 ExecuteTruncate((TruncateStmt *) parsetree);
732 break;
733
734 case T_CopyStmt:
735 {
736 uint64 processed;
737
738 DoCopy(pstate, (CopyStmt *) parsetree,
739 pstmt->stmt_location, pstmt->stmt_len,
740 &processed);
741 if (qc)
742 SetQueryCompletion(qc, CMDTAG_COPY, processed);
743 }
744 break;
745
746 case T_PrepareStmt:
747 CheckRestrictedOperation("PREPARE");
748 PrepareQuery(pstate, (PrepareStmt *) parsetree,
749 pstmt->stmt_location, pstmt->stmt_len);
750 break;
751
752 case T_ExecuteStmt:
753 ExecuteQuery(pstate,
754 (ExecuteStmt *) parsetree, NULL,
755 params,
756 dest, qc);
757 break;
758
759 case T_DeallocateStmt:
760 CheckRestrictedOperation("DEALLOCATE");
761 DeallocateQuery((DeallocateStmt *) parsetree);
762 break;
763
764 case T_GrantRoleStmt:
765 /* no event triggers for global objects */
766 GrantRole(pstate, (GrantRoleStmt *) parsetree);
767 break;
768
769 case T_CreatedbStmt:
770 /* no event triggers for global objects */
771 PreventInTransactionBlock(isTopLevel, "CREATE DATABASE");
772 createdb(pstate, (CreatedbStmt *) parsetree);
773 break;
774
775 case T_AlterDatabaseStmt:
776 /* no event triggers for global objects */
777 AlterDatabase(pstate, (AlterDatabaseStmt *) parsetree, isTopLevel);
778 break;
779
780 case T_AlterDatabaseRefreshCollStmt:
781 /* no event triggers for global objects */
782 AlterDatabaseRefreshColl((AlterDatabaseRefreshCollStmt *) parsetree);
783 break;
784
785 case T_AlterDatabaseSetStmt:
786 /* no event triggers for global objects */
787 AlterDatabaseSet((AlterDatabaseSetStmt *) parsetree);
788 break;
789
790 case T_DropdbStmt:
791 /* no event triggers for global objects */
792 PreventInTransactionBlock(isTopLevel, "DROP DATABASE");
793 DropDatabase(pstate, (DropdbStmt *) parsetree);
794 break;
795
796 /* Query-level asynchronous notification */
797 case T_NotifyStmt:
798 {
799 NotifyStmt *stmt = (NotifyStmt *) parsetree;
800
801 Async_Notify(stmt->conditionname, stmt->payload);
802 }
803 break;
804
805 case T_ListenStmt:
806 {
807 ListenStmt *stmt = (ListenStmt *) parsetree;
808
809 CheckRestrictedOperation("LISTEN");
810
811 /*
812 * We don't allow LISTEN in background processes, as there is
813 * no mechanism for them to collect NOTIFY messages, so they'd
814 * just block cleanout of the async SLRU indefinitely.
815 * (Authors of custom background workers could bypass this
816 * restriction by calling Async_Listen directly, but then it's
817 * on them to provide some mechanism to process the message
818 * queue.) Note there seems no reason to forbid UNLISTEN.
819 */
820 if (MyBackendType != B_BACKEND)
821 ereport(ERROR,
822 (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
823 /* translator: %s is name of a SQL command, eg LISTEN */
824 errmsg("cannot execute %s within a background process",
825 "LISTEN")));
826
827 Async_Listen(stmt->conditionname);
828 }
829 break;
830
831 case T_UnlistenStmt:
832 {
833 UnlistenStmt *stmt = (UnlistenStmt *) parsetree;
834
835 CheckRestrictedOperation("UNLISTEN");
836 if (stmt->conditionname)
837 Async_Unlisten(stmt->conditionname);
838 else
839 Async_UnlistenAll();
840 }
841 break;
842
843 case T_LoadStmt:
844 {
845 LoadStmt *stmt = (LoadStmt *) parsetree;
846
847 closeAllVfds(); /* probably not necessary... */
848 /* Allowed names are restricted if you're not superuser */
849 load_file(stmt->filename, !superuser());
850 }
851 break;
852
853 case T_CallStmt:
854 ExecuteCallStmt(castNode(CallStmt, parsetree), params, isAtomicContext, dest);
855 break;
856
857 case T_ClusterStmt:
858 cluster(pstate, (ClusterStmt *) parsetree, isTopLevel);
859 break;
860
861 case T_VacuumStmt:
862 ExecVacuum(pstate, (VacuumStmt *) parsetree, isTopLevel);
863 break;
864
865 case T_ExplainStmt:
866 ExplainQuery(pstate, (ExplainStmt *) parsetree, params, dest);
867 break;
868
869 case T_AlterSystemStmt:
870 PreventInTransactionBlock(isTopLevel, "ALTER SYSTEM");
871 AlterSystemSetConfigFile((AlterSystemStmt *) parsetree);
872 break;
873
874 case T_VariableSetStmt:
875 ExecSetVariableStmt((VariableSetStmt *) parsetree, isTopLevel);
876 break;
877
878 case T_VariableShowStmt:
879 {
880 VariableShowStmt *n = (VariableShowStmt *) parsetree;
881
882 GetPGVariable(n->name, dest);
883 }
884 break;
885
886 case T_DiscardStmt:
887 /* should we allow DISCARD PLANS? */
888 CheckRestrictedOperation("DISCARD");
889 DiscardCommand((DiscardStmt *) parsetree, isTopLevel);
890 break;
891
892 case T_CreateEventTrigStmt:
893 /* no event triggers on event triggers */
894 CreateEventTrigger((CreateEventTrigStmt *) parsetree);
895 break;
896
897 case T_AlterEventTrigStmt:
898 /* no event triggers on event triggers */
899 AlterEventTrigger((AlterEventTrigStmt *) parsetree);
900 break;
901
902 /*
903 * ******************************** ROLE statements ****
904 */
905 case T_CreateRoleStmt:
906 /* no event triggers for global objects */
907 CreateRole(pstate, (CreateRoleStmt *) parsetree);
908 break;
909
910 case T_AlterRoleStmt:
911 /* no event triggers for global objects */
912 AlterRole(pstate, (AlterRoleStmt *) parsetree);
913 break;
914
915 case T_AlterRoleSetStmt:
916 /* no event triggers for global objects */
917 AlterRoleSet((AlterRoleSetStmt *) parsetree);
918 break;
919
920 case T_DropRoleStmt:
921 /* no event triggers for global objects */
922 DropRole((DropRoleStmt *) parsetree);
923 break;
924
925 case T_ReassignOwnedStmt:
926 /* no event triggers for global objects */
927 ReassignOwnedObjects((ReassignOwnedStmt *) parsetree);
928 break;
929
930 case T_LockStmt:
931
932 /*
933 * Since the lock would just get dropped immediately, LOCK TABLE
934 * outside a transaction block is presumed to be user error.
935 */
936 RequireTransactionBlock(isTopLevel, "LOCK TABLE");
937 LockTableCommand((LockStmt *) parsetree);
938 break;
939
940 case T_ConstraintsSetStmt:
941 WarnNoTransactionBlock(isTopLevel, "SET CONSTRAINTS");
942 AfterTriggerSetState((ConstraintsSetStmt *) parsetree);
943 break;
944
945 case T_CheckPointStmt:
946 if (!has_privs_of_role(GetUserId(), ROLE_PG_CHECKPOINT))
947 ereport(ERROR,
948 (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
949 /* translator: %s is name of a SQL command, eg CHECKPOINT */
950 errmsg("permission denied to execute %s command",
951 "CHECKPOINT"),
952 errdetail("Only roles with privileges of the \"%s\" role may execute this command.",
953 "pg_checkpoint")));
954
955 RequestCheckpoint(CHECKPOINT_IMMEDIATE | CHECKPOINT_WAIT |
956 (RecoveryInProgress() ? 0 : CHECKPOINT_FORCE));
957 break;
958
959 /*
960 * The following statements are supported by Event Triggers only
961 * in some cases, so we "fast path" them in the other cases.
962 */
963
964 case T_GrantStmt:
965 {
966 GrantStmt *stmt = (GrantStmt *) parsetree;
967
968 if (EventTriggerSupportsObjectType(stmt->objtype))
969 ProcessUtilitySlow(pstate, pstmt, queryString,
970 context, params, queryEnv,
971 dest, qc);
972 else
973 ExecuteGrantStmt(stmt);
974 }
975 break;
976
977 case T_DropStmt:
978 {
979 DropStmt *stmt = (DropStmt *) parsetree;
980
981 if (EventTriggerSupportsObjectType(stmt->removeType))
982 ProcessUtilitySlow(pstate, pstmt, queryString,
983 context, params, queryEnv,
984 dest, qc);
985 else
986 ExecDropStmt(stmt, isTopLevel);
987 }
988 break;
989
990 case T_RenameStmt:
991 {
992 RenameStmt *stmt = (RenameStmt *) parsetree;
993
994 if (EventTriggerSupportsObjectType(stmt->renameType))
995 ProcessUtilitySlow(pstate, pstmt, queryString,
996 context, params, queryEnv,
997 dest, qc);
998 else
999 ExecRenameStmt(stmt);
1000 }
1001 break;
1002
1003 case T_AlterObjectDependsStmt:
1004 {
1005 AlterObjectDependsStmt *stmt = (AlterObjectDependsStmt *) parsetree;
1006
1007 if (EventTriggerSupportsObjectType(stmt->objectType))
1008 ProcessUtilitySlow(pstate, pstmt, queryString,
1009 context, params, queryEnv,
1010 dest, qc);
1011 else
1012 ExecAlterObjectDependsStmt(stmt, NULL);
1013 }
1014 break;
1015
1016 case T_AlterObjectSchemaStmt:
1017 {
1018 AlterObjectSchemaStmt *stmt = (AlterObjectSchemaStmt *) parsetree;
1019
1020 if (EventTriggerSupportsObjectType(stmt->objectType))
1021 ProcessUtilitySlow(pstate, pstmt, queryString,
1022 context, params, queryEnv,
1023 dest, qc);
1024 else
1025 ExecAlterObjectSchemaStmt(stmt, NULL);
1026 }
1027 break;
1028
1029 case T_AlterOwnerStmt:
1030 {
1031 AlterOwnerStmt *stmt = (AlterOwnerStmt *) parsetree;
1032
1033 if (EventTriggerSupportsObjectType(stmt->objectType))
1034 ProcessUtilitySlow(pstate, pstmt, queryString,
1035 context, params, queryEnv,
1036 dest, qc);
1037 else
1038 ExecAlterOwnerStmt(stmt);
1039 }
1040 break;
1041
1042 case T_CommentStmt:
1043 {
1044 CommentStmt *stmt = (CommentStmt *) parsetree;
1045
1046 if (EventTriggerSupportsObjectType(stmt->objtype))
1047 ProcessUtilitySlow(pstate, pstmt, queryString,
1048 context, params, queryEnv,
1049 dest, qc);
1050 else
1051 CommentObject(stmt);
1052 break;
1053 }
1054
1055 case T_SecLabelStmt:
1056 {
1057 SecLabelStmt *stmt = (SecLabelStmt *) parsetree;
1058
1059 if (EventTriggerSupportsObjectType(stmt->objtype))
1060 ProcessUtilitySlow(pstate, pstmt, queryString,
1061 context, params, queryEnv,
1062 dest, qc);
1063 else
1064 ExecSecLabelStmt(stmt);
1065 break;
1066 }
1067
1068 default:
1069 /* All other statement types have event trigger support */
1070 ProcessUtilitySlow(pstate, pstmt, queryString,
1071 context, params, queryEnv,
1072 dest, qc);
1073 break;
1074 }
1075
1076 free_parsestate(pstate);
1077
1078 /*
1079 * Make effects of commands visible, for instance so that
1080 * PreCommit_on_commit_actions() can see them (see for example bug
1081 * #15631).
1082 */
1083 CommandCounterIncrement();
1084}
has_privs_of_role
bool has_privs_of_role(Oid member, Oid role)
Definition: acl.c:5268
ExecuteGrantStmt
void ExecuteGrantStmt(GrantStmt *stmt)
Definition: aclchk.c:392
ExecAlterOwnerStmt
ObjectAddress ExecAlterOwnerStmt(AlterOwnerStmt *stmt)
Definition: alter.c:837
ExecAlterObjectDependsStmt
ObjectAddress ExecAlterObjectDependsStmt(AlterObjectDependsStmt *stmt, ObjectAddress *refAddress)
Definition: alter.c:471
ExecRenameStmt
ObjectAddress ExecRenameStmt(RenameStmt *stmt)
Definition: alter.c:373
ExecAlterObjectSchemaStmt
ObjectAddress ExecAlterObjectSchemaStmt(AlterObjectSchemaStmt *stmt, ObjectAddress *oldSchemaAddr)
Definition: alter.c:534
Async_UnlistenAll
void Async_UnlistenAll(void)
Definition: async.c:770
Async_Unlisten
void Async_Unlisten(const char *channel)
Definition: async.c:752
Async_Listen
void Async_Listen(const char *channel)
Definition: async.c:738
Async_Notify
void Async_Notify(const char *channel, const char *payload)
Definition: async.c:591
DoCopy
void DoCopy(ParseState *pstate, const CopyStmt *stmt, int stmt_location, int stmt_len, uint64 *processed)
Definition: copy.c:62
PrepareQuery
void PrepareQuery(ParseState *pstate, PrepareStmt *stmt, int stmt_location, int stmt_len)
Definition: prepare.c:59
ExecuteQuery
void ExecuteQuery(ParseState *pstate, ExecuteStmt *stmt, IntoClause *intoClause, ParamListInfo params, DestReceiver *dest, QueryCompletion *qc)
Definition: prepare.c:150
DeallocateQuery
void DeallocateQuery(DeallocateStmt *stmt)
Definition: prepare.c:506
AlterTableSpaceOptions
Oid AlterTableSpaceOptions(AlterTableSpaceOptionsStmt *stmt)
Definition: tablespace.c:1015
DropTableSpace
void DropTableSpace(DropTableSpaceStmt *stmt)
Definition: tablespace.c:395
CreateTableSpace
Oid CreateTableSpace(CreateTableSpaceStmt *stmt)
Definition: tablespace.c:208
uint64
uint64_t uint64
Definition: c.h:503
RequestCheckpoint
void RequestCheckpoint(int flags)
Definition: checkpointer.c:1001
cluster
void cluster(ParseState *pstate, ClusterStmt *stmt, bool isTopLevel)
Definition: cluster.c:107
SetQueryCompletion
static void SetQueryCompletion(QueryCompletion *qc, CommandTag commandTag, uint64 nprocessed)
Definition: cmdtag.h:37
CommentObject
ObjectAddress CommentObject(CommentStmt *stmt)
Definition: comment.c:40
AlterDatabaseRefreshColl
ObjectAddress AlterDatabaseRefreshColl(AlterDatabaseRefreshCollStmt *stmt)
Definition: dbcommands.c:2515
createdb
Oid createdb(ParseState *pstate, const CreatedbStmt *stmt)
Definition: dbcommands.c:684
AlterDatabase
Oid AlterDatabase(ParseState *pstate, AlterDatabaseStmt *stmt, bool isTopLevel)
Definition: dbcommands.c:2342
DropDatabase
void DropDatabase(ParseState *pstate, DropdbStmt *stmt)
Definition: dbcommands.c:2317
AlterDatabaseSet
Oid AlterDatabaseSet(AlterDatabaseSetStmt *stmt)
Definition: dbcommands.c:2612
load_file
void load_file(const char *filename, bool restricted)
Definition: dfmgr.c:134
DiscardCommand
void DiscardCommand(DiscardStmt *stmt, bool isTopLevel)
Definition: discard.c:31
errdetail
int errdetail(const char *fmt,...)
Definition: elog.c:1204
errcode
int errcode(int sqlerrcode)
Definition: elog.c:854
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:1071
ERROR
#define ERROR
Definition: elog.h:39
ereport
#define ereport(elevel,...)
Definition: elog.h:149
EventTriggerSupportsObjectType
bool EventTriggerSupportsObjectType(ObjectType obtype)
Definition: event_trigger.c:1129
CreateEventTrigger
Oid CreateEventTrigger(CreateEventTrigStmt *stmt)
Definition: event_trigger.c:120
AlterEventTrigger
Oid AlterEventTrigger(AlterEventTrigStmt *stmt)
Definition: event_trigger.c:423
ExplainQuery
void ExplainQuery(ParseState *pstate, ExplainStmt *stmt, ParamListInfo params, DestReceiver *dest)
Definition: explain.c:176
closeAllVfds
void closeAllVfds(void)
Definition: fd.c:3084
ExecuteCallStmt
void ExecuteCallStmt(CallStmt *stmt, ParamListInfo params, bool atomic, DestReceiver *dest)
Definition: functioncmds.c:2206
ExecuteDoStmt
void ExecuteDoStmt(ParseState *pstate, DoStmt *stmt, bool atomic)
Definition: functioncmds.c:2084
AlterSystemSetConfigFile
void AlterSystemSetConfigFile(AlterSystemStmt *altersysstmt)
Definition: guc.c:4607
GetPGVariable
void GetPGVariable(const char *name, DestReceiver *dest)
Definition: guc_funcs.c:382
SetPGVariable
void SetPGVariable(const char *name, List *args, bool is_local)
Definition: guc_funcs.c:315
ExecSetVariableStmt
void ExecSetVariableStmt(VariableSetStmt *stmt, bool isTopLevel)
Definition: guc_funcs.c:43
LockTableCommand
void LockTableCommand(LockStmt *lockstmt)
Definition: lockcmds.c:41
B_BACKEND
@ B_BACKEND
Definition: miscadmin.h:342
GetUserId
Oid GetUserId(void)
Definition: miscinit.c:520
MyBackendType
BackendType MyBackendType
Definition: miscinit.c:64
copyObject
#define copyObject(obj)
Definition: nodes.h:230
castNode
#define castNode(_type_, nodeptr)
Definition: nodes.h:182
free_parsestate
void free_parsestate(ParseState *pstate)
Definition: parse_node.c:72
make_parsestate
ParseState * make_parsestate(ParseState *parentParseState)
Definition: parse_node.c:39
list_make1
#define list_make1(x1)
Definition: pg_list.h:212
PerformCursorOpen
void PerformCursorOpen(ParseState *pstate, DeclareCursorStmt *cstmt, ParamListInfo params, bool isTopLevel)
Definition: portalcmds.c:45
PerformPortalClose
void PerformPortalClose(const char *name)
Definition: portalcmds.c:225
PerformPortalFetch
void PerformPortalFetch(FetchStmt *stmt, DestReceiver *dest, QueryCompletion *qc)
Definition: portalcmds.c:178
ExecSecLabelStmt
ObjectAddress ExecSecLabelStmt(SecLabelStmt *stmt)
Definition: seclabel.c:115
check_stack_depth
void check_stack_depth(void)
Definition: stack_depth.c:95
DefElem::arg
Node * arg
Definition: parsenodes.h:827
Node
Definition: nodes.h:135
ParseState::p_queryEnv
QueryEnvironment * p_queryEnv
Definition: parse_node.h:239
ParseState::p_sourcetext
const char * p_sourcetext
Definition: parse_node.h:209
superuser
bool superuser(void)
Definition: superuser.c:46
ExecuteTruncate
void ExecuteTruncate(TruncateStmt *stmt)
Definition: tablecmds.c:1851
AfterTriggerSetState
void AfterTriggerSetState(ConstraintsSetStmt *stmt)
Definition: trigger.c:5709
FinishPreparedTransaction
void FinishPreparedTransaction(const char *gid, bool isCommit)
Definition: twophase.c:1487
ReassignOwnedObjects
void ReassignOwnedObjects(ReassignOwnedStmt *stmt)
Definition: user.c:1611
AlterRole
Oid AlterRole(ParseState *pstate, AlterRoleStmt *stmt)
Definition: user.c:619
AlterRoleSet
Oid AlterRoleSet(AlterRoleSetStmt *stmt)
Definition: user.c:1000
DropRole
void DropRole(DropRoleStmt *stmt)
Definition: user.c:1090
CreateRole
Oid CreateRole(ParseState *pstate, CreateRoleStmt *stmt)
Definition: user.c:133
GrantRole
void GrantRole(ParseState *pstate, GrantRoleStmt *stmt)
Definition: user.c:1480
ClassifyUtilityCommandAsReadOnly
static int ClassifyUtilityCommandAsReadOnly(Node *parsetree)
Definition: utility.c:128
PreventCommandIfReadOnly
void PreventCommandIfReadOnly(const char *cmdname)
Definition: utility.c:404
PreventCommandIfParallelMode
void PreventCommandIfParallelMode(const char *cmdname)
Definition: utility.c:422
ExecDropStmt
static void ExecDropStmt(DropStmt *stmt, bool isTopLevel)
Definition: utility.c:1995
CheckRestrictedOperation
static void CheckRestrictedOperation(const char *cmdname)
Definition: utility.c:459
PreventCommandDuringRecovery
void PreventCommandDuringRecovery(const char *cmdname)
Definition: utility.c:441
ProcessUtilitySlow
static void ProcessUtilitySlow(ParseState *pstate, PlannedStmt *pstmt, const char *queryString, ProcessUtilityContext context, ParamListInfo params, QueryEnvironment *queryEnv, DestReceiver *dest, QueryCompletion *qc)
Definition: utility.c:1092
COMMAND_OK_IN_PARALLEL_MODE
#define COMMAND_OK_IN_PARALLEL_MODE
Definition: utility.h:57
COMMAND_IS_STRICTLY_READ_ONLY
#define COMMAND_IS_STRICTLY_READ_ONLY
Definition: utility.h:65
ExecVacuum
void ExecVacuum(ParseState *pstate, VacuumStmt *vacstmt, bool isTopLevel)
Definition: vacuum.c:160
WarnNoTransactionBlock
void WarnNoTransactionBlock(bool isTopLevel, const char *stmtType)
Definition: xact.c:3710
UserAbortTransactionBlock
void UserAbortTransactionBlock(bool chain)
Definition: xact.c:4204
PrepareTransactionBlock
bool PrepareTransactionBlock(const char *gid)
Definition: xact.c:3992
RequireTransactionBlock
void RequireTransactionBlock(bool isTopLevel, const char *stmtType)
Definition: xact.c:3716
DefineSavepoint
void DefineSavepoint(const char *name)
Definition: xact.c:4373
XactReadOnly
bool XactReadOnly
Definition: xact.c:82
CommandCounterIncrement
void CommandCounterIncrement(void)
Definition: xact.c:1100
PreventInTransactionBlock
void PreventInTransactionBlock(bool isTopLevel, const char *stmtType)
Definition: xact.c:3648
ReleaseSavepoint
void ReleaseSavepoint(const char *name)
Definition: xact.c:4458
IsTransactionBlock
bool IsTransactionBlock(void)
Definition: xact.c:4971
IsInParallelMode
bool IsInParallelMode(void)
Definition: xact.c:1089
BeginTransactionBlock
void BeginTransactionBlock(void)
Definition: xact.c:3924
RollbackToSavepoint
void RollbackToSavepoint(const char *name)
Definition: xact.c:4567
EndTransactionBlock
bool EndTransactionBlock(bool chain)
Definition: xact.c:4044
RecoveryInProgress
bool RecoveryInProgress(void)
Definition: xlog.c:6522
CHECKPOINT_FORCE
#define CHECKPOINT_FORCE
Definition: xlog.h:142
CHECKPOINT_WAIT
#define CHECKPOINT_WAIT
Definition: xlog.h:145
CHECKPOINT_IMMEDIATE
#define CHECKPOINT_IMMEDIATE
Definition: xlog.h:141

References AfterTriggerSetState(), AlterDatabase(), AlterDatabaseRefreshColl(), AlterDatabaseSet(), AlterEventTrigger(), AlterRole(), AlterRoleSet(), AlterSystemSetConfigFile(), AlterTableSpaceOptions(), DefElem::arg, Async_Listen(), Async_Notify(), Async_Unlisten(), Async_UnlistenAll(), B_BACKEND, BeginTransactionBlock(), castNode, check_stack_depth(), CHECKPOINT_FORCE, CHECKPOINT_IMMEDIATE, CHECKPOINT_WAIT, CheckRestrictedOperation(), ClassifyUtilityCommandAsReadOnly(), closeAllVfds(), cluster(), COMMAND_IS_STRICTLY_READ_ONLY, COMMAND_OK_IN_PARALLEL_MODE, COMMAND_OK_IN_READ_ONLY_TXN, COMMAND_OK_IN_RECOVERY, CommandCounterIncrement(), CommentObject(), copyObject, CreateCommandTag(), createdb(), CreateEventTrigger(), CreateRole(), CreateTableSpace(), DeallocateQuery(), DefineSavepoint(), DefElem::defname, generate_unaccent_rules::dest, DiscardCommand(), DoCopy(), DropDatabase(), DropRole(), DropTableSpace(), EndTransactionBlock(), ereport, errcode(), errdetail(), errmsg(), ERROR, EventTriggerSupportsObjectType(), ExecAlterObjectDependsStmt(), ExecAlterObjectSchemaStmt(), ExecAlterOwnerStmt(), ExecDropStmt(), ExecRenameStmt(), ExecSecLabelStmt(), ExecSetVariableStmt(), ExecuteCallStmt(), ExecuteDoStmt(), ExecuteGrantStmt(), ExecuteQuery(), ExecuteTruncate(), ExecVacuum(), ExplainQuery(), FinishPreparedTransaction(), free_parsestate(), GetCommandTagName(), GetPGVariable(), GetUserId(), GrantRole(), has_privs_of_role(), IsInParallelMode(), IsTransactionBlock(), lfirst, list_make1, load_file(), LockTableCommand(), make_parsestate(), MyBackendType, VariableShowStmt::name, nodeTag, ParseState::p_queryEnv, ParseState::p_sourcetext, PerformCursorOpen(), PerformPortalClose(), PerformPortalFetch(), PrepareQuery(), PrepareTransactionBlock(), PreventCommandDuringRecovery(), PreventCommandIfParallelMode(), PreventCommandIfReadOnly(), PreventInTransactionBlock(), PROCESS_UTILITY_QUERY_NONATOMIC, PROCESS_UTILITY_TOPLEVEL, ProcessUtilitySlow(), ReassignOwnedObjects(), RecoveryInProgress(), ReleaseSavepoint(), RequestCheckpoint(), RequireTransactionBlock(), RollbackToSavepoint(), SetPGVariable(), SetQueryCompletion(), stmt, PlannedStmt::stmt_len, PlannedStmt::stmt_location, superuser(), TRANS_STMT_BEGIN, TRANS_STMT_COMMIT, TRANS_STMT_COMMIT_PREPARED, TRANS_STMT_PREPARE, TRANS_STMT_RELEASE, TRANS_STMT_ROLLBACK, TRANS_STMT_ROLLBACK_PREPARED, TRANS_STMT_ROLLBACK_TO, TRANS_STMT_SAVEPOINT, TRANS_STMT_START, UserAbortTransactionBlock(), PlannedStmt::utilityStmt, WarnNoTransactionBlock(), and XactReadOnly.

Referenced by pgss_ProcessUtility(), ProcessUtility(), REGRESS_utility_command(), and sepgsql_utility_command().

◆ UtilityContainsQuery()

Query * UtilityContainsQuery ( Node *  parsetree)

Definition at line 2179 of file utility.c.

2180{
2181 Query *qry;
2182
2183 switch (nodeTag(parsetree))
2184 {
2185 case T_DeclareCursorStmt:
2186 qry = castNode(Query, ((DeclareCursorStmt *) parsetree)->query);
2187 if (qry->commandType == CMD_UTILITY)
2188 return UtilityContainsQuery(qry->utilityStmt);
2189 return qry;
2190
2191 case T_ExplainStmt:
2192 qry = castNode(Query, ((ExplainStmt *) parsetree)->query);
2193 if (qry->commandType == CMD_UTILITY)
2194 return UtilityContainsQuery(qry->utilityStmt);
2195 return qry;
2196
2197 case T_CreateTableAsStmt:
2198 qry = castNode(Query, ((CreateTableAsStmt *) parsetree)->query);
2199 if (qry->commandType == CMD_UTILITY)
2200 return UtilityContainsQuery(qry->utilityStmt);
2201 return qry;
2202
2203 default:
2204 return NULL;
2205 }
2206}
Query::commandType
CmdType commandType
Definition: parsenodes.h:121
Query::utilityStmt
Node * utilityStmt
Definition: parsenodes.h:136
UtilityContainsQuery
Query * UtilityContainsQuery(Node *parsetree)
Definition: utility.c:2179

References castNode, CMD_UTILITY, Query::commandType, nodeTag, UtilityContainsQuery(), and Query::utilityStmt.

Referenced by AcquireExecutorLocks(), AcquirePlannerLocks(), extract_query_dependencies_walker(), and UtilityContainsQuery().

◆ UtilityReturnsTuples()

bool UtilityReturnsTuples ( Node *  parsetree)

Definition at line 2028 of file utility.c.

2029{
2030 switch (nodeTag(parsetree))
2031 {
2032 case T_CallStmt:
2033 {
2034 CallStmt *stmt = (CallStmt *) parsetree;
2035
2036 return (stmt->funcexpr->funcresulttype == RECORDOID);
2037 }
2038 case T_FetchStmt:
2039 {
2040 FetchStmt *stmt = (FetchStmt *) parsetree;
2041 Portal portal;
2042
2043 if (stmt->ismove)
2044 return false;
2045 portal = GetPortalByName(stmt->portalname);
2046 if (!PortalIsValid(portal))
2047 return false; /* not our business to raise error */
2048 return portal->tupDesc ? true : false;
2049 }
2050
2051 case T_ExecuteStmt:
2052 {
2053 ExecuteStmt *stmt = (ExecuteStmt *) parsetree;
2054 PreparedStatement *entry;
2055
2056 entry = FetchPreparedStatement(stmt->name, false);
2057 if (!entry)
2058 return false; /* not our business to raise error */
2059 if (entry->plansource->resultDesc)
2060 return true;
2061 return false;
2062 }
2063
2064 case T_ExplainStmt:
2065 return true;
2066
2067 case T_VariableShowStmt:
2068 return true;
2069
2070 default:
2071 return false;
2072 }
2073}
true
return true
Definition: isn.c:130
PortalIsValid
#define PortalIsValid(p)
Definition: portal.h:212
GetPortalByName
Portal GetPortalByName(const char *name)
Definition: portalmem.c:130
CachedPlanSource::resultDesc
TupleDesc resultDesc
Definition: plancache.h:122
PortalData::tupDesc
TupleDesc tupDesc
Definition: portal.h:160
PreparedStatement::plansource
CachedPlanSource * plansource
Definition: prepare.h:32

References FetchPreparedStatement(), GetPortalByName(), nodeTag, PreparedStatement::plansource, PortalIsValid, CachedPlanSource::resultDesc, stmt, true, and PortalData::tupDesc.

Referenced by ChoosePortalStrategy().

◆ UtilityTupleDescriptor()

TupleDesc UtilityTupleDescriptor ( Node *  parsetree)

Definition at line 2084 of file utility.c.

2085{
2086 switch (nodeTag(parsetree))
2087 {
2088 case T_CallStmt:
2089 return CallStmtResultDesc((CallStmt *) parsetree);
2090
2091 case T_FetchStmt:
2092 {
2093 FetchStmt *stmt = (FetchStmt *) parsetree;
2094 Portal portal;
2095
2096 if (stmt->ismove)
2097 return NULL;
2098 portal = GetPortalByName(stmt->portalname);
2099 if (!PortalIsValid(portal))
2100 return NULL; /* not our business to raise error */
2101 return CreateTupleDescCopy(portal->tupDesc);
2102 }
2103
2104 case T_ExecuteStmt:
2105 {
2106 ExecuteStmt *stmt = (ExecuteStmt *) parsetree;
2107 PreparedStatement *entry;
2108
2109 entry = FetchPreparedStatement(stmt->name, false);
2110 if (!entry)
2111 return NULL; /* not our business to raise error */
2112 return FetchPreparedStatementResultDesc(entry);
2113 }
2114
2115 case T_ExplainStmt:
2116 return ExplainResultDesc((ExplainStmt *) parsetree);
2117
2118 case T_VariableShowStmt:
2119 {
2120 VariableShowStmt *n = (VariableShowStmt *) parsetree;
2121
2122 return GetPGVariableResultDesc(n->name);
2123 }
2124
2125 default:
2126 return NULL;
2127 }
2128}
FetchPreparedStatementResultDesc
TupleDesc FetchPreparedStatementResultDesc(PreparedStatement *stmt)
Definition: prepare.c:467
ExplainResultDesc
TupleDesc ExplainResultDesc(ExplainStmt *stmt)
Definition: explain.c:254
CallStmtResultDesc
TupleDesc CallStmtResultDesc(CallStmt *stmt)
Definition: functioncmds.c:2383
GetPGVariableResultDesc
TupleDesc GetPGVariableResultDesc(const char *name)
Definition: guc_funcs.c:394
CreateTupleDescCopy
TupleDesc CreateTupleDescCopy(TupleDesc tupdesc)
Definition: tupdesc.c:245

References CallStmtResultDesc(), CreateTupleDescCopy(), ExplainResultDesc(), FetchPreparedStatement(), FetchPreparedStatementResultDesc(), GetPGVariableResultDesc(), GetPortalByName(), VariableShowStmt::name, nodeTag, PortalIsValid, stmt, and PortalData::tupDesc.

Referenced by PlanCacheComputeResultDesc(), and PortalStart().

Variable Documentation

◆ ProcessUtility_hook

PGDLLIMPORT ProcessUtility_hook_type ProcessUtility_hook
extern

Definition at line 70 of file utility.c.

Referenced by _PG_init(), and ProcessUtility().