Follow new shared memory request convention since PG15

[pgstoreplans/pg_store_plans.git] / pgsp_json_text.h

diff --git a/pgsp_json_text.h b/pgsp_json_text.h
index 688fd03..a01ba71 100644 (file)
--- a/pgsp_json_text.h
+++ b/pgsp_json_text.h
@@ -1,3 +1,22 @@
+/*-------------------------------------------------------------------------
+ *
+ * pgsp_json_text.h: Defenitions for text plan generator for pg_store_plans.
+ *
+ * Copyright (c) 2012-2021, NIPPON TELEGRAPH AND TELEPHONE CORPORATION
+ *
+ * IDENTIFICATION
+ *       pg_store_plans/pgsp_json_text.h
+ *
+ *-------------------------------------------------------------------------
+ */
+
+typedef struct
+{
+       const char *sort_keys;
+       List *group_keys;
+       char *key_type;
+} grouping_set;
+
 typedef struct
 {
        NodeTag nodetag;
@@ -15,9 +34,13 @@ typedef struct
        const char *rows_removed_by_filter;
        const char *alias;
        StringInfo output;
+       List       *target_tables;
        const char *func_call;
        const char *sort_method;
-       const char *sort_key;
+       StringInfo sort_key;
+       StringInfo group_key;
+       StringInfo hash_key;
+       List       *grouping_sets;
        const char *index_cond;
        const char *merge_cond;
        const char *hash_cond;
@@ -28,6 +51,7 @@ typedef struct
        const char *setopcommand;
        const char *join_type;
        const char *org_hash_batches;
+       const char *org_hash_buckets;
        const char *peak_memory_usage;
        const char *startup_cost;
        const char *total_cost;
@@ -54,11 +78,42 @@ typedef struct
        const char *io_write_time;
        const char *filter_removed;
        const char *idxrchk_removed;
-
        const char *trig_name;
        const char *trig_relation;
        const char *trig_time;
-       const char * trig_calls;
+       const char *trig_calls;
+       const char *plan_time;
+       const char *exec_time;
+       const char *exact_heap_blks;
+       const char *lossy_heap_blks;
+       const char *joinfilt_removed;
+       const char *conflict_resolution;
+       StringInfo      conflict_arbiter_indexes;
+       const char *tuples_inserted;
+       const char *conflicting_tuples;
+       const char *sampling_method;
+       StringInfo sampling_params;
+       const char *repeatable_seed;
+       bool            parallel_aware;
+       const char *partial_mode;
+       const char *worker_number;
+       const char *workers_planned;
+       const char *workers_launched;
+       bool            inner_unique;
+       bool            async_capable;
+       const char *table_func_name;
+       StringInfo      presorted_key;
+       StringInfo      sortmethod_used;
+       const char *sortspace_mem;
+       const char *group_count;
+       const char *avg_sortspc_used;
+       const char *peak_sortspc_used;
+
+       const char *tmp_obj_name;
+       const char *tmp_schema_name;
+       const char *tmp_alias;
+       List       *_undef;
+       bool            _undef_newelem;
 } node_vals;
 
 #define SETTER(name) pgsp_node_set_##name
@@ -70,12 +125,30 @@ typedef struct
 #define SQLQUOTE_SETTER(name) \
        SETTERDECL(name) { vals->name = quote_identifier(val);}
 
+#define BOOL_SETTER(name) \
+       SETTERDECL(name) { vals->name = (strcmp(val, "true") == 0 ? 1 : 0);}
+
+#define LIST_SETTER(name) \
+       SETTERDECL(name) { \
+               if (!vals->name || !vals->name->data[0])\
+               { \
+                       vals->name = makeStringInfo(); \
+                       appendStringInfoString(vals->name, val); \
+               } \
+               else \
+               { \
+                       appendStringInfoString(vals->name, ", "); \
+                       appendStringInfoString(vals->name, val); \
+               } \
+       }\
+
 #define CONVERSION_SETTER(name, converter) \
        SETTERDECL(name) { vals->name = converter(val, PGSP_JSON_TEXTIZE);}
 
 extern char *pgsp_json_textize(char *json);
 
 /* Prototypes for setter for node_vals */
+SETTERDECL(_undef);
 SETTERDECL(node_type);
 SETTERDECL(scan_dir);
 SETTERDECL(obj_name);
@@ -87,6 +160,11 @@ SETTERDECL(join_type);
 SETTERDECL(setopcommand);
 SETTERDECL(sort_method);
 SETTERDECL(sort_key);
+SETTERDECL(group_key);
+SETTERDECL(group_keys);
+SETTERDECL(hash_key);
+SETTERDECL(parallel_aware);
+SETTERDECL(partial_mode);
 SETTERDECL(index_name);
 SETTERDECL(startup_cost);
 SETTERDECL(total_cost);
@@ -107,10 +185,10 @@ SETTERDECL(recheck_cond);
 SETTERDECL(hash_buckets);
 SETTERDECL(hash_batches);
 SETTERDECL(org_hash_batches);
+SETTERDECL(org_hash_buckets);
 SETTERDECL(peak_memory_usage);
 SETTERDECL(filter_removed);
 SETTERDECL(idxrchk_removed);
-
 SETTERDECL(actual_startup_time);
 SETTERDECL(actual_total_time);
 SETTERDECL(actual_rows);
@@ -132,3 +210,27 @@ SETTERDECL(trig_name);
 SETTERDECL(trig_relation);
 SETTERDECL(trig_time);
 SETTERDECL(trig_calls);
+SETTERDECL(plan_time);
+SETTERDECL(exec_time);
+SETTERDECL(exact_heap_blks);
+SETTERDECL(lossy_heap_blks);
+SETTERDECL(joinfilt_removed);
+SETTERDECL(conflict_resolution);
+SETTERDECL(conflict_arbiter_indexes);
+SETTERDECL(tuples_inserted);
+SETTERDECL(conflicting_tuples);
+SETTERDECL(sampling_method);
+SETTERDECL(sampling_params);
+SETTERDECL(repeatable_seed);
+SETTERDECL(worker_number);
+SETTERDECL(workers_planned);
+SETTERDECL(workers_launched);
+SETTERDECL(inner_unique);
+SETTERDECL(async_capable);
+SETTERDECL(table_func_name);
+SETTERDECL(presorted_key);
+SETTERDECL(sortmethod_used);
+SETTERDECL(sortspace_mem);
+SETTERDECL(group_count);
+SETTERDECL(avg_sortspc_used);
+SETTERDECL(peak_sortspc_used);