45 #include "utils/fmgroids.h"
95 result = amop_tup->amopstrategy;
120 result = amop_tup->amopsortfamily;
148 elog(
ERROR,
"operator %u is not a member of opfamily %u",
151 *strategy = amop_tup->amopstrategy;
152 *lefttype = amop_tup->amoplefttype;
153 *righttype = amop_tup->amoprighttype;
180 result = amop_tup->amopopr;
230 if (aform->amopmethod != BTREE_AM_OID)
237 if (aform->amoplefttype == aform->amoprighttype)
240 *opfamily = aform->amopfamily;
241 *opcintype = aform->amoplefttype;
242 *strategy = aform->amopstrategy;
275 &opfamily, &opcintype, &strategy))
322 if (aform->amopmethod != BTREE_AM_OID)
330 typid = use_lhs_type ? aform->amoplefttype : aform->amoprighttype;
383 if (aform->amopmethod == BTREE_AM_OID &&
410 Oid *lhs_opno,
Oid *rhs_opno)
434 if (aform->amopmethod == HASH_AM_OID &&
438 if (aform->amoplefttype == aform->amoprighttype)
471 aform->amoprighttype,
472 aform->amoprighttype,
534 if (aform->amopmethod == HASH_AM_OID &&
557 if (aform->amoplefttype == aform->amoprighttype)
559 *rhs_procno = *lhs_procno;
567 aform->amoprighttype,
568 aform->amoprighttype,
619 if (op_form->amopmethod != BTREE_AM_OID)
624 Assert(op_strategy >= 1 && op_strategy <= 5);
630 thisresult->
oplefttype = op_form->amoplefttype;
632 result =
lappend(result, thisresult);
657 if (op_form->amopmethod != BTREE_AM_OID)
662 Assert(op_strategy >= 1 && op_strategy <= 5);
673 thisresult->
oplefttype = op_form->amoplefttype;
675 result =
lappend(result, thisresult);
719 if (op_form->amopmethod == BTREE_AM_OID ||
720 op_form->amopmethod == HASH_AM_OID)
769 if (op_form->amopmethod == BTREE_AM_OID)
809 result = amproc_tup->amproc;
843 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
867 result = att_tup->attnum;
894 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
897 result = att_tup->attstattarget;
924 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
927 result = att_tup->attgenerated;
951 result = att_tup->atttypid;
979 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
983 *typid = att_tup->atttypid;
984 *typmod = att_tup->atttypmod;
985 *
collid = att_tup->attcollation;
1008 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
1042 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1043 errmsg(
"cast from type %s to type %s does not exist",
1088 elog(
ERROR,
"cache lookup failed for collation %u", colloid);
1090 result = colltup->collisdeterministic;
1149 if (contup->contype == CONSTRAINT_UNIQUE ||
1150 contup->contype == CONSTRAINT_PRIMARY ||
1151 contup->contype == CONSTRAINT_EXCLUSION)
1152 result = contup->conindid;
1181 elog(
ERROR,
"cache lookup failed for language %u",
1202 elog(
ERROR,
"cache lookup failed for opclass %u", opclass);
1205 result = cla_tup->opcfamily;
1224 elog(
ERROR,
"cache lookup failed for opclass %u", opclass);
1227 result = cla_tup->opcintype;
1250 *opfamily = cla_tup->opcfamily;
1251 *opcintype = cla_tup->opcintype;
1277 result = optup->oprcode;
1325 result = optup->oprresult;
1347 elog(
ERROR,
"cache lookup failed for operator %u", opno);
1349 *lefttype = optup->oprleft;
1350 *righttype = optup->oprright;
1370 bool result =
false;
1380 if (opno == ARRAY_EQ_OP)
1383 if (typentry->
cmp_proc == F_BTARRAYCMP)
1386 else if (opno == RECORD_EQ_OP)
1389 if (typentry->
cmp_proc == F_BTRECORDCMP)
1400 result = optup->oprcanmerge;
1421 bool result =
false;
1426 if (opno == ARRAY_EQ_OP)
1429 if (typentry->
hash_proc == F_HASH_ARRAY)
1432 else if (opno == RECORD_EQ_OP)
1435 if (typentry->
hash_proc == F_HASH_RECORD)
1446 result = optup->oprcanhash;
1464 elog(
ERROR,
"operator %u does not exist", opno);
1480 elog(
ERROR,
"operator %u does not exist", opno);
1501 result = optup->oprcom;
1525 result = optup->oprnegate;
1549 result = optup->oprrest;
1573 result = optup->oprjoin;
1624 result = functup->pronamespace;
1644 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1663 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1686 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1690 result = procstruct->prorettype;
1691 *nargs = (int) procstruct->pronargs;
1692 Assert(*nargs == procstruct->proargtypes.dim1);
1694 memcpy(*argtypes, procstruct->proargtypes.values, *nargs *
sizeof(
Oid));
1712 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1731 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1750 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1769 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1788 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1807 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1826 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1850 result = functup->prosupport;
1881 get_relnatts(
Oid relid)
1891 result = reltup->relnatts;
1944 result = reltup->relnamespace;
1971 result = reltup->reltype;
1995 result = reltup->relkind;
2019 result = reltup->relispartition;
2046 result = reltup->reltablespace;
2068 elog(
ERROR,
"cache lookup failed for relation %u", relid);
2070 result = reltup->relpersistence;
2141 result = typtup->typisdefined;
2165 result = typtup->typlen;
2190 result = typtup->typbyval;
2216 elog(
ERROR,
"cache lookup failed for type %u", typid);
2218 *typlen = typtup->typlen;
2219 *typbyval = typtup->typbyval;
2237 elog(
ERROR,
"cache lookup failed for type %u", typid);
2239 *typlen = typtup->typlen;
2240 *typbyval = typtup->typbyval;
2270 return typeStruct->typelem;
2272 return typeStruct->oid;
2321 elog(
ERROR,
"binary I/O not supported during bootstrap");
2329 elog(
ERROR,
"cache lookup failed for type %u", typid);
2332 *typlen = typeStruct->typlen;
2333 *typbyval = typeStruct->typbyval;
2335 *typdelim = typeStruct->typdelim;
2340 *func = typeStruct->typinput;
2343 *func = typeStruct->typoutput;
2346 *func = typeStruct->typreceive;
2349 *func = typeStruct->typsend;
2357 get_typalign(
Oid typid)
2367 result = typtup->typalign;
2372 return TYPALIGN_INT;
2387 result = typtup->typstorage;
2392 return TYPSTORAGE_PLAIN;
2416 elog(
ERROR,
"cache lookup failed for type %u", typid);
2426 Anum_pg_type_typdefaultbin,
2439 Anum_pg_type_typdefault,
2444 char *strDefaultVal;
2459 pfree(strDefaultVal);
2508 elog(
ERROR,
"cache lookup failed for type %u", typid);
2510 if (typTup->typtype != TYPTYPE_DOMAIN)
2518 typid = typTup->typbasetype;
2519 *typmod = typTup->typtypmod;
2559 if (typid == BPCHAROID)
2563 if (maxwidth < 1000)
2564 return 32 + (maxwidth - 32) / 2;
2571 return 32 + (1000 - 32) / 2;
2597 result = typtup->typtype;
2615 if (typid == RECORDOID)
2619 case TYPTYPE_COMPOSITE:
2621 case TYPTYPE_DOMAIN:
2658 return (
get_typtype(typid) == TYPTYPE_MULTIRANGE);
2675 elog(
ERROR,
"cache lookup failed for type %u", typid);
2677 *typcategory = typtup->typcategory;
2678 *typispreferred = typtup->typispreferred;
2699 result = typtup->typrelid;
2727 if (IsTrueArrayType(typtup))
2728 result = typtup->typelem;
2804 if (typTup->typtype != TYPTYPE_DOMAIN)
2810 if (IsTrueArrayType(typTup))
2811 result = typTup->typelem;
2818 typid = typTup->typbasetype;
2842 if (!pt->typisdefined)
2844 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2845 errmsg(
"type %s is only a shell",
2849 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2850 errmsg(
"no input function available for type %s",
2853 *typInput = pt->typinput;
2875 if (!pt->typisdefined)
2877 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2878 errmsg(
"type %s is only a shell",
2882 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2883 errmsg(
"no output function available for type %s",
2886 *typOutput = pt->typoutput;
2887 *typIsVarlena = (!pt->typbyval) && (pt->typlen == -1);
2908 if (!pt->typisdefined)
2910 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2911 errmsg(
"type %s is only a shell",
2915 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2916 errmsg(
"no binary input function available for type %s",
2919 *typReceive = pt->typreceive;
2941 if (!pt->typisdefined)
2943 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2944 errmsg(
"type %s is only a shell",
2948 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
2949 errmsg(
"no binary output function available for type %s",
2952 *typSend = pt->typsend;
2953 *typIsVarlena = (!pt->typbyval) && (pt->typlen == -1);
2974 result = typtup->typmodin;
2989 get_typmodout(
Oid typid)
2999 result = typtup->typmodout;
3024 result = typtup->typcollation;
3066 *typelemp = typform->typelem;
3123 stawidth = (*get_attavgwidth_hook) (relid,
attnum);
3193 int reqkind,
Oid reqop,
int flags)
3210 if ((&stats->stakind1)[
i] == reqkind &&
3211 (reqop ==
InvalidOid || (&stats->staop1)[
i] == reqop))
3217 sslot->
staop = (&stats->staop1)[
i];
3218 sslot->
stacoll = (&stats->stacoll1)[
i];
3223 Anum_pg_statistic_stavalues1 +
i,
3243 elog(
ERROR,
"cache lookup failed for type %u", arrayelemtype);
3260 if (!typeForm->typbyval)
3271 Anum_pg_statistic_stanumbers1 +
i,
3287 narrayelem =
ARR_DIMS(statarray)[0];
3288 if (
ARR_NDIM(statarray) != 1 || narrayelem <= 0 ||
3291 elog(
ERROR,
"stanumbers is not a 1-D float4 array");
3382 result = rngtup->rngsubtype;
3408 result = rngtup->rngcollation;
3433 result = rngtup->rngmultitypid;
3458 result = rngtup->rngtypid;
3495 Assert(attno > 0 && attno <= rd_index->indnatts);
3498 if (attno > rd_index->indnkeyatts)
3505 Anum_pg_index_indclass, &isnull);
3510 Assert(attno <= indclass->dim1);
3511 opclass = indclass->
values[attno - 1];
3535 result = rd_index->indisreplident;
3555 elog(
ERROR,
"cache lookup failed for index %u", index_oid);
3558 isvalid = rd_index->indisvalid;
3578 elog(
ERROR,
"cache lookup failed for index %u", index_oid);
3581 isclustered = rd_index->indisclustered;
3602 (
errcode(ERRCODE_UNDEFINED_OBJECT),
3603 errmsg(
"publication \"%s\" does not exist", pubname)));
3625 elog(
ERROR,
"cache lookup failed for publication %u", pubid);
3652 (
errcode(ERRCODE_UNDEFINED_OBJECT),
3675 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)
elog(ERROR, "%s: %s", p2, msg)
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)
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)
int get_attstattarget(Oid relid, AttrNumber attnum)
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)
#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