本节介绍standard_ExecutorRun和ExecutorRun函数。

standard_ExecutorRun函数

//src/include/execurot/executor.h

extern void standard_ExecutorRun(QueryDesc *queryDesc,
			 ScanDirection direction, uint64 count, bool execute_once);

//src/backend/executor/execMain.c

Assert(queryDesc != NULL);

estate = queryDesc->estate;

Assert(estate != NULL);
Assert(!(estate->es_top_eflags & EXEC_FLAG_EXPLAIN_ONLY));


oldcontext = MemoryContextSwitchTo(estate->es_query_cxt);


if (queryDesc->totaltime)
	InstrStartNode(queryDesc->totaltime);

operation = queryDesc->operation;
dest = queryDesc->dest;


estate->es_processed = 0;

sendTuples = (operation == CMD_SELECT ||
		  queryDesc->plannedstmt->hasReturning);

if (sendTuples)
	dest->rStartup(dest, operation, queryDesc->tupDesc);


if (!ScanDirectionIsNoMovement(direction))
{
	if (execute_once && queryDesc->already_executed)
		elog(ERROR, "can"t re-execute query flagged for single execution");
	queryDesc->already_executed = true;

	ExecutePlan(estate,
		queryDesc->planstate,
		queryDesc->plannedstmt->parallelModeNeeded,
		operation,
		sendTuples,
		count,
		direction,
		dest,
		execute_once);
}


if (sendTuples)
	dest->rShutdown(dest);


if (queryDesc->totaltime)
	InstrStopNode(queryDesc->totaltime, estate->es_processed);


MemoryContextSwitchTo(oldcontext);

ExecutorRun函数

void
ExecutorRun(QueryDesc *queryDesc,
			ScanDirection direction, uint64 count,
			bool execute_once)
{
	if (ExecutorRun_hook)
		(*ExecutorRun_hook) (queryDesc, direction, count, execute_once);
	else
		standard_ExecutorRun(queryDesc, direction, count, execute_once);
}