107 #define REL_ALIAS_PREFIX "r"
109 #define ADD_REL_QUALIFIER(buf, varno) \
110 appendStringInfo((buf), "%s%d.", REL_ALIAS_PREFIX, (varno))
111 #define SUBQUERY_REL_ALIAS_PREFIX "s"
112 #define SUBQUERY_COL_ALIAS_PREFIX "c"
134 List **retrieved_attrs);
137 List **retrieved_attrs,
143 List *withCheckOptionList,
145 List **retrieved_attrs);
199 int *relno,
int *colno);
201 int *relno,
int *colno);
222 foreach(lc, input_conds)
227 *remote_conds =
lappend(*remote_conds, ri);
229 *local_conds =
lappend(*local_conds, ri);
249 glob_cxt.
root = root;
310 bool check_type =
true;
364 collation == DEFAULT_COLLATION_OID)
393 collation =
c->constcollid;
395 collation == DEFAULT_COLLATION_OID)
426 collation == DEFAULT_COLLATION_OID)
446 glob_cxt, &inner_cxt, case_arg_cxt))
451 glob_cxt, &inner_cxt, case_arg_cxt))
456 glob_cxt, &inner_cxt, case_arg_cxt))
468 collation == inner_cxt.collation)
470 else if (collation == DEFAULT_COLLATION_OID)
492 glob_cxt, &inner_cxt, case_arg_cxt))
502 fe->inputcollid != inner_cxt.collation)
511 collation =
fe->funccollid;
515 collation == inner_cxt.collation)
517 else if (collation == DEFAULT_COLLATION_OID)
540 glob_cxt, &inner_cxt, case_arg_cxt))
558 collation == inner_cxt.collation)
560 else if (collation == DEFAULT_COLLATION_OID)
580 glob_cxt, &inner_cxt, case_arg_cxt))
606 glob_cxt, &inner_cxt, case_arg_cxt))
617 collation == inner_cxt.collation)
619 else if (collation == DEFAULT_COLLATION_OID)
633 glob_cxt, &inner_cxt, case_arg_cxt))
649 glob_cxt, &inner_cxt, case_arg_cxt))
674 glob_cxt, &arg_cxt, case_arg_cxt))
679 foreach(lc, ce->
args)
702 opArgs = ((
OpExpr *) whenExpr)->args;
717 glob_cxt, &tmp_cxt, &arg_cxt))
722 glob_cxt, &inner_cxt, case_arg_cxt))
728 glob_cxt, &inner_cxt, case_arg_cxt))
745 else if (collation == DEFAULT_COLLATION_OID)
764 collation =
c->collation;
770 else if (collation == DEFAULT_COLLATION_OID)
784 glob_cxt, &inner_cxt, case_arg_cxt))
791 collation =
a->array_collid;
795 collation == inner_cxt.collation)
797 else if (collation == DEFAULT_COLLATION_OID)
814 glob_cxt, &inner_cxt, case_arg_cxt))
851 foreach(lc, agg->
args)
864 glob_cxt, &inner_cxt, case_arg_cxt))
899 glob_cxt, &inner_cxt, case_arg_cxt))
924 else if (collation == DEFAULT_COLLATION_OID)
969 if (outer_cxt->
collation == DEFAULT_COLLATION_OID)
974 else if (collation != DEFAULT_COLLATION_OID)
1027 relids = baserel->
relids;
1161 bool has_final_sort,
bool has_limit,
bool is_subquery,
1162 List **retrieved_attrs,
List **params_list)
1176 context.
root = root;
1197 quals = remote_conds;
1340 List **retrieved_attrs)
1347 *retrieved_attrs =
NIL;
1354 for (
i = 1;
i <= tupdesc->
natts;
i++)
1359 if (attr->attisdropped)
1362 if (have_wholerow ||
1368 else if (is_returning)
1387 else if (is_returning)
1400 if (first && !is_returning)
1503 bool is_first =
true;
1551 elog(
ERROR,
"unsupported join type %d", jointype);
1572 List **retrieved_attrs,
1579 *retrieved_attrs =
NIL;
1587 else if (is_returning)
1592 *retrieved_attrs =
lappend_int(*retrieved_attrs,
i + 1);
1596 if (
i == 0 && !is_returning)
1648 bool use_alias,
Index ignore_rel,
List **ignore_conds,
1659 bool outerrel_is_target =
false;
1660 bool innerrel_is_target =
false;
1685 if (outerrel->
relid == ignore_rel)
1686 outerrel_is_target =
true;
1687 else if (innerrel->
relid == ignore_rel)
1688 innerrel_is_target =
true;
1692 if (!outerrel_is_target)
1697 ignore_rel, ignore_conds, params_list);
1708 if (innerrel_is_target)
1718 if (!innerrel_is_target)
1723 ignore_rel, ignore_conds, params_list);
1729 if (outerrel_is_target)
1739 Assert(!outerrel_is_target && !innerrel_is_target);
1757 context.
root = root;
1799 bool make_subquery,
Index ignore_rel,
List **ignore_conds,
1812 List *retrieved_attrs;
1820 Assert(ignore_rel == 0 ||
1828 &retrieved_attrs, params_list);
1846 for (
i = 1;
i <= ncols;
i++)
1858 ignore_conds, params_list);
1874 List *targetAttrs,
bool doNothing,
1875 List *withCheckOptionList,
List *returningList,
1876 List **retrieved_attrs,
int *values_end_len)
1891 foreach(lc, targetAttrs)
1906 foreach(lc, targetAttrs)
1915 if (attr->attgenerated)
1928 *values_end_len =
buf->len;
1935 withCheckOptionList, returningList, retrieved_attrs);
1946 char *orig_query,
List *target_attrs,
1947 int values_end_len,
int num_params,
1957 Assert((values_end_len > 0) && (values_end_len <= strlen(orig_query)));
1966 pindex = num_params + 1;
1967 for (
i = 0;
i < num_rows;
i++)
1972 foreach(lc, target_attrs)
1981 if (attr->attgenerated)
2008 List *withCheckOptionList,
List *returningList,
2009 List **retrieved_attrs)
2022 foreach(lc, targetAttrs)
2032 if (attr->attgenerated)
2044 withCheckOptionList, returningList, retrieved_attrs);
2072 List *returningList,
2073 List **retrieved_attrs)
2083 context.
root = root;
2099 forboth(lc, targetlist, lc2, targetAttrs)
2124 &ignore_conds, params_list);
2125 remote_conds =
list_concat(remote_conds, ignore_conds);
2139 NIL, returningList, retrieved_attrs);
2152 List *returningList,
2153 List **retrieved_attrs)
2161 NIL, returningList, retrieved_attrs);
2184 List *returningList,
2185 List **retrieved_attrs)
2190 context.
root = root;
2207 &ignore_conds, params_list);
2208 remote_conds =
list_concat(remote_conds, ignore_conds);
2222 rtindex, rel,
false,
2223 NIL, returningList, retrieved_attrs);
2232 bool trig_after_row,
2233 List *withCheckOptionList,
2234 List *returningList,
2235 List **retrieved_attrs)
2246 if (withCheckOptionList !=
NIL)
2261 if (returningList !=
NIL)
2271 if (attrs_used != NULL)
2275 *retrieved_attrs =
NIL;
2317 *retrieved_attrs =
NIL;
2320 for (
i = 0;
i < tupdesc->
natts;
i++)
2338 if (strcmp(def->
defname,
"column_name") == 0)
2347 *retrieved_attrs =
lappend_int(*retrieved_attrs,
i + 1);
2385 restart_seqs ?
"RESTART" :
"CONTINUE");
2410 else if (varattno < 0)
2421 fetchval = rte->
relid;
2432 else if (varattno == 0)
2439 List *retrieved_attrs;
2485 char *colname = NULL;
2501 if (strcmp(def->
defname,
"column_name") == 0)
2512 if (colname == NULL)
2531 const char *nspname = NULL;
2545 if (strcmp(def->
defname,
"schema_name") == 0)
2547 else if (strcmp(def->
defname,
"table_name") == 0)
2555 if (nspname == NULL)
2578 if (strchr(
val,
'\\') != NULL)
2581 for (valptr =
val; *valptr; valptr++)
2653 elog(
ERROR,
"unsupported expression type for deparse: %d",
2745 bool isfloat =
false;
2746 bool isstring =
false;
2760 &typoutput, &typIsVarlena);
2777 if (strspn(extval,
"0123456789+-eE.") == strlen(extval))
2779 if (extval[0] ==
'+' || extval[0] ==
'-')
2783 if (strcspn(extval,
"eE.") != strlen(extval))
2795 if (strcmp(extval,
"t") == 0)
2832 needlabel = !isstring;
2838 if (needlabel || showtype > 0)
2956 int32 coercedTypmod;
3001 bool canSuppressRightConstCast =
false;
3007 elog(
ERROR,
"cache lookup failed for operator %u", node->
opno);
3009 oprkind = form->oprkind;
3026 bool canSuppressLeftConstCast =
false;
3054 if (leftType == rightType)
3062 if (canSuppressLeftConstCast)
3076 if (canSuppressRightConstCast)
3130 opname =
NameStr(opform->oprname);
3133 if (opform->oprnamespace != PG_CATALOG_NAMESPACE)
3135 const char *opnspname;
3182 elog(
ERROR,
"cache lookup failed for operator %u", node->
opno);
3232 const char *op = NULL;
3253 foreach(lc, node->
args)
3308 if (node->
arg != NULL)
3315 foreach(lc, node->
args)
3321 if (node->
arg == NULL)
3394 if (AGGKIND_IS_ORDERED_SET(node->
aggkind))
3474 foreach(lc, orderList)
3507 if (sortop == typentry->
lt_opr)
3509 else if (sortop == typentry->
gt_opr)
3521 elog(
ERROR,
"cache lookup failed for operator %u", sortop);
3627 const char *delim =
" ";
3634 foreach(lcell, pathkeys)
3662 elog(
ERROR,
"could not find pathkey item to sort");
3676 elog(
ERROR,
"missing operator %d(%u,%u) in opfamily %u",
3736 elog(
ERROR,
"cache lookup failed for function %u", funcid);
3740 if (procform->pronamespace != PG_CATALOG_NAMESPACE)
3742 const char *schemaname;
3787 else if (!expr ||
IsA(expr,
Var))
3797 return (
Node *) expr;
3870 int *relno,
int *colno)
3892 elog(
ERROR,
"unexpected expression in subquery output");
int bms_next_member(const Bitmapset *a, int prevbit)
void bms_free(Bitmapset *a)
bool bms_is_member(int x, const Bitmapset *a)
Bitmapset * bms_make_singleton(int x)
Bitmapset * bms_add_member(Bitmapset *a, int x)
BMS_Membership bms_membership(const Bitmapset *a)
#define FORMAT_TYPE_TYPEMOD_GIVEN
#define FORMAT_TYPE_FORCE_QUALIFY
#define ESCAPE_STRING_SYNTAX
#define SQL_STR_DOUBLE(ch, escape_backslash)
#define OidIsValid(objectId)
bool contain_mutable_functions(Node *clause)
char * defGetString(DefElem *def)
static void deparseCaseExpr(CaseExpr *node, deparse_expr_cxt *context)
void deparseAnalyzeSizeSql(StringInfo buf, Relation rel)
static void deparseBoolExpr(BoolExpr *node, deparse_expr_cxt *context)
static void appendGroupByClause(List *tlist, deparse_expr_cxt *context)
static void deparseTargetList(StringInfo buf, RangeTblEntry *rte, Index rtindex, Relation rel, bool is_returning, Bitmapset *attrs_used, bool qualify_col, List **retrieved_attrs)
static void deparseRangeTblRef(StringInfo buf, PlannerInfo *root, RelOptInfo *foreignrel, bool make_subquery, Index ignore_rel, List **ignore_conds, List **params_list)
#define SUBQUERY_REL_ALIAS_PREFIX
static void deparseFromExpr(List *quals, deparse_expr_cxt *context)
static void deparseExpr(Expr *expr, deparse_expr_cxt *context)
static Node * deparseSortGroupClause(Index ref, List *tlist, bool force_colno, deparse_expr_cxt *context)
static void deparseLockingClause(deparse_expr_cxt *context)
const char * get_jointype_name(JoinType jointype)
static void deparseAggref(Aggref *node, deparse_expr_cxt *context)
static void appendOrderBySuffix(Oid sortop, Oid sortcoltype, bool nulls_first, deparse_expr_cxt *context)
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)
struct deparse_expr_cxt deparse_expr_cxt
static void get_relation_column_alias_ids(Var *node, RelOptInfo *foreignrel, int *relno, int *colno)
void deparseAnalyzeSql(StringInfo buf, Relation rel, List **retrieved_attrs)
static void printRemoteParam(int paramindex, Oid paramtype, int32 paramtypmod, deparse_expr_cxt *context)
static bool is_subquery_var(Var *node, RelOptInfo *foreignrel, int *relno, int *colno)
bool is_foreign_param(PlannerInfo *root, RelOptInfo *baserel, Expr *expr)
static void printRemotePlaceholder(Oid paramtype, int32 paramtypmod, deparse_expr_cxt *context)
static void appendOrderByClause(List *pathkeys, bool has_final_sort, deparse_expr_cxt *context)
static bool foreign_expr_walker(Node *node, foreign_glob_cxt *glob_cxt, foreign_loc_cxt *outer_cxt, foreign_loc_cxt *case_arg_cxt)
static void deparseColumnRef(StringInfo buf, int varno, int varattno, RangeTblEntry *rte, bool qualify_col)
static void deparseRelabelType(RelabelType *node, deparse_expr_cxt *context)
static void deparseNullTest(NullTest *node, deparse_expr_cxt *context)
static void deparseOperatorName(StringInfo buf, Form_pg_operator opform)
static void deparseOpExpr(OpExpr *node, deparse_expr_cxt *context)
static void deparseConst(Const *node, deparse_expr_cxt *context, int showtype)
static bool isPlainForeignVar(Expr *node, deparse_expr_cxt *context)
static void deparseDistinctExpr(DistinctExpr *node, deparse_expr_cxt *context)
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)
static void deparseFuncExpr(FuncExpr *node, deparse_expr_cxt *context)
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)
struct foreign_glob_cxt foreign_glob_cxt
static void deparseArrayExpr(ArrayExpr *node, deparse_expr_cxt *context)
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)
static void deparseReturningList(StringInfo buf, RangeTblEntry *rte, Index rtindex, Relation rel, bool trig_after_row, List *withCheckOptionList, List *returningList, List **retrieved_attrs)
void deparseUpdateSql(StringInfo buf, RangeTblEntry *rte, Index rtindex, Relation rel, List *targetAttrs, List *withCheckOptionList, List *returningList, List **retrieved_attrs)
static void deparseVar(Var *node, deparse_expr_cxt *context)
static void appendFunctionName(Oid funcid, deparse_expr_cxt *context)
static void appendConditions(List *exprs, deparse_expr_cxt *context)
struct foreign_loc_cxt foreign_loc_cxt
void deparseDeleteSql(StringInfo buf, RangeTblEntry *rte, Index rtindex, Relation rel, List *returningList, List **retrieved_attrs)
static void deparseSubscriptingRef(SubscriptingRef *node, deparse_expr_cxt *context)
static void deparseRelation(StringInfo buf, Relation rel)
static void deparseExplicitTargetList(List *tlist, bool is_returning, List **retrieved_attrs, deparse_expr_cxt *context)
static char * deparse_type_name(Oid type_oid, int32 typemod)
#define ADD_REL_QUALIFIER(buf, varno)
static void appendLimitClause(deparse_expr_cxt *context)
bool is_foreign_expr(PlannerInfo *root, RelOptInfo *baserel, Expr *expr)
List * build_tlist_to_deparse(RelOptInfo *foreignrel)
#define SUBQUERY_COL_ALIAS_PREFIX
void classifyConditions(PlannerInfo *root, RelOptInfo *baserel, List *input_conds, List **remote_conds, List **local_conds)
static void deparseScalarArrayOpExpr(ScalarArrayOpExpr *node, deparse_expr_cxt *context)
static void deparseFromExprForRel(StringInfo buf, PlannerInfo *root, RelOptInfo *foreignrel, bool use_alias, Index ignore_rel, List **ignore_conds, List **params_list)
void deparseTruncateSql(StringInfo buf, List *rels, DropBehavior behavior, bool restart_seqs)
static void deparseSubqueryTargetList(deparse_expr_cxt *context)
bool is_foreign_pathkey(PlannerInfo *root, RelOptInfo *baserel, PathKey *pathkey)
static void deparseSelectSql(List *tlist, bool is_subquery, List **retrieved_attrs, deparse_expr_cxt *context)
static void deparseParam(Param *node, deparse_expr_cxt *context)
static void appendAggOrderBy(List *orderList, List *targetList, deparse_expr_cxt *context)
bool equal(const void *a, const void *b)
char * OidOutputFunctionCall(Oid functionId, Datum val)
ForeignTable * GetForeignTable(Oid relid)
List * GetForeignColumnOptions(Oid relid, AttrNumber attnum)
#define HeapTupleIsValid(tuple)
Assert(fmt[strlen(fmt) - 1] !='\n')
List * lappend(List *list, void *datum)
List * lappend_int(List *list, int datum)
List * list_concat(List *list1, const List *list2)
bool type_is_rowtype(Oid typid)
char * get_namespace_name(Oid nspid)
void getTypeOutputInfo(Oid type, Oid *typOutput, bool *typIsVarlena)
Oid get_opfamily_member(Oid opfamily, Oid lefttype, Oid righttype, int16 strategy)
char * get_attname(Oid relid, AttrNumber attnum, bool missing_ok)
void pfree(void *pointer)
Oid exprType(const Node *expr)
bool exprIsLengthCoercion(const Node *expr, int32 *coercedTypmod)
Node * strip_implicit_coercions(Node *node)
#define IsA(nodeptr, _type_)
#define castNode(_type_, nodeptr)
#define PVC_RECURSE_PLACEHOLDERS
#define IS_SIMPLE_REL(rel)
#define planner_rt_fetch(rti, root)
#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)
static ListCell * list_head(const List *l)
static ListCell * lnext(const List *l, const ListCell *c)
FormData_pg_operator * Form_pg_operator
FormData_pg_proc * Form_pg_proc
#define ObjectIdGetDatum(X)
void reset_transmission_modes(int nestlevel)
int set_transmission_modes(void)
EquivalenceMember * find_em_for_rel(PlannerInfo *root, EquivalenceClass *ec, RelOptInfo *rel)
EquivalenceMember * find_em_for_rel_target(PlannerInfo *root, EquivalenceClass *ec, RelOptInfo *rel)
bool is_shippable(Oid objectId, Oid classId, PgFdwRelationInfo *fpinfo)
bool is_builtin(Oid objectId)
PlanRowMark * get_plan_rowmark(List *rowmarks, Index rtindex)
#define IS_SPECIAL_VARNO(varno)
#define RelationGetRelid(relation)
#define RelationGetDescr(relation)
#define RelationGetRelationName(relation)
#define RelationGetNamespace(relation)
const char * quote_identifier(const char *ident)
void appendStringInfo(StringInfo str, const char *fmt,...)
void appendBinaryStringInfo(StringInfo str, const char *data, int datalen)
void appendStringInfoString(StringInfo str, const char *s)
void appendStringInfoChar(StringInfo str, char ch)
void initStringInfo(StringInfo str)
NullTestType nulltesttype
EquivalenceClass * pk_eclass
bool make_outerrel_subquery
Relids lower_subquery_rels
bool make_innerrel_subquery
LockClauseStrength strength
struct PathTarget * reltarget
CoercionForm relabelformat
bool trig_update_after_row
bool trig_insert_after_row
bool trig_delete_after_row
#define FirstLowInvalidHeapAttributeNumber
#define TableOidAttributeNumber
#define SelfItemPointerAttributeNumber
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
TargetEntry * get_sortgroupref_tle(Index sortref, List *targetList)
List * add_to_flat_tlist(List *tlist, List *exprs)
#define TupleDescAttr(tupdesc, i)
TypeCacheEntry * lookup_type_cache(Oid type_id, int flags)
List * pull_var_clause(Node *node, int flags)
void pull_varattnos(Node *node, Index varno, Bitmapset **varattnos)