47#include "utils/fmgroids.h"
96 result = amop_tup->amopstrategy;
121 result = amop_tup->amopsortfamily;
149 elog(
ERROR,
"operator %u is not a member of opfamily %u",
152 *strategy = amop_tup->amopstrategy;
153 *lefttype = amop_tup->amoplefttype;
154 *righttype = amop_tup->amoprighttype;
181 result = amop_tup->amopopr;
231 if (aform->amopmethod != BTREE_AM_OID)
238 if (aform->amoplefttype == aform->amoprighttype)
241 *opfamily = aform->amopfamily;
242 *opcintype = aform->amoplefttype;
243 *strategy = aform->amopstrategy;
276 &opfamily, &opcintype, &strategy))
323 if (aform->amopmethod != BTREE_AM_OID)
331 typid = use_lhs_type ? aform->amoplefttype : aform->amoprighttype;
384 if (aform->amopmethod == BTREE_AM_OID &&
411 Oid *lhs_opno,
Oid *rhs_opno)
435 if (aform->amopmethod == HASH_AM_OID &&
439 if (aform->amoplefttype == aform->amoprighttype)
472 aform->amoprighttype,
473 aform->amoprighttype,
535 if (aform->amopmethod == HASH_AM_OID &&
558 if (aform->amoplefttype == aform->amoprighttype)
560 *rhs_procno = *lhs_procno;
568 aform->amoprighttype,
569 aform->amoprighttype,
620 if (op_form->amopmethod != BTREE_AM_OID)
625 Assert(op_strategy >= 1 && op_strategy <= 5);
631 thisresult->
oplefttype = op_form->amoplefttype;
633 result =
lappend(result, thisresult);
658 if (op_form->amopmethod != BTREE_AM_OID)
663 Assert(op_strategy >= 1 && op_strategy <= 5);
674 thisresult->
oplefttype = op_form->amoplefttype;
676 result =
lappend(result, thisresult);
720 if (op_form->amopmethod == BTREE_AM_OID ||
721 op_form->amopmethod == HASH_AM_OID)
770 if (op_form->amopmethod == BTREE_AM_OID)
810 result = amproc_tup->amproc;
844 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
868 result = att_tup->attnum;
898 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
901 result = att_tup->attgenerated;
925 result = att_tup->atttypid;
953 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
957 *typid = att_tup->atttypid;
958 *typmod = att_tup->atttypmod;
959 *
collid = att_tup->attcollation;
982 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
985 attopts =
SysCacheGetAttr(ATTNAME, tuple, Anum_pg_attribute_attoptions,
1016 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1017 errmsg(
"cast from type %s to type %s does not exist",
1062 elog(
ERROR,
"cache lookup failed for collation %u", colloid);
1064 result = colltup->collisdeterministic;
1123 if (contup->contype == CONSTRAINT_UNIQUE ||
1124 contup->contype == CONSTRAINT_PRIMARY ||
1125 contup->contype == CONSTRAINT_EXCLUSION)
1126 result = contup->conindid;
1150 elog(
ERROR,
"cache lookup failed for constraint %u", conoid);
1177 elog(
ERROR,
"cache lookup failed for language %u",
1198 elog(
ERROR,
"cache lookup failed for opclass %u", opclass);
1201 result = cla_tup->opcfamily;
1220 elog(
ERROR,
"cache lookup failed for opclass %u", opclass);
1223 result = cla_tup->opcintype;
1246 *opfamily = cla_tup->opcfamily;
1247 *opcintype = cla_tup->opcintype;
1268 elog(
ERROR,
"cache lookup failed for opclass %u", opclass);
1271 result = cla_tup->opcmethod;
1295 result = optup->oprcode;
1343 result = optup->oprresult;
1365 elog(
ERROR,
"cache lookup failed for operator %u", opno);
1367 *lefttype = optup->oprleft;
1368 *righttype = optup->oprright;
1388 bool result =
false;
1398 if (opno == ARRAY_EQ_OP)
1401 if (typentry->
cmp_proc == F_BTARRAYCMP)
1404 else if (opno == RECORD_EQ_OP)
1407 if (typentry->
cmp_proc == F_BTRECORDCMP)
1418 result = optup->oprcanmerge;
1439 bool result =
false;
1444 if (opno == ARRAY_EQ_OP)
1447 if (typentry->
hash_proc == F_HASH_ARRAY)
1450 else if (opno == RECORD_EQ_OP)
1453 if (typentry->
hash_proc == F_HASH_RECORD)
1464 result = optup->oprcanhash;
1482 elog(
ERROR,
"operator %u does not exist", opno);
1498 elog(
ERROR,
"operator %u does not exist", opno);
1519 result = optup->oprcom;
1543 result = optup->oprnegate;
1567 result = optup->oprrest;
1591 result = optup->oprjoin;
1642 result = functup->pronamespace;
1662 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1681 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1704 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1708 result = procstruct->prorettype;
1709 *nargs = (int) procstruct->pronargs;
1710 Assert(*nargs == procstruct->proargtypes.dim1);
1712 memcpy(*argtypes, procstruct->proargtypes.values, *nargs *
sizeof(
Oid));
1730 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1749 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1768 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1787 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1806 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1825 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1844 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1868 result = functup->prosupport;
1899get_relnatts(
Oid relid)
1909 result = reltup->relnatts;
1962 result = reltup->relnamespace;
1989 result = reltup->reltype;
2013 result = reltup->relkind;
2037 result = reltup->relispartition;
2064 result = reltup->reltablespace;
2086 elog(
ERROR,
"cache lookup failed for relation %u", relid);
2088 result = reltup->relpersistence;
2108 elog(
ERROR,
"cache lookup failed for relation %u", relid);
2110 result = reltup->relam;
2183 result = typtup->typisdefined;
2207 result = typtup->typlen;
2232 result = typtup->typbyval;
2258 elog(
ERROR,
"cache lookup failed for type %u", typid);
2260 *typlen = typtup->typlen;
2261 *typbyval = typtup->typbyval;
2279 elog(
ERROR,
"cache lookup failed for type %u", typid);
2281 *typlen = typtup->typlen;
2282 *typbyval = typtup->typbyval;
2312 return typeStruct->typelem;
2314 return typeStruct->oid;
2363 elog(
ERROR,
"binary I/O not supported during bootstrap");
2371 elog(
ERROR,
"cache lookup failed for type %u", typid);
2374 *typlen = typeStruct->typlen;
2375 *typbyval = typeStruct->typbyval;
2377 *typdelim = typeStruct->typdelim;
2382 *func = typeStruct->typinput;
2385 *func = typeStruct->typoutput;
2388 *func = typeStruct->typreceive;
2391 *func = typeStruct->typsend;
2399get_typalign(
Oid typid)
2409 result = typtup->typalign;
2414 return TYPALIGN_INT;
2429 result = typtup->typstorage;
2434 return TYPSTORAGE_PLAIN;
2458 elog(
ERROR,
"cache lookup failed for type %u", typid);
2468 Anum_pg_type_typdefaultbin,
2481 Anum_pg_type_typdefault,
2486 char *strDefaultVal;
2501 pfree(strDefaultVal);
2550 elog(
ERROR,
"cache lookup failed for type %u", typid);
2552 if (typTup->typtype != TYPTYPE_DOMAIN)
2560 typid = typTup->typbasetype;
2561 *typmod = typTup->typtypmod;
2601 if (typid == BPCHAROID)
2605 if (maxwidth < 1000)
2606 return 32 + (maxwidth - 32) / 2;
2613 return 32 + (1000 - 32) / 2;
2639 result = typtup->typtype;
2657 if (typid == RECORDOID)
2661 case TYPTYPE_COMPOSITE:
2663 case TYPTYPE_DOMAIN:
2700 return (
get_typtype(typid) == TYPTYPE_MULTIRANGE);
2717 elog(
ERROR,
"cache lookup failed for type %u", typid);
2719 *typcategory = typtup->typcategory;
2720 *typispreferred = typtup->typispreferred;
2741 result = typtup->typrelid;
2769 if (IsTrueArrayType(typtup))
2770 result = typtup->typelem;
2846 if (typTup->typtype != TYPTYPE_DOMAIN)
2852 if (IsTrueArrayType(typTup))
2853 result = typTup->typelem;
2860 typid = typTup->typbasetype;
2884 if (!pt->typisdefined)
2886 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2887 errmsg(
"type %s is only a shell",
2891 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2892 errmsg(
"no input function available for type %s",
2895 *typInput = pt->typinput;
2917 if (!pt->typisdefined)
2919 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2920 errmsg(
"type %s is only a shell",
2924 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2925 errmsg(
"no output function available for type %s",
2928 *typOutput = pt->typoutput;
2929 *typIsVarlena = (!pt->typbyval) && (pt->typlen == -1);
2950 if (!pt->typisdefined)
2952 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2953 errmsg(
"type %s is only a shell",
2957 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2958 errmsg(
"no binary input function available for type %s",
2961 *typReceive = pt->typreceive;
2983 if (!pt->typisdefined)
2985 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2986 errmsg(
"type %s is only a shell",
2990 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2991 errmsg(
"no binary output function available for type %s",
2994 *typSend = pt->typsend;
2995 *typIsVarlena = (!pt->typbyval) && (pt->typlen == -1);
3016 result = typtup->typmodin;
3031get_typmodout(
Oid typid)
3041 result = typtup->typmodout;
3066 result = typtup->typcollation;
3108 *typelemp = typform->typelem;
3165 stawidth = (*get_attavgwidth_hook) (relid,
attnum);
3235 int reqkind,
Oid reqop,
int flags)
3251 if ((&stats->stakind1)[
i] == reqkind &&
3252 (reqop ==
InvalidOid || (&stats->staop1)[
i] == reqop))
3258 sslot->
staop = (&stats->staop1)[
i];
3259 sslot->
stacoll = (&stats->stacoll1)[
i];
3264 Anum_pg_statistic_stavalues1 +
i);
3281 elog(
ERROR,
"cache lookup failed for type %u", arrayelemtype);
3298 if (!typeForm->typbyval)
3309 Anum_pg_statistic_stanumbers1 +
i);
3322 narrayelem =
ARR_DIMS(statarray)[0];
3323 if (
ARR_NDIM(statarray) != 1 || narrayelem <= 0 ||
3326 elog(
ERROR,
"stanumbers is not a 1-D float4 array");
3417 result = rngtup->rngsubtype;
3443 result = rngtup->rngcollation;
3468 result = rngtup->rngmultitypid;
3493 result = rngtup->rngtypid;
3529 Assert(attno > 0 && attno <= rd_index->indnatts);
3532 if (attno > rd_index->indnkeyatts)
3541 Assert(attno <= indclass->dim1);
3542 opclass = indclass->
values[attno - 1];
3566 result = rd_index->indisreplident;
3586 elog(
ERROR,
"cache lookup failed for index %u", index_oid);
3589 isvalid = rd_index->indisvalid;
3609 elog(
ERROR,
"cache lookup failed for index %u", index_oid);
3612 isclustered = rd_index->indisclustered;
3633 (
errcode(ERRCODE_UNDEFINED_OBJECT),
3634 errmsg(
"publication \"%s\" does not exist", pubname)));
3656 elog(
ERROR,
"cache lookup failed for publication %u", pubid);
3683 (
errcode(ERRCODE_UNDEFINED_OBJECT),
3706 elog(
ERROR,
"cache lookup failed for subscription %u", subid);
#define DatumGetArrayTypePCopy(X)
void deconstruct_array(ArrayType *array, Oid elmtype, int elmlen, bool elmbyval, char elmalign, Datum **elemsp, bool **nullsp, int *nelemsp)
#define InvalidAttrNumber
void boot_get_type_io_data(Oid typid, int16 *typlen, bool *typbyval, char *typalign, char *typdelim, Oid *typioparam, Oid *typinput, Oid *typoutput)
#define TextDatumGetCString(d)
#define Assert(condition)
#define OidIsValid(objectId)
Datum datumCopy(Datum value, bool typByVal, int typLen)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
Datum OidInputFunctionCall(Oid functionId, char *str, Oid typioparam, int32 typmod)
#define OidFunctionCall0(functionId)
#define HASHSTANDARD_PROC
#define HeapTupleIsValid(tuple)
List * lappend(List *list, void *datum)
List * lappend_oid(List *list, Oid datum)
bool list_member_oid(const List *list, Oid datum)
List * get_op_btree_interpretation(Oid opno)
Oid get_range_subtype(Oid rangeOid)
char * get_rel_name(Oid relid)
void get_op_opfamily_properties(Oid opno, Oid opfamily, bool ordering_op, int *strategy, Oid *lefttype, Oid *righttype)
Oid get_func_variadictype(Oid funcid)
Oid get_opclass_method(Oid opclass)
bool get_compatible_hash_operators(Oid opno, Oid *lhs_opno, Oid *rhs_opno)
bool get_rel_relispartition(Oid relid)
Oid get_op_opfamily_sortfamily(Oid opno, Oid opfamily)
char get_rel_persistence(Oid relid)
char get_func_prokind(Oid funcid)
bool get_index_isvalid(Oid index_oid)
Oid get_cast_oid(Oid sourcetypeid, Oid targettypeid, bool missing_ok)
void getTypeBinaryOutputInfo(Oid type, Oid *typSend, bool *typIsVarlena)
AttrNumber get_attnum(Oid relid, const char *attname)
RegProcedure get_oprrest(Oid opno)
void free_attstatsslot(AttStatsSlot *sslot)
bool comparison_ops_are_compatible(Oid opno1, Oid opno2)
Oid get_constraint_index(Oid conoid)
bool get_func_retset(Oid funcid)
Oid get_element_type(Oid typid)
Oid get_opclass_input_type(Oid opclass)
bool type_is_rowtype(Oid typid)
bool type_is_range(Oid typid)
char func_parallel(Oid funcid)
Oid get_opclass_family(Oid opclass)
char get_attgenerated(Oid relid, AttrNumber attnum)
bool type_is_enum(Oid typid)
Oid get_multirange_range(Oid multirangeOid)
Oid get_typmodin(Oid typid)
char get_typstorage(Oid typid)
bool get_opclass_opfamily_and_input_type(Oid opclass, Oid *opfamily, Oid *opcintype)
RegProcedure get_func_support(Oid funcid)
void getTypeOutputInfo(Oid type, Oid *typOutput, bool *typIsVarlena)
bool get_typisdefined(Oid typid)
char * get_opname(Oid opno)
Datum get_attoptions(Oid relid, int16 attnum)
void get_typlenbyvalalign(Oid typid, int16 *typlen, bool *typbyval, char *typalign)
int32 get_attavgwidth(Oid relid, AttrNumber attnum)
bool get_index_isreplident(Oid index_oid)
Oid get_opfamily_proc(Oid opfamily, Oid lefttype, Oid righttype, int16 procnum)
RegProcedure get_oprjoin(Oid opno)
Oid get_equality_op_for_ordering_op(Oid opno, bool *reverse)
bool op_hashjoinable(Oid opno, Oid inputtype)
char get_rel_relkind(Oid relid)
void get_typlenbyval(Oid typid, int16 *typlen, bool *typbyval)
Oid get_func_signature(Oid funcid, Oid **argtypes, int *nargs)
Oid get_publication_oid(const char *pubname, bool missing_ok)
Oid get_rel_namespace(Oid relid)
RegProcedure get_opcode(Oid opno)
Oid get_typcollation(Oid typid)
Oid get_op_rettype(Oid opno)
int get_op_opfamily_strategy(Oid opno, Oid opfamily)
char * get_collation_name(Oid colloid)
Oid get_rel_type_id(Oid relid)
char * get_language_name(Oid langoid, bool missing_ok)
char * get_namespace_name_or_temp(Oid nspid)
void getTypeInputInfo(Oid type, Oid *typInput, Oid *typIOParam)
char func_volatile(Oid funcid)
bool equality_ops_are_compatible(Oid opno1, Oid opno2)
get_attavgwidth_hook_type get_attavgwidth_hook
bool get_index_isclustered(Oid index_oid)
Oid get_opfamily_member(Oid opfamily, Oid lefttype, Oid righttype, int16 strategy)
Oid get_ordering_op_for_equality_op(Oid opno, bool use_lhs_type)
Oid get_transform_tosql(Oid typid, Oid langid, List *trftypes)
bool func_strict(Oid funcid)
Oid get_index_column_opclass(Oid index_oid, int attno)
char * get_constraint_name(Oid conoid)
char * get_attname(Oid relid, AttrNumber attnum, bool missing_ok)
bool get_ordering_op_properties(Oid opno, Oid *opfamily, Oid *opcintype, int16 *strategy)
bool get_func_leakproof(Oid funcid)
const struct SubscriptRoutines * getSubscriptingRoutines(Oid typid, Oid *typelemp)
Node * get_typdefault(Oid typid)
bool get_collation_isdeterministic(Oid colloid)
Oid get_subscription_oid(const char *subname, bool missing_ok)
char * get_subscription_name(Oid subid, bool missing_ok)
Oid get_range_collation(Oid rangeOid)
char * get_func_name(Oid funcid)
Oid get_range_multirange(Oid rangeOid)
Oid get_rel_relam(Oid relid)
char op_volatile(Oid opno)
Oid get_func_namespace(Oid funcid)
bool type_is_collatable(Oid typid)
Oid get_rel_tablespace(Oid relid)
int get_func_nargs(Oid funcid)
void get_type_io_data(Oid typid, IOFuncSelector which_func, int16 *typlen, bool *typbyval, char *typalign, char *typdelim, Oid *typioparam, Oid *func)
int16 get_typlen(Oid typid)
Oid get_typ_typrelid(Oid typid)
char get_typtype(Oid typid)
Oid get_base_element_type(Oid typid)
Oid getTypeIOParam(HeapTuple typeTuple)
Oid getBaseTypeAndTypmod(Oid typid, int32 *typmod)
Oid get_transform_fromsql(Oid typid, Oid langid, List *trftypes)
char * get_publication_name(Oid pubid, bool missing_ok)
Oid getBaseType(Oid typid)
bool get_op_hash_functions(Oid opno, RegProcedure *lhs_procno, RegProcedure *rhs_procno)
bool get_typbyval(Oid typid)
bool op_mergejoinable(Oid opno, Oid inputtype)
List * get_mergejoin_opfamilies(Oid opno)
char * get_namespace_name(Oid nspid)
Oid get_array_type(Oid typid)
Oid get_func_rettype(Oid funcid)
Oid get_promoted_array_type(Oid typid)
Oid get_atttype(Oid relid, AttrNumber attnum)
char get_constraint_type(Oid conoid)
int32 get_typavgwidth(Oid typid, int32 typmod)
bool op_in_opfamily(Oid opno, Oid opfamily)
RegProcedure get_typsubscript(Oid typid, Oid *typelemp)
void get_type_category_preferred(Oid typid, char *typcategory, bool *typispreferred)
bool get_attstatsslot(AttStatsSlot *sslot, HeapTuple statstuple, int reqkind, Oid reqop, int flags)
Oid get_relname_relid(const char *relname, Oid relnamespace)
Oid get_negator(Oid opno)
Oid get_commutator(Oid opno)
void op_input_types(Oid opno, Oid *lefttype, Oid *righttype)
bool type_is_multirange(Oid typid)
void getTypeBinaryInputInfo(Oid type, Oid *typReceive, Oid *typIOParam)
void get_atttypetypmodcoll(Oid relid, AttrNumber attnum, Oid *typid, int32 *typmod, Oid *collid)
#define ATTSTATSSLOT_NUMBERS
#define ATTSTATSSLOT_VALUES
int32(* get_attavgwidth_hook_type)(Oid relid, AttrNumber attnum)
Const * makeConst(Oid consttype, int32 consttypmod, Oid constcollid, int constlen, Datum constvalue, bool constisnull, bool constbyval)
char * pstrdup(const char *in)
void pfree(void *pointer)
#define IsBootstrapProcessingMode()
bool isTempNamespace(Oid namespaceId)
FormData_pg_amop * Form_pg_amop
FormData_pg_amproc * Form_pg_amproc
FormData_pg_attribute * Form_pg_attribute
FormData_pg_class * Form_pg_class
FormData_pg_collation * Form_pg_collation
FormData_pg_constraint * Form_pg_constraint
FormData_pg_index * Form_pg_index
FormData_pg_language * Form_pg_language
FormData_pg_namespace * Form_pg_namespace
FormData_pg_opclass * Form_pg_opclass
FormData_pg_operator * Form_pg_operator
FormData_pg_proc * Form_pg_proc
FormData_pg_publication * Form_pg_publication
FormData_pg_range * Form_pg_range
#define STATISTIC_NUM_SLOTS
FormData_pg_statistic * Form_pg_statistic
FormData_pg_subscription * Form_pg_subscription
FormData_pg_type * Form_pg_type
static Datum PointerGetDatum(const void *X)
static Datum Int16GetDatum(int16 X)
static Datum BoolGetDatum(bool X)
static Datum ObjectIdGetDatum(Oid X)
static Pointer DatumGetPointer(Datum X)
static Datum CStringGetDatum(const char *X)
static Datum CharGetDatum(char X)
void * stringToNode(const char *str)
#define BTGreaterStrategyNumber
#define HTEqualStrategyNumber
#define BTLessStrategyNumber
#define BTEqualStrategyNumber
CatCTup * members[FLEXIBLE_ARRAY_MEMBER]
Oid values[FLEXIBLE_ARRAY_MEMBER]
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
HeapTuple SearchSysCache3(int cacheId, Datum key1, Datum key2, Datum key3)
Datum SysCacheGetAttr(int cacheId, HeapTuple tup, AttrNumber attributeNumber, bool *isNull)
HeapTuple SearchSysCache2(int cacheId, Datum key1, Datum key2)
HeapTuple SearchSysCacheAttName(Oid relid, const char *attname)
HeapTuple SearchSysCache4(int cacheId, Datum key1, Datum key2, Datum key3, Datum key4)
Datum SysCacheGetAttrNotNull(int cacheId, HeapTuple tup, AttrNumber attributeNumber)
#define ReleaseSysCacheList(x)
#define SearchSysCacheList1(cacheId, key1)
#define SearchSysCacheExists3(cacheId, key1, key2, key3)
#define GetSysCacheOid1(cacheId, oidcol, key1)
#define GetSysCacheOid2(cacheId, oidcol, key1, key2)
TypeCacheEntry * lookup_type_cache(Oid type_id, int flags)
#define TYPECACHE_CMP_PROC
#define TYPECACHE_HASH_PROC