54 .
name =
"postgres_fdw",
59#define DEFAULT_FDW_STARTUP_COST 100.0
62#define DEFAULT_FDW_TUPLE_COST 0.2
65#define DEFAULT_FDW_SORT_MULTIPLIER 1.2
352 Index resultRelation,
386 Index resultRelation,
445 double retrieved_rows,
467 List *retrieved_attrs);
484 List *returningList);
489 List *fdw_scan_tlist,
500 const char ***param_values);
504 const char **param_values);
518 List *retrieved_attrs,
641 fpinfo->pushdown_safe =
true;
652 fpinfo->use_remote_estimate =
false;
657 fpinfo->async_capable =
false;
668 if (
fpinfo->use_remote_estimate)
722 fpinfo->retrieved_rows = -1;
723 fpinfo->rel_startup_cost = -1;
724 fpinfo->rel_total_cost = -1;
733 if (
fpinfo->use_remote_estimate)
785 fpinfo->make_outerrel_subquery =
false;
786 fpinfo->make_innerrel_subquery =
false;
826 foreach(
lc,
root->eq_classes)
922 fpinfo->qp_is_pushdown_safe =
false;
923 if (
root->query_pathkeys)
927 foreach(
lc,
root->query_pathkeys)
948 fpinfo->qp_is_pushdown_safe =
true;
961 if (!
fpinfo->use_remote_estimate)
1057 if (!
fpinfo->use_remote_estimate)
1119 if (
baserel->has_eclass_joins)
1141 baserel->lateral_referencers);
1151 foreach(
lc, clauses)
1201 &rows, &width, &disabled_nodes,
1202 &startup_cost, &total_cost);
1246 List *fdw_recheck_quals =
NIL;
1247 List *retrieved_attrs;
1249 bool has_final_sort =
false;
1250 bool has_limit =
false;
1295 if (rinfo->pseudoconstant)
1410 has_final_sort, has_limit,
false,
1411 &retrieved_attrs, ¶ms_list);
1424 fdw_private =
lappend(fdw_private,
1464 for (
int i = 0;
i < tupdesc->
natts;
i++)
1489 att->atttypid = reltype;
1529 if (
fsplan->scan.scanrelid > 0)
1530 rtindex =
fsplan->scan.scanrelid;
1559 "postgres_fdw tuple data",
1562 "postgres_fdw temporary data",
1569 if (
fsplan->scan.scanrelid > 0)
1684 snprintf(sql,
sizeof(sql),
"CLOSE c%u",
1690 snprintf(sql,
sizeof(sql),
"MOVE BACKWARD ALL IN c%u",
1695 snprintf(sql,
sizeof(sql),
"CLOSE c%u",
1729 if (fsstate ==
NULL)
1779 Index resultRelation,
1841 elog(
ERROR,
"system-column update is not supported");
1849 if (
plan->withCheckOptionLists)
1856 if (
plan->returningLists)
1868 elog(
ERROR,
"unexpected ON CONFLICT specification: %d",
1869 (
int)
plan->onConflictAction);
1894 elog(
ERROR,
"unexpected operation: %d", (
int) operation);
1927 List *retrieved_attrs;
2056 batch_size =
fmstate->batch_size;
2164 Index resultRelation;
2187 errmsg(
"cannot route tuples into foreign table to be updated \"%s\"",
2210 elog(
ERROR,
"unexpected ON CONFLICT specification: %d",
2211 (
int) onConflictAction);
2266 retrieved_attrs !=
NIL,
2451 Index resultRelation,
2493 if (
fscan->scan.scanrelid == 0)
2500 foreignrel =
root->simple_rel_array[resultRelation];
2501 rte =
root->simple_rte_array[resultRelation];
2528 elog(
ERROR,
"system-column update is not supported");
2556 if (
plan->returningLists)
2569 if (
fscan->scan.scanrelid == 0)
2585 returningList, &retrieved_attrs);
2591 returningList, &retrieved_attrs);
2594 elog(
ERROR,
"unexpected operation: %d", (
int) operation);
2601 fscan->operation = operation;
2602 fscan->resultRelation = resultRelation;
2607 fscan->fdw_exprs = params_list;
2621 if (
fscan->scan.scanrelid == 0)
2635 if (
fscan->scan.plan.async_capable)
2636 fscan->scan.plan.async_capable =
false;
2678 if (
fsplan->scan.scanrelid == 0)
2692 if (
fsplan->scan.scanrelid == 0)
2721 "postgres_fdw temporary data",
2729 if (
fsplan->scan.scanrelid == 0)
2741 if (
fsplan->scan.scanrelid == 0)
2749 dmstate->numParams = numParams;
2773 if (
dmstate->num_tuples == -1)
2834 List *fdw_private =
plan->fdw_private;
2866 if (
isdigit((
unsigned char) *ptr))
2868 int rti =
strtol(ptr, &ptr, 10);
2883 if (
isdigit((
unsigned char) *ptr))
2885 int rti =
strtol(ptr, &ptr, 10);
2909 if (refname ==
NULL)
2910 refname =
rte->eref->aliasname;
3016 serverid =
table->serverid;
3019 foreach(cell, server->
options)
3039 foreach(cell,
table->options)
3053 errmsg(
"foreign table \"%s\" does not allow truncates",
3101 double retrieved_rows;
3103 int disabled_nodes = 0;
3117 if (
fpinfo->use_remote_estimate)
3129 List *retrieved_attrs;
3142 fdw_scan_tlist =
NIL;
3160 remote_conds, pathkeys,
3163 false, &retrieved_attrs,
NULL);
3168 &startup_cost, &total_cost);
3171 retrieved_rows = rows;
3184 startup_cost +=
fpinfo->local_conds_cost.startup;
3185 total_cost +=
fpinfo->local_conds_cost.per_tuple * retrieved_rows;
3188 total_cost +=
local_cost.per_tuple * retrieved_rows;
3225 if (
fpinfo->rel_startup_cost >= 0 &&
fpinfo->rel_total_cost >= 0)
3230 retrieved_rows =
fpinfo->retrieved_rows;
3232 startup_cost =
fpinfo->rel_startup_cost;
3233 run_cost =
fpinfo->rel_total_cost -
fpinfo->rel_startup_cost;
3262 rows = foreignrel->
rows;
3279 retrieved_rows =
Min(retrieved_rows, nrows);
3304 startup_cost +=
fpinfo->local_conds_cost.startup;
3323 run_cost += nrows *
join_cost.per_tuple;
3326 run_cost +=
fpinfo->local_conds_cost.per_tuple * retrieved_rows;
3339 double numGroups = 1;
3360 if (
root->parse->hasAggs)
3376 if (
root->hasHavingQual)
3391 rows = retrieved_rows = numGroups;
3404 startup_cost =
ofpinfo->rel_startup_cost;
3406 startup_cost +=
aggcosts.transCost.startup;
3408 startup_cost +=
aggcosts.finalCost.startup;
3420 run_cost +=
aggcosts.finalCost.per_tuple * numGroups;
3424 if (
root->hasHavingQual)
3433 startup_cost +=
fpinfo->local_conds_cost.startup;
3434 run_cost +=
fpinfo->local_conds_cost.per_tuple * retrieved_rows;
3446 rows = foreignrel->
rows;
3454 retrieved_rows =
Min(retrieved_rows, foreignrel->
tuples);
3483 if (pathkeys !=
NIL)
3497 retrieved_rows, width,
3500 &startup_cost, &run_cost);
3509 total_cost = startup_cost + run_cost;
3516 retrieved_rows = rows;
3551 fpinfo->retrieved_rows = retrieved_rows;
3552 fpinfo->rel_startup_cost = startup_cost;
3553 fpinfo->rel_total_cost = total_cost;
3562 startup_cost +=
fpinfo->fdw_startup_cost;
3563 total_cost +=
fpinfo->fdw_startup_cost;
3564 total_cost +=
fpinfo->fdw_tuple_cost * retrieved_rows;
3581 if (!
fpinfo->use_remote_estimate &&
3587 total_cost -= (total_cost - startup_cost) * 0.05 *
3605 double *rows,
int *width,
3606 Cost *startup_cost,
Cost *total_cost)
3628 elog(
ERROR,
"could not interpret EXPLAIN output: \"%s\"", line);
3629 n =
sscanf(p,
"(cost=%lf..%lf rows=%lf width=%d)",
3630 startup_cost, total_cost, rows, width);
3632 elog(
ERROR,
"could not interpret EXPLAIN output: \"%s\"", line);
3643 double retrieved_rows,
3645 double limit_tuples,
3702 Expr *expr =
em->em_expr;
3718 state->current = expr;
3837 snprintf(sql,
sizeof(sql),
"FETCH %d FROM c%u",
3852 for (
i = 0;
i < numrows;
i++)
3967 List *retrieved_attrs)
4002 fmstate->target_attrs = target_attrs;
4003 fmstate->values_end = values_end;
4004 fmstate->has_returning = has_returning;
4005 fmstate->retrieved_attrs = retrieved_attrs;
4009 "postgres_fdw temporary data",
4029 elog(
ERROR,
"could not find junk ctid column");
4045 Assert(!attr->attisdropped);
4048 if (attr->attgenerated)
4098 if (
fmstate->conn_state->pendingAreq)
4409 var->
varno == rtindex &&
4422 for (
i = 1;
i <= tupdesc->
natts;
i++)
4428 if (attr->attisdropped)
4457 var->
varno == rtindex &&
4520 int numParams =
dmstate->numParams;
4524 if (
dmstate->conn_state->pendingAreq)
4634 List *fdw_scan_tlist,
4659 dmstate->hasSystemCols =
false;
4660 foreach(
lc, fdw_scan_tlist)
4671 if (var->
varno == rtindex &&
4685 dmstate->hasSystemCols =
true;
4810 const char ***param_values)
4821 foreach(
lc, fdw_exprs)
4843 *param_values = (
const char **)
palloc0(numParams *
sizeof(
char *));
4853 const char **param_values)
4862 foreach(
lc, param_exprs)
4876 param_values[
i] =
NULL;
4930 elog(
ERROR,
"unexpected result from deparseAnalyzeSizeSql query");
4979 elog(
ERROR,
"unexpected result from deparseAnalyzeInfoSql query");
5022 double reltuples = -1.0;
5031 astate.
rel = relation;
5044 "postgres_fdw temporary data",
5117 errmsg(
"remote server does not support TABLESAMPLE feature")));
5143 if ((reltuples <= 0) || (targrows >= reltuples))
5262 for (
i = 0;
i < numrows;
i++)
5294 (
errmsg(
"\"%s\": table contains %.0f rows, %d rows in sample",
5320 if (astate->
numrows < targrows)
5339 Assert(pos >= 0 && pos < targrows);
5391 foreach(
lc,
stmt->options)
5435 errmsg(
"schema \"%s\" is not present on foreign server \"%s\"",
5461 " format_type(atttypid, atttypmod), "
5463 " pg_get_expr(adbin, adrelid), ");
5476 " collnsp.nspname ");
5483 " JOIN pg_namespace n ON "
5484 " relnamespace = n.oid "
5485 " LEFT JOIN pg_attribute a ON "
5486 " attrelid = c.oid AND attnum > 0 "
5487 " AND NOT attisdropped "
5488 " LEFT JOIN pg_attrdef ad ON "
5489 " adrelid = c.oid AND adnum = attnum ");
5493 " LEFT JOIN pg_collation coll ON "
5494 " coll.oid = attcollation "
5495 " LEFT JOIN pg_namespace collnsp ON "
5496 " collnsp.oid = collnamespace ");
5499 "WHERE c.relkind IN ("
5505 " AND n.nspname = ");
5517 bool first_item =
true;
5525 foreach(
lc,
stmt->table_list)
5549 for (
i = 0;
i < numrows;)
5552 bool first_item =
true;
5611 (!attgenerated || !attgenerated[0]))
5620 " GENERATED ALWAYS AS (%s) STORED",
5628 while (++
i < numrows &&
5781 joinclauses =
lappend(joinclauses, rinfo);
5802 foreach(
lc,
root->placeholder_list)
5817 fpinfo->joinclauses = joinclauses;
5819 fpinfo->outerrel = outerrel;
5820 fpinfo->innerrel = innerrel;
5821 fpinfo->jointype = jointype;
5829 fpinfo->make_outerrel_subquery =
false;
5830 fpinfo->make_innerrel_subquery =
false;
5924 fpinfo->make_outerrel_subquery =
true;
5925 fpinfo->lower_subquery_rels =
5931 fpinfo->make_innerrel_subquery =
true;
5932 fpinfo->lower_subquery_rels =
5940 elog(
ERROR,
"unsupported join type %d", jointype);
5962 fpinfo->make_outerrel_subquery =
true;
5968 fpinfo->make_innerrel_subquery =
true;
5974 fpinfo->pushdown_safe =
true;
5977 if (
fpinfo->use_remote_estimate)
5992 fpinfo->retrieved_rows = -1;
5993 fpinfo->rel_startup_cost = -1;
5994 fpinfo->rel_total_cost = -1;
6090 &rows, &width, &disabled_nodes,
6091 &startup_cost, &total_cost);
6148 foreach(
lc,
fpinfo->server->options)
6161 fpinfo->shippable_extensions =
6180 foreach(
lc,
fpinfo->table->options)
6284 if (joinrel->fdw_private)
6302 fpinfo->pushdown_safe =
false;
6303 joinrel->fdw_private =
fpinfo;
6324 elog(
DEBUG3,
"could not push down foreign join because a local path suitable for EPQ checks was not found");
6358 if (!
fpinfo->use_remote_estimate)
6365 &rows, &width, &disabled_nodes,
6366 &startup_cost, &total_cost);
6368 joinrel->
rows = rows;
6372 fpinfo->disabled_nodes = disabled_nodes;
6373 fpinfo->startup_cost = startup_cost;
6374 fpinfo->total_cost = total_cost;
6551 foreach(
lc, (
List *) havingQual)
6567 root->qual_security_level,
6617 fpinfo->grouped_tlist = tlist;
6620 fpinfo->pushdown_safe =
true;
6627 fpinfo->retrieved_rows = -1;
6628 fpinfo->rel_startup_cost = -1;
6629 fpinfo->rel_total_cost = -1;
6671 fpinfo->pushdown_safe =
false;
6689 elog(
ERROR,
"unexpected upper relation: %d", (
int) stage);
6718 !
root->hasHavingQual)
6763 &rows, &width, &disabled_nodes,
6764 &startup_cost, &total_cost);
6769 fpinfo->disabled_nodes = disabled_nodes;
6770 fpinfo->startup_cost = startup_cost;
6771 fpinfo->total_cost = total_cost;
6818 if (
parse->hasTargetSRFs)
6862 foreach(
lc,
root->sort_pathkeys)
6892 fpinfo->pushdown_safe =
true;
6897 fpextra->has_final_sort =
true;
6901 &rows, &width, &disabled_nodes,
6902 &startup_cost, &total_cost);
6918 root->sort_pathkeys,
6943 bool has_final_sort =
false;
6969 if (
parse->hasTargetSRFs)
7047 fpinfo->pushdown_safe =
true;
7072 has_final_sort =
true;
7073 pathkeys =
root->sort_pathkeys;
7126 fpinfo->pushdown_safe =
true;
7131 fpextra->has_final_sort = has_final_sort;
7149 ifpinfo->use_remote_estimate =
false;
7152 &rows, &width, &disabled_nodes,
7153 &startup_cost, &total_cost);
7194 return fpinfo->async_capable;
7231 if (
areq->request_complete)
7346 if (fetch && !pendingAreq)
7360 result =
areq->requestee->ExecProcNodeReal(
areq->requestee);
7377 if (fetch && !pendingAreq)
7411 snprintf(sql,
sizeof(sql),
"FETCH %d FROM c%u",
7446 areq->callback_pending =
false;
7464 areq->callback_pending =
false;
7473 if (
areq->requestee->instrument)
7496 List *retrieved_attrs,
7533 nulls = (
bool *)
palloc(tupdesc->
natts *
sizeof(
bool));
7535 memset(nulls,
true, tupdesc->
natts *
sizeof(
bool));
7542 errpos.fsstate = fsstate;
7552 foreach(
lc, retrieved_attrs)
7604 elog(
ERROR,
"remote query result does not match the foreign table");
7670 if (
fsplan->scan.scanrelid > 0)
7673 varno =
fsplan->scan.scanrelid;
7674 colno =
errpos->cur_attno;
7735 errcontext(
"processing expression at position %d in select list",
7824 if (
em->em_is_const)
7831 em_expr =
em->em_expr;
7835 if (!
equal(em_expr, expr))
void get_translated_update_targetlist(PlannerInfo *root, Index relid, List **processed_tlist, List **update_colnos)
void add_row_identity_var(PlannerInfo *root, Var *orig_var, Index rtindex, const char *rowid_name)
#define AttributeNumberIsValid(attributeNumber)
#define InvalidAttrNumber
Bitmapset * bms_intersect(const Bitmapset *a, const Bitmapset *b)
int bms_next_member(const Bitmapset *a, int prevbit)
Bitmapset * bms_del_member(Bitmapset *a, int x)
bool bms_is_subset(const Bitmapset *a, const Bitmapset *b)
bool bms_is_member(int x, const Bitmapset *a)
Bitmapset * bms_add_members(Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_union(const Bitmapset *a, const Bitmapset *b)
bool bms_overlap(const Bitmapset *a, const Bitmapset *b)
bool bms_nonempty_difference(const Bitmapset *a, const Bitmapset *b)
static Datum values[MAXATTR]
#define Assert(condition)
#define OidIsValid(objectId)
Selectivity clauselist_selectivity(PlannerInfo *root, List *clauses, int varRelid, JoinType jointype, SpecialJoinInfo *sjinfo)
unsigned int GetCursorNumber(PGconn *conn)
void do_sql_command(PGconn *conn, const char *sql)
PGresult * pgfdw_exec_query(PGconn *conn, const char *query, PgFdwConnState *state)
void ReleaseConnection(PGconn *conn)
PGresult * pgfdw_get_result(PGconn *conn)
void pgfdw_report_error(PGresult *res, PGconn *conn, const char *sql)
static unsigned int cursor_number
unsigned int GetPrepStmtNumber(PGconn *conn)
List * ExtractExtensionList(const char *extensionsString, bool warnOnMissing)
void set_baserel_size_estimates(PlannerInfo *root, RelOptInfo *rel)
void cost_sort(Path *path, PlannerInfo *root, List *pathkeys, int input_disabled_nodes, Cost input_cost, double tuples, int width, Cost comparison_cost, int sort_mem, double limit_tuples)
void cost_qual_eval(QualCost *cost, List *quals, PlannerInfo *root)
double clamp_row_est(double nrows)
bool is_projection_capable_path(Path *path)
ForeignScan * make_foreignscan(List *qptlist, List *qpqual, Index scanrelid, List *fdw_exprs, List *fdw_private, List *fdw_scan_tlist, List *fdw_recheck_quals, Plan *outer_plan)
Plan * change_plan_targetlist(Plan *subplan, List *tlist, bool tlist_parallel_safe)
char * defGetString(DefElem *def)
bool defGetBoolean(DefElem *def)
void deparseAnalyzeSizeSql(StringInfo buf, Relation rel)
const char * get_jointype_name(JoinType jointype)
void deparseAnalyzeInfoSql(StringInfo buf, Relation rel)
void deparseDirectDeleteSql(StringInfo buf, PlannerInfo *root, Index rtindex, Relation rel, RelOptInfo *foreignrel, List *remote_conds, List **params_list, List *returningList, List **retrieved_attrs)
void deparseDirectUpdateSql(StringInfo buf, PlannerInfo *root, Index rtindex, Relation rel, RelOptInfo *foreignrel, List *targetlist, List *targetAttrs, List *remote_conds, List **params_list, List *returningList, List **retrieved_attrs)
bool is_foreign_param(PlannerInfo *root, RelOptInfo *baserel, Expr *expr)
void deparseSelectStmtForRel(StringInfo buf, PlannerInfo *root, RelOptInfo *rel, List *tlist, List *remote_conds, List *pathkeys, bool has_final_sort, bool has_limit, bool is_subquery, List **retrieved_attrs, List **params_list)
void deparseStringLiteral(StringInfo buf, const char *val)
void rebuildInsertSql(StringInfo buf, Relation rel, char *orig_query, List *target_attrs, int values_end_len, int num_params, int num_rows)
void deparseInsertSql(StringInfo buf, RangeTblEntry *rte, Index rtindex, Relation rel, List *targetAttrs, bool doNothing, List *withCheckOptionList, List *returningList, List **retrieved_attrs, int *values_end_len)
void deparseUpdateSql(StringInfo buf, RangeTblEntry *rte, Index rtindex, Relation rel, List *targetAttrs, List *withCheckOptionList, List *returningList, List **retrieved_attrs)
void deparseDeleteSql(StringInfo buf, RangeTblEntry *rte, Index rtindex, Relation rel, List *returningList, List **retrieved_attrs)
void deparseAnalyzeSql(StringInfo buf, Relation rel, PgFdwSamplingMethod sample_method, double sample_frac, List **retrieved_attrs)
bool is_foreign_expr(PlannerInfo *root, RelOptInfo *baserel, Expr *expr)
void classifyConditions(PlannerInfo *root, RelOptInfo *baserel, List *input_conds, List **remote_conds, List **local_conds)
void deparseTruncateSql(StringInfo buf, List *rels, DropBehavior behavior, bool restart_seqs)
bool is_foreign_pathkey(PlannerInfo *root, RelOptInfo *baserel, PathKey *pathkey)
List * build_tlist_to_deparse(RelOptInfo *foreignrel)
ErrorContextCallback * error_context_stack
int errcode(int sqlerrcode)
#define ereport(elevel,...)
bool equal(const void *a, const void *b)
void setup_eclass_member_iterator(EquivalenceMemberIterator *it, EquivalenceClass *ec, Relids child_relids)
List * generate_implied_equalities_for_column(PlannerInfo *root, RelOptInfo *rel, ec_matches_callback_type callback, void *callback_arg, Relids prohibited_rels)
EquivalenceMember * eclass_member_iterator_next(EquivalenceMemberIterator *it)
bool eclass_useful_for_merging(PlannerInfo *root, EquivalenceClass *eclass, RelOptInfo *rel)
void ExecAsyncResponse(AsyncRequest *areq)
void ExecAsyncRequestPending(AsyncRequest *areq)
void ExecAsyncRequestDone(AsyncRequest *areq, TupleTableSlot *result)
List * ExecInitExprList(List *nodes, PlanState *parent)
AttrNumber ExecFindJunkAttributeInTlist(List *targetlist, const char *attrName)
TupleTableSlot * ExecStoreVirtualTuple(TupleTableSlot *slot)
HeapTuple ExecFetchSlotHeapTuple(TupleTableSlot *slot, bool materialize, bool *shouldFree)
TupleTableSlot * ExecStoreAllNullTuple(TupleTableSlot *slot)
AttInMetadata * TupleDescGetAttInMetadata(TupleDesc tupdesc)
TupleTableSlot * ExecStoreHeapTuple(HeapTuple tuple, TupleTableSlot *slot, bool shouldFree)
void ExecForceStoreHeapTuple(HeapTuple tuple, TupleTableSlot *slot, bool shouldFree)
TupleTableSlot * ExecGetReturningSlot(EState *estate, ResultRelInfo *relInfo)
Relation ExecOpenScanRelation(EState *estate, Index scanrelid, int eflags)
Oid ExecGetResultRelCheckAsUser(ResultRelInfo *relInfo, EState *estate)
#define outerPlanState(node)
static RangeTblEntry * exec_rt_fetch(Index rti, EState *estate)
static TupleTableSlot * ExecProcNode(PlanState *node)
static Datum ExecEvalExpr(ExprState *state, ExprContext *econtext, bool *isNull)
#define EXEC_FLAG_EXPLAIN_ONLY
static Datum ExecGetJunkAttribute(TupleTableSlot *slot, AttrNumber attno, bool *isNull)
int(* AcquireSampleRowsFunc)(Relation relation, int elevel, HeapTuple *rows, int targrows, double *totalrows, double *totaldeadrows)
int PQserverVersion(const PGconn *conn)
int PQsocket(const PGconn *conn)
int PQsendQueryParams(PGconn *conn, const char *command, int nParams, const Oid *paramTypes, const char *const *paramValues, const int *paramLengths, const int *paramFormats, int resultFormat)
int PQconsumeInput(PGconn *conn)
int PQsendPrepare(PGconn *conn, const char *stmtName, const char *query, int nParams, const Oid *paramTypes)
int PQsendQuery(PGconn *conn, const char *query)
int PQsendQueryPrepared(PGconn *conn, const char *stmtName, int nParams, const char *const *paramValues, const int *paramLengths, const int *paramFormats, int resultFormat)
#define palloc0_array(type, count)
#define palloc0_object(type)
Datum InputFunctionCall(FmgrInfo *flinfo, char *str, Oid typioparam, int32 typmod)
void fmgr_info(Oid functionId, FmgrInfo *finfo)
char * OutputFunctionCall(FmgrInfo *flinfo, Datum val)
#define PG_MODULE_MAGIC_EXT(...)
#define DirectFunctionCall1(func, arg1)
#define PG_FUNCTION_INFO_V1(funcname)
#define PG_RETURN_POINTER(x)
ForeignTable * GetForeignTable(Oid relid)
Path * GetExistingLocalJoinPath(RelOptInfo *joinrel)
UserMapping * GetUserMapping(Oid userid, Oid serverid)
ForeignServer * GetForeignServer(Oid serverid)
bool parse_int(const char *value, int *result, int flags, const char **hintmsg)
int NewGUCNestLevel(void)
bool parse_real(const char *value, double *result, int flags, const char **hintmsg)
void AtEOXact_GUC(bool isCommit, int nestLevel)
int set_config_option(const char *name, const char *value, GucContext context, GucSource source, GucAction action, bool changeVal, int elevel, bool is_reload)
static int server_version_num
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
void heap_freetuple(HeapTuple htup)
#define SizeofHeapTupleHeader
static void HeapTupleHeaderSetCmin(HeapTupleHeaderData *tup, CommandId cid)
static void HeapTupleHeaderSetXmin(HeapTupleHeaderData *tup, TransactionId xid)
static void HeapTupleHeaderSetXmax(HeapTupleHeaderData *tup, TransactionId xid)
Bitmapset * get_rel_all_updated_cols(PlannerInfo *root, RelOptInfo *rel)
void InstrUpdateTupleCount(Instrumentation *instr, double nTuples)
ItemPointerData * ItemPointer
static libpqsrv_PGresult * libpqsrv_PGresultSetParent(libpqsrv_PGresult *bres, MemoryContext ctx)
#define PQ_QUERY_PARAM_MAX_LIMIT
List * lappend(List *list, void *datum)
List * list_delete(List *list, void *datum)
List * list_concat(List *list1, const List *list2)
List * list_copy(const List *oldlist)
List * lappend_int(List *list, int datum)
bool list_member_ptr(const List *list, const void *datum)
void list_free(List *list)
bool list_member_int(const List *list, int datum)
bool list_member(const List *list, const void *datum)
List * list_append_unique_ptr(List *list, void *datum)
char * get_rel_name(Oid relid)
void getTypeOutputInfo(Oid type, Oid *typOutput, bool *typIsVarlena)
Oid get_rel_namespace(Oid relid)
Oid get_rel_type_id(Oid relid)
char * get_namespace_name_or_temp(Oid nspid)
Datum subpath(PG_FUNCTION_ARGS)
Var * makeVar(int varno, AttrNumber varattno, Oid vartype, int32 vartypmod, Oid varcollid, Index varlevelsup)
TargetEntry * makeTargetEntry(Expr *expr, AttrNumber resno, char *resname, bool resjunk)
void MemoryContextReset(MemoryContext context)
char * pstrdup(const char *in)
void pfree(void *pointer)
void * palloc0(Size size)
MemoryContext CurrentMemoryContext
MemoryContext GetMemoryChunkContext(void *pointer)
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
#define ALLOCSET_SMALL_SIZES
#define CHECK_FOR_INTERRUPTS()
#define INTSTYLE_POSTGRES
Oid exprType(const Node *expr)
#define IsA(nodeptr, _type_)
#define IS_OUTER_JOIN(jointype)
#define castNode(_type_, nodeptr)
#define PVC_RECURSE_PLACEHOLDERS
#define PVC_INCLUDE_PLACEHOLDERS
#define PVC_INCLUDE_AGGREGATES
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
@ FDW_IMPORT_SCHEMA_LIMIT_TO
@ FDW_IMPORT_SCHEMA_EXCEPT
#define rt_fetch(rangetable_index, rangetable)
PathKey * make_canonical_pathkey(PlannerInfo *root, EquivalenceClass *eclass, Oid opfamily, CompareType cmptype, bool nulls_first)
void update_mergeclause_eclasses(PlannerInfo *root, RestrictInfo *restrictinfo)
bool pathkeys_contained_in(List *keys1, List *keys2)
ForeignPath * create_foreign_upper_path(PlannerInfo *root, RelOptInfo *rel, PathTarget *target, double rows, int disabled_nodes, Cost startup_cost, Cost total_cost, List *pathkeys, Path *fdw_outerpath, List *fdw_restrictinfo, List *fdw_private)
ProjectionPath * create_projection_path(PlannerInfo *root, RelOptInfo *rel, Path *subpath, PathTarget *target)
SortPath * create_sort_path(PlannerInfo *root, RelOptInfo *rel, Path *subpath, List *pathkeys, double limit_tuples)
ForeignPath * create_foreignscan_path(PlannerInfo *root, RelOptInfo *rel, PathTarget *target, double rows, int disabled_nodes, Cost startup_cost, Cost total_cost, List *pathkeys, Relids required_outer, Path *fdw_outerpath, List *fdw_restrictinfo, List *fdw_private)
ForeignPath * create_foreign_join_path(PlannerInfo *root, RelOptInfo *rel, PathTarget *target, double rows, int disabled_nodes, Cost startup_cost, Cost total_cost, List *pathkeys, Relids required_outer, Path *fdw_outerpath, List *fdw_restrictinfo, List *fdw_private)
void add_path(RelOptInfo *parent_rel, Path *new_path)
void adjust_limit_rows_costs(double *rows, Cost *startup_cost, Cost *total_cost, int64 offset_est, int64 count_est)
#define RINFO_IS_PUSHED_DOWN(rinfo, joinrelids)
@ PARTITIONWISE_AGGREGATE_FULL
@ PARTITIONWISE_AGGREGATE_NONE
#define IS_SIMPLE_REL(rel)
#define get_pathtarget_sortgroupref(target, colno)
#define planner_rt_fetch(rti, root)
#define IS_OTHER_REL(rel)
#define IS_UPPER_REL(rel)
FormData_pg_attribute * Form_pg_attribute
#define lfirst_node(type, lc)
static int list_length(const List *l)
#define forboth(cell1, list1, cell2, list2)
#define list_make5(x1, x2, x3, x4, x5)
static void * list_nth(const List *list, int n)
#define list_make3(x1, x2, x3)
#define list_nth_node(type, list, n)
#define list_make2(x1, x2)
#define list_make4(x1, x2, x3, x4)
static const struct lconv_member_info table[]
static char buf[DEFAULT_XLOG_SEG_SIZE]
static Datum PointerGetDatum(const void *X)
static Pointer DatumGetPointer(Datum X)
static Datum CStringGetDatum(const char *X)
static int postgresGetForeignModifyBatchSize(ResultRelInfo *resultRelInfo)
#define DEFAULT_FDW_SORT_MULTIPLIER
static const char ** convert_prep_stmt_params(PgFdwModifyState *fmstate, ItemPointer tupleid, TupleTableSlot **slots, int numSlots)
static TupleTableSlot * apply_returning_filter(PgFdwDirectModifyState *dmstate, ResultRelInfo *resultRelInfo, TupleTableSlot *slot, EState *estate)
static bool foreign_join_ok(PlannerInfo *root, RelOptInfo *joinrel, JoinType jointype, RelOptInfo *outerrel, RelOptInfo *innerrel, JoinPathExtraData *extra)
static void postgresBeginForeignScan(ForeignScanState *node, int eflags)
static bool postgresIsForeignPathAsyncCapable(ForeignPath *path)
static void store_returning_result(PgFdwModifyState *fmstate, TupleTableSlot *slot, PGresult *res)
static void create_cursor(ForeignScanState *node)
static void postgresExecForeignTruncate(List *rels, DropBehavior behavior, bool restart_seqs)
static void postgresExplainForeignModify(ModifyTableState *mtstate, ResultRelInfo *rinfo, List *fdw_private, int subplan_index, ExplainState *es)
static void analyze_row_processor(PGresult *res, int row, PgFdwAnalyzeState *astate)
static TupleTableSlot ** postgresExecForeignBatchInsert(EState *estate, ResultRelInfo *resultRelInfo, TupleTableSlot **slots, TupleTableSlot **planSlots, int *numSlots)
static void deallocate_query(PgFdwModifyState *fmstate)
static void postgresGetForeignJoinPaths(PlannerInfo *root, RelOptInfo *joinrel, RelOptInfo *outerrel, RelOptInfo *innerrel, JoinType jointype, JoinPathExtraData *extra)
static void postgresExplainForeignScan(ForeignScanState *node, ExplainState *es)
static TupleDesc get_tupdesc_for_join_scan_tuples(ForeignScanState *node)
static TupleTableSlot * postgresExecForeignUpdate(EState *estate, ResultRelInfo *resultRelInfo, TupleTableSlot *slot, TupleTableSlot *planSlot)
static bool postgresPlanDirectModify(PlannerInfo *root, ModifyTable *plan, Index resultRelation, int subplan_index)
static void conversion_error_callback(void *arg)
static void postgresReScanForeignScan(ForeignScanState *node)
static void prepare_foreign_modify(PgFdwModifyState *fmstate)
static void postgresForeignAsyncRequest(AsyncRequest *areq)
static int postgresIsForeignRelUpdatable(Relation rel)
void reset_transmission_modes(int nestlevel)
int set_transmission_modes(void)
static double postgresGetAnalyzeInfoForForeignTable(Relation relation, bool *can_tablesample)
FdwDirectModifyPrivateIndex
@ FdwDirectModifyPrivateSetProcessed
@ FdwDirectModifyPrivateHasReturning
@ FdwDirectModifyPrivateRetrievedAttrs
@ FdwDirectModifyPrivateUpdateSql
static void rebuild_fdw_scan_tlist(ForeignScan *fscan, List *tlist)
static ForeignScan * postgresGetForeignPlan(PlannerInfo *root, RelOptInfo *foreignrel, Oid foreigntableid, ForeignPath *best_path, List *tlist, List *scan_clauses, Plan *outer_plan)
static void postgresEndForeignScan(ForeignScanState *node)
static void postgresGetForeignPaths(PlannerInfo *root, RelOptInfo *baserel, Oid foreigntableid)
static void add_foreign_grouping_paths(PlannerInfo *root, RelOptInfo *input_rel, RelOptInfo *grouped_rel, GroupPathExtraData *extra)
static List * postgresPlanForeignModify(PlannerInfo *root, ModifyTable *plan, Index resultRelation, int subplan_index)
static void estimate_path_cost_size(PlannerInfo *root, RelOptInfo *foreignrel, List *param_join_conds, List *pathkeys, PgFdwPathExtraData *fpextra, double *p_rows, int *p_width, int *p_disabled_nodes, Cost *p_startup_cost, Cost *p_total_cost)
static void fetch_more_data(ForeignScanState *node)
static void prepare_query_params(PlanState *node, List *fdw_exprs, int numParams, FmgrInfo **param_flinfo, List **param_exprs, const char ***param_values)
static void postgresEndForeignModify(EState *estate, ResultRelInfo *resultRelInfo)
static void produce_tuple_asynchronously(AsyncRequest *areq, bool fetch)
static ForeignScan * find_modifytable_subplan(PlannerInfo *root, ModifyTable *plan, Index rtindex, int subplan_index)
static void add_foreign_ordered_paths(PlannerInfo *root, RelOptInfo *input_rel, RelOptInfo *ordered_rel)
static bool semijoin_target_ok(PlannerInfo *root, RelOptInfo *joinrel, RelOptInfo *outerrel, RelOptInfo *innerrel)
static void merge_fdw_options(PgFdwRelationInfo *fpinfo, const PgFdwRelationInfo *fpinfo_o, const PgFdwRelationInfo *fpinfo_i)
static void postgresAddForeignUpdateTargets(PlannerInfo *root, Index rtindex, RangeTblEntry *target_rte, Relation target_relation)
static void postgresGetForeignRelSize(PlannerInfo *root, RelOptInfo *baserel, Oid foreigntableid)
static HeapTuple make_tuple_from_result_row(PGresult *res, int row, Relation rel, AttInMetadata *attinmeta, List *retrieved_attrs, ForeignScanState *fsstate, MemoryContext temp_context)
static void postgresEndDirectModify(ForeignScanState *node)
static void get_remote_estimate(const char *sql, PGconn *conn, double *rows, int *width, Cost *startup_cost, Cost *total_cost)
static void postgresForeignAsyncConfigureWait(AsyncRequest *areq)
EquivalenceMember * find_em_for_rel_target(PlannerInfo *root, EquivalenceClass *ec, RelOptInfo *rel)
static void postgresGetForeignUpperPaths(PlannerInfo *root, UpperRelationKind stage, RelOptInfo *input_rel, RelOptInfo *output_rel, void *extra)
static void apply_server_options(PgFdwRelationInfo *fpinfo)
static void close_cursor(PGconn *conn, unsigned int cursor_number, PgFdwConnState *conn_state)
@ FdwPathPrivateHasFinalSort
static int get_batch_size_option(Relation rel)
static void postgresForeignAsyncNotify(AsyncRequest *areq)
static void adjust_foreign_grouping_path_cost(PlannerInfo *root, List *pathkeys, double retrieved_rows, double width, double limit_tuples, int *p_disabled_nodes, Cost *p_startup_cost, Cost *p_run_cost)
static void add_foreign_final_paths(PlannerInfo *root, RelOptInfo *input_rel, RelOptInfo *final_rel, FinalPathExtraData *extra)
static void fetch_more_data_begin(AsyncRequest *areq)
static void execute_dml_stmt(ForeignScanState *node)
static TupleTableSlot * postgresIterateForeignScan(ForeignScanState *node)
static TupleTableSlot * postgresExecForeignDelete(EState *estate, ResultRelInfo *resultRelInfo, TupleTableSlot *slot, TupleTableSlot *planSlot)
static bool foreign_grouping_ok(PlannerInfo *root, RelOptInfo *grouped_rel, Node *havingQual)
@ FdwScanPrivateRetrievedAttrs
@ FdwScanPrivateSelectSql
@ FdwScanPrivateFetchSize
@ FdwScanPrivateRelations
static bool ec_member_matches_foreign(PlannerInfo *root, RelOptInfo *rel, EquivalenceClass *ec, EquivalenceMember *em, void *arg)
@ FdwModifyPrivateUpdateSql
@ FdwModifyPrivateTargetAttnums
@ FdwModifyPrivateRetrievedAttrs
@ FdwModifyPrivateHasReturning
static TupleTableSlot ** execute_foreign_modify(EState *estate, ResultRelInfo *resultRelInfo, CmdType operation, TupleTableSlot **slots, TupleTableSlot **planSlots, int *numSlots)
static PgFdwModifyState * create_foreign_modify(EState *estate, RangeTblEntry *rte, ResultRelInfo *resultRelInfo, CmdType operation, Plan *subplan, char *query, List *target_attrs, int values_end, bool has_returning, List *retrieved_attrs)
static void add_paths_with_pathkeys_for_rel(PlannerInfo *root, RelOptInfo *rel, Path *epq_path, List *restrictlist)
static bool postgresRecheckForeignScan(ForeignScanState *node, TupleTableSlot *slot)
static List * postgresImportForeignSchema(ImportForeignSchemaStmt *stmt, Oid serverOid)
static void complete_pending_request(AsyncRequest *areq)
static bool postgresAnalyzeForeignTable(Relation relation, AcquireSampleRowsFunc *func, BlockNumber *totalpages)
static List * build_remote_returning(Index rtindex, Relation rel, List *returningList)
static TupleTableSlot * get_returning_data(ForeignScanState *node)
void process_pending_request(AsyncRequest *areq)
#define DEFAULT_FDW_TUPLE_COST
static void postgresBeginForeignModify(ModifyTableState *mtstate, ResultRelInfo *resultRelInfo, List *fdw_private, int subplan_index, int eflags)
static void process_query_params(ExprContext *econtext, FmgrInfo *param_flinfo, List *param_exprs, const char **param_values)
static void postgresBeginForeignInsert(ModifyTableState *mtstate, ResultRelInfo *resultRelInfo)
static void init_returning_filter(PgFdwDirectModifyState *dmstate, List *fdw_scan_tlist, Index rtindex)
static TupleTableSlot * postgresIterateDirectModify(ForeignScanState *node)
static void postgresBeginDirectModify(ForeignScanState *node, int eflags)
static List * get_useful_pathkeys_for_relation(PlannerInfo *root, RelOptInfo *rel)
Datum postgres_fdw_handler(PG_FUNCTION_ARGS)
static TupleTableSlot * postgresExecForeignInsert(EState *estate, ResultRelInfo *resultRelInfo, TupleTableSlot *slot, TupleTableSlot *planSlot)
static void apply_table_options(PgFdwRelationInfo *fpinfo)
static int postgresAcquireSampleRowsFunc(Relation relation, int elevel, HeapTuple *rows, int targrows, double *totalrows, double *totaldeadrows)
static void postgresEndForeignInsert(EState *estate, ResultRelInfo *resultRelInfo)
EquivalenceMember * find_em_for_rel(PlannerInfo *root, EquivalenceClass *ec, RelOptInfo *rel)
static void postgresExplainDirectModify(ForeignScanState *node, ExplainState *es)
#define DEFAULT_FDW_STARTUP_COST
static List * get_useful_ecs_for_relation(PlannerInfo *root, RelOptInfo *rel)
static void finish_foreign_modify(PgFdwModifyState *fmstate)
bool is_shippable(Oid objectId, Oid classId, PgFdwRelationInfo *fpinfo)
@ ANALYZE_SAMPLE_BERNOULLI
void get_agg_clause_costs(PlannerInfo *root, AggSplit aggsplit, AggClauseCosts *costs)
char * psprintf(const char *fmt,...)
#define RelationGetRelid(relation)
#define RelationGetDescr(relation)
#define RelationGetRelationName(relation)
RelOptInfo * find_base_rel(PlannerInfo *root, int relid)
RelOptInfo * find_join_rel(PlannerInfo *root, Relids relids)
ParamPathInfo * get_baserel_parampathinfo(PlannerInfo *root, RelOptInfo *baserel, Relids required_outer)
List * extract_actual_clauses(List *restrictinfo_list, bool pseudoconstant)
bool join_clause_is_movable_to(RestrictInfo *rinfo, RelOptInfo *baserel)
RestrictInfo * make_restrictinfo(PlannerInfo *root, Expr *clause, bool is_pushed_down, bool has_clone, bool is_clone, bool pseudoconstant, Index security_level, Relids required_relids, Relids incompatible_relids, Relids outer_relids)
const char * quote_identifier(const char *ident)
void reservoir_init_selection_state(ReservoirState rs, int n)
double sampler_random_fract(pg_prng_state *randstate)
double reservoir_get_next_S(ReservoirState rs, double t, int n)
double estimate_num_groups(PlannerInfo *root, List *groupExprs, double input_rows, List **pgset, EstimationInfo *estinfo)
PGconn * GetConnection(void)
void resetStringInfo(StringInfo str)
void appendStringInfo(StringInfo str, const char *fmt,...)
void appendStringInfoString(StringInfo str, const char *s)
void appendStringInfoChar(StringInfo str, char ch)
void initStringInfo(StringInfo str)
Bitmapset * as_needrequest
struct WaitEventSet * as_eventset
ForeignScanState * fsstate
MemoryContext es_query_cxt
struct ErrorContextCallback * previous
void(* callback)(void *arg)
MemoryContext ecxt_per_tuple_memory
TupleTableSlot * ecxt_scantuple
EndForeignInsert_function EndForeignInsert
ReScanForeignScan_function ReScanForeignScan
BeginForeignInsert_function BeginForeignInsert
RecheckForeignScan_function RecheckForeignScan
AddForeignUpdateTargets_function AddForeignUpdateTargets
BeginForeignModify_function BeginForeignModify
EndForeignModify_function EndForeignModify
BeginDirectModify_function BeginDirectModify
PlanForeignModify_function PlanForeignModify
PlanDirectModify_function PlanDirectModify
ExecForeignInsert_function ExecForeignInsert
BeginForeignScan_function BeginForeignScan
ForeignAsyncRequest_function ForeignAsyncRequest
IterateDirectModify_function IterateDirectModify
ExecForeignUpdate_function ExecForeignUpdate
GetForeignJoinPaths_function GetForeignJoinPaths
ExecForeignBatchInsert_function ExecForeignBatchInsert
GetForeignPaths_function GetForeignPaths
GetForeignModifyBatchSize_function GetForeignModifyBatchSize
GetForeignRelSize_function GetForeignRelSize
ExplainForeignScan_function ExplainForeignScan
EndForeignScan_function EndForeignScan
AnalyzeForeignTable_function AnalyzeForeignTable
EndDirectModify_function EndDirectModify
ExplainForeignModify_function ExplainForeignModify
IsForeignPathAsyncCapable_function IsForeignPathAsyncCapable
IterateForeignScan_function IterateForeignScan
ForeignAsyncNotify_function ForeignAsyncNotify
ImportForeignSchema_function ImportForeignSchema
GetForeignPlan_function GetForeignPlan
ExecForeignDelete_function ExecForeignDelete
ExecForeignTruncate_function ExecForeignTruncate
ExplainDirectModify_function ExplainDirectModify
IsForeignRelUpdatable_function IsForeignRelUpdatable
GetForeignUpperPaths_function GetForeignUpperPaths
ForeignAsyncConfigureWait_function ForeignAsyncConfigureWait
ResultRelInfo * resultRelInfo
ResultRelInfo * resultRelInfo
ReservoirStateData rstate
AttInMetadata * attinmeta
AsyncRequest * pendingAreq
PgFdwConnState * conn_state
const char ** param_values
AttInMetadata * attinmeta
AttInMetadata * attinmeta
PgFdwConnState * conn_state
struct PgFdwModifyState * aux_fmstate
const char ** param_values
AttInMetadata * attinmeta
unsigned int cursor_number
PgFdwConnState * conn_state
Instrumentation * instrument
ExprContext * ps_ExprContext
ExprContext * pi_exprContext
struct PathTarget * reltarget
QualCost baserestrictcost
struct ResultRelInfo * ri_RootResultRelInfo
List * ri_WithCheckOptions
TriggerDesc * ri_TrigDesc
ProjectionInfo * ri_projectReturning
bool ri_usesFdwDirectModify
Relation ss_currentRelation
TupleTableSlot * ss_ScanTupleSlot
bool trig_insert_after_row
bool trig_update_before_row
bool trig_insert_before_row
TupleDesc tts_tupleDescriptor
#define FirstLowInvalidHeapAttributeNumber
#define SelfItemPointerAttributeNumber
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
Datum tidin(PG_FUNCTION_ARGS)
TargetEntry * tlist_member(Expr *node, List *targetlist)
SortGroupClause * get_sortgroupref_clause_noerr(Index sortref, List *clauses)
bool grouping_is_sortable(List *groupClause)
PathTarget * copy_pathtarget(PathTarget *src)
void add_new_columns_to_pathtarget(PathTarget *target, List *exprs)
List * get_sortgrouplist_exprs(List *sgClauses, List *targetList)
List * add_to_flat_tlist(List *tlist, List *exprs)
#define InvalidTransactionId
TupleDesc CreateTupleDescCopy(TupleDesc tupdesc)
static FormData_pg_attribute * TupleDescAttr(TupleDesc tupdesc, int i)
static CompactAttribute * TupleDescCompactAttr(TupleDesc tupdesc, int i)
static Datum slot_getattr(TupleTableSlot *slot, int attnum, bool *isnull)
static TupleTableSlot * ExecClearTuple(TupleTableSlot *slot)
static void slot_getallattrs(TupleTableSlot *slot)
static TupleTableSlot * ExecCopySlot(TupleTableSlot *dstslot, TupleTableSlot *srcslot)
Integer * makeInteger(int i)
String * makeString(char *str)
Boolean * makeBoolean(bool val)
List * pull_var_clause(Node *node, int flags)
void pull_varattnos(Node *node, Index varno, Bitmapset **varattnos)
int GetNumRegisteredWaitEvents(WaitEventSet *set)
int AddWaitEventToSet(WaitEventSet *set, uint32 events, pgsocket fd, Latch *latch, void *user_data)
#define WL_SOCKET_READABLE