58 #include "utils/fmgroids.h"
107 static char *
get_sql_insert(
Relation rel,
int *pkattnums,
int pknumatts,
char **src_pkattvals,
char **tgt_pkattvals);
109 static char *
get_sql_update(
Relation rel,
int *pkattnums,
int pknumatts,
char **src_pkattvals,
char **tgt_pkattvals);
124 int **pkattnums,
int *pknumatts);
175 dblink_conn_not_avail(const
char *conname)
179 (
errcode(ERRCODE_CONNECTION_DOES_NOT_EXIST),
180 errmsg(
"connection \"%s\" not available", conname)));
183 (
errcode(ERRCODE_CONNECTION_DOES_NOT_EXIST),
184 errmsg(
"connection not available")));
189 PGconn *
volatile *conn_p,
char **conname_p,
volatile bool *freeconn_p)
199 conname = conname_or_str;
224 (
errcode(ERRCODE_SQLCLIENT_UNABLE_TO_ESTABLISH_SQLCONNECTION),
225 errmsg(
"could not establish connection"),
236 *conname_p = conname;
237 *freeconn_p = freeconn;
248 dblink_conn_not_avail(conname);
274 char *conname_or_str = NULL;
276 char *connname = NULL;
323 (
errcode(ERRCODE_SQLCLIENT_UNABLE_TO_ESTABLISH_SQLCONNECTION),
324 errmsg(
"could not establish connection"),
357 char *conname = NULL;
374 dblink_conn_not_avail(conname);
397 char *curname = NULL;
399 char *conname = NULL;
442 if (!rconn || !rconn->
conn)
443 dblink_conn_not_avail(conname);
452 dblink_res_internalerror(
conn,
res,
"begin error");
473 "while opening cursor \"%s\"", curname);
490 char *curname = NULL;
491 char *conname = NULL;
530 if (!rconn || !rconn->
conn)
531 dblink_conn_not_avail(conname);
542 "while closing cursor \"%s\"", curname);
560 dblink_res_internalerror(
conn,
res,
"commit error");
576 char *conname = NULL;
580 char *curname = NULL;
630 dblink_conn_not_avail(conname);
646 "while fetching from cursor \"%s\"", curname);
654 (
errcode(ERRCODE_INVALID_CURSOR_NAME),
655 errmsg(
"cursor \"%s\" does not exist", curname)));
687 elog(
ERROR,
"wrong number of arguments");
708 volatile bool freeconn =
false;
717 char *conname = NULL;
754 elog(
ERROR,
"wrong number of arguments");
774 elog(
ERROR,
"wrong number of arguments");
778 dblink_conn_not_avail(conname);
797 "while executing query");
832 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
833 errmsg(
"set-valued function called in context that cannot accept a set")));
836 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
837 errmsg(
"materialize mode required, but it is not allowed in this context")));
896 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
897 errmsg(
"function returning record called in context "
898 "that cannot accept type record")));
902 elog(
ERROR,
"return type must be a row type");
915 if (nfields != tupdesc->
natts)
917 (
errcode(ERRCODE_DATATYPE_MISMATCH),
918 errmsg(
"remote query result rowtype does not match "
919 "the specified FROM clause rowtype")));
945 for (row = 0; row < ntuples; row++)
953 for (
i = 0;
i < nfields;
i++)
1005 sinfo.fcinfo = fcinfo;
1011 "dblink temporary context",
1029 "while executing query");
1056 rsinfo->setResult = tupstore;
1057 rsinfo->setDesc = tupdesc;
1073 Assert(rsinfo->setResult != NULL);
1080 if (sinfo.tmpcontext != NULL)
1082 sinfo.tmpcontext = NULL;
1085 sinfo.last_res = NULL;
1087 sinfo.cur_res = NULL;
1118 elog(
ERROR,
"failed to set single-row mode for dblink query");
1137 if (first && nestlevel < 0)
1207 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1208 errmsg(
"function returning record called in context "
1209 "that cannot accept type record")));
1213 elog(
ERROR,
"return type must be a row type");
1221 if (nfields != tupdesc->
natts)
1223 (
errcode(ERRCODE_DATATYPE_MISMATCH),
1224 errmsg(
"remote query result rowtype does not match "
1225 "the specified FROM clause rowtype")));
1263 for (
i = 0;
i < nfields;
i++)
1395 if (msg == NULL || msg[0] ==
'\0')
1408 text *
volatile sql_cmd_status = NULL;
1410 volatile bool freeconn =
false;
1418 char *conname = NULL;
1453 elog(
ERROR,
"wrong number of arguments");
1456 dblink_conn_not_avail(conname);
1464 "while executing command");
1485 (
errcode(ERRCODE_S_R_E_PROHIBITED_SQL_STATEMENT_ATTEMPTED),
1486 errmsg(
"statement returning results not allowed")));
1557 if ((results != NULL) && (indnkeyatts > 0))
1586 if (call_cntr < max_calls)
1594 values[1] = results[call_cntr];
1643 char **src_pkattvals;
1644 char **tgt_pkattvals;
1658 &pkattnums, &pknumatts);
1669 if (src_nitems != pknumatts)
1671 (
errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
1672 errmsg(
"source key array length must match number of key attributes")));
1683 if (tgt_nitems != pknumatts)
1685 (
errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
1686 errmsg(
"target key array length must match number of key attributes")));
1691 sql =
get_sql_insert(rel, pkattnums, pknumatts, src_pkattvals, tgt_pkattvals);
1731 char **tgt_pkattvals;
1744 &pkattnums, &pknumatts);
1755 if (tgt_nitems != pknumatts)
1757 (
errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
1758 errmsg(
"target key array length must match number of key attributes")));
1808 char **src_pkattvals;
1809 char **tgt_pkattvals;
1823 &pkattnums, &pknumatts);
1834 if (src_nitems != pknumatts)
1836 (
errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
1837 errmsg(
"source key array length must match number of key attributes")));
1848 if (tgt_nitems != pknumatts)
1850 (
errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
1851 errmsg(
"target key array length must match number of key attributes")));
1856 sql =
get_sql_update(rel, pkattnums, pknumatts, src_pkattvals, tgt_pkattvals);
1891 #define DBLINK_NOTIFY_COLS 3
1916 memset(nulls, 0,
sizeof(nulls));
1925 if (notify->
extra != NULL)
1968 (
errcode(ERRCODE_FDW_OUT_OF_MEMORY),
1970 errdetail(
"Could not get libpq's default connection options.")));
1974 foreach(cell, options_list)
1986 const char *closest_match;
1988 bool has_valid_options =
false;
1995 has_valid_options =
true;
2002 (
errcode(ERRCODE_FDW_OPTION_NAME_NOT_FOUND),
2004 has_valid_options ? closest_match ?
2005 errhint(
"Perhaps you meant the option \"%s\".",
2006 closest_match) : 0 :
2007 errhint(
"There are no valid options in this context.")));
2034 char **result = NULL;
2045 Anum_pg_index_indrelid,
2057 if (
index->indisprimary)
2059 *indnkeyatts =
index->indnkeyatts;
2060 if (*indnkeyatts > 0)
2064 for (
i = 0;
i < *indnkeyatts;
i++)
2111 if (bitmap && (*bitmap & bitmask) == 0)
2126 if (bitmask == 0x100)
2156 natts = tupdesc->
natts;
2161 (
errcode(ERRCODE_CARDINALITY_VIOLATION),
2162 errmsg(
"source row not found")));
2167 for (
i = 0;
i < natts;
i++)
2171 if (att->attisdropped)
2188 for (
i = 0;
i < natts;
i++)
2233 for (
i = 0;
i < pknumatts;
i++)
2235 int pkattnum = pkattnums[
i];
2244 if (tgt_pkattvals[
i] != NULL)
2273 natts = tupdesc->
natts;
2278 (
errcode(ERRCODE_CARDINALITY_VIOLATION),
2279 errmsg(
"source row not found")));
2287 for (
i = 0;
i < natts;
i++)
2291 if (attr->attisdropped)
2319 for (
i = 0;
i < pknumatts;
i++)
2321 int pkattnum = pkattnums[
i];
2330 val = tgt_pkattvals[
i];
2368 for (
i = 0;
i < pknumatts;
i++)
2369 if (
key == pkattnums[
i])
2391 elog(
ERROR,
"SPI connect failure - returned %d", ret);
2399 natts = tupdesc->
natts;
2410 for (
i = 0;
i < natts;
i++)
2417 if (attr->attisdropped)
2426 for (
i = 0;
i < pknumatts;
i++)
2428 int pkattnum = pkattnums[
i];
2437 if (src_pkattvals[
i] != NULL)
2455 (
errcode(ERRCODE_CARDINALITY_VIOLATION),
2456 errmsg(
"source criteria matched more than one record")));
2546 return hentry->
rconn;
2585 errmsg(
"duplicate connection name")));
2588 hentry->
rconn = rconn;
2608 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2609 errmsg(
"undefined connection name")));
2640 (
errcode(ERRCODE_S_R_E_PROHIBITED_SQL_STATEMENT_ATTEMPTED),
2641 errmsg(
"password or GSSAPI delegated credentials required"),
2642 errdetail(
"Non-superusers may only connect using credentials they provide, eg: password in connection string or delegated GSSAPI credentials"),
2643 errhint(
"Ensure provided credentials match target server's authentication method.")));
2657 bool connstr_gives_password =
false;
2664 if (strcmp(
option->keyword,
"password") == 0)
2668 connstr_gives_password =
true;
2676 return connstr_gives_password;
2702 (
errcode(ERRCODE_S_R_E_PROHIBITED_SQL_STATEMENT_ATTEMPTED),
2703 errmsg(
"password or GSSAPI delegated credentials required"),
2704 errdetail(
"Non-superusers must provide a password in the connection string or send delegated GSSAPI credentials.")));
2717 bool fail,
const char *
fmt,...)
2726 char *message_primary;
2727 char *message_detail;
2729 char *message_context;
2731 char dblink_context_msg[512];
2738 if (pg_diag_sqlstate)
2740 pg_diag_sqlstate[1],
2741 pg_diag_sqlstate[2],
2742 pg_diag_sqlstate[3],
2743 pg_diag_sqlstate[4]);
2745 sqlstate = ERRCODE_CONNECTION_FAILURE;
2747 message_primary =
xpstrdup(pg_diag_message_primary);
2748 message_detail =
xpstrdup(pg_diag_message_detail);
2749 message_hint =
xpstrdup(pg_diag_message_hint);
2750 message_context =
xpstrdup(pg_diag_context);
2757 if (message_primary == NULL)
2776 vsnprintf(dblink_context_msg,
sizeof(dblink_context_msg),
fmt, ap);
2781 (message_primary != NULL && message_primary[0] !=
'\0') ?
2783 errmsg(
"could not obtain message string for remote error"),
2785 message_hint ?
errhint(
"%s", message_hint) : 0,
2786 message_context ? (
errcontext(
"%s", message_context)) : 0,
2788 (
errcontext(
"%s on dblink connection named \"%s\"",
2789 dblink_context_msg, conname)) :
2790 (
errcontext(
"%s on unnamed dblink connection",
2791 dblink_context_msg))));
2824 (
errcode(ERRCODE_FDW_OUT_OF_MEMORY),
2826 errdetail(
"Could not get libpq's default connection options.")));
2830 srvname =
pstrdup(servername);
2857 foreach(cell, foreign_server->
options)
2866 foreach(cell, user_mapping->
options)
2895 for (cp =
str; *cp; cp++)
2897 if (*cp ==
'\\' || *cp ==
'\'')
2923 int **pkattnums,
int *pknumatts)
2926 int natts = tupdesc->
natts;
2930 pknumatts_arg =
Min(pknumatts_arg, pkattnums_arg->
dim1);
2933 if (pknumatts_arg <= 0)
2935 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2936 errmsg(
"number of key attributes must be > 0")));
2940 *pknumatts = pknumatts_arg;
2943 for (
i = 0;
i < pknumatts_arg;
i++)
2945 int pkattnum = pkattnums_arg->
values[
i];
2950 if (pkattnum <= 0 || pkattnum > natts)
2952 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2953 errmsg(
"invalid attribute number %d", pkattnum)));
2957 for (
j = 0;
j < natts;
j++)
2963 if (++lnum == pkattnum)
2968 (*pkattnums)[
i] =
j;
2971 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2972 errmsg(
"invalid attribute number %d", pkattnum)));
3011 if (strcmp(opt->
keyword,
"client_encoding") == 0)
3020 if (context != UserMappingRelationId)
3025 if (context != ForeignServerRelationId)
3045 static const char *
const GUCsAffectingIO[] = {
3055 const char *gucName = GUCsAffectingIO[
i];
3057 const char *localVal;
3065 if (remoteVal == NULL)
3073 Assert(localVal != NULL);
3075 if (strcmp(remoteVal, localVal) == 0)
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
AclResult object_aclcheck(Oid classid, Oid objectid, Oid roleid, AclMode mode)
AclResult pg_class_aclcheck(Oid table_oid, Oid roleid, AclMode mode)
#define PG_GETARG_ARRAYTYPE_P(n)
#define ARR_NULLBITMAP(a)
ArrayBuildState * accumArrayResult(ArrayBuildState *astate, Datum dvalue, bool disnull, Oid element_type, MemoryContext rcontext)
Datum makeArrayResult(ArrayBuildState *astate, MemoryContext rcontext)
int ArrayGetNItems(int ndim, const int *dims)
Datum current_query(PG_FUNCTION_ARGS)
bool be_gssapi_get_delegation(Port *port)
static Datum values[MAXATTR]
#define CStringGetTextDatum(s)
#define TextDatumGetCString(d)
#define pg_attribute_printf(f, a)
static PGcancel *volatile cancelConn
static bool dblink_connstr_has_pw(const char *connstr)
static void createNewConnection(const char *name, remoteConn *rconn)
static uint32 dblink_we_get_result
Datum dblink_get_result(PG_FUNCTION_ARGS)
static int get_attnum_pk_pos(int *pkattnums, int pknumatts, int key)
Datum dblink_build_sql_delete(PG_FUNCTION_ARGS)
Datum dblink_get_pkey(PG_FUNCTION_ARGS)
static void pg_attribute_noreturn() dblink_res_internalerror(PGconn *conn
Datum dblink_open(PG_FUNCTION_ARGS)
static remoteConn * pconn
static void dblink_security_check(PGconn *conn, remoteConn *rconn, const char *connstr)
static HeapTuple get_tuple_of_interest(Relation rel, int *pkattnums, int pknumatts, char **src_pkattvals)
static uint32 dblink_we_connect
Datum dblink_close(PG_FUNCTION_ARGS)
static void restoreLocalGucs(int nestlevel)
static char * escape_param_str(const char *str)
static PGconn * dblink_get_named_conn(const char *conname)
static char * quote_ident_cstr(char *rawstr)
static HTAB * createConnHash(void)
Datum dblink_exec(PG_FUNCTION_ARGS)
static void dblink_connstr_check(const char *connstr)
static char * get_sql_insert(Relation rel, int *pkattnums, int pknumatts, char **src_pkattvals, char **tgt_pkattvals)
static void PGresult const char * p2
static char * get_sql_update(Relation rel, int *pkattnums, int pknumatts, char **src_pkattvals, char **tgt_pkattvals)
static bool is_valid_dblink_option(const PQconninfoOption *options, const char *option, Oid context)
Datum dblink_build_sql_insert(PG_FUNCTION_ARGS)
static remoteConn * getConnectionByName(const char *name)
Datum dblink_get_notify(PG_FUNCTION_ARGS)
static HTAB * remoteConnHash
static void storeRow(volatile storeInfo *sinfo, PGresult *res, bool first)
Datum dblink_disconnect(PG_FUNCTION_ARGS)
static void dblink_get_conn(char *conname_or_str, PGconn *volatile *conn_p, char **conname_p, volatile bool *freeconn_p)
static int applyRemoteGucs(PGconn *conn)
Datum dblink_fdw_validator(PG_FUNCTION_ARGS)
static void dblink_init(void)
static Datum dblink_record_internal(FunctionCallInfo fcinfo, bool is_async)
Datum dblink_get_connections(PG_FUNCTION_ARGS)
static char ** get_pkey_attnames(Relation rel, int16 *indnkeyatts)
static void prepTuplestoreResult(FunctionCallInfo fcinfo)
static void dblink_res_error(PGconn *conn, const char *conname, PGresult *res, bool fail, const char *fmt,...) pg_attribute_printf(5
Datum dblink_record(PG_FUNCTION_ARGS)
static void materializeResult(FunctionCallInfo fcinfo, PGconn *conn, PGresult *res)
struct remoteConn remoteConn
Datum dblink_is_busy(PG_FUNCTION_ARGS)
static char ** get_text_array_contents(ArrayType *array, int *numitems)
static void static char * get_connect_string(const char *servername)
Datum dblink_connect(PG_FUNCTION_ARGS)
Datum dblink_current_query(PG_FUNCTION_ARGS)
Datum dblink_fetch(PG_FUNCTION_ARGS)
static void PGresult * res
struct remoteConnHashEnt remoteConnHashEnt
Datum dblink_build_sql_update(PG_FUNCTION_ARGS)
static void deleteConnection(const char *name)
static char * xpstrdup(const char *in)
struct storeInfo storeInfo
static char * generate_relation_name(Relation rel)
#define DBLINK_NOTIFY_COLS
Datum dblink_cancel_query(PG_FUNCTION_ARGS)
Datum dblink_send_query(PG_FUNCTION_ARGS)
static char * get_sql_delete(Relation rel, int *pkattnums, int pknumatts, char **tgt_pkattvals)
elog(ERROR, "%s: %s", p2, msg)
Datum dblink_error_message(PG_FUNCTION_ARGS)
static void validate_pkattnums(Relation rel, int2vector *pkattnums_arg, int32 pknumatts_arg, int **pkattnums, int *pknumatts)
static void materializeQueryResult(FunctionCallInfo fcinfo, PGconn *conn, const char *conname, const char *sql, bool fail)
static PGresult * storeQueryResult(volatile storeInfo *sinfo, PGconn *conn, const char *sql)
static uint32 dblink_we_get_conn
PG_FUNCTION_INFO_V1(dblink_connect)
static Relation get_rel_from_relname(text *relname_text, LOCKMODE lockmode, AclMode aclmode)
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
HTAB * hash_create(const char *tabname, long nelem, const HASHCTL *info, int flags)
void * hash_seq_search(HASH_SEQ_STATUS *status)
void hash_seq_init(HASH_SEQ_STATUS *status, HTAB *hashp)
int errmsg_internal(const char *fmt,...)
int errdetail_internal(const char *fmt,...)
int errdetail(const char *fmt,...)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define MAKE_SQLSTATE(ch1, ch2, ch3, ch4, ch5)
#define ereport(elevel,...)
HeapTuple BuildTupleFromCStrings(AttInMetadata *attinmeta, char **values)
AttInMetadata * TupleDescGetAttInMetadata(TupleDesc tupdesc)
PGcancelConn * PQcancelCreate(PGconn *conn)
int PQcancelBlocking(PGcancelConn *cancelConn)
char * PQcancelErrorMessage(const PGcancelConn *cancelConn)
void PQcancelFinish(PGcancelConn *cancelConn)
const char * PQparameterStatus(const PGconn *conn, const char *paramName)
PQconninfoOption * PQconninfoParse(const char *conninfo, char **errmsg)
PGTransactionStatusType PQtransactionStatus(const PGconn *conn)
PQconninfoOption * PQconndefaults(void)
int PQconnectionUsedPassword(const PGconn *conn)
void PQconninfoFree(PQconninfoOption *connOptions)
int PQconnectionUsedGSSAPI(const PGconn *conn)
char * PQerrorMessage(const PGconn *conn)
ConnStatusType PQstatus(const PGconn *conn)
int PQclientEncoding(const PGconn *conn)
int PQsetClientEncoding(PGconn *conn, const char *encoding)
int PQsetSingleRowMode(PGconn *conn)
void PQfreemem(void *ptr)
PGnotify * PQnotifies(PGconn *conn)
ExecStatusType PQresultStatus(const PGresult *res)
int PQntuples(const PGresult *res)
int PQconsumeInput(PGconn *conn)
char * PQgetvalue(const PGresult *res, int tup_num, int field_num)
char * PQcmdStatus(PGresult *res)
int PQgetisnull(const PGresult *res, int tup_num, int field_num)
int PQsendQuery(PGconn *conn, const char *query)
int PQisBusy(PGconn *conn)
char * PQresultErrorField(const PGresult *res, int fieldcode)
int PQnfields(const PGresult *res)
#define palloc_array(type, count)
Oid get_fn_expr_argtype(FmgrInfo *flinfo, int argnum)
#define PG_GETARG_TEXT_PP(n)
#define DatumGetTextPP(X)
#define PG_GETARG_POINTER(n)
#define DirectFunctionCall1(func, arg1)
#define PG_GETARG_DATUM(n)
#define PG_RETURN_TEXT_P(x)
#define PG_RETURN_INT32(x)
#define PG_GETARG_INT32(n)
#define PG_GETARG_BOOL(n)
#define PG_RETURN_DATUM(x)
ForeignDataWrapper * GetForeignDataWrapper(Oid fdwid)
UserMapping * GetUserMapping(Oid userid, Oid serverid)
ForeignServer * GetForeignServerByName(const char *srvname, bool missing_ok)
void InitMaterializedSRF(FunctionCallInfo fcinfo, bits32 flags)
TypeFuncClass get_call_result_type(FunctionCallInfo fcinfo, Oid *resultTypeId, TupleDesc *resultTupleDesc)
#define SRF_IS_FIRSTCALL()
#define SRF_PERCALL_SETUP()
#define SRF_RETURN_NEXT(_funcctx, _result)
#define SRF_FIRSTCALL_INIT()
static Datum HeapTupleGetDatum(const HeapTupleData *tuple)
#define SRF_RETURN_DONE(_funcctx)
void systable_endscan(SysScanDesc sysscan)
HeapTuple systable_getnext(SysScanDesc sysscan)
SysScanDesc systable_beginscan(Relation heapRelation, Oid indexId, bool indexOK, Snapshot snapshot, int nkeys, ScanKey key)
int NewGUCNestLevel(void)
const char * GetConfigOption(const char *name, bool missing_ok, bool restrict_privileged)
void AtEOXact_GUC(bool isCommit, int nestLevel)
int set_config_option(const char *name, const char *value, GucContext context, GucSource source, GucAction action, bool changeVal, int elevel, bool is_reload)
#define HeapTupleIsValid(tuple)
struct parser_state match_state[5]
if(TABLE==NULL||TABLE_index==NULL)
static PGconn * libpqsrv_connect(const char *conninfo, uint32 wait_event_info)
static PGresult * libpqsrv_get_result(PGconn *conn, uint32 wait_event_info)
static PGresult * libpqsrv_exec(PGconn *conn, const char *query, uint32 wait_event_info)
static void libpqsrv_disconnect(PGconn *conn)
static void const char * fmt
Assert(fmt[strlen(fmt) - 1] !='\n')
char * get_namespace_name(Oid nspid)
void get_typlenbyvalalign(Oid typid, int16 *typlen, bool *typbyval, char *typalign)
int GetDatabaseEncoding(void)
const char * GetDatabaseEncodingName(void)
void MemoryContextReset(MemoryContext context)
char * pchomp(const char *in)
char * pstrdup(const char *in)
void pfree(void *pointer)
MemoryContext TopMemoryContext
MemoryContext CurrentMemoryContext
void * MemoryContextAlloc(MemoryContext context, Size size)
void MemoryContextDelete(MemoryContext context)
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
#define CHECK_FOR_INTERRUPTS()
bool RelationIsVisible(Oid relid)
RangeVar * makeRangeVarFromNameList(const List *names)
#define IsA(nodeptr, _type_)
ObjectType get_relkind_objtype(char relkind)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
FormData_pg_attribute * Form_pg_attribute
FormData_pg_index * Form_pg_index
static Datum PointerGetDatum(const void *X)
static Datum ObjectIdGetDatum(Oid X)
static Datum Int32GetDatum(int32 X)
#define PG_DIAG_MESSAGE_HINT
#define PG_DIAG_MESSAGE_PRIMARY
#define PG_DIAG_MESSAGE_DETAIL
char * psprintf(const char *fmt,...)
Datum quote_ident(PG_FUNCTION_ARGS)
char * quote_literal_cstr(const char *rawstr)
#define RelationGetRelid(relation)
#define RelationGetRelationName(relation)
List * untransformRelOptions(Datum options)
char * quote_qualified_identifier(const char *qualifier, const char *ident)
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
void truncate_identifier(char *ident, int len, bool warn)
SPITupleTable * SPI_tuptable
int SPI_exec(const char *src, long tcount)
char * SPI_getvalue(HeapTuple tuple, TupleDesc tupdesc, int fnumber)
char * SPI_fname(TupleDesc tupdesc, int fnumber)
HeapTuple SPI_copytuple(HeapTuple tuple)
void relation_close(Relation relation, LOCKMODE lockmode)
#define BTEqualStrategyNumber
#define ERRCODE_DUPLICATE_OBJECT
void appendStringInfo(StringInfo str, const char *fmt,...)
void appendStringInfoString(StringInfo str, const char *s)
void appendStringInfoChar(StringInfo str, char ch)
void initStringInfo(StringInfo str)
MemoryContext ecxt_per_query_memory
AttInMetadata * attinmeta
MemoryContext multi_call_memory_ctx
SetFunctionReturnMode returnMode
Tuplestorestate * setResult
int16 values[FLEXIBLE_ARRAY_MEMBER]
Tuplestorestate * tuplestore
AttInMetadata * attinmeta
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
Relation table_openrv(const RangeVar *relation, LOCKMODE lockmode)
TupleDesc CreateTemplateTupleDesc(int natts)
TupleDesc CreateTupleDescCopy(TupleDesc tupdesc)
void TupleDescInitEntry(TupleDesc desc, AttrNumber attributeNumber, const char *attributeName, Oid oidtypeid, int32 typmod, int attdim)
#define TupleDescAttr(tupdesc, i)
Tuplestorestate * tuplestore_begin_heap(bool randomAccess, bool interXact, int maxKBytes)
void tuplestore_putvalues(Tuplestorestate *state, TupleDesc tdesc, const Datum *values, const bool *isnull)
void tuplestore_end(Tuplestorestate *state)
void tuplestore_puttuple(Tuplestorestate *state, HeapTuple tuple)
#define att_align_nominal(cur_offset, attalign)
#define att_addlength_pointer(cur_offset, attlen, attptr)
List * textToQualifiedNameList(text *textval)
const char * getClosestMatch(ClosestMatchState *state)
char * text_to_cstring(const text *t)
text * cstring_to_text(const char *s)
void initClosestMatch(ClosestMatchState *state, const char *source, int max_d)
void updateClosestMatch(ClosestMatchState *state, const char *candidate)
uint32 WaitEventExtensionNew(const char *wait_event_name)