Please enable JavaScript.

Coggle requires JavaScript to display documents.

Greenplumdb Source Read (PostgresMain (exec_simple_query (. (pg_parse…

- - - - pg_parse_query(query_string);
        
        .
        
        raw_parsetree_list = raw_parser(query_string);
        
        .
        
        yyresult = base_yyparse(yyscanner);
        
        .
        
        .
        
        yyextra.have_lookahead = false;
        parser_init(&yyextra);
        
        .
        
        .
        
        scanner_finish(yyscanner);
        
        .
        
        .
        
        yyscanner = scanner_init(str, &yyextra.core_yy_extra,
        ScanKeywords, NumScanKeywords);
        
        .
        
        .
        
        return yyextra.parsetree;
        
        .
        
        .
        
        core_yyscan_t yyscanner;
        base_yy_extra_type yyextra;
        int yyresult;
        
        .
        
        .
        
        #ifdef COPY_PARSE_PLAN_TREES
        copyObject(raw_parsetree_list);
        
        .
        
        .
        
        List *raw_parsetree_list;
        
        .
    - - MemoryContextSwitchTo(oldcontext);
        
        .
        
        .
    - - oldcontext = MemoryContextSwitchTo(MessageContext);
        
        .
    - - isTopLevel = (list_length(parsetree_list) == 1);
        
        .
    - - drop_unnamed_stmt
        
        .
    - - foreach(parsetree_item, parsetree_list)——————————
        
        .
        
        oldcontext = MemoryContextSwitchTo(MessageContext);
        
        .
        
        .
        
        querytree_list = pg_analyze_and_rewrite(
        parsetree, query_string,NULL, 0);
        
        .
        
        query = parse_analyze(parsetree, query_string,
        paramTypes, numParams);
        
        .
        
        1 more item...
        
        .
        
        1 more item...
        
        .
        
        1 more item...
        
        .
        
        1 more item...
        
        .
        
        1 more item...
        
        .
        
        1 more item...
        
        .
        
        querytree_list = pg_rewrite_query(query);
        
        querytree_list = QueryRewrite(query);
        
        1 more item...
        
        .
        
        Query query;
        List querytree_list;
        
        .
        
        return querytree_list;
        
        .
        
        if (analyze_requires_snapshot(parsetree))
        
        .
        
        .
        
        plantree_list = pg_plan_queries(querytree_list,
        0, NULL);
        
        foreach(query_list, querytrees)
        stmt = (Node *) pg_plan_query(query,
        cursorOptions, boundParams);
        
        plan = planner(querytree, cursorOptions,
        boundParams);
        
        .
        
        1 more item...
        
        .
        
        1 more item...
        
        .
        
        CHECK_FOR_INTERRUPTS();
        
        .
        
        .
        
        if (snapshot_set): PopActiveSnapshot();
        CHECK_FOR_INTERRUPTS();
        
        .
        
        .
        
        start_xact_command();
        
        .
        
        .
        
        CreatePortal
        
        .
        
        portal->heap = AllocSetContextCreate
        portal->resowner = ResourceOwnerCreate
        
        .
        
        .
        
        portal = (Portal) MemoryContextAllocZero(PortalMemory, sizeof *portal);
        
        .
        
        .
        
        GetPortalByName()
        if (PortalIsValid(portal))
        ...
        
        .
        
        .
        
        PortalHashTableInsert(portal, name);
        
        .
        
        .
        
        gpmon_init();
        
        .
        
        .
        
        if (Gp_role == GP_ROLE_UTILITY &&.......
        //in utility mode, disallow PREPARE TRANSACTION statments
        
        .
        
        .
        
        PortalDefineQuery(portal,NULL,query_string,nodeTag(parsetree),
        commandTag,plantree_list, NULL);
        
        .
        
        .
        
        BeginCommand(commandTag, dest);
        
        .
        
        .
        
        PortalStart___————————————
        
        .
        
        switch (portal->strategy)————————
        
        .
        
        1 more item...
        
        .
        
        1 more item...
        
        .
        
        1 more item...
        
        .
        
        1 more item...
        
        .
        
        MemoryContextSwitchTo(oldContext);
        
        .
        
        .
        
        portal->strategy =
        ChoosePortalStrategy(portal->stmts);
        PortalBackoffEntryInit(portal);
        
        .
        
        .
        
        portal->status = PORTAL_READY;
        
        .
        
        .
        
        MemoryContextSwitchTo
        
        .
        
        .
        
        commandTag = CreateCommandTag(parsetree);
        set_ps_display(commandTag, false);
        
        .
        
        .
        
        if (IsA(parsetree, FetchStmt))
        ...
        format = 1
        PortalSetResultFormat(portal, 1, &format);
        
        .
        
        .
        
        List querytree_list, plantree_list;
        Portal portal;
        .......
        
        .
        
        .
        
        receiver = CreateDestReceiver(dest);
        if (dest == DestRemote){ SetRemoteDestReceiverParams(receiver, portal);}
        MemoryContextSwitchTo(oldcontext);
        
        CreateDestReceiver: switch (dest)
        
        .
        
        DestSPI
        
        1 more item...
        
        .
        
        DestTuplestore
        
        1 more item...
        
        .
        
        DestDebug
        
        1 more item...
        
        .
        
        DestIntoRel
        
        1 more item...
        
        .
        
        DestNone
        
        1 more item...
        
        .
        
        DestCopyOut
        
        1 more item...
        
        .
        
        DestSQLFunction
        
        1 more item...
        
        .
        
        DestRemote
        DestRemoteExecute
        
        1 more item...
        
        .
        
        DestTransientRel
        
        1 more item...
        
        .
        
        PortalRun(portal...);
        
        .
        
        switch (portal->strategy)
        
        case
        
        1 more item...
        
        case
        
        1 more item...
        
        .
        
        PortalContext = PortalGetHeapMemory(portal)
        MemoryContextSwitchTo(PortalContext);
        
        .
        
        .
        
        MemoryContextSwitchTo
        return result;
        
        .
        
        .
        
        portal->status = PORTAL_ACTIVE;
        portal->activeSubid = GetCurrentSubTransactionId();
        
        .
        
        .
        
        (receiver->rDestroy) (receiver);
        PortalDrop(portal, false);
        finish_xact_command() or *CommandCounterIncrement();
        
        .
        
        .
        
        EndCommand(completionTag, dest);
        
        .
    - - start_xact_command
        
        .
    - - pgstat_report_activity(STATE_RUNNING, query_string);
        
        .
    - - increment_command_count
        
        . gp_command_count++;
        MyProc->queryCommandId = gp_command_count;
        
        .
    - - finish_xact_command();
        
        .
    - - if (!parsetree_list) NullCommand(dest);
        switch (check_log_duration(msec_str, was_logged))
        ereport(......)
        debug_query_string = NULL;
        
        END OF:exec_simple_query
        
        .
  - - - .
        
        standard_ExecutorStart