external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Support EXPLAIN(ANALYZE, WAL)

pull/4196/head
Ahmet Gedemenli 2020-09-25 17:06:35 +03:00
parent f3962fc7f6
commit d268aa7bc8
1 changed files with 29 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
src/backend/distributed/planner/multi_explain.c
View File

@ -83,6 +83,7 @@ typedef struct
bool verbose; bool verbose;
bool costs; bool costs;
bool buffers; bool buffers;
bool wal;
bool timing; bool timing;
bool summary; bool summary;
ExplainFormat format; ExplainFormat format;
@ -91,7 +92,7 @@ typedef struct
/* EXPLAIN flags of current distributed explain */ /* EXPLAIN flags of current distributed explain */
static ExplainOptions CurrentDistributedQueryExplainOptions = { static ExplainOptions CurrentDistributedQueryExplainOptions = {
0, 0, 0, 0, 0, EXPLAIN_FORMAT_TEXT 0, 0, 0, 0, 0, 0, EXPLAIN_FORMAT_TEXT
}; };
/* Result for a single remote EXPLAIN command */ /* Result for a single remote EXPLAIN command */
@ -904,12 +905,18 @@ BuildRemoteExplainQuery(char *queryString, ExplainState *es)
appendStringInfo(explainQuery, appendStringInfo(explainQuery,
"EXPLAIN (ANALYZE %s, VERBOSE %s, " "EXPLAIN (ANALYZE %s, VERBOSE %s, "
"COSTS %s, BUFFERS %s, TIMING %s, SUMMARY %s, " "COSTS %s, BUFFERS %s, "
"FORMAT %s) %s", #if PG_VERSION_NUM >= PG_VERSION_13
"WAL %s, "
#endif
"TIMING %s, SUMMARY %s, FORMAT %s) %s",
es->analyze ? "TRUE" : "FALSE", es->analyze ? "TRUE" : "FALSE",
es->verbose ? "TRUE" : "FALSE", es->verbose ? "TRUE" : "FALSE",
es->costs ? "TRUE" : "FALSE", es->costs ? "TRUE" : "FALSE",
es->buffers ? "TRUE" : "FALSE", es->buffers ? "TRUE" : "FALSE",
#if PG_VERSION_NUM >= PG_VERSION_13
es->wal ? "TRUE" : "FALSE",
#endif
es->timing ? "TRUE" : "FALSE", es->timing ? "TRUE" : "FALSE",
es->summary ? "TRUE" : "FALSE", es->summary ? "TRUE" : "FALSE",
formatStr, formatStr,
@ -1005,6 +1012,9 @@ worker_save_query_explain_analyze(PG_FUNCTION_ARGS)
/* use the same defaults as NewExplainState() for following options */ /* use the same defaults as NewExplainState() for following options */
es->buffers = ExtractFieldBoolean(explainOptions, "buffers", es->buffers); es->buffers = ExtractFieldBoolean(explainOptions, "buffers", es->buffers);
#if PG_VERSION_NUM >= PG_VERSION_13
es->wal = ExtractFieldBoolean(explainOptions, "wal", es->wal);
#endif
es->costs = ExtractFieldBoolean(explainOptions, "costs", es->costs); es->costs = ExtractFieldBoolean(explainOptions, "costs", es->costs);
es->summary = ExtractFieldBoolean(explainOptions, "summary", es->summary); es->summary = ExtractFieldBoolean(explainOptions, "summary", es->summary);
es->verbose = ExtractFieldBoolean(explainOptions, "verbose", es->verbose); es->verbose = ExtractFieldBoolean(explainOptions, "verbose", es->verbose);
@ -1206,6 +1216,9 @@ CitusExplainOneQuery(Query *query, int cursorOptions, IntoClause *into,
/* save the flags of current EXPLAIN command */ /* save the flags of current EXPLAIN command */
CurrentDistributedQueryExplainOptions.costs = es->costs; CurrentDistributedQueryExplainOptions.costs = es->costs;
CurrentDistributedQueryExplainOptions.buffers = es->buffers; CurrentDistributedQueryExplainOptions.buffers = es->buffers;
#if PG_VERSION_NUM >= PG_VERSION_13
CurrentDistributedQueryExplainOptions.wal = es->wal;
#endif
CurrentDistributedQueryExplainOptions.verbose = es->verbose; CurrentDistributedQueryExplainOptions.verbose = es->verbose;
CurrentDistributedQueryExplainOptions.summary = es->summary; CurrentDistributedQueryExplainOptions.summary = es->summary;
CurrentDistributedQueryExplainOptions.timing = es->timing; CurrentDistributedQueryExplainOptions.timing = es->timing;
@ -1482,11 +1495,18 @@ WrapQueryForExplainAnalyze(const char *queryString, TupleDesc tupleDesc)
} }
StringInfo explainOptions = makeStringInfo(); StringInfo explainOptions = makeStringInfo();
appendStringInfo(explainOptions, "{\"verbose\": %s, \"costs\": %s, \"buffers\": %s, " appendStringInfo(explainOptions,
"\"timing\": %s, \"summary\": %s, \"format\": \"%s\"}", "{\"verbose\": %s, \"costs\": %s, \"buffers\": %s, "
#if PG_VERSION_NUM >= PG_VERSION_13
"\"wal\": %s, "
#endif
"\"timing\": %s, \"summary\": %s, \"format\": \"%s\"}",
CurrentDistributedQueryExplainOptions.verbose ? "true" : "false", CurrentDistributedQueryExplainOptions.verbose ? "true" : "false",
CurrentDistributedQueryExplainOptions.costs ? "true" : "false", CurrentDistributedQueryExplainOptions.costs ? "true" : "false",
CurrentDistributedQueryExplainOptions.buffers ? "true" : "false", CurrentDistributedQueryExplainOptions.buffers ? "true" : "false",
#if PG_VERSION_NUM >= PG_VERSION_13
CurrentDistributedQueryExplainOptions.wal ? "true" : "false",
#endif
CurrentDistributedQueryExplainOptions.timing ? "true" : "false", CurrentDistributedQueryExplainOptions.timing ? "true" : "false",
CurrentDistributedQueryExplainOptions.summary ? "true" : "false", CurrentDistributedQueryExplainOptions.summary ? "true" : "false",
ExplainFormatStr(CurrentDistributedQueryExplainOptions.format)); ExplainFormatStr(CurrentDistributedQueryExplainOptions.format));
@ -1632,7 +1652,10 @@ ExplainWorkerPlan(PlannedStmt *plannedstmt, DestReceiver *dest, ExplainState *es
if (es->buffers) if (es->buffers)
instrument_option |= INSTRUMENT_BUFFERS; instrument_option |= INSTRUMENT_BUFFERS;
#if PG_VERSION_NUM >= PG_VERSION_13
if (es->wal)
instrument_option |= INSTRUMENT_WAL;
#endif
/* /*
* We always collect timing for the entire statement, even when node-level * We always collect timing for the entire statement, even when node-level
* timing is off, so we don't look at es->timing here. (We could skip * timing is off, so we don't look at es->timing here. (We could skip