61 elog(
ERROR,
"cache lookup failed for foreign-data wrapper %u", fdwid);
69 fdw->
owner = fdwform->fdwowner;
77 Anum_pg_foreign_data_wrapper_fdwoptions,
135 elog(
ERROR,
"cache lookup failed for foreign server %u", serverid);
144 server->
owner = serverform->srvowner;
145 server->
fdwid = serverform->srvfdw;
150 Anum_pg_foreign_server_srvtype,
157 Anum_pg_foreign_server_srvversion,
164 Anum_pg_foreign_server_srvoptions,
223 (
errcode(ERRCODE_UNDEFINED_OBJECT),
224 errmsg(
"user mapping not found for user \"%s\", server \"%s\"",
236 Anum_pg_user_mapping_umoptions,
263 elog(
ERROR,
"cache lookup failed for foreign table %u", relid);
273 Anum_pg_foreign_table_ftoptions,
302 elog(
ERROR,
"cache lookup failed for attribute %d of relation %u",
306 Anum_pg_attribute_attfdwoptions,
333 elog(
ERROR,
"foreign-data wrapper handler function %u did not return an FdwRoutine struct",
353 elog(
ERROR,
"cache lookup failed for foreign table %u", relid);
355 serverid = tableform->ftserver;
378 elog(
ERROR,
"cache lookup failed for foreign server %u", serverid);
380 fdwid = serverform->srvfdw;
386 elog(
ERROR,
"cache lookup failed for foreign-data wrapper %u", fdwid);
388 fdwhandler = fdwform->fdwhandler;
393 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
394 errmsg(
"foreign-data wrapper \"%s\" has no handler",
445 memcpy(cfdwroutine, fdwroutine,
sizeof(
FdwRoutine));
477 switch (
stmt->list_type)
483 foreach(lc,
stmt->table_list)
487 if (strcmp(tablename, rv->
relname) == 0)
493 foreach(lc,
stmt->table_list)
497 if (strcmp(tablename, rv->
relname) == 0)
566 {
"authtype", ForeignServerRelationId},
567 {
"service", ForeignServerRelationId},
568 {
"user", UserMappingRelationId},
569 {
"password", UserMappingRelationId},
570 {
"connect_timeout", ForeignServerRelationId},
571 {
"dbname", ForeignServerRelationId},
572 {
"host", ForeignServerRelationId},
573 {
"hostaddr", ForeignServerRelationId},
574 {
"port", ForeignServerRelationId},
575 {
"tty", ForeignServerRelationId},
576 {
"options", ForeignServerRelationId},
577 {
"requiressl", ForeignServerRelationId},
578 {
"sslmode", ForeignServerRelationId},
579 {
"gsslib", ForeignServerRelationId},
580 {
"gssdelegation", ForeignServerRelationId},
622 foreach(cell, options_list)
629 const char *closest_match;
631 bool has_valid_options =
false;
642 has_valid_options =
true;
649 (
errcode(ERRCODE_SYNTAX_ERROR),
651 has_valid_options ? closest_match ?
652 errhint(
"Perhaps you meant the option \"%s\".",
654 errhint(
"There are no valid options in this context.")));
676 Anum_pg_foreign_data_wrapper_oid,
680 (
errcode(ERRCODE_UNDEFINED_OBJECT),
681 errmsg(
"foreign-data wrapper \"%s\" does not exist",
702 (
errcode(ERRCODE_UNDEFINED_OBJECT),
703 errmsg(
"server \"%s\" does not exist", servername)));
743 if (path->param_info != NULL)
752 memcpy(hash_path, path,
sizeof(
HashPath));
761 memcpy(nest_path, path,
sizeof(
NestPath));
770 memcpy(merge_path, path,
sizeof(
MergePath));
813 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)
ForeignDataWrapper * GetForeignDataWrapper(Oid fdwid)
ForeignServer * GetForeignServerExtended(Oid serverid, bits16 flags)
static bool is_conninfo_option(const char *option, Oid context)
static const struct ConnectionOption libpq_conninfo_options[]
FdwRoutine * GetFdwRoutineByRelId(Oid relid)
ForeignTable * GetForeignTable(Oid relid)
Path * GetExistingLocalJoinPath(RelOptInfo *joinrel)
Oid get_foreign_server_oid(const char *servername, bool missing_ok)
UserMapping * GetUserMapping(Oid userid, Oid serverid)
List * GetForeignColumnOptions(Oid relid, AttrNumber attnum)
Datum pg_options_to_table(PG_FUNCTION_ARGS)
Datum postgresql_fdw_validator(PG_FUNCTION_ARGS)
FdwRoutine * GetFdwRoutineForRelation(Relation relation, bool makecopy)
FdwRoutine * GetFdwRoutine(Oid fdwhandler)
ForeignDataWrapper * GetForeignDataWrapperExtended(Oid fdwid, bits16 flags)
ForeignDataWrapper * GetForeignDataWrapperByName(const char *fdwname, bool missing_ok)
ForeignServer * GetForeignServer(Oid serverid)
ForeignServer * GetForeignServerByName(const char *srvname, bool missing_ok)
Oid GetForeignServerIdByRelId(Oid relid)
FdwRoutine * GetFdwRoutineByServerId(Oid serverid)
bool IsImportableForeignTable(const char *tablename, ImportForeignSchemaStmt *stmt)
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)
char * pstrdup(const char *in)
void * MemoryContextAlloc(MemoryContext context, Size size)
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
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)
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)