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;
1155 elog(
ERROR,
"cache lookup failed for language %u",
1176 elog(
ERROR,
"cache lookup failed for opclass %u", opclass);
1179 result = cla_tup->opcfamily;
1198 elog(
ERROR,
"cache lookup failed for opclass %u", opclass);
1201 result = cla_tup->opcintype;
1224 *opfamily = cla_tup->opcfamily;
1225 *opcintype = cla_tup->opcintype;
1246 elog(
ERROR,
"cache lookup failed for opclass %u", opclass);
1249 result = cla_tup->opcmethod;
1273 result = optup->oprcode;
1321 result = optup->oprresult;
1343 elog(
ERROR,
"cache lookup failed for operator %u", opno);
1345 *lefttype = optup->oprleft;
1346 *righttype = optup->oprright;
1366 bool result =
false;
1376 if (opno == ARRAY_EQ_OP)
1379 if (typentry->
cmp_proc == F_BTARRAYCMP)
1382 else if (opno == RECORD_EQ_OP)
1385 if (typentry->
cmp_proc == F_BTRECORDCMP)
1396 result = optup->oprcanmerge;
1417 bool result =
false;
1422 if (opno == ARRAY_EQ_OP)
1425 if (typentry->
hash_proc == F_HASH_ARRAY)
1428 else if (opno == RECORD_EQ_OP)
1431 if (typentry->
hash_proc == F_HASH_RECORD)
1442 result = optup->oprcanhash;
1460 elog(
ERROR,
"operator %u does not exist", opno);
1476 elog(
ERROR,
"operator %u does not exist", opno);
1497 result = optup->oprcom;
1521 result = optup->oprnegate;
1545 result = optup->oprrest;
1569 result = optup->oprjoin;
1620 result = functup->pronamespace;
1640 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1659 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1682 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1686 result = procstruct->prorettype;
1687 *nargs = (int) procstruct->pronargs;
1688 Assert(*nargs == procstruct->proargtypes.dim1);
1690 memcpy(*argtypes, procstruct->proargtypes.values, *nargs *
sizeof(
Oid));
1708 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1727 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1746 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1765 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1784 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1803 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1822 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1846 result = functup->prosupport;
1877 get_relnatts(
Oid relid)
1887 result = reltup->relnatts;
1940 result = reltup->relnamespace;
1967 result = reltup->reltype;
1991 result = reltup->relkind;
2015 result = reltup->relispartition;
2042 result = reltup->reltablespace;
2064 elog(
ERROR,
"cache lookup failed for relation %u", relid);
2066 result = reltup->relpersistence;
2139 result = typtup->typisdefined;
2163 result = typtup->typlen;
2188 result = typtup->typbyval;
2214 elog(
ERROR,
"cache lookup failed for type %u", typid);
2216 *typlen = typtup->typlen;
2217 *typbyval = typtup->typbyval;
2235 elog(
ERROR,
"cache lookup failed for type %u", typid);
2237 *typlen = typtup->typlen;
2238 *typbyval = typtup->typbyval;
2268 return typeStruct->typelem;
2270 return typeStruct->oid;
2319 elog(
ERROR,
"binary I/O not supported during bootstrap");
2327 elog(
ERROR,
"cache lookup failed for type %u", typid);
2330 *typlen = typeStruct->typlen;
2331 *typbyval = typeStruct->typbyval;
2333 *typdelim = typeStruct->typdelim;
2338 *func = typeStruct->typinput;
2341 *func = typeStruct->typoutput;
2344 *func = typeStruct->typreceive;
2347 *func = typeStruct->typsend;
2355 get_typalign(
Oid typid)
2365 result = typtup->typalign;
2370 return TYPALIGN_INT;
2385 result = typtup->typstorage;
2390 return TYPSTORAGE_PLAIN;
2414 elog(
ERROR,
"cache lookup failed for type %u", typid);
2424 Anum_pg_type_typdefaultbin,
2437 Anum_pg_type_typdefault,
2442 char *strDefaultVal;
2457 pfree(strDefaultVal);
2506 elog(
ERROR,
"cache lookup failed for type %u", typid);
2508 if (typTup->typtype != TYPTYPE_DOMAIN)
2516 typid = typTup->typbasetype;
2517 *typmod = typTup->typtypmod;
2557 if (typid == BPCHAROID)
2561 if (maxwidth < 1000)
2562 return 32 + (maxwidth - 32) / 2;
2569 return 32 + (1000 - 32) / 2;
2595 result = typtup->typtype;
2613 if (typid == RECORDOID)
2617 case TYPTYPE_COMPOSITE:
2619 case TYPTYPE_DOMAIN:
2656 return (
get_typtype(typid) == TYPTYPE_MULTIRANGE);
2673 elog(
ERROR,
"cache lookup failed for type %u", typid);
2675 *typcategory = typtup->typcategory;
2676 *typispreferred = typtup->typispreferred;
2697 result = typtup->typrelid;
2725 if (IsTrueArrayType(typtup))
2726 result = typtup->typelem;
2802 if (typTup->typtype != TYPTYPE_DOMAIN)
2808 if (IsTrueArrayType(typTup))
2809 result = typTup->typelem;
2816 typid = typTup->typbasetype;
2840 if (!pt->typisdefined)
2842 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2843 errmsg(
"type %s is only a shell",
2847 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2848 errmsg(
"no input function available for type %s",
2851 *typInput = pt->typinput;
2873 if (!pt->typisdefined)
2875 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2876 errmsg(
"type %s is only a shell",
2880 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2881 errmsg(
"no output function available for type %s",
2884 *typOutput = pt->typoutput;
2885 *typIsVarlena = (!pt->typbyval) && (pt->typlen == -1);
2906 if (!pt->typisdefined)
2908 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2909 errmsg(
"type %s is only a shell",
2913 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2914 errmsg(
"no binary input function available for type %s",
2917 *typReceive = pt->typreceive;
2939 if (!pt->typisdefined)
2941 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2942 errmsg(
"type %s is only a shell",
2946 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2947 errmsg(
"no binary output function available for type %s",
2950 *typSend = pt->typsend;
2951 *typIsVarlena = (!pt->typbyval) && (pt->typlen == -1);
2972 result = typtup->typmodin;
2987 get_typmodout(
Oid typid)
2997 result = typtup->typmodout;
3022 result = typtup->typcollation;
3064 *typelemp = typform->typelem;
3121 stawidth = (*get_attavgwidth_hook) (relid,
attnum);
3191 int reqkind,
Oid reqop,
int flags)
3207 if ((&stats->stakind1)[
i] == reqkind &&
3208 (reqop ==
InvalidOid || (&stats->staop1)[
i] == reqop))
3214 sslot->
staop = (&stats->staop1)[
i];
3215 sslot->
stacoll = (&stats->stacoll1)[
i];
3220 Anum_pg_statistic_stavalues1 +
i);
3237 elog(
ERROR,
"cache lookup failed for type %u", arrayelemtype);
3254 if (!typeForm->typbyval)
3265 Anum_pg_statistic_stanumbers1 +
i);
3278 narrayelem =
ARR_DIMS(statarray)[0];
3279 if (
ARR_NDIM(statarray) != 1 || narrayelem <= 0 ||
3282 elog(
ERROR,
"stanumbers is not a 1-D float4 array");
3373 result = rngtup->rngsubtype;
3399 result = rngtup->rngcollation;
3424 result = rngtup->rngmultitypid;
3449 result = rngtup->rngtypid;
3485 Assert(attno > 0 && attno <= rd_index->indnatts);
3488 if (attno > rd_index->indnkeyatts)
3497 Assert(attno <= indclass->dim1);
3498 opclass = indclass->
values[attno - 1];
3522 result = rd_index->indisreplident;
3542 elog(
ERROR,
"cache lookup failed for index %u", index_oid);
3545 isvalid = rd_index->indisvalid;
3565 elog(
ERROR,
"cache lookup failed for index %u", index_oid);
3568 isclustered = rd_index->indisclustered;
3589 (
errcode(ERRCODE_UNDEFINED_OBJECT),
3590 errmsg(
"publication \"%s\" does not exist", pubname)));
3612 elog(
ERROR,
"cache lookup failed for publication %u", pubid);
3639 (
errcode(ERRCODE_UNDEFINED_OBJECT),
3662 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 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)
Assert(fmt[strlen(fmt) - 1] !='\n')
List * lappend(List *list, void *datum)
List * lappend_oid(List *list, Oid datum)
bool list_member_oid(const List *list, Oid datum)
Oid get_range_subtype(Oid rangeOid)
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)
char * get_language_name(Oid langoid, bool missing_ok)
Oid get_op_opfamily_sortfamily(Oid opno, Oid opfamily)
char get_rel_persistence(Oid relid)
char get_func_prokind(Oid funcid)
char * get_opname(Oid opno)
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)
List * get_mergejoin_opfamilies(Oid opno)
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)
char * get_namespace_name_or_temp(Oid nspid)
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)
char * get_namespace_name(Oid nspid)
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)
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)
char * get_publication_name(Oid pubid, 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)
Oid get_rel_type_id(Oid relid)
char * get_rel_name(Oid relid)
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
char * get_func_name(Oid funcid)
bool get_index_isclustered(Oid index_oid)
Oid get_opfamily_member(Oid opfamily, Oid lefttype, Oid righttype, int16 strategy)
char * get_collation_name(Oid colloid)
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)
bool get_ordering_op_properties(Oid opno, Oid *opfamily, Oid *opcintype, int16 *strategy)
bool get_func_leakproof(Oid funcid)
List * get_op_btree_interpretation(Oid opno)
char * get_constraint_name(Oid conoid)
bool get_collation_isdeterministic(Oid colloid)
Oid get_subscription_oid(const char *subname, bool missing_ok)
Oid get_range_collation(Oid rangeOid)
Oid get_range_multirange(Oid rangeOid)
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)
Node * get_typdefault(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)
const struct SubscriptRoutines * getSubscriptingRoutines(Oid typid, Oid *typelemp)
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)
Oid get_array_type(Oid typid)
Oid get_func_rettype(Oid funcid)
char * get_subscription_name(Oid subid, bool missing_ok)
Oid get_promoted_array_type(Oid typid)
Oid get_atttype(Oid relid, AttrNumber attnum)
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)
char * get_attname(Oid relid, AttrNumber attnum, bool missing_ok)
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