49#include "utils/fmgroids.h"
59 .
name =
"postgres_fdw",
64#define DEFAULT_FDW_STARTUP_COST 100.0
67#define DEFAULT_FDW_TUPLE_COST 0.2
70#define DEFAULT_FDW_SORT_MULTIPLIER 1.2
405 Index resultRelation,
439 Index resultRelation,
501 double retrieved_rows,
523 List *retrieved_attrs);
540 List *returningList);
545 List *fdw_scan_tlist,
556 const char ***param_values);
560 const char **param_values);
592 const char *schemaname,
610 List *retrieved_attrs,
734 fpinfo->pushdown_safe =
true;
745 fpinfo->use_remote_estimate =
false;
750 fpinfo->async_capable =
false;
761 if (
fpinfo->use_remote_estimate)
815 fpinfo->retrieved_rows = -1;
816 fpinfo->rel_startup_cost = -1;
817 fpinfo->rel_total_cost = -1;
826 if (
fpinfo->use_remote_estimate)
878 fpinfo->make_outerrel_subquery =
false;
879 fpinfo->make_innerrel_subquery =
false;
919 foreach(
lc,
root->eq_classes)
1015 fpinfo->qp_is_pushdown_safe =
false;
1016 if (
root->query_pathkeys)
1020 foreach(
lc,
root->query_pathkeys)
1041 fpinfo->qp_is_pushdown_safe =
true;
1054 if (!
fpinfo->use_remote_estimate)
1150 if (!
fpinfo->use_remote_estimate)
1212 if (
baserel->has_eclass_joins)
1234 baserel->lateral_referencers);
1244 foreach(
lc, clauses)
1294 &rows, &width, &disabled_nodes,
1295 &startup_cost, &total_cost);
1339 List *fdw_recheck_quals =
NIL;
1340 List *retrieved_attrs;
1342 bool has_final_sort =
false;
1343 bool has_limit =
false;
1388 if (rinfo->pseudoconstant)
1503 has_final_sort, has_limit,
false,
1504 &retrieved_attrs, ¶ms_list);
1517 fdw_private =
lappend(fdw_private,
1557 for (
int i = 0;
i < tupdesc->
natts;
i++)
1565 if (att->atttypid !=
RECORDOID || att->atttypmod >= 0)
1582 att->atttypid = reltype;
1622 if (
fsplan->scan.scanrelid > 0)
1623 rtindex =
fsplan->scan.scanrelid;
1652 "postgres_fdw tuple data",
1655 "postgres_fdw temporary data",
1662 if (
fsplan->scan.scanrelid > 0)
1777 snprintf(sql,
sizeof(sql),
"CLOSE c%u",
1783 snprintf(sql,
sizeof(sql),
"MOVE BACKWARD ALL IN c%u",
1788 snprintf(sql,
sizeof(sql),
"CLOSE c%u",
1822 if (fsstate ==
NULL)
1872 Index resultRelation,
1934 elog(
ERROR,
"system-column update is not supported");
1942 if (
plan->withCheckOptionLists)
1949 if (
plan->returningLists)
1961 elog(
ERROR,
"unexpected ON CONFLICT specification: %d",
1962 (
int)
plan->onConflictAction);
2020 List *retrieved_attrs;
2149 batch_size =
fmstate->batch_size;
2257 Index resultRelation;
2280 errmsg(
"cannot route tuples into foreign table to be updated \"%s\"",
2303 elog(
ERROR,
"unexpected ON CONFLICT specification: %d",
2304 (
int) onConflictAction);
2359 retrieved_attrs !=
NIL,
2544 Index resultRelation,
2586 if (
fscan->scan.scanrelid == 0)
2593 foreignrel =
root->simple_rel_array[resultRelation];
2594 rte =
root->simple_rte_array[resultRelation];
2621 elog(
ERROR,
"system-column update is not supported");
2649 if (
plan->returningLists)
2662 if (
fscan->scan.scanrelid == 0)
2678 returningList, &retrieved_attrs);
2684 returningList, &retrieved_attrs);
2695 fscan->resultRelation = resultRelation;
2700 fscan->fdw_exprs = params_list;
2714 if (
fscan->scan.scanrelid == 0)
2728 if (
fscan->scan.plan.async_capable)
2729 fscan->scan.plan.async_capable =
false;
2771 if (
fsplan->scan.scanrelid == 0)
2785 if (
fsplan->scan.scanrelid == 0)
2814 "postgres_fdw temporary data",
2822 if (
fsplan->scan.scanrelid == 0)
2834 if (
fsplan->scan.scanrelid == 0)
2842 dmstate->numParams = numParams;
2866 if (
dmstate->num_tuples == -1)
2927 List *fdw_private =
plan->fdw_private;
2959 if (
isdigit((
unsigned char) *ptr))
2961 int rti =
strtol(ptr, &ptr, 10);
2976 if (
isdigit((
unsigned char) *ptr))
2978 int rti =
strtol(ptr, &ptr, 10);
3002 if (refname ==
NULL)
3003 refname =
rte->eref->aliasname;
3109 serverid =
table->serverid;
3112 foreach(cell, server->
options)
3132 foreach(cell,
table->options)
3146 errmsg(
"foreign table \"%s\" does not allow truncates",
3194 double retrieved_rows;
3196 int disabled_nodes = 0;
3210 if (
fpinfo->use_remote_estimate)
3222 List *retrieved_attrs;
3235 fdw_scan_tlist =
NIL;
3253 remote_conds, pathkeys,
3256 false, &retrieved_attrs,
NULL);
3261 &startup_cost, &total_cost);
3264 retrieved_rows = rows;
3277 startup_cost +=
fpinfo->local_conds_cost.startup;
3278 total_cost +=
fpinfo->local_conds_cost.per_tuple * retrieved_rows;
3281 total_cost +=
local_cost.per_tuple * retrieved_rows;
3318 if (
fpinfo->rel_startup_cost >= 0 &&
fpinfo->rel_total_cost >= 0)
3323 retrieved_rows =
fpinfo->retrieved_rows;
3325 startup_cost =
fpinfo->rel_startup_cost;
3326 run_cost =
fpinfo->rel_total_cost -
fpinfo->rel_startup_cost;
3355 rows = foreignrel->
rows;
3372 retrieved_rows =
Min(retrieved_rows, nrows);
3397 startup_cost +=
fpinfo->local_conds_cost.startup;
3416 run_cost += nrows *
join_cost.per_tuple;
3419 run_cost +=
fpinfo->local_conds_cost.per_tuple * retrieved_rows;
3432 double numGroups = 1;
3453 if (
root->parse->hasAggs)
3469 if (
root->hasHavingQual)
3484 rows = retrieved_rows = numGroups;
3497 startup_cost =
ofpinfo->rel_startup_cost;
3499 startup_cost +=
aggcosts.transCost.startup;
3501 startup_cost +=
aggcosts.finalCost.startup;
3513 run_cost +=
aggcosts.finalCost.per_tuple * numGroups;
3517 if (
root->hasHavingQual)
3526 startup_cost +=
fpinfo->local_conds_cost.startup;
3527 run_cost +=
fpinfo->local_conds_cost.per_tuple * retrieved_rows;
3539 rows = foreignrel->
rows;
3547 retrieved_rows =
Min(retrieved_rows, foreignrel->
tuples);
3576 if (pathkeys !=
NIL)
3590 retrieved_rows, width,
3593 &startup_cost, &run_cost);
3602 total_cost = startup_cost + run_cost;
3609 retrieved_rows = rows;
3644 fpinfo->retrieved_rows = retrieved_rows;
3645 fpinfo->rel_startup_cost = startup_cost;
3646 fpinfo->rel_total_cost = total_cost;
3655 startup_cost +=
fpinfo->fdw_startup_cost;
3656 total_cost +=
fpinfo->fdw_startup_cost;
3657 total_cost +=
fpinfo->fdw_tuple_cost * retrieved_rows;
3674 if (!
fpinfo->use_remote_estimate &&
3680 total_cost -= (total_cost - startup_cost) * 0.05 *
3698 double *rows,
int *width,
3699 Cost *startup_cost,
Cost *total_cost)
3721 elog(
ERROR,
"could not interpret EXPLAIN output: \"%s\"", line);
3722 n =
sscanf(p,
"(cost=%lf..%lf rows=%lf width=%d)",
3723 startup_cost, total_cost, rows, width);
3725 elog(
ERROR,
"could not interpret EXPLAIN output: \"%s\"", line);
3736 double retrieved_rows,
3738 double limit_tuples,
3795 Expr *expr =
em->em_expr;
3811 state->current = expr;
3930 snprintf(sql,
sizeof(sql),
"FETCH %d FROM c%u",
3945 for (
i = 0;
i < numrows;
i++)
4060 List *retrieved_attrs)
4095 fmstate->target_attrs = target_attrs;
4096 fmstate->values_end = values_end;
4097 fmstate->has_returning = has_returning;
4098 fmstate->retrieved_attrs = retrieved_attrs;
4102 "postgres_fdw temporary data",
4122 elog(
ERROR,
"could not find junk ctid column");
4138 Assert(!attr->attisdropped);
4141 if (attr->attgenerated)
4191 if (
fmstate->conn_state->pendingAreq)
4502 var->
varno == rtindex &&
4515 for (
i = 1;
i <= tupdesc->
natts;
i++)
4521 if (attr->attisdropped)
4550 var->
varno == rtindex &&
4613 int numParams =
dmstate->numParams;
4617 if (
dmstate->conn_state->pendingAreq)
4727 List *fdw_scan_tlist,
4752 dmstate->hasSystemCols =
false;
4753 foreach(
lc, fdw_scan_tlist)
4764 if (var->
varno == rtindex &&
4778 dmstate->hasSystemCols =
true;
4903 const char ***param_values)
4914 foreach(
lc, fdw_exprs)
4936 *param_values = (
const char **)
palloc0(numParams *
sizeof(
char *));
4946 const char **param_values)
4955 foreach(
lc, param_exprs)
4969 param_values[
i] =
NULL;
5023 elog(
ERROR,
"unexpected result from deparseAnalyzeSizeSql query");
5072 elog(
ERROR,
"unexpected result from deparseAnalyzeInfoSql query");
5116 double reltuples = -1.0;
5125 astate.
rel = relation;
5138 "postgres_fdw temporary data",
5211 errmsg(
"remote server does not support TABLESAMPLE feature")));
5237 if ((reltuples <= 0) || (targrows >= reltuples))
5356 for (
i = 0;
i < numrows;
i++)
5388 (
errmsg(
"\"%s\": table contains %.0f rows, %d rows in sample",
5414 if (astate->
numrows < targrows)
5433 Assert(pos >= 0 && pos < targrows);
5471 const char *schemaname =
NULL;
5526 errmsg(
"cannot import statistics for foreign table \"%s.%s\" --- this foreign table has extended statistics objects",
5535 (
errmsg(
"importing statistics for foreign table \"%s.%s\"",
5552 (va_cols ==
NIL), starttime);
5555 (
errmsg(
"finished importing statistics for foreign table \"%s.%s\"",
5638 errmsg(
"could not import statistics for foreign table \"%s.%s\" --- remote table \"%s.%s\" is of relkind \"%c\" which cannot have statistics",
5664 errmsg(
"could not import statistics for foreign table \"%s.%s\" --- remote table \"%s.%s\" has no relation statistics to import",
5724 elog(
ERROR,
"unexpected result from deparseAnalyzeInfoSql query");
5742 "SELECT DISTINCT ON (attname COLLATE \"C\") attname,"
5746 " most_common_vals,"
5747 " most_common_freqs,"
5748 " histogram_bounds,"
5754 " most_common_elems,"
5755 " most_common_elem_freqs,"
5756 " elem_count_histogram,");
5759 " NULL, NULL, NULL,");
5764 " range_length_histogram,"
5765 " range_empty_frac,"
5766 " range_bounds_histogram");
5769 " NULL, NULL, NULL");
5772 " FROM pg_catalog.pg_stats"
5773 " WHERE schemaname = ");
5776 " AND tablename = ");
5779 " AND attname = ANY(%s)",
5785 " ORDER BY attname COLLATE \"C\", inherited DESC");
5788 " ORDER BY attname COLLATE \"C\"");
5795 elog(
ERROR,
"unexpected result from fetch_attstats query");
5815 for (
int i = 0;
i < tupdesc->
natts;
i++)
5820 char *remote_attname;
5874 for (
int i = 0;
i <
len;
i++)
5877 pfree(map[
i].local_attname);
5878 Assert(map[
i].remote_attname);
5879 pfree(map[
i].remote_attname);
5898 foreach(
lc, va_cols)
5917 return strcmp(
r1->remote_attname,
r2->remote_attname);
5946 errmsg(
"could not import statistics for foreign table \"%s.%s\" --- remote table \"%s.%s\" has no attribute statistics to import",
5971 if (row >= numrows - 1)
5974 errmsg(
"could not import statistics for foreign table \"%s.%s\" --- no attribute statistics found for column \"%s\" of remote table \"%s.%s\"",
5992 errmsg(
"could not import statistics for foreign table \"%s.%s\" --- no attribute statistics found for column \"%s\" of remote table \"%s.%s\"",
6002 elog(
ERROR,
"unexpected result from fetch_attstats query");
6011 if (row < numrows - 1)
6012 elog(
ERROR,
"unexpected result from fetch_attstats query");
6022 const char *schemaname,
6033 args[0].isnull =
false;
6090 &args[0], &args[1], &args[2],
6091 &args[3], &args[4], &args[5],
6092 &args[6], &args[7], &args[8],
6093 &args[9], &args[10], &args[11],
6094 &args[12], &args[13]))
6097 errmsg(
"could not import statistics for foreign table \"%s.%s\" --- attribute statistics import failed for column \"%s\" of this foreign table",
6118 args[3].value = (
Datum) 0;
6119 args[3].isnull =
true;
6120 args[4].value = (
Datum) 0;
6121 args[4].isnull =
true;
6125 &args[2], &args[3], &args[4]))
6128 errmsg(
"could not import statistics for foreign table \"%s.%s\" --- relation statistics import failed for this foreign table",
6156 arg->isnull =
false;
6176 arg->isnull =
false;
6196 arg->isnull =
false;
6216 arg->isnull =
false;
6240 arg->isnull =
false;
6270 foreach(
lc,
stmt->options)
6314 errmsg(
"schema \"%s\" is not present on foreign server \"%s\"",
6340 " format_type(atttypid, atttypmod), "
6342 " pg_get_expr(adbin, adrelid), ");
6355 " collnsp.nspname ");
6362 " JOIN pg_namespace n ON "
6363 " relnamespace = n.oid "
6364 " LEFT JOIN pg_attribute a ON "
6365 " attrelid = c.oid AND attnum > 0 "
6366 " AND NOT attisdropped "
6367 " LEFT JOIN pg_attrdef ad ON "
6368 " adrelid = c.oid AND adnum = attnum ");
6372 " LEFT JOIN pg_collation coll ON "
6373 " coll.oid = attcollation "
6374 " LEFT JOIN pg_namespace collnsp ON "
6375 " collnsp.oid = collnamespace ");
6378 "WHERE c.relkind IN ("
6384 " AND n.nspname = ");
6396 bool first_item =
true;
6404 foreach(
lc,
stmt->table_list)
6428 for (
i = 0;
i < numrows;)
6431 bool first_item =
true;
6490 (!attgenerated || !attgenerated[0]))
6499 " GENERATED ALWAYS AS (%s) STORED",
6507 while (++
i < numrows &&
6660 joinclauses =
lappend(joinclauses, rinfo);
6681 foreach(
lc,
root->placeholder_list)
6696 fpinfo->joinclauses = joinclauses;
6698 fpinfo->outerrel = outerrel;
6699 fpinfo->innerrel = innerrel;
6700 fpinfo->jointype = jointype;
6708 fpinfo->make_outerrel_subquery =
false;
6709 fpinfo->make_innerrel_subquery =
false;
6803 fpinfo->make_outerrel_subquery =
true;
6804 fpinfo->lower_subquery_rels =
6810 fpinfo->make_innerrel_subquery =
true;
6811 fpinfo->lower_subquery_rels =
6819 elog(
ERROR,
"unsupported join type %d", jointype);
6841 fpinfo->make_outerrel_subquery =
true;
6847 fpinfo->make_innerrel_subquery =
true;
6853 fpinfo->pushdown_safe =
true;
6856 if (
fpinfo->use_remote_estimate)
6871 fpinfo->retrieved_rows = -1;
6872 fpinfo->rel_startup_cost = -1;
6873 fpinfo->rel_total_cost = -1;
6969 &rows, &width, &disabled_nodes,
6970 &startup_cost, &total_cost);
7027 foreach(
lc,
fpinfo->server->options)
7040 fpinfo->shippable_extensions =
7059 foreach(
lc,
fpinfo->table->options)
7163 if (joinrel->fdw_private)
7181 fpinfo->pushdown_safe =
false;
7182 joinrel->fdw_private =
fpinfo;
7203 elog(
DEBUG3,
"could not push down foreign join because a local path suitable for EPQ checks was not found");
7237 if (!
fpinfo->use_remote_estimate)
7244 &rows, &width, &disabled_nodes,
7245 &startup_cost, &total_cost);
7247 joinrel->
rows = rows;
7251 fpinfo->disabled_nodes = disabled_nodes;
7252 fpinfo->startup_cost = startup_cost;
7253 fpinfo->total_cost = total_cost;
7430 foreach(
lc, (
List *) havingQual)
7446 root->qual_security_level,
7496 fpinfo->grouped_tlist = tlist;
7499 fpinfo->pushdown_safe =
true;
7506 fpinfo->retrieved_rows = -1;
7507 fpinfo->rel_startup_cost = -1;
7508 fpinfo->rel_total_cost = -1;
7550 fpinfo->pushdown_safe =
false;
7568 elog(
ERROR,
"unexpected upper relation: %d", (
int) stage);
7597 !
root->hasHavingQual)
7642 &rows, &width, &disabled_nodes,
7643 &startup_cost, &total_cost);
7648 fpinfo->disabled_nodes = disabled_nodes;
7649 fpinfo->startup_cost = startup_cost;
7650 fpinfo->total_cost = total_cost;
7697 if (
parse->hasTargetSRFs)
7741 foreach(
lc,
root->sort_pathkeys)
7771 fpinfo->pushdown_safe =
true;
7776 fpextra->has_final_sort =
true;
7780 &rows, &width, &disabled_nodes,
7781 &startup_cost, &total_cost);
7797 root->sort_pathkeys,
7822 bool has_final_sort =
false;
7848 if (
parse->hasTargetSRFs)
7926 fpinfo->pushdown_safe =
true;
7951 has_final_sort =
true;
7952 pathkeys =
root->sort_pathkeys;
8005 fpinfo->pushdown_safe =
true;
8010 fpextra->has_final_sort = has_final_sort;
8028 ifpinfo->use_remote_estimate =
false;
8031 &rows, &width, &disabled_nodes,
8032 &startup_cost, &total_cost);
8073 return fpinfo->async_capable;
8110 if (
areq->request_complete)
8225 if (fetch && !pendingAreq)
8256 if (fetch && !pendingAreq)
8290 snprintf(sql,
sizeof(sql),
"FETCH %d FROM c%u",
8325 areq->callback_pending =
false;
8343 areq->callback_pending =
false;
8352 if (
areq->requestee->instrument)
8375 List *retrieved_attrs,
8412 nulls = (
bool *)
palloc(tupdesc->
natts *
sizeof(
bool));
8414 memset(nulls,
true, tupdesc->
natts *
sizeof(
bool));
8421 errpos.fsstate = fsstate;
8431 foreach(
lc, retrieved_attrs)
8483 elog(
ERROR,
"remote query result does not match the foreign table");
8549 if (
fsplan->scan.scanrelid > 0)
8552 varno =
fsplan->scan.scanrelid;
8553 colno =
errpos->cur_attno;
8614 errcontext(
"processing expression at position %d in select list",
8703 if (
em->em_is_const)
8710 em_expr =
em->em_expr;
8714 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
bool delete_attribute_statistics(Relation rel, AttrNumber attnum, bool inherited)
bool import_attribute_statistics(Relation rel, AttrNumber attnum, bool inherited, const NullableDatum *version, const NullableDatum *null_frac, const NullableDatum *avg_width, const NullableDatum *n_distinct, const NullableDatum *most_common_vals, const NullableDatum *most_common_freqs, const NullableDatum *histogram_bounds, const NullableDatum *correlation, const NullableDatum *most_common_elems, const NullableDatum *most_common_elem_freqs, const NullableDatum *elem_count_histogram, const NullableDatum *range_length_histogram, const NullableDatum *range_empty_frac, const NullableDatum *range_bounds_histogram)
TimestampTz GetCurrentTimestamp(void)
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 CStringGetTextDatum(s)
#define Assert(condition)
#define OidIsValid(objectId)
Selectivity clauselist_selectivity(PlannerInfo *root, List *clauses, int varRelid, JoinType jointype, SpecialJoinInfo *sjinfo)
bool attribute_is_analyzable(Relation onerel, int attnum, Form_pg_attribute attr, int *p_attstattarget)
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)
static DataChecksumsWorkerOperation operation
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)
bool HasRelationExtStatistics(Relation onerel)
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 palloc_array(type, count)
#define palloc0_array(type, count)
#define palloc0_object(type)
float4 float4in_internal(char *num, char **endptr_p, const char *type_name, const char *orig_string, struct Node *escontext)
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)
List * GetForeignColumnOptions(Oid relid, AttrNumber attnum)
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(NodeInstrumentation *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)
char * get_namespace_name(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)
uint32 uint32in_subr(const char *s, char **endloc, const char *typname, Node *escontext)
int32 pg_strtoint32(const char *s)
#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]
void pgstat_report_analyze(Relation rel, PgStat_Counter livetuples, PgStat_Counter deadtuples, bool resetcounter, TimestampTz starttime)
#define qsort(a, b, c, d)
static Datum Float4GetDatum(float4 X)
static Pointer DatumGetPointer(Datum X)
static Datum CStringGetDatum(const char *X)
static Datum Int32GetDatum(int32 X)
static Datum UInt32GetDatum(uint32 X)
#define PointerGetDatum(X)
static int postgresGetForeignModifyBatchSize(ResultRelInfo *resultRelInfo)
#define DEFAULT_FDW_SORT_MULTIPLIER
static char * get_opt_value(PGresult *res, int row, int col)
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 postgresImportForeignStatistics(Relation relation, List *va_cols, int elevel)
static bool foreign_join_ok(PlannerInfo *root, RelOptInfo *joinrel, JoinType jointype, RelOptInfo *outerrel, RelOptInfo *innerrel, JoinPathExtraData *extra)
static bool import_fetched_statistics(Relation relation, const char *schemaname, const char *relname, int attrcnt, const RemoteAttributeMapping *remattrmap, RemoteStatsResults *remstats)
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)
static RemoteAttributeMapping * build_remattrmap(Relation relation, List *va_cols, int *p_attrcnt, StringInfo column_list)
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 free_remattrmap(RemoteAttributeMapping *map, int len)
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 bool attname_in_list(const char *attname, List *va_cols)
static void merge_fdw_options(PgFdwRelationInfo *fpinfo, const PgFdwRelationInfo *fpinfo_o, const PgFdwRelationInfo *fpinfo_i)
static void set_text_arg(NullableDatum *arg, const char *s)
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)
static PGresult * fetch_attstats(PGconn *conn, int server_version_num, const char *remote_schemaname, const char *remote_relname, const char *column_list)
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 int remattrmap_cmp(const void *v1, const void *v2)
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 void set_float_arg(NullableDatum *arg, const char *s)
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 void set_int32_arg(NullableDatum *arg, const char *s)
static bool postgresRecheckForeignScan(ForeignScanState *node, TupleTableSlot *slot)
static List * postgresImportForeignSchema(ImportForeignSchemaStmt *stmt, Oid serverOid)
static void complete_pending_request(AsyncRequest *areq)
static PGresult * fetch_relstats(PGconn *conn, Relation relation)
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)
@ ATTSTATS_HISTOGRAM_BOUNDS
@ ATTSTATS_MOST_COMMON_ELEM_FREQS
@ ATTSTATS_MOST_COMMON_VALS
@ ATTSTATS_MOST_COMMON_ELEMS
@ ATTSTATS_ELEM_COUNT_HISTOGRAM
@ ATTSTATS_RANGE_LENGTH_HISTOGRAM
@ ATTSTATS_MOST_COMMON_FREQS
@ ATTSTATS_RANGE_BOUNDS_HISTOGRAM
@ ATTSTATS_RANGE_EMPTY_FRAC
void process_pending_request(AsyncRequest *areq)
#define DEFAULT_FDW_TUPLE_COST
static bool match_attrmap(PGresult *res, const char *local_schemaname, const char *local_relname, const char *remote_schemaname, const char *remote_relname, int attrcnt, RemoteAttributeMapping *remattrmap)
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)
static void set_floatarr_arg(NullableDatum *arg, const char *s)
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)
static bool fetch_remote_statistics(Relation relation, List *va_cols, ForeignTable *table, const char *local_schemaname, const char *local_relname, int *p_attrcnt, RemoteAttributeMapping **p_remattrmap, RemoteStatsResults *remstats)
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)
static void set_uint32_arg(NullableDatum *arg, const char *s)
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)
#define RelationGetNamespace(relation)
bool import_relation_statistics(Relation rel, const NullableDatum *version, const NullableDatum *relpages, const NullableDatum *reltuples, const NullableDatum *relallvisible, const NullableDatum *relallfrozen)
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
ImportForeignStatistics_function ImportForeignStatistics
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
NodeInstrumentation * 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