50 Index *childRTindex_p);
52 List *translated_vars);
93 bool old_isParent =
false;
94 int old_allMarkTypes = 0;
106 parentOID = rte->
relid;
139 if (oldrelation->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE)
198 if (childOID != parentOID)
201 newrelation = oldrelation;
218 &childrte, &childRTindex);
224 if (childOID != parentOID)
265 newvars =
lappend(newvars, var);
282 newvars =
lappend(newvars, var);
300 newvars =
lappend(newvars, var);
350 if (partdesc->
nparts == 0)
363 if (num_live_parts > 0)
371 Assert(relinfo->part_rels == NULL);
398 elog(
ERROR,
"temporary relation from another session found as partition");
402 parentrel, top_parentrc, childrel,
403 &childrte, &childRTindex);
407 relinfo->part_rels[
i] = childrelinfo;
412 if (childrel->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE)
414 AppendRelInfo *appinfo = root->append_rel_array[childRTindex];
421 childrte, childRTindex,
424 top_parentrc, lockmode);
457 Index *childRTindex_p)
467 List *parent_colnames;
468 List *child_colnames;
486 childrte->
relid = childOID;
489 if (childrte->
relkind == RELKIND_PARTITIONED_TABLE)
491 Assert(childOID != parentOID);
492 childrte->
inh =
true;
495 childrte->
inh =
false;
504 *childrte_p = childrte;
505 *childRTindex_p = childRTindex;
511 parentRTindex, childRTindex);
527 child_colnames =
NIL;
528 for (
int cattno = 0; cattno < child_tupdesc->
natts; cattno++)
533 if (att->attisdropped)
538 else if (appinfo->parent_colnos[cattno] > 0 &&
539 appinfo->parent_colnos[cattno] <=
list_length(parent_colnames))
543 appinfo->parent_colnos[cattno] - 1));
565 Assert(childRTindex < root->simple_rel_array_size);
566 Assert(root->simple_rte_array[childRTindex] == NULL);
567 root->simple_rte_array[childRTindex] = childrte;
568 Assert(root->append_rel_array[childRTindex] == NULL);
569 root->append_rel_array[childRTindex] = appinfo;
578 childrc->
rti = childRTindex;
579 childrc->
prti = top_parentrc->
rti;
614 if (childrte->
relkind != RELKIND_PARTITIONED_TABLE)
664 relid = root->
parse->resultRelation;
670 if (rel->
relid != relid)
687 return bms_union(updatedCols, extraUpdatedCols);
703 List *translated_vars)
725 foreach(lc, translated_vars)
759 if (parent_cols == NULL)
763 if (rel->parent != parent_rel)
774 Assert(root->append_rel_array != NULL);
775 appinfo = root->append_rel_array[rel->
relid];
808 Assert(childRTindex < root->simple_rel_array_size);
809 childrte = root->simple_rte_array[childRTindex];
837 Index cq_min_security;
849 cq_min_security = UINT_MAX;
862 if (childqual &&
IsA(childqual,
Const))
864 if (((
Const *) childqual)->constisnull ||
889 childquals =
lappend(childquals,
916 Index security_level = 0;
923 foreach(lc2, qualset)
928 childquals =
lappend(childquals,
935 cq_min_security =
Min(cq_min_security, security_level);
939 Assert(security_level <= root->qual_security_level);
Node * adjust_appendrel_attrs(PlannerInfo *root, Node *node, int nappinfos, AppendRelInfo **appinfos)
void add_row_identity_columns(PlannerInfo *root, Index rtindex, RangeTblEntry *target_rte, Relation target_relation)
AppendRelInfo * make_append_rel_info(Relation parentrel, Relation childrel, Index parentRTindex, Index childRTindex)
void add_row_identity_var(PlannerInfo *root, Var *orig_var, Index rtindex, const char *rowid_name)
#define InvalidAttrNumber
int bms_next_member(const Bitmapset *a, int prevbit)
int bms_num_members(const 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)
Bitmapset * bms_union(const Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_add_members(Bitmapset *a, const Bitmapset *b)
#define PG_USED_FOR_ASSERTS_ONLY
Node * eval_const_expressions(PlannerInfo *root, Node *node)
bool contain_volatile_functions(Node *clause)
elog(ERROR, "%s: %s", p2, msg)
static Bitmapset * translate_col_privs(const Bitmapset *parent_privs, List *translated_vars)
Bitmapset * get_rel_all_updated_cols(PlannerInfo *root, RelOptInfo *rel)
static void expand_partitioned_rtentry(PlannerInfo *root, RelOptInfo *relinfo, RangeTblEntry *parentrte, Index parentRTindex, Relation parentrel, Bitmapset *parent_updatedCols, PlanRowMark *top_parentrc, LOCKMODE lockmode)
bool apply_child_basequals(PlannerInfo *root, RelOptInfo *parentrel, RelOptInfo *childrel, RangeTblEntry *childRTE, AppendRelInfo *appinfo)
static void expand_appendrel_subquery(PlannerInfo *root, RelOptInfo *rel, RangeTblEntry *rte, Index rti)
static Bitmapset * translate_col_privs_multilevel(PlannerInfo *root, RelOptInfo *rel, RelOptInfo *parent_rel, Bitmapset *parent_cols)
static void expand_single_inheritance_child(PlannerInfo *root, RangeTblEntry *parentrte, Index parentRTindex, Relation parentrel, PlanRowMark *top_parentrc, Relation childrel, RangeTblEntry **childrte_p, Index *childRTindex_p)
void expand_inherited_rtentry(PlannerInfo *root, RelOptInfo *rel, RangeTblEntry *rte, Index rti)
void add_vars_to_targetlist(PlannerInfo *root, List *vars, Relids where_needed)
Assert(fmt[strlen(fmt) - 1] !='\n')
List * lappend(List *list, void *datum)
Alias * makeAlias(const char *aliasname, List *colnames)
Var * makeWholeRowVar(RangeTblEntry *rte, int varno, Index varlevelsup, bool allowScalar)
List * make_ands_implicit(Expr *clause)
TargetEntry * makeTargetEntry(Expr *expr, AttrNumber resno, char *resname, bool resjunk)
Var * makeVar(int varno, AttrNumber varattno, Oid vartype, int32 vartypmod, Oid varcollid, Index varlevelsup)
char * pstrdup(const char *in)
void * palloc0(Size size)
#define IsA(nodeptr, _type_)
RTEPermissionInfo * getRTEPermissionInfo(List *rteperminfos, RangeTblEntry *rte)
PartitionDesc PartitionDirectoryLookup(PartitionDirectory pdir, Relation rel)
bool has_partition_attrs(Relation rel, Bitmapset *attnums, bool *used_in_expr)
Bitmapset * prune_append_rel_partitions(RelOptInfo *rel)
#define IS_SIMPLE_REL(rel)
#define planner_rt_fetch(rti, root)
#define IS_OTHER_REL(rel)
FormData_pg_attribute * Form_pg_attribute
List * find_all_inheritors(Oid parentrelId, LOCKMODE lockmode, List **numparents)
#define lfirst_node(type, lc)
static int list_length(const List *l)
static void * list_nth(const List *list, int n)
Bitmapset * get_dependent_generated_columns(PlannerInfo *root, Index rti, Bitmapset *target_cols)
RowMarkType select_rowmark_type(RangeTblEntry *rte, LockClauseStrength strength)
void check_stack_depth(void)
static bool DatumGetBool(Datum X)
PlanRowMark * get_plan_rowmark(List *rowmarks, Index rtindex)
static struct subre * parse(struct vars *v, int stopper, int type, struct state *init, struct state *final)
#define RelationGetRelid(relation)
#define RelationGetDescr(relation)
#define RELATION_IS_OTHER_TEMP(relation)
RelOptInfo * find_base_rel(PlannerInfo *root, int relid)
RelOptInfo * build_simple_rel(PlannerInfo *root, int relid, RelOptInfo *parent)
void expand_planner_arrays(PlannerInfo *root, int add_size)
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)
LockClauseStrength strength
LockWaitPolicy waitPolicy
bool hasPseudoConstantQuals
Relids leaf_result_relids
struct TableSampleClause * tablesample
Index baserestrict_min_security
#define FirstLowInvalidHeapAttributeNumber
#define TableOidAttributeNumber
#define SelfItemPointerAttributeNumber
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
#define TupleDescAttr(tupdesc, i)
String * makeString(char *str)
bool contain_vars_of_level(Node *node, int levelsup)