nodeTableFuncscan.h File Reference

#include "nodes/execnodes.h"

Include dependency graph for nodeTableFuncscan.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
TableFuncScanState *	ExecInitTableFuncScan (TableFuncScan *node, EState *estate, int eflags)
void	ExecEndTableFuncScan (TableFuncScanState *node)
void	ExecReScanTableFuncScan (TableFuncScanState *node)

Function Documentation

ExecEndTableFuncScan()

void ExecEndTableFuncScan ( TableFuncScanState *  node )

extern

Definition at line 220 of file nodeTableFuncscan.c.

{
    /*
     * Release tuplestore resources
     */
    if (node->tupstore != NULL)
        tuplestore_end(node->tupstore);
    node->tupstore = NULL;
}

References fb(), tuplestore_end(), and TableFuncScanState::tupstore.

Referenced by ExecEndNode().

ExecInitTableFuncScan()

TableFuncScanState * ExecInitTableFuncScan ( TableFuncScan *  node, EState *  estate, int  eflags  )

extern

Definition at line 111 of file nodeTableFuncscan.c.

{
    TableFuncScanState *scanstate;
    TableFunc  *tf = node->tablefunc;
    TupleDesc   tupdesc;
    int         i;
 
    /* check for unsupported flags */
    Assert(!(eflags & EXEC_FLAG_MARK));
 
    /*
     * TableFuncscan should not have any children.
     */
    Assert(outerPlan(node) == NULL);
    Assert(innerPlan(node) == NULL);
 
    /*
     * create new ScanState for node
     */
    scanstate = makeNode(TableFuncScanState);
    scanstate->ss.ps.plan = (Plan *) node;
    scanstate->ss.ps.state = estate;
    scanstate->ss.ps.ExecProcNode = ExecTableFuncScan;
 
    /*
     * Miscellaneous initialization
     *
     * create expression context for node
     */
    ExecAssignExprContext(estate, &scanstate->ss.ps);
 
    /*
     * initialize source tuple type
     */
    tupdesc = BuildDescFromLists(tf->colnames,
                                 tf->coltypes,
                                 tf->coltypmods,
                                 tf->colcollations);
    /* and the corresponding scan slot */
    ExecInitScanTupleSlot(estate, &scanstate->ss, tupdesc,
                          &TTSOpsMinimalTuple);
 
    /*
     * Initialize result type and projection.
     */
    ExecInitResultTypeTL(&scanstate->ss.ps);
    ExecAssignScanProjectionInfo(&scanstate->ss);
 
    /*
     * initialize child expressions
     */
    scanstate->ss.ps.qual =
        ExecInitQual(node->scan.plan.qual, &scanstate->ss.ps);
 
    /* Only XMLTABLE and JSON_TABLE are supported currently */
    scanstate->routine =
        tf->functype == TFT_XMLTABLE ? &XmlTableRoutine : &JsonbTableRoutine;
 
    scanstate->perTableCxt =
        AllocSetContextCreate(CurrentMemoryContext,
                              "TableFunc per value context",
                              ALLOCSET_DEFAULT_SIZES);
    scanstate->opaque = NULL;   /* initialized at runtime */
 
    scanstate->ns_names = tf->ns_names;
 
    scanstate->ns_uris =
        ExecInitExprList(tf->ns_uris, (PlanState *) scanstate);
    scanstate->docexpr =
        ExecInitExpr((Expr *) tf->docexpr, (PlanState *) scanstate);
    scanstate->rowexpr =
        ExecInitExpr((Expr *) tf->rowexpr, (PlanState *) scanstate);
    scanstate->colexprs =
        ExecInitExprList(tf->colexprs, (PlanState *) scanstate);
    scanstate->coldefexprs =
        ExecInitExprList(tf->coldefexprs, (PlanState *) scanstate);
    scanstate->colvalexprs =
        ExecInitExprList(tf->colvalexprs, (PlanState *) scanstate);
    scanstate->passingvalexprs =
        ExecInitExprList(tf->passingvalexprs, (PlanState *) scanstate);
 
    scanstate->notnulls = tf->notnulls;
 
    /* these are allocated now and initialized later */
    scanstate->in_functions = palloc_array(FmgrInfo, tupdesc->natts);
    scanstate->typioparams = palloc_array(Oid, tupdesc->natts);
 
    /*
     * Fill in the necessary fmgr infos.
     */
    for (i = 0; i < tupdesc->natts; i++)
    {
        Oid         in_funcid;
 
        getTypeInputInfo(TupleDescAttr(tupdesc, i)->atttypid,
                         &in_funcid, &scanstate->typioparams[i]);
        fmgr_info(in_funcid, &scanstate->in_functions[i]);
    }
 
    return scanstate;
}

References ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate, Assert, BuildDescFromLists(), TableFunc::colexprs, CurrentMemoryContext, TableFunc::docexpr, EXEC_FLAG_MARK, ExecAssignExprContext(), ExecAssignScanProjectionInfo(), ExecInitExpr(), ExecInitExprList(), ExecInitQual(), ExecInitResultTypeTL(), ExecInitScanTupleSlot(), ExecTableFuncScan(), fb(), fmgr_info(), TableFunc::functype, getTypeInputInfo(), i, innerPlan, JsonbTableRoutine, makeNode, TupleDescData::natts, outerPlan, palloc_array, TableFunc::rowexpr, TableFuncScan::scan, TableFuncScan::tablefunc, TFT_XMLTABLE, TTSOpsMinimalTuple, TupleDescAttr(), and XmlTableRoutine.

Referenced by ExecInitNode().

ExecReScanTableFuncScan()

void ExecReScanTableFuncScan ( TableFuncScanState *  node )

extern

Definition at line 237 of file nodeTableFuncscan.c.

{
    Bitmapset  *chgparam = node->ss.ps.chgParam;
 
    if (node->ss.ps.ps_ResultTupleSlot)
        ExecClearTuple(node->ss.ps.ps_ResultTupleSlot);
    ExecScanReScan(&node->ss);
 
    /*
     * Recompute when parameters are changed.
     */
    if (chgparam)
    {
        if (node->tupstore != NULL)
        {
            tuplestore_end(node->tupstore);
            node->tupstore = NULL;
        }
    }
 
    if (node->tupstore != NULL)
        tuplestore_rescan(node->tupstore);
}

References PlanState::chgParam, ExecClearTuple(), ExecScanReScan(), fb(), ScanState::ps, PlanState::ps_ResultTupleSlot, TableFuncScanState::ss, tuplestore_end(), tuplestore_rescan(), and TableFuncScanState::tupstore.

Referenced by ExecReScan().