mirror of https://github.com/postgres/postgres
XMLTABLE is defined by the SQL/XML standard as a feature that allows turning XML-formatted data into relational form, so that it can be used as a <table primary> in the FROM clause of a query. This new construct provides significant simplicity and performance benefit for XML data processing; what in a client-side custom implementation was reported to take 20 minutes can be executed in 400ms using XMLTABLE. (The same functionality was said to take 10 seconds using nested PostgreSQL XPath function calls, and 5 seconds using XMLReader under PL/Python). The implemented syntax deviates slightly from what the standard requires. First, the standard indicates that the PASSING clause is optional and that multiple XML input documents may be given to it; we make it mandatory and accept a single document only. Second, we don't currently support a default namespace to be specified. This implementation relies on a new executor node based on a hardcoded method table. (Because the grammar is fixed, there is no extensibility in the current approach; further constructs can be implemented on top of this such as JSON_TABLE, but they require changes to core code.) Author: Pavel Stehule, Álvaro Herrera Extensively reviewed by: Craig Ringer Discussion: https://postgr.es/m/CAFj8pRAgfzMD-LoSmnMGybD0WsEznLHWap8DO79+-GTRAPR4qA@mail.gmail.compull/17/merge
parent
270d7dd8a5
commit
fcec6caafa
@ -0,0 +1,502 @@ |
||||
/*-------------------------------------------------------------------------
|
||||
* |
||||
* nodeTableFuncscan.c |
||||
* Support routines for scanning RangeTableFunc (XMLTABLE like functions). |
||||
* |
||||
* Portions Copyright (c) 1996-2017, PostgreSQL Global Development Group |
||||
* Portions Copyright (c) 1994, Regents of the University of California |
||||
* |
||||
* |
||||
* IDENTIFICATION |
||||
* src/backend/executor/nodeTableFuncscan.c |
||||
* |
||||
*------------------------------------------------------------------------- |
||||
*/ |
||||
/*
|
||||
* INTERFACE ROUTINES |
||||
* ExecTableFuncscan scans a function. |
||||
* ExecFunctionNext retrieve next tuple in sequential order. |
||||
* ExecInitTableFuncscan creates and initializes a TableFuncscan node. |
||||
* ExecEndTableFuncscan releases any storage allocated. |
||||
* ExecReScanTableFuncscan rescans the function |
||||
*/ |
||||
#include "postgres.h" |
||||
|
||||
#include "nodes/execnodes.h" |
||||
#include "executor/executor.h" |
||||
#include "executor/nodeTableFuncscan.h" |
||||
#include "executor/tablefunc.h" |
||||
#include "miscadmin.h" |
||||
#include "utils/builtins.h" |
||||
#include "utils/lsyscache.h" |
||||
#include "utils/memutils.h" |
||||
#include "utils/xml.h" |
||||
|
||||
|
||||
static TupleTableSlot *TableFuncNext(TableFuncScanState *node); |
||||
static bool TableFuncRecheck(TableFuncScanState *node, TupleTableSlot *slot); |
||||
|
||||
static void tfuncFetchRows(TableFuncScanState *tstate, ExprContext *econtext); |
||||
static void tfuncInitialize(TableFuncScanState *tstate, ExprContext *econtext, Datum doc); |
||||
static void tfuncLoadRows(TableFuncScanState *tstate, ExprContext *econtext); |
||||
|
||||
/* ----------------------------------------------------------------
|
||||
* Scan Support |
||||
* ---------------------------------------------------------------- |
||||
*/ |
||||
/* ----------------------------------------------------------------
|
||||
* TableFuncNext |
||||
* |
||||
* This is a workhorse for ExecTableFuncscan |
||||
* ---------------------------------------------------------------- |
||||
*/ |
||||
static TupleTableSlot * |
||||
TableFuncNext(TableFuncScanState *node) |
||||
{ |
||||
TupleTableSlot *scanslot; |
||||
|
||||
scanslot = node->ss.ss_ScanTupleSlot; |
||||
|
||||
/*
|
||||
* If first time through, read all tuples from function and put them in a |
||||
* tuplestore. Subsequent calls just fetch tuples from tuplestore. |
||||
*/ |
||||
if (node->tupstore == NULL) |
||||
tfuncFetchRows(node, node->ss.ps.ps_ExprContext); |
||||
|
||||
/*
|
||||
* Get the next tuple from tuplestore. |
||||
*/ |
||||
(void) tuplestore_gettupleslot(node->tupstore, |
||||
true, |
||||
false, |
||||
scanslot); |
||||
return scanslot; |
||||
} |
||||
|
||||
/*
|
||||
* TableFuncRecheck -- access method routine to recheck a tuple in EvalPlanQual |
||||
*/ |
||||
static bool |
||||
TableFuncRecheck(TableFuncScanState *node, TupleTableSlot *slot) |
||||
{ |
||||
/* nothing to check */ |
||||
return true; |
||||
} |
||||
|
||||
/* ----------------------------------------------------------------
|
||||
* ExecTableFuncscan(node) |
||||
* |
||||
* Scans the function sequentially and returns the next qualifying |
||||
* tuple. |
||||
* We call the ExecScan() routine and pass it the appropriate |
||||
* access method functions. |
||||
* ---------------------------------------------------------------- |
||||
*/ |
||||
TupleTableSlot * |
||||
ExecTableFuncScan(TableFuncScanState *node) |
||||
{ |
||||
return ExecScan(&node->ss, |
||||
(ExecScanAccessMtd) TableFuncNext, |
||||
(ExecScanRecheckMtd) TableFuncRecheck); |
||||
} |
||||
|
||||
/* ----------------------------------------------------------------
|
||||
* ExecInitTableFuncscan |
||||
* ---------------------------------------------------------------- |
||||
*/ |
||||
TableFuncScanState * |
||||
ExecInitTableFuncScan(TableFuncScan *node, EState *estate, int eflags) |
||||
{ |
||||
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; |
||||
|
||||
/*
|
||||
* Miscellaneous initialization |
||||
* |
||||
* create expression context for node |
||||
*/ |
||||
ExecAssignExprContext(estate, &scanstate->ss.ps); |
||||
|
||||
/*
|
||||
* initialize child expressions |
||||
*/ |
||||
scanstate->ss.ps.targetlist = (List *) |
||||
ExecInitExpr((Expr *) node->scan.plan.targetlist, |
||||
(PlanState *) scanstate); |
||||
scanstate->ss.ps.qual = (List *) |
||||
ExecInitExpr((Expr *) node->scan.plan.qual, |
||||
(PlanState *) scanstate); |
||||
|
||||
/*
|
||||
* tuple table initialization |
||||
*/ |
||||
ExecInitResultTupleSlot(estate, &scanstate->ss.ps); |
||||
ExecInitScanTupleSlot(estate, &scanstate->ss); |
||||
|
||||
/*
|
||||
* initialize source tuple type |
||||
*/ |
||||
tupdesc = BuildDescFromLists(tf->colnames, |
||||
tf->coltypes, |
||||
tf->coltypmods, |
||||
tf->colcollations); |
||||
|
||||
ExecAssignScanType(&scanstate->ss, tupdesc); |
||||
|
||||
/*
|
||||
* Initialize result tuple type and projection info. |
||||
*/ |
||||
ExecAssignResultTypeFromTL(&scanstate->ss.ps); |
||||
ExecAssignScanProjectionInfo(&scanstate->ss); |
||||
|
||||
/* Only XMLTABLE is supported currently */ |
||||
scanstate->routine = &XmlTableRoutine; |
||||
|
||||
scanstate->perValueCxt = |
||||
AllocSetContextCreate(CurrentMemoryContext, |
||||
"TableFunc per value context", |
||||
ALLOCSET_DEFAULT_SIZES); |
||||
scanstate->opaque = NULL; /* initialized at runtime */ |
||||
|
||||
scanstate->ns_names = tf->ns_names; |
||||
|
||||
scanstate->ns_uris = (List *) |
||||
ExecInitExpr((Expr *) tf->ns_uris, (PlanState *) scanstate); |
||||
scanstate->docexpr = |
||||
ExecInitExpr((Expr *) tf->docexpr, (PlanState *) scanstate); |
||||
scanstate->rowexpr = |
||||
ExecInitExpr((Expr *) tf->rowexpr, (PlanState *) scanstate); |
||||
scanstate->colexprs = (List *) |
||||
ExecInitExpr((Expr *) tf->colexprs, (PlanState *) scanstate); |
||||
scanstate->coldefexprs = (List *) |
||||
ExecInitExpr((Expr *) tf->coldefexprs, (PlanState *) scanstate); |
||||
|
||||
scanstate->notnulls = tf->notnulls; |
||||
|
||||
/* these are allocated now and initialized later */ |
||||
scanstate->in_functions = palloc(sizeof(FmgrInfo) * tupdesc->natts); |
||||
scanstate->typioparams = palloc(sizeof(Oid) * tupdesc->natts); |
||||
|
||||
/*
|
||||
* Fill in the necessary fmgr infos. |
||||
*/ |
||||
for (i = 0; i < tupdesc->natts; i++) |
||||
{ |
||||
Oid in_funcid; |
||||
|
||||
getTypeInputInfo(tupdesc->attrs[i]->atttypid, |
||||
&in_funcid, &scanstate->typioparams[i]); |
||||
fmgr_info(in_funcid, &scanstate->in_functions[i]); |
||||
} |
||||
|
||||
return scanstate; |
||||
} |
||||
|
||||
/* ----------------------------------------------------------------
|
||||
* ExecEndTableFuncscan |
||||
* |
||||
* frees any storage allocated through C routines. |
||||
* ---------------------------------------------------------------- |
||||
*/ |
||||
void |
||||
ExecEndTableFuncScan(TableFuncScanState *node) |
||||
{ |
||||
/*
|
||||
* Free the exprcontext |
||||
*/ |
||||
ExecFreeExprContext(&node->ss.ps); |
||||
|
||||
/*
|
||||
* clean out the tuple table |
||||
*/ |
||||
ExecClearTuple(node->ss.ps.ps_ResultTupleSlot); |
||||
ExecClearTuple(node->ss.ss_ScanTupleSlot); |
||||
|
||||
/*
|
||||
* Release tuplestore resources |
||||
*/ |
||||
if (node->tupstore != NULL) |
||||
tuplestore_end(node->tupstore); |
||||
node->tupstore = NULL; |
||||
} |
||||
|
||||
/* ----------------------------------------------------------------
|
||||
* ExecReScanTableFuncscan |
||||
* |
||||
* Rescans the relation. |
||||
* ---------------------------------------------------------------- |
||||
*/ |
||||
void |
||||
ExecReScanTableFuncScan(TableFuncScanState *node) |
||||
{ |
||||
Bitmapset *chgparam = node->ss.ps.chgParam; |
||||
|
||||
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); |
||||
} |
||||
|
||||
/* ----------------------------------------------------------------
|
||||
* tfuncFetchRows |
||||
* |
||||
* Read rows from a TableFunc producer |
||||
* ---------------------------------------------------------------- |
||||
*/ |
||||
static void |
||||
tfuncFetchRows(TableFuncScanState *tstate, ExprContext *econtext) |
||||
{ |
||||
const TableFuncRoutine *routine = tstate->routine; |
||||
MemoryContext oldcxt; |
||||
Datum value; |
||||
bool isnull; |
||||
|
||||
Assert(tstate->opaque == NULL); |
||||
|
||||
/* build tuplestore for the result */ |
||||
oldcxt = MemoryContextSwitchTo(econtext->ecxt_per_query_memory); |
||||
tstate->tupstore = tuplestore_begin_heap(false, false, work_mem); |
||||
|
||||
PG_TRY(); |
||||
{ |
||||
routine->InitOpaque(tstate, |
||||
tstate->ss.ss_ScanTupleSlot->tts_tupleDescriptor->natts); |
||||
|
||||
/*
|
||||
* If evaluating the document expression returns NULL, the table |
||||
* expression is empty and we return immediately. |
||||
*/ |
||||
value = ExecEvalExpr(tstate->docexpr, econtext, &isnull); |
||||
|
||||
if (!isnull) |
||||
{ |
||||
/* otherwise, pass the document value to the table builder */ |
||||
tfuncInitialize(tstate, econtext, value); |
||||
|
||||
/* initialize ordinality counter */ |
||||
tstate->ordinal = 1; |
||||
|
||||
/* Load all rows into the tuplestore, and we're done */ |
||||
tfuncLoadRows(tstate, econtext); |
||||
} |
||||
} |
||||
PG_CATCH(); |
||||
{ |
||||
if (tstate->opaque != NULL) |
||||
routine->DestroyOpaque(tstate); |
||||
PG_RE_THROW(); |
||||
} |
||||
PG_END_TRY(); |
||||
|
||||
/* return to original memory context, and clean up */ |
||||
MemoryContextSwitchTo(oldcxt); |
||||
|
||||
if (tstate->opaque != NULL) |
||||
{ |
||||
routine->DestroyOpaque(tstate); |
||||
tstate->opaque = NULL; |
||||
} |
||||
|
||||
return; |
||||
} |
||||
|
||||
/*
|
||||
* Fill in namespace declarations, the row filter, and column filters in a |
||||
* table expression builder context. |
||||
*/ |
||||
static void |
||||
tfuncInitialize(TableFuncScanState *tstate, ExprContext *econtext, Datum doc) |
||||
{ |
||||
const TableFuncRoutine *routine = tstate->routine; |
||||
TupleDesc tupdesc; |
||||
ListCell *lc1, |
||||
*lc2; |
||||
bool isnull; |
||||
int colno; |
||||
Datum value; |
||||
int ordinalitycol = |
||||
((TableFuncScan *) (tstate->ss.ps.plan))->tablefunc->ordinalitycol; |
||||
|
||||
/*
|
||||
* Install the document as a possibly-toasted Datum into the tablefunc |
||||
* context. |
||||
*/ |
||||
routine->SetDocument(tstate, doc); |
||||
|
||||
/* Evaluate namespace specifications */ |
||||
forboth(lc1, tstate->ns_uris, lc2, tstate->ns_names) |
||||
{ |
||||
ExprState *expr = (ExprState *) lfirst(lc1); |
||||
char *ns_name = strVal(lfirst(lc2)); |
||||
char *ns_uri; |
||||
|
||||
value = ExecEvalExpr((ExprState *) expr, econtext, &isnull); |
||||
if (isnull) |
||||
ereport(ERROR, |
||||
(errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED), |
||||
errmsg("namespace URI must not be null"))); |
||||
ns_uri = TextDatumGetCString(value); |
||||
|
||||
routine->SetNamespace(tstate, ns_name, ns_uri); |
||||
} |
||||
|
||||
/* Install the row filter expression into the table builder context */ |
||||
value = ExecEvalExpr(tstate->rowexpr, econtext, &isnull); |
||||
if (isnull) |
||||
ereport(ERROR, |
||||
(errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED), |
||||
errmsg("row filter expression must not be null"))); |
||||
|
||||
routine->SetRowFilter(tstate, TextDatumGetCString(value)); |
||||
|
||||
/*
|
||||
* Install the column filter expressions into the table builder context. |
||||
* If an expression is given, use that; otherwise the column name itself |
||||
* is the column filter. |
||||
*/ |
||||
colno = 0; |
||||
tupdesc = tstate->ss.ss_ScanTupleSlot->tts_tupleDescriptor; |
||||
foreach(lc1, tstate->colexprs) |
||||
{ |
||||
char *colfilter; |
||||
|
||||
if (colno != ordinalitycol) |
||||
{ |
||||
ExprState *colexpr = lfirst(lc1); |
||||
|
||||
if (colexpr != NULL) |
||||
{ |
||||
value = ExecEvalExpr(colexpr, econtext, &isnull); |
||||
if (isnull) |
||||
ereport(ERROR, |
||||
(errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED), |
||||
errmsg("column filter expression must not be null"), |
||||
errdetail("Filter for column \"%s\" is null.", |
||||
NameStr(tupdesc->attrs[colno]->attname)))); |
||||
colfilter = TextDatumGetCString(value); |
||||
} |
||||
else |
||||
colfilter = NameStr(tupdesc->attrs[colno]->attname); |
||||
|
||||
routine->SetColumnFilter(tstate, colfilter, colno); |
||||
} |
||||
|
||||
colno++; |
||||
} |
||||
} |
||||
|
||||
/*
|
||||
* Load all the rows from the TableFunc table builder into a tuplestore. |
||||
*/ |
||||
static void |
||||
tfuncLoadRows(TableFuncScanState *tstate, ExprContext *econtext) |
||||
{ |
||||
const TableFuncRoutine *routine = tstate->routine; |
||||
TupleTableSlot *slot = tstate->ss.ss_ScanTupleSlot; |
||||
TupleDesc tupdesc = slot->tts_tupleDescriptor; |
||||
Datum *values = slot->tts_values; |
||||
bool *nulls = slot->tts_isnull; |
||||
int natts = tupdesc->natts; |
||||
MemoryContext oldcxt; |
||||
int ordinalitycol; |
||||
|
||||
ordinalitycol = |
||||
((TableFuncScan *) (tstate->ss.ps.plan))->tablefunc->ordinalitycol; |
||||
oldcxt = MemoryContextSwitchTo(tstate->perValueCxt); |
||||
|
||||
/*
|
||||
* Keep requesting rows from the table builder until there aren't any. |
||||
*/ |
||||
while (routine->FetchRow(tstate)) |
||||
{ |
||||
ListCell *cell = list_head(tstate->coldefexprs); |
||||
int colno; |
||||
|
||||
ExecClearTuple(tstate->ss.ss_ScanTupleSlot); |
||||
|
||||
/*
|
||||
* Obtain the value of each column for this row, installing them into the |
||||
* slot; then add the tuple to the tuplestore. |
||||
*/ |
||||
for (colno = 0; colno < natts; colno++) |
||||
{ |
||||
if (colno == ordinalitycol) |
||||
{ |
||||
/* Fast path for ordinality column */ |
||||
values[colno] = Int32GetDatum(tstate->ordinal++); |
||||
nulls[colno] = false; |
||||
} |
||||
else |
||||
{ |
||||
bool isnull; |
||||
|
||||
values[colno] = routine->GetValue(tstate, |
||||
colno, |
||||
tupdesc->attrs[colno]->atttypid, |
||||
tupdesc->attrs[colno]->atttypmod, |
||||
&isnull); |
||||
|
||||
/* No value? Evaluate and apply the default, if any */ |
||||
if (isnull && cell != NULL) |
||||
{ |
||||
ExprState *coldefexpr = (ExprState *) lfirst(cell); |
||||
|
||||
if (coldefexpr != NULL) |
||||
values[colno] = ExecEvalExpr(coldefexpr, econtext, |
||||
&isnull); |
||||
} |
||||
|
||||
/* Verify a possible NOT NULL constraint */ |
||||
if (isnull && bms_is_member(colno, tstate->notnulls)) |
||||
ereport(ERROR, |
||||
(errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED), |
||||
errmsg("null is not allowed in column \"%s\"", |
||||
NameStr(tupdesc->attrs[colno]->attname)))); |
||||
|
||||
nulls[colno] = isnull; |
||||
} |
||||
|
||||
/* advance list of default expressions */ |
||||
if (cell != NULL) |
||||
cell = lnext(cell); |
||||
} |
||||
|
||||
tuplestore_putvalues(tstate->tupstore, tupdesc, values, nulls); |
||||
|
||||
MemoryContextReset(tstate->perValueCxt); |
||||
} |
||||
|
||||
MemoryContextSwitchTo(oldcxt); |
||||
} |
||||
@ -0,0 +1,24 @@ |
||||
/*-------------------------------------------------------------------------
|
||||
* |
||||
* nodeTableFuncscan.h |
||||
* |
||||
* |
||||
* |
||||
* Portions Copyright (c) 1996-2017, PostgreSQL Global Development Group |
||||
* Portions Copyright (c) 1994, Regents of the University of California |
||||
* |
||||
* src/include/executor/nodeTableFuncscan.h |
||||
* |
||||
*------------------------------------------------------------------------- |
||||
*/ |
||||
#ifndef NODETABLEFUNCSCAN_H |
||||
#define NODETABLEFUNCSCAN_H |
||||
|
||||
#include "nodes/execnodes.h" |
||||
|
||||
extern TableFuncScanState *ExecInitTableFuncScan(TableFuncScan *node, EState *estate, int eflags); |
||||
extern TupleTableSlot *ExecTableFuncScan(TableFuncScanState *node); |
||||
extern void ExecEndTableFuncScan(TableFuncScanState *node); |
||||
extern void ExecReScanTableFuncScan(TableFuncScanState *node); |
||||
|
||||
#endif /* NODETABLEFUNCSCAN_H */ |
||||
@ -0,0 +1,67 @@ |
||||
/*-------------------------------------------------------------------------
|
||||
* |
||||
* tablefunc.h |
||||
* interface for TableFunc executor node |
||||
* |
||||
* Portions Copyright (c) 1996-2017, PostgreSQL Global Development Group |
||||
* Portions Copyright (c) 1994, Regents of the University of California |
||||
* |
||||
* src/include/executor/tablefunc.h |
||||
* |
||||
*------------------------------------------------------------------------- |
||||
*/ |
||||
#ifndef _TABLEFUNC_H |
||||
#define _TABLEFUNC_H |
||||
|
||||
/* Forward-declare this to avoid including execnodes.h here */ |
||||
struct TableFuncScanState; |
||||
|
||||
/*
|
||||
* TableFuncRoutine holds function pointers used for generating content of |
||||
* table-producer functions, such as XMLTABLE. |
||||
* |
||||
* InitBuilder initialize table builder private objects. The output tuple |
||||
* descriptor, input functions for the columns, and typioparams are passed |
||||
* from executor state. |
||||
* |
||||
* SetDoc is called to define the input document. The table builder may |
||||
* apply additional transformations not exposed outside the table builder |
||||
* context. |
||||
* |
||||
* SetNamespace is called to pass namespace declarations from the table |
||||
* expression. This function may be NULL if namespaces are not supported by |
||||
* the table builder. Namespaces must be given before setting the row and |
||||
* column filters. If the name is given as NULL, the entry shall be for the |
||||
* default namespace. |
||||
* |
||||
* SetRowFilter is called do define the row-generating filter, which shall be |
||||
* used to extract each row from the input document. |
||||
* |
||||
* SetColumnFilter is called once for each column, to define the column- |
||||
* generating filter for the given column. |
||||
* |
||||
* FetchRow shall be called repeatedly until it returns that no more rows are |
||||
* found in the document. On each invocation it shall set state in the table |
||||
* builder context such that each subsequent GetValue call returns the values |
||||
* for the indicated column for the row being processed. |
||||
* |
||||
* DestroyBuilder shall release all resources associated with a table builder |
||||
* context. It may be called either because all rows have been consumed, or |
||||
* because an error ocurred while processing the table expression. |
||||
*/ |
||||
typedef struct TableFuncRoutine |
||||
{ |
||||
void (*InitOpaque) (struct TableFuncScanState *state, int natts); |
||||
void (*SetDocument) (struct TableFuncScanState *state, Datum value); |
||||
void (*SetNamespace) (struct TableFuncScanState *state, char *name, |
||||
char *uri); |
||||
void (*SetRowFilter) (struct TableFuncScanState *state, char *path); |
||||
void (*SetColumnFilter) (struct TableFuncScanState *state, |
||||
char *path, int colnum); |
||||
bool (*FetchRow) (struct TableFuncScanState *state); |
||||
Datum (*GetValue) (struct TableFuncScanState *state, int colnum, |
||||
Oid typid, int32 typmod, bool *isnull); |
||||
void (*DestroyOpaque) (struct TableFuncScanState *state); |
||||
} TableFuncRoutine; |
||||
|
||||
#endif /* _TABLEFUNC_H */ |
||||
Loading…
Reference in new issue