68 bool include_noinherit,
70 bool include_partition);
139 if (!(relation->
rd_rel->relkind == RELKIND_FOREIGN_TABLE ||
140 relation->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE))
142 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
143 errmsg(
"cannot open relation \"%s\"",
151 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
152 errmsg(
"cannot access temporary or unlogged relations during recovery")));
159 rel->attr_needed = (
Relids *)
161 rel->attr_widths = (
int32 *)
169 if (attr->attnotnull)
179 Assert(!attr->attisdropped);
203 if ((inhparent && relation->
rd_rel->relkind != RELKIND_PARTITIONED_TABLE)
207 hasindex = relation->
rd_rel->relhasindex;
225 lmode = root->simple_rte_array[varno]->rellockmode;
227 foreach(l, indexoidlist)
251 if (!
index->indisvalid)
262 if (
index->indcheckxmin &&
280 info->indexkeys = (
int *)
palloc(
sizeof(
int) * ncolumns);
281 info->indexcollations = (
Oid *)
palloc(
sizeof(
Oid) * nkeycolumns);
282 info->opfamily = (
Oid *)
palloc(
sizeof(
Oid) * nkeycolumns);
283 info->opcintype = (
Oid *)
palloc(
sizeof(
Oid) * nkeycolumns);
284 info->canreturn = (
bool *)
palloc(
sizeof(
bool) * ncolumns);
286 for (
i = 0;
i < ncolumns;
i++)
288 info->indexkeys[
i] =
index->indkey.values[
i];
292 for (
i = 0;
i < nkeycolumns;
i++)
305 if (indexRelation->
rd_rel->relkind != RELKIND_PARTITIONED_INDEX)
308 amroutine = indexRelation->
rd_indam;
328 if (info->
relam == BTREE_AM_OID)
336 info->sortopfamily = info->opfamily;
337 info->reverse_sort = (
bool *)
palloc(
sizeof(
bool) * nkeycolumns);
338 info->nulls_first = (
bool *)
palloc(
sizeof(
bool) * nkeycolumns);
340 for (
i = 0;
i < nkeycolumns;
i++)
344 info->reverse_sort[
i] = (opt & INDOPTION_DESC) != 0;
345 info->nulls_first[
i] = (opt & INDOPTION_NULLS_FIRST) != 0;
365 info->sortopfamily = (
Oid *)
palloc(
sizeof(
Oid) * nkeycolumns);
366 info->reverse_sort = (
bool *)
palloc(
sizeof(
bool) * nkeycolumns);
367 info->nulls_first = (
bool *)
palloc(
sizeof(
bool) * nkeycolumns);
369 for (
i = 0;
i < nkeycolumns;
i++)
377 info->reverse_sort[
i] = (opt & INDOPTION_DESC) != 0;
378 info->nulls_first[
i] = (opt & INDOPTION_NULLS_FIRST) != 0;
389 btopcintype == info->opcintype[
i] &&
393 info->sortopfamily[
i] = btopfamily;
398 info->sortopfamily = NULL;
399 info->reverse_sort = NULL;
400 info->nulls_first = NULL;
407 info->sortopfamily = NULL;
408 info->reverse_sort = NULL;
409 info->nulls_first = NULL;
424 info->sortopfamily = NULL;
425 info->reverse_sort = NULL;
426 info->nulls_first = NULL;
437 if (info->indexprs && varno != 1)
439 if (info->
indpred && varno != 1)
459 if (indexRelation->
rd_rel->relkind != RELKIND_PARTITIONED_INDEX)
476 if (info->
relam == BTREE_AM_OID)
507 indexinfos =
lcons(info, indexinfos);
518 if (relation->
rd_rel->relkind == RELKIND_FOREIGN_TABLE)
526 rel->fdwroutine = NULL;
542 if (inhparent && relation->
rd_rel->relkind == RELKIND_PARTITIONED_TABLE)
553 (*get_relation_info_hook) (root, relationObjectId, inhparent, rel);
611 foreach(lc, cachedfkeys)
636 if (rti == rel->
relid)
644 memcpy(info->conkey, cachedfk->conkey,
sizeof(info->conkey));
645 memcpy(info->confkey, cachedfk->confkey,
sizeof(info->confkey));
646 memcpy(info->conpfeqop, cachedfk->conpfeqop,
sizeof(info->conpfeqop));
742 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
743 errmsg(
"whole row unique index inference specifications are not supported")));
759 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
760 errmsg(
"constraint in ON CONFLICT clause has no associated index")));
769 foreach(l, indexList)
791 if (!idxForm->indisvalid)
805 if (indexOidFromConstraint == idxForm->indexrelid)
809 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
810 errmsg(
"ON CONFLICT DO UPDATE not supported with exclusion constraints")));
812 results =
lappend_oid(results, idxForm->indexrelid);
818 else if (indexOidFromConstraint !=
InvalidOid)
829 if (!idxForm->indisunique)
834 for (natt = 0; natt < idxForm->indnkeyatts; natt++)
836 int attno = idxRel->
rd_index->indkey.values[natt];
844 if (!
bms_equal(indexedAttrs, inferAttrs))
904 results =
lappend_oid(results, idxForm->indexrelid);
914 (
errcode(ERRCODE_INVALID_COLUMN_REFERENCE),
915 errmsg(
"there is no unique or exclusion constraint matching the ON CONFLICT specification")));
972 for (natt = 1; natt <= idxRel->
rd_att->
natts; natt++)
977 int attno = idxRel->
rd_index->indkey.values[natt - 1];
983 (inferopfamily != opfamily || inferopcinputtype != opcinputtype))
999 if (((
Var *) elem->
expr)->varattno == attno)
1002 else if (attno == 0)
1004 Node *nattExpr =
list_nth(idxExprs, (natt - 1) - nplain);
1031 BlockNumber *pages,
double *tuples,
double *allvisfrac)
1039 if (RELKIND_HAS_TABLE_AM(rel->
rd_rel->relkind))
1044 else if (rel->
rd_rel->relkind == RELKIND_INDEX)
1066 reltuples = (
double) rel->
rd_rel->reltuples;
1082 if (reltuples >= 0 && relpages > 0)
1083 density = reltuples / (double) relpages;
1111 *tuples = rint(density * (
double) curpages);
1119 if (relallvisible == 0 || curpages <= 0)
1121 else if ((
double) relallvisible >= curpages)
1124 *allvisfrac = (double) relallvisible / curpages;
1134 *pages = rel->
rd_rel->relpages;
1135 *tuples = rel->
rd_rel->reltuples;
1157 int64 tuple_width = 0;
1165 if (att->attisdropped)
1169 if (attr_widths != NULL && attr_widths[
i] > 0)
1171 tuple_width += attr_widths[
i];
1177 if (item_width <= 0)
1182 if (attr_widths != NULL)
1183 attr_widths[
i] = item_width;
1184 tuple_width += item_width;
1239 bool include_noinherit,
1240 bool include_notnull,
1241 bool include_partition)
1259 for (
i = 0;
i < num_check;
i++)
1306 for (
i = 1;
i <= natts;
i++)
1310 if (att->attnotnull && !att->attisdropped)
1327 ntest->argisrow =
false;
1329 result =
lappend(result, ntest);
1338 if (include_partition && relation->
rd_rel->relispartition)
1358 Oid statOid,
bool inh,
1377 info->
inherit = dataForm->stxdinherit;
1379 info->
kind = STATS_EXT_NDISTINCT;
1381 info->
exprs = exprs;
1383 *stainfos =
lappend(*stainfos, info);
1391 info->
inherit = dataForm->stxdinherit;
1393 info->
kind = STATS_EXT_DEPENDENCIES;
1395 info->
exprs = exprs;
1397 *stainfos =
lappend(*stainfos, info);
1405 info->
inherit = dataForm->stxdinherit;
1407 info->
kind = STATS_EXT_MCV;
1409 info->
exprs = exprs;
1411 *stainfos =
lappend(*stainfos, info);
1419 info->
inherit = dataForm->stxdinherit;
1421 info->
kind = STATS_EXT_EXPRESSIONS;
1423 info->
exprs = exprs;
1425 *stainfos =
lappend(*stainfos, info);
1449 foreach(l, statoidlist)
1460 elog(
ERROR,
"cache lookup failed for statistics object %u", statOid);
1468 for (
i = 0;
i < staForm->stxkeys.dim1;
i++)
1486 Anum_pg_statistic_ext_stxexprs, &isnull);
1549 bool include_noinherit;
1550 bool include_notnull;
1551 bool include_partition =
false;
1552 List *safe_restrictions;
1553 List *constraint_pred;
1554 List *safe_constraints;
1582 if (clause &&
IsA(clause,
Const) &&
1583 (((
Const *) clause)->constisnull ||
1619 include_partition =
true;
1631 safe_restrictions =
NIL;
1637 safe_restrictions =
lappend(safe_restrictions, rinfo->
clause);
1659 include_noinherit = !rte->
inh;
1668 include_notnull = (!rte->
inh || rte->
relkind == RELKIND_PARTITIONED_TABLE);
1685 safe_constraints =
NIL;
1686 foreach(lc, constraint_pred)
1691 safe_constraints =
lappend(safe_constraints, pred);
1756 for (attrno = 1; attrno <= numattrs; attrno++)
1761 if (att_tup->attisdropped || att_tup->atthasmissing)
1772 att_tup->attcollation,
1838 elog(
ERROR,
"unsupported RTE kind %d in build_physical_tlist",
1866 for (
i = 0;
i <
index->ncolumns;
i++)
1868 int indexkey =
index->indexkeys[
i];
1885 att_tup->attcollation,
1891 if (indexpr_item == NULL)
1892 elog(
ERROR,
"wrong number of index expressions");
1894 indexpr_item =
lnext(
index->indexprs, indexpr_item);
1903 if (indexpr_item != NULL)
1904 elog(
ERROR,
"wrong number of index expressions");
1942 if (result < 0.0 || result > 1.0)
1943 elog(
ERROR,
"invalid restriction selectivity: %f", result);
1983 if (result < 0.0 || result > 1.0)
1984 elog(
ERROR,
"invalid join selectivity: %f", result);
2022 req.
type = T_SupportRequestSelectivity;
2038 if (sresult != &req)
2069 elog(
ERROR,
"cache lookup failed for function %u", funcid);
2077 req.
type = T_SupportRequestCost;
2090 if (sresult == &req)
2130 elog(
ERROR,
"cache lookup failed for function %u", funcid);
2133 Assert(procform->proretset);
2140 req.
type = T_SupportRequestRows;
2151 if (sresult == &req)
2160 result = procform->prorows;
2196 if (
index->unique &&
2197 index->nkeycolumns == 1 &&
2198 index->indexkeys[0] == attno &&
2217 bool result =
false;
2248 elog(
ERROR,
"unrecognized CmdType: %d", (
int) event);
2267 bool result =
false;
2302 constr = tupdesc->
constr;
2328 return dependentCols;
2345 if (root->
glob->partition_directory == NULL)
2347 root->
glob->partition_directory =
2354 Assert(partdesc != NULL && rel->part_scheme != NULL);
2381 foreach(lc, root->part_schemes)
2383 part_scheme =
lfirst(lc);
2392 sizeof(
Oid) * partnatts) != 0 ||
2394 sizeof(
Oid) * partnatts) != 0 ||
2396 sizeof(
Oid) * partnatts) != 0)
2404 sizeof(
int16) * partnatts) == 0);
2406 sizeof(
bool) * partnatts) == 0);
2415 #ifdef USE_ASSERT_CHECKING
2437 sizeof(
Oid) * partnatts);
2441 sizeof(
Oid) * partnatts);
2445 sizeof(
Oid) * partnatts);
2449 sizeof(
int16) * partnatts);
2453 sizeof(
bool) * partnatts);
2457 for (
i = 0;
i < partnatts;
i++)
2462 root->part_schemes =
lappend(root->part_schemes, part_scheme);
2493 for (cnt = 0; cnt < partnatts; cnt++)
2511 elog(
ERROR,
"wrong number of partition key expressions");
2523 rel->partexprs = partexprs;
2531 rel->nullable_partexprs = (
List **)
palloc0(
sizeof(
List *) * partnatts);
2560 if (rel->
relid != 1)
#define InvalidAttrNumber
bool bms_equal(const Bitmapset *a, const Bitmapset *b)
void bms_free(Bitmapset *a)
Bitmapset * bms_add_member(Bitmapset *a, int x)
bool bms_overlap(const Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_copy(const Bitmapset *a)
#define RelationGetNumberOfBlocks(reln)
#define SizeOfPageHeaderData
#define TextDatumGetCString(d)
#define OidIsValid(objectId)
bool IsSystemRelation(Relation relation)
bool contain_mutable_functions(Node *clause)
Node * eval_const_expressions(PlannerInfo *root, Node *node)
@ CONSTRAINT_EXCLUSION_OFF
@ CONSTRAINT_EXCLUSION_PARTITION
@ CONSTRAINT_EXCLUSION_ON
int32 clamp_width_est(int64 tuple_width)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
bool equal(const void *a, const void *b)
bool statext_is_kind_built(HeapTuple htup, char type)
Datum OidFunctionCall5Coll(Oid functionId, Oid collation, Datum arg1, Datum arg2, Datum arg3, Datum arg4, Datum arg5)
Datum OidFunctionCall4Coll(Oid functionId, Oid collation, Datum arg1, Datum arg2, Datum arg3, Datum arg4)
void fmgr_info_copy(FmgrInfo *dstinfo, FmgrInfo *srcinfo, MemoryContext destcxt)
#define OidFunctionCall1(functionId, arg1)
FdwRoutine * GetFdwRoutineForRelation(Relation relation, bool makecopy)
Oid GetForeignServerIdByRelId(Oid relid)
const FormData_pg_attribute * SystemAttributeDefinition(AttrNumber attno)
#define HeapTupleIsValid(tuple)
#define SizeofHeapTupleHeader
#define HeapTupleHeaderGetXmin(tup)
void index_close(Relation relation, LOCKMODE lockmode)
bool index_can_return(Relation indexRelation, int attno)
Relation index_open(Oid relationId, LOCKMODE lockmode)
if(TABLE==NULL||TABLE_index==NULL)
struct ItemIdData ItemIdData
Assert(fmt[strlen(fmt) - 1] !='\n')
List * lappend(List *list, void *datum)
List * lappend_oid(List *list, Oid datum)
void list_free(List *list)
List * list_concat(List *list1, const List *list2)
bool list_member(const List *list, const void *datum)
List * lcons(void *datum, List *list)
List * list_difference(const List *list1, const List *list2)
RegProcedure get_oprrest(Oid opno)
Oid get_constraint_index(Oid conoid)
Oid get_opclass_input_type(Oid opclass)
Oid get_opclass_family(Oid opclass)
RegProcedure get_func_support(Oid funcid)
int32 get_attavgwidth(Oid relid, AttrNumber attnum)
RegProcedure get_oprjoin(Oid opno)
Oid get_opfamily_member(Oid opfamily, Oid lefttype, Oid righttype, int16 strategy)
bool get_ordering_op_properties(Oid opno, Oid *opfamily, Oid *opcintype, int16 *strategy)
int32 get_typavgwidth(Oid typid, int32 typmod)
Var * makeVarFromTargetEntry(int varno, TargetEntry *tle)
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)
void pfree(void *pointer)
void * palloc0(Size size)
MemoryContext CurrentMemoryContext
int _bt_getrootheight(Relation rel)
void fix_opfuncids(Node *node)
#define IsA(nodeptr, _type_)
void expandRTE(RangeTblEntry *rte, int rtindex, int sublevels_up, int location, bool include_dropped, List **colnames, List **colvars)
#define rt_fetch(rangetable_index, rangetable)
List * RelationGetPartitionQual(Relation rel)
PartitionKey RelationGetPartitionKey(Relation rel)
PartitionDirectory CreatePartitionDirectory(MemoryContext mcxt, bool omit_detached)
PartitionDesc PartitionDirectoryLookup(PartitionDirectory pdir, Relation rel)
#define IS_SIMPLE_REL(rel)
#define planner_rt_fetch(rti, root)
struct PartitionSchemeData * PartitionScheme
@ RELOPT_OTHER_MEMBER_REL
#define AMFLAG_HAS_TID_RANGE
FormData_pg_attribute * Form_pg_attribute
int errdetail_relkind_not_supported(char relkind)
FormData_pg_index * Form_pg_index
static int list_length(const List *l)
static ListCell * list_head(const List *l)
static void * list_nth(const List *list, int n)
static ListCell * lnext(const List *l, const ListCell *c)
FormData_pg_proc * Form_pg_proc
FormData_pg_statistic_ext * Form_pg_statistic_ext
FormData_pg_statistic_ext_data * Form_pg_statistic_ext_data
void estimate_rel_size(Relation rel, int32 *attr_widths, BlockNumber *pages, double *tuples, double *allvisfrac)
Bitmapset * get_dependent_generated_columns(PlannerInfo *root, Index rti, Bitmapset *target_cols)
int32 get_rel_data_width(Relation rel, int32 *attr_widths)
bool has_stored_generated_columns(PlannerInfo *root, Index rti)
static void get_relation_foreign_keys(PlannerInfo *root, RelOptInfo *rel, Relation relation, bool inhparent)
bool relation_excluded_by_constraints(PlannerInfo *root, RelOptInfo *rel, RangeTblEntry *rte)
double get_function_rows(PlannerInfo *root, Oid funcid, Node *node)
bool has_row_triggers(PlannerInfo *root, Index rti, CmdType event)
static List * get_relation_constraints(PlannerInfo *root, Oid relationObjectId, RelOptInfo *rel, bool include_noinherit, bool include_notnull, bool include_partition)
void add_function_cost(PlannerInfo *root, Oid funcid, Node *node, QualCost *cost)
List * build_physical_tlist(PlannerInfo *root, RelOptInfo *rel)
get_relation_info_hook_type get_relation_info_hook
List * infer_arbiter_indexes(PlannerInfo *root)
static void get_relation_statistics_worker(List **stainfos, RelOptInfo *rel, Oid statOid, bool inh, Bitmapset *keys, List *exprs)
Selectivity restriction_selectivity(PlannerInfo *root, Oid operatorid, List *args, Oid inputcollid, int varRelid)
int32 get_relation_data_width(Oid relid, int32 *attr_widths)
static void set_baserel_partition_constraint(Relation relation, RelOptInfo *rel)
static List * build_index_tlist(PlannerInfo *root, IndexOptInfo *index, Relation heapRelation)
static bool infer_collation_opclass_match(InferenceElem *elem, Relation idxRel, List *idxExprs)
static List * get_relation_statistics(RelOptInfo *rel, Relation relation)
static void set_relation_partition_info(PlannerInfo *root, RelOptInfo *rel, Relation relation)
bool has_unique_index(RelOptInfo *rel, AttrNumber attno)
static PartitionScheme find_partition_scheme(PlannerInfo *root, Relation relation)
static void set_baserel_partition_key_exprs(Relation relation, RelOptInfo *rel)
Selectivity join_selectivity(PlannerInfo *root, Oid operatorid, List *args, Oid inputcollid, JoinType jointype, SpecialJoinInfo *sjinfo)
Selectivity function_selectivity(PlannerInfo *root, Oid funcid, List *args, Oid inputcollid, bool is_join, int varRelid, JoinType jointype, SpecialJoinInfo *sjinfo)
void get_relation_info(PlannerInfo *root, Oid relationObjectId, bool inhparent, RelOptInfo *rel)
void(* get_relation_info_hook_type)(PlannerInfo *root, Oid relationObjectId, bool inhparent, RelOptInfo *rel)
Expr * expression_planner(Expr *expr)
static bool DatumGetBool(Datum X)
static Datum PointerGetDatum(const void *X)
static Datum Int16GetDatum(int16 X)
static Datum BoolGetDatum(bool X)
static float8 DatumGetFloat8(Datum X)
static Datum ObjectIdGetDatum(Oid X)
static Pointer DatumGetPointer(Datum X)
static Datum Int32GetDatum(int32 X)
bool predicate_refuted_by(List *predicate_list, List *clause_list, bool weak)
bool predicate_implied_by(List *predicate_list, List *clause_list, bool weak)
Expr * canonicalize_qual(Expr *qual, bool is_check)
void * stringToNode(const char *str)
#define RelationGetForm(relation)
#define RelationGetRelid(relation)
#define RelationGetParallelWorkers(relation, defaultpw)
#define RelationGetDescr(relation)
#define RelationGetNumberOfAttributes(relation)
#define RelationGetRelationName(relation)
#define RelationIsPermanent(relation)
List * RelationGetIndexList(Relation relation)
List * RelationGetIndexPredicate(Relation relation)
List * RelationGetStatExtList(Relation relation)
List * RelationGetFKeyList(Relation relation)
bytea ** RelationGetIndexAttOptions(Relation relation, bool copy)
List * RelationGetIndexExpressions(Relation relation)
void ChangeVarNodes(Node *node, int rt_index, int new_index, int sublevels_up)
TransactionId TransactionXmin
#define BTLessStrategyNumber
struct EquivalenceClass * eclass[INDEX_MAX_KEYS]
List * rinfos[INDEX_MAX_KEYS]
struct EquivalenceMember * fk_eclass_member[INDEX_MAX_KEYS]
amrestrpos_function amrestrpos
amcostestimate_function amcostestimate
amgettuple_function amgettuple
amgetbitmap_function amgetbitmap
ammarkpos_function ammarkpos
void(* amcostestimate)() pg_node_attr(read_write_ignore)
NullTestType nulltesttype
PartitionBoundInfo boundinfo
PartitionStrategy strategy
struct FmgrInfo * partsupfunc
OnConflictExpr * onConflict
Bitmapset * notnullattnums
const struct TableAmRoutine * rd_tableam
struct IndexAmRoutine * rd_indam
struct HeapTupleData * rd_indextuple
struct PlannerInfo * root
struct PlannerInfo * root
struct PlannerInfo * root
struct SpecialJoinInfo * sjinfo
bool(* scan_getnextslot_tidrange)(TableScanDesc scan, ScanDirection direction, TupleTableSlot *slot)
void(* scan_set_tidrange)(TableScanDesc scan, ItemPointer mintid, ItemPointer maxtid)
bool(* scan_bitmap_next_block)(TableScanDesc scan, struct TBMIterateResult *tbmres)
bool trig_delete_before_row
bool trig_update_after_row
bool trig_insert_after_row
bool trig_update_before_row
bool trig_delete_after_row
bool trig_insert_before_row
bool has_generated_stored
FormData_pg_attribute attrs[FLEXIBLE_ARRAY_MEMBER]
#define FirstLowInvalidHeapAttributeNumber
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
Datum SysCacheGetAttr(int cacheId, HeapTuple tup, AttrNumber attributeNumber, bool *isNull)
HeapTuple SearchSysCache2(int cacheId, Datum key1, Datum key2)
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
static void table_relation_estimate_size(Relation rel, int32 *attr_widths, BlockNumber *pages, double *tuples, double *allvisfrac)
bool TransactionIdPrecedes(TransactionId id1, TransactionId id2)
#define TupleDescAttr(tupdesc, i)
void pull_varattnos(Node *node, Index varno, Bitmapset **varattnos)
bool RecoveryInProgress(void)