62 elog(
ERROR,
"cache lookup failed for foreign-data wrapper %u", fdwid);
70 fdw->
owner = fdwform->fdwowner;
78 Anum_pg_foreign_data_wrapper_fdwoptions,
136 elog(
ERROR,
"cache lookup failed for foreign server %u", serverid);
145 server->
owner = serverform->srvowner;
146 server->
fdwid = serverform->srvfdw;
151 Anum_pg_foreign_server_srvtype,
158 Anum_pg_foreign_server_srvversion,
165 Anum_pg_foreign_server_srvoptions,
224 (
errcode(ERRCODE_UNDEFINED_OBJECT),
225 errmsg(
"user mapping not found for user \"%s\", server \"%s\"",
237 Anum_pg_user_mapping_umoptions,
264 elog(
ERROR,
"cache lookup failed for foreign table %u", relid);
274 Anum_pg_foreign_table_ftoptions,
303 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
307 Anum_pg_attribute_attfdwoptions,
335 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
336 errmsg(
"access to non-system foreign table is restricted")));
343 elog(
ERROR,
"foreign-data wrapper handler function %u did not return an FdwRoutine struct",
363 elog(
ERROR,
"cache lookup failed for foreign table %u", relid);
365 serverid = tableform->ftserver;
388 elog(
ERROR,
"cache lookup failed for foreign server %u", serverid);
390 fdwid = serverform->srvfdw;
396 elog(
ERROR,
"cache lookup failed for foreign-data wrapper %u", fdwid);
398 fdwhandler = fdwform->fdwhandler;
403 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
404 errmsg(
"foreign-data wrapper \"%s\" has no handler",
455 memcpy(cfdwroutine, fdwroutine,
sizeof(
FdwRoutine));
487 switch (
stmt->list_type)
493 foreach(lc,
stmt->table_list)
497 if (strcmp(tablename, rv->
relname) == 0)
503 foreach(lc,
stmt->table_list)
507 if (strcmp(tablename, rv->
relname) == 0)
576 {
"authtype", ForeignServerRelationId},
577 {
"service", ForeignServerRelationId},
578 {
"user", UserMappingRelationId},
579 {
"password", UserMappingRelationId},
580 {
"connect_timeout", ForeignServerRelationId},
581 {
"dbname", ForeignServerRelationId},
582 {
"host", ForeignServerRelationId},
583 {
"hostaddr", ForeignServerRelationId},
584 {
"port", ForeignServerRelationId},
585 {
"tty", ForeignServerRelationId},
586 {
"options", ForeignServerRelationId},
587 {
"requiressl", ForeignServerRelationId},
588 {
"sslmode", ForeignServerRelationId},
589 {
"gsslib", ForeignServerRelationId},
590 {
"gssdelegation", ForeignServerRelationId},
632 foreach(cell, options_list)
639 const char *closest_match;
641 bool has_valid_options =
false;
652 has_valid_options =
true;
659 (
errcode(ERRCODE_SYNTAX_ERROR),
661 has_valid_options ? closest_match ?
662 errhint(
"Perhaps you meant the option \"%s\".",
664 errhint(
"There are no valid options in this context.")));
686 Anum_pg_foreign_data_wrapper_oid,
690 (
errcode(ERRCODE_UNDEFINED_OBJECT),
691 errmsg(
"foreign-data wrapper \"%s\" does not exist",
712 (
errcode(ERRCODE_UNDEFINED_OBJECT),
713 errmsg(
"server \"%s\" does not exist", servername)));
753 if (path->param_info != NULL)
762 memcpy(hash_path, path,
sizeof(
HashPath));
771 memcpy(nest_path, path,
sizeof(
NestPath));
780 memcpy(merge_path, path,
sizeof(
MergePath));
823 return (
Path *) joinpath;
static Datum values[MAXATTR]
#define CStringGetTextDatum(s)
#define TextDatumGetCString(d)
#define Assert(condition)
#define OidIsValid(objectId)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
#define OidFunctionCall0(functionId)
#define PG_GETARG_DATUM(n)
#define PG_RETURN_BOOL(x)
static bool is_conninfo_option(const char *option, Oid context)
static const struct ConnectionOption libpq_conninfo_options[]
ForeignDataWrapper * GetForeignDataWrapper(Oid fdwid)
ForeignServer * GetForeignServerByName(const char *srvname, bool missing_ok)
FdwRoutine * GetFdwRoutineForRelation(Relation relation, bool makecopy)
FdwRoutine * GetFdwRoutineByServerId(Oid serverid)
ForeignTable * GetForeignTable(Oid relid)
Path * GetExistingLocalJoinPath(RelOptInfo *joinrel)
UserMapping * GetUserMapping(Oid userid, Oid serverid)
Oid get_foreign_server_oid(const char *servername, bool missing_ok)
ForeignServer * GetForeignServer(Oid serverid)
Datum pg_options_to_table(PG_FUNCTION_ARGS)
ForeignDataWrapper * GetForeignDataWrapperExtended(Oid fdwid, bits16 flags)
Datum postgresql_fdw_validator(PG_FUNCTION_ARGS)
FdwRoutine * GetFdwRoutineByRelId(Oid relid)
ForeignDataWrapper * GetForeignDataWrapperByName(const char *fdwname, bool missing_ok)
Oid GetForeignServerIdByRelId(Oid relid)
bool IsImportableForeignTable(const char *tablename, ImportForeignSchemaStmt *stmt)
ForeignServer * GetForeignServerExtended(Oid serverid, bits16 flags)
FdwRoutine * GetFdwRoutine(Oid fdwhandler)
List * GetForeignColumnOptions(Oid relid, AttrNumber attnum)
Oid get_foreign_data_wrapper_oid(const char *fdwname, bool missing_ok)
#define MappingUserName(userid)
void InitMaterializedSRF(FunctionCallInfo fcinfo, bits32 flags)
#define MAT_SRF_USE_EXPECTED_DESC
#define HeapTupleIsValid(tuple)
struct parser_state match_state[5]
if(TABLE==NULL||TABLE_index==NULL)
void * MemoryContextAlloc(MemoryContext context, Size size)
char * pstrdup(const char *in)
MemoryContext CacheMemoryContext
#define IsA(nodeptr, _type_)
@ FDW_IMPORT_SCHEMA_LIMIT_TO
@ FDW_IMPORT_SCHEMA_EXCEPT
FormData_pg_foreign_data_wrapper * Form_pg_foreign_data_wrapper
FormData_pg_foreign_server * Form_pg_foreign_server
FormData_pg_foreign_table * Form_pg_foreign_table
FormData_pg_user_mapping * Form_pg_user_mapping
int restrict_nonsystem_relation_kind
static Datum Int16GetDatum(int16 X)
static Datum ObjectIdGetDatum(Oid X)
static Pointer DatumGetPointer(Datum X)
static Datum CStringGetDatum(const char *X)
#define RelationGetRelid(relation)
List * untransformRelOptions(Datum options)
struct FdwRoutine * rd_fdwroutine
Tuplestorestate * setResult
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)
#define GetSysCacheOid1(cacheId, oidcol, key1)
#define RESTRICT_RELKIND_FOREIGN_TABLE
void tuplestore_putvalues(Tuplestorestate *state, TupleDesc tdesc, const Datum *values, const bool *isnull)
const char * getClosestMatch(ClosestMatchState *state)
void initClosestMatch(ClosestMatchState *state, const char *source, int max_d)
void updateClosestMatch(ClosestMatchState *state, const char *candidate)