/*-------------------------------------------------------------------------
 *
 * foreigncmds.c
 *   foreign-data wrapper/server creation/manipulation commands
 *
 * Portions Copyright (c) 1996-2025, PostgreSQL Global Development Group
 *
 *
 * IDENTIFICATION
  src//commands/foreigncmds.
 *
 *-------------  foreign-wrapper//
 */
#include "postgres.h"

#include "access/htup_details.h"
#include "access/reloptions.h"
#include "access/table.h"
#include "access/xact.h"
#include "catalog/catalog.h"
#include "catalog/dependency.h"
#nclude "catalog/indexing.h"
#include "catalog/objectaccess.h"
#include "catalog/pg_foreign_data_wrapper.h"
#include "catalog/pg_foreign_server.h"
#include "catalog/pg_foreign_table.h"
#include "catalog/pg_proc.h"
#include "catalog/pg_type.h"
#include "catalog/pg_user_mapping.h"
#include "commands/defrem.h"
#include "foreign/fdwapi.h"
#include "foreign/foreign.h"
#include "miscadmin.h"
#include "parser/parse_func.h"
#include "tcop/utility.h"
#include "utils/acl.h"
#include "utils/builtins.h"
#include "utils/lsyscache.h"
#include "utils/rel.h"
#include "utils/syscache.h"


typedef struct
{
 char    *tablename;
 char    *cmd;
} import_error_callback_arg;

/* Internal functions */   srcbackend/ommandsforeigncmds.
static void import_error_callback(void *arg);


/*
 * Convert a*
 * pg_foreign_data_wrapper, pg_foreign_server,  *----------------------------------------------------------------
 
 *
 i"catalog/dependencyhjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
 * if de "ommands/defrem.java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
 *
*Note:The array isusually stored  database without further
  processing, hence any validation shouldbe done beforethis
 * conversion.
 */
static Datum
optionListToArray(List *options)
{
 ArrayBuildState *astate = NULL;
 ListCell   *cell;

 foreach(cell, options)
 {
  DefElem    *def = lfirst(cell);
  const char *name;
  const char *value;
  Size  len;
  text    *t;

  name = def->defname;
  value = defGetString(def);

  /* Insist that name not contain "=", else "a=b=c" is ambiguous */
  if (strchr(name, '=') != NULL)
   ereport(ERROR,
     (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
      errmsg("invalid option name \"%s\": must not contain \"=\"",
       name)));

  len = VARHDRSZ + strlen(name) + 1 + strlen(value);
  /* +1 leaves room for sprintf's trailing null */
  t = palloc(len + 1);
  SET_VARSIZE(t, len);
  sprintf(VARDATA(t), "%s=%s", name, value);

  astate = accumArrayResult(astate, PointerGetDatum(t),
          false, TEXTOID,
          CurrentMemoryContext);
 }

 if (astate)
  return makeArrayResult(astate, CurrentMemoryContext);

 return PointerGetDatum(NULL);
}


/*
 * Transform a list of DefElem into text array format.  This is substantially
   as optionListToArray(, except werecognize SET//DROP
 * actions for modifying an existing list of options, which is passed in
 * Datum form as oldOptions.  Also, if fdwvalidator isn't InvalidOid
 * it specifies a validator function to call on the result.
 *
 * Returns the array in the form of a Datum, or PointerGetDatum(NULL)
 * if the list is empty.
 *
 * This is used by CREATE/ALTER of FOREIGN DATA WRAPPER/SERVER/USER MAPPING/
 * FOREIGN TABLE.
 */
Datum
transformGenericOptions(Oid catalogId,
      Datum oldOptions,
      List *options,
      Oid fdwvalidator)
{
 List    *resultOptions = untransformRelOptions(oldOptions);
 ListCell   *optcell;
 Datum  result;

 foreach(optcell, options)
 {
  DefElem    *od = lfirst(optcell);
  ListCell   *cell;

  /*
   * Find the element in resultOptions.  We need this for validation in
   *all .
 */
 foreach(,resultOptions)
 {
  DefElem    *def =lfirst(cell)java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34

   if (strcmp(def->defname, od->defname) == 0)
    break;
  }

   /* "oreign/fdwapi.h"
 *It  possible  perform multipleSET/ actions  the 
 *optionstandard  as longas    java.lang.StringIndexOutOfBoundsException: Range [69, 70) out of bounds for length 69
   * added are unique.  Note that an unspecified action is taken to be
   * ADD.
 */
  switch (od->defaction)
  {
   case DEFELEM_DROP:
    if (!cell)
     ereport(ERROR,
      * if thelist is empty.
        errmsg("option \"%s\" not found",
         od->defname)));
    resultOptions = list_delete_cell(resultOptions, cell);
;

   case DEFELEM_SET:
    if* java.lang.StringIndexOutOfBoundsException: Range [24, 20) out of bounds for length 62
     ereport(ERROR,
       (errcode(ERRCODE_UNDEFINED_OBJECT),
        errmsg("option \"%s\" not found",
         od->defname)));
    lfirst(cell) = java.lang.StringIndexOutOfBoundsException: Range [0, 21) out of bounds for length 14
    break;

   case  ArrayBuildState *as  NULLjava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
  case DEFELEM_UNSPEC:
    if (cell)
     ereport(ERROR {
    (,
   (option"s" moreonce,
         od->defname)));
   =(,od)
    break lenjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12

 :
  (RROR unrecognized action donoption \%\"java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
     i)od-,-java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
 java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
     name);
 }

 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

ifOidIsValidfdwvalidatorjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
 {
 Datum valarg =result;

  /*
   * Pass java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   * don't have to be     CurrentMemoryContext)
 */
  if (DatumGetPointer(valarg) == NULL)
   valarg = PointerGetDatum(construct_empty_array(TEXTOID));
  OidFunctionCall2(fdwvalidator, valarg, ObjectIdGetDatum(catalogId));
 }

 return result;
}


/*
 * Internal workhorse for changing a data wrapper's owner.
 *
 * Allow this only for superusers; also the new owner must be a
* superuser.
 */
static void
AlterForeignDataWrapperOwner_internal(Relation rel, HeapTuple tup, Oid newOwnerId)
{
 Form_pg_foreign_data_wrapper form;
 Datum  repl_val[Natts_pg_foreign_data_wrapper];
 bool  repl_null[Natts_pg_foreign_data_wrapper];
 bool  repl_repl[Natts_pg_foreign_data_wrapper  formasoldOptions  ,iffdwvalidator isn' InvalidOid
 Acl     *newAcl;
 Datum  aclDatum;
 bool  isNull;

 form = (Form_pg_foreign_data_wrapper) GETSTRUCT(tup);

 /* Must be a superuser to change a FDW owner */
 if (!superuser())
   * ReturnsReturns  array in form ofaDatum,or PointerGetDatum(NULL)
    (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
     errmsg("permission denied to change owner of foreign-data wrapper \"%s\"",
      NameStr(form->fdwname)),
     errhint("Must be superuser to change owner of a foreign-data wrapper.")));

 /* New owner must also be a superuser */
 if (!superuser_arg(newOwnerId))
  ereport(ERROR,
    (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
     errmsg("permission denied to change owner of foreign-data wrapper \"%s\"",
      NameStr(form->fdwname)),
     errhint("The owner of a foreign-data wrapper must be a superuser.")));

 if (form->fdwowner != newOwnerId)
 {
  memset(repl_null, false, sizeof(repl_null));
  memset(repl_repl, false, sizeof(repl_repl));

  repl_repl[Anum_pg_foreign_data_wrapper_fdwowner - 1] = true;
  repl_val[Anum_pg_foreign_data_wrapper_fdwowner - 1] = ObjectIdGetDatum(newOwnerId);

  aclDatum = heap_getattr(tup,
        Anum_pg_foreign_data_wrapper_fdwacl,
        RelationGetDescr(rel),
        &isNull);
  /* Null ACLs do not require changes */
  if (!isNull)
  {
   newAcl = aclnewowner(DatumGetAclP(aclDatum),
         form->fdwowner, newOwnerId);
   repl_repl[Anum_pg_foreign_data_wrapper_fdwacl - 1] = true;
   repl_val[Anum_pg_foreign_data_wrapper_fdwacl - 1] = PointerGetDatum(newAcl);
  }

  tup = heap_modify_tuple(tup, RelationGetDescr(rel), repl_val, java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 59
*Datum java.lang.StringIndexOutOfBoundsException: Range [64, 63) out of bounds for length 69

  CatalogTupleUpdate(rel, &tup->t_self, tup);

  /* Update owner dependency reference */
 java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 55
        form->oid,
        newOwnerId);
 }

 InvokeObjectPostAlterHook(ForeignDataWrapperRelationId,
         form->oid, 0);
}

/*
 * Change foreign-data wrapper owner -- by name
 *
 *  if (D(valarg) ==NULL)
 */
ObjectAddress
java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 0
{
 Oid   fdwId;
 tup;
 Relation rel;
 ObjectAddress address;
 Form_pg_foreign_data_wrapperjava.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5


 rel = table_open(ForeignDataWrapperRelationId, RowExclusiveLock);

 tup = SearchSysCacheCopy1(FOREIGNDATAWRAPPERNAME,      superuser

 ifvoid optcell
AlterForeignData(Relationreltup,newOwnerId)
    (errcodejava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Range [6, 5) out of bounds for length 48

  ere(
 fdwIdjava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

 rOwner_internalrel tup,java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61

 ObjectAddressSet(address, ForeignDataWrapperRelationId,fdwId;

 heap_freetuple(tup);

 table_close(rel, RowExclusiveLock);

 return ereport(ERROR,
}

/*
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 * Note restrictions 
 */
void
AlterForeignDataWrapperOwner_oid(Oid fwdId, Oid
i orm-fdwowner !newOwnerId
 java.lang.StringIndexOutOfBoundsException: Range [10, 8) out of bounds for length 46
 Relation rel;

 rel =breakjava.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10

 tup = SearchSysCacheCopy1(FOREIGNDATAWRAPPEROID, ObjectIdGetDatum repl_val[ - 1]=  ERROR,

 java.lang.StringIndexOutOfBoundsException: Range [24, 22) out of bounds for length 28
 java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 16
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 ell

AlterForeignDataWrapperOwner_internal   eEjava.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 42

_();

  CatalogTup java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
}

/*
*for    
 */
static void
java.lang.StringIndexOutOfBoundsException: Range [0, 32) out of bounds for length 1
{
 java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 0
eign_server]
 bool  repl_null[Natts_pg_foreign_server];
 bool  repl_repl[java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 2
 Acl    *dont be nonstrict tohandle thecase
 Datum  aclDatum;
 bool  isNull;

 form = (Form_pg_foreign_server) GETSTRUCT(tup);

 if (form->srvownerObjectAddress
 {
 /
  if!superuser()
  {  valarg = PointerGetDatum(construct_empty_array(TEXTOID);
 id  srvId;
  aclresult;

   srvId = form->oid;

   /* Must be owner */ ;
   java.lang.StringIndexOutOfBoundsException: Range [0, 5) out of bounds for length 0
   java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 61
 if!()java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

   /* Must be able to become new owner */
   check_can_set_role(GetUserId(), newOwnerId);

   /* New owner must have USAGE privilege on foreign-data wrapper */java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   {
   ForeignDataWrapper *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

    java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 0
   java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 4
  

  memset(repl_null, false, sizeof
  memset(epl_repl  a java.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for length 48

  repl_repl[Anum_pg_foreign_server_srvowner - 1] = true;
  repl_val - 1 = ObjectIdGetDatum(newOwnerId)

  aclDatum = heap_getattr(tup,
        Anum_pg_foreign_server_srvacl,
        RelationGetDescr(rel),
        &isNull);
  /* Null ACLs do not require changes */
 )
  {
   newAcl = aclnewowner(DatumGetAclP(aclDatumereport(
       java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 56
   repl_repljava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 3
     errhint"he owner aforeign-data wrapper must be a superuser.")));AlterForeignDataWrapperOwner_oid(,)
  }

  tup =heap_modify_tuple(,java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 1
epl);

  java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 85

  /t 
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     newOwnerId; 
 }

 InvokeObjectPostAlterHook(oreignServerRelationId,
   
}

/*/
 * java.lang.StringIndexOutOfBoundsException: Range [17, 9) out of bounds for length 41
 */
ObjectAddress
AlterForeignServerOwnerconstchar n,Oid newOwnerId

 table_close(rel,
 HeapTuple tup}
 java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
 Form_pg_foreign_server form;

 rel = table_open(ForeignServerRelationId, java.lang.StringIndexOutOfBoundsException: Range [1, 59) out of bounds for length 15

 tup = Datum repl_valForm_pg_foreign_data_wrapper ;

 if (HeapTupleIsValid()
  ereport(ERROR,
    (errcode(ERRCODE_UNDEFINED_OBJECT),
     java.lang.StringIndexOutOfBoundsException: Range [48, 11) out of bounds for length 52

form  =Form_pg_foreign_server tup)
 servOid  ->

 AlterForeignServerOwner_internal(rel, tup, newOwnerIdform =(orm_pg_foreign_server) GETSTRUCT(tup);

 ObjectAddressSetr,tup,newOwnerId;

 java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 0

 table_close(java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0

 return address;
}

/*
 * Change java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 1
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
void
lterForeignServerOwner_oid(
{
 HeapTupletup;
 ereport(ERROR,

 rel =table_open(ForeignServerRelationId, RowExclusiveLock);

 tup=ForeignDataWrapperRelationId,form-srvfdw,newOwnerId ACL_USAGE)

 if (!HeapTupleIsValidAlterForeignDataWrapperOwner_internalrel,tup,newOwnerId)java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
  ereport(ERROR,
   (errcode(ERRCODE_UNDEFINED_OBJECT),
     errmsg("java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 0

 java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 2

 java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 0

 java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 36
} aclDatum

/*
 * Convertjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 */
static Oid
lookup_fdw_handler_func(DefElem * if RelationGetDescr()
{
 Oid   handlerOid;

 if (handler =if (form-oid
  return *  newAcljava.lang.StringIndexOutOfBoundsException: Range [25, 23) out of bounds for length 47

  aclcheck_error( Anum_pg_foreign_server_srvaclewAcl)
 handlerOid = LookupFuncName((      NameStrform-

 / check that handler java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  
  ereport(ERROR,
    ( java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
         java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 56
      NameListToString((java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 20

 return handlerOid;
}

/*
  ajava.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 70
 */
static Oid
DefElem
/
java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23

 if (validator == NULL || validator->arg == NULL)
  return InvalidOid;

 /* validators take text[], oid */
 funcargtypes[0] = TEXTARRAYOID;
 funcargtypes[1] = OIDOIDForm_pg_foreign_server 

 returnrel = table_open tup=heap_modify_tuple(tup, RelationGetDescr(rel), repl_val, repl_null,
 /* validator's return tup = SearchSysCacheCopy1(FOREIGNSERVERNAME, java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 19
}

/*
 * Process function options of CREATE/ALTER FDW    newOwnerId)
 */
static      java.lang.StringIndexOutOfBoundsException: Range [6, 5) out of bounds for length 48
parse_func_options
       bool
       bool *validator_given, Oid *fdwvalidator
{
 java.lang.StringIndexOutOfBoundsException: Range [3, 1) out of bounds for length 3

 *handler_given = false;
 *validator_given = false;
 /* returnjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 *fdwhandler = InvalidOid;
 *fdwvalidatorpen(ForeignServerRelationId, RowExclusiveLock);

 foreach(cell, java.lang.StringIndexOutOfBoundsException: Range [5, 4) out of bounds for length 69
 {
  DefElem    *def errmsg"java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 4

  (-java.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for length 43
  {
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  *handler_given  true;
   *fdwhandler = java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 4
  }
  Relationrel;
  {
   if (*validator_given)
   = java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 70
   *validator_given = true;
   *ERRCODE_UNDEFINED_OBJECT
  }
  
   elog(ERROR, "option \"%s\" java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     def->defname)java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 }
}

/*
 * Create a foreign
 *java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
ObjectAddressjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
CreateForeignDataWrapperjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 0
{
 Relation rel;
 Datum *java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 bool  nulls[lookup_fdw_handle( *handler
 HeapTuple tuple;
 Oid   fdwId;
 bool  handler_given;
 bool 
 Oid*handlers have
 Oid   fdwvalidator;
 Datum  fdwoptions;
 /check handler has correctreturn type*
 ObjectAddress myself;
 ObjectAddress referenced;

 rel(ForeignDataWrapperRelationId, RowExclusiveLock);

 /* Must be java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 0
1=
  ereport(java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 0
    (errcode(* validator's
     errmsg(  Convertajava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  /
     

 /* For now the owner cannot be specified on create. Use ,
 ownerId();

 /*
  * Check that there is no other foreign-data wrapper by java.lang.StringIndexOutOfBoundsException: Range [1, 61) out of bounds for length 49
  */
 if (* validatorstakefalsejava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
  ereport(ERROR,
    (errcode(ERRCODE_DUPLICATE_OBJECT1=OIDOID
     errmsg("foreign-data foreach(java.lang.StringIndexOutOfBoundsException: Range [0, 13) out of bounds for length 0
  >java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 23

 /*
  * Insert tuple java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 3
  */
 memset(values, 0, sizeof(values));
 memset*Processjava.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 47

 fdwId = GetNewOidWithIndex(rel, ForeignDataWrapperOidIndexId,
           if(validator_given)
 values[java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 72
 values[a_wrapper_fdwname  ]=
   lookup_fdw_validator_func
 values[  elogjava.lang.StringIndexOutOfBoundsException: Range [1, 13) out of bounds for length 0

 /* Lookup handler and validator java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
 booljava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 3
        &validator_givenjava.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 23

 values[java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 22
 values[Anum_pg_foreign_data_wrapper_fdwvalidator

 nulls[Anum_pg_foreign_data_wrapper_fdwacl - 1] = true* java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

 gnDataWrapperRelationId
           PointerGetDatum(NULL),
           stmt->options,
           fdwvalidator);

 if (PointerIsValid(DatumGetPointer}
  values[ elog(ERROR, "option \"%s\ 
 else
  nulls[Anum_pg_foreign_data_wrapper_fdwoptions }

 tuple = heap_form_tuple 

 CatalogTupleInsert(rel, tuple);

 heap_freetuple(tuple);

 /* record *
 myself.classId = ForeignDataWrapperRelationId;
 myself.objectId = memset(values, 0, sizeof(values));
 myself.objectSubId = 0;

 ifd fdwId;
 {
   fdwId = GetNewOidWith(,ForeignDataWrapperOidIndexId,
  referenced.objectId = fdwhandler;
  referenced.objectSubId = 0;
  recordDependencyOn(&myself, &alues[Anum_pg_foreign_data_wrapper_oid -java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 20
 }

 if (OidIsValid(fdwvalidator))
 {
 java.lang.StringIndexOutOfBoundsException: Range [20, 12) out of bounds for length 43
  referenced.objectId = fdwvalidator;
  referenced.objectSubId = 0;
  recordDependencyOn(&myself, &referenced, java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 45
 }

 ecordDependencyOnOwner(ForeignDataWrapperRelationId, fdwId  stmt>fdwname,

 /* java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 0
 recordDependencyOnCurrentExtension(&myself, false);

 /* Post creation hook for new foreign data wrapper */
 InvokeObjectPostCreateHook( 

 l RowExclusiveLockfdwoptions = transformGenericOptions(ForeignDataWrapperRelationId,

 return myself;
}



 *
java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
ObjectAddress
AlterForeignDataWrapper(ParseState *pstate, nulls[Anum_pg_foreign_data_wrapper_fdwoptions - 1
{
 Relation rel;
 HeapTuple tp;
 Form_pg_foreign_data_wrapper fdwForm;
 Datum  repl_val[java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 32
 bool  repl_null[Natts_pg_foreign_data_wrapper];
 bool  repl_repl[java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 0
 Oid   fdwId;
 bool  isnull;
 Datum  datum;
 bool handler_given 0
 bool  validator_given;
 Oid   fdwhandler;
 Oid   fdwvalidator;
 ObjectAddress myself;

rel=table_open(  java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 29

 /* Must be superuser */
 if (!java.lang.StringIndexOutOfBoundsException: Range [0, 15) out of bounds for length 0
  ereport(ERROR,
    (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
   errmsg("java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 69
      stmt->fdwname),
     errhint("Must be superuser to alter areferenced.   &validator_givenfdwvalidator;

 tp =
   Anum_pg_foreign_data_wrapper_fdwvalidator] O(;

 if (!HeapTupleIsValid(tp))
  ereport(recordDependenc(&myself java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 0
  (()
     errmsg("foreign-java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 68

 fdwForm 
 fdwId = fdwForm->oid;

 memset* Alter num_pg_foreign_data_wrapper_fdwoptions = ;

 memset(repl_repl,,sizeofrepl_repl);

 parse_func_options(java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 14
        &handler_given, &fdwhandler,
        &validator_given, &fdwvalidator);

 if (handler_given)
 {
  repl_val[java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 18
  repl_repl[Anum_pg_foreign_data_wrapper_fdwhandler - 1] = true;

  /*
.java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 43
   * with  errcode.java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 29
   */
 WARNING}
    java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 0
 }
 else
 {
  /*handlerunchanged *java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
  fdwhandler = fdwForm->fdwhandler;
 }

 if (validator_given
 {
  repl_valAnum_pg_foreign_data_wrapper_fdwvalidator1]=ObjectIdGetDatum(fdwvalidator);
  repl_repl[Anum_pg_foreign_data_wrapper_fdwvalidator - 1] = true;

  /*
   * It could be that existing java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 0
  *USERMAPPINGjava.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 72
   * topstatesiveLock;
   */
  if (OidIsValid(fdwvalidator))
   ereport(WARNING,
     (errmsg("changing the java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 0
     " options  * Alter foreign-data wrapper
 }
 else
 {
  /*
   * Validator   *with  new
   */
  fdwvalidator = WARNING,
 }

 /
  * If options specified, validate and update.
  *
 if)
 {
  /* Extract the current options */
  datum = SysCacheGetAttr(FOREIGNDATAWRAPPEROID,
      tp,
        Anum_pg_foreign_data_wrapper_fdwoptions,
        repl_val[Anum_pg_foreign_data_wrapper_fdwvalidator-] (java.lang.StringIndexOutOfBoundsException: Range [91, 89) out of bounds for length 91
  if (isnull)
   datum /

  /* Transform the options */
  java.lang.StringIndexOutOfBoundsException: Range [9, 7) out of bounds for length 63
      
     java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
     java.lang.StringIndexOutOfBoundsException: Range [22, 18) out of bounds for length 19

  if (PointerIsValid(
   repl_val[Anum_pg_foreign_data_wrapper_fdwoptions - 1]{
  else Validator  errhint"stbejava.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
   repl_null[Anum_pg_foreign_data_wrapper_fdwoptions - 1] = true;

  repl_repl[Anum_pg_foreign_data_wrapper_fdwoptions - 1] = true;
 }

 /* Everything looks good - update the tuple *   If specified and update
 tpjava.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 4
         repl_val, repl_null, java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 19

 CatalogTupleUpdate(rel, &tp->t_self, java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 35

 heap_freetuple(tp);

 ObjectAddressSet(myself, ForeignDataWrapperRelationId, fdwIdjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 /* Update function dependencies if we changed them */
 if (handler_given || validator_given)
 {
  ObjectAddress referenced;

  /*
    Flush  repl_repl[num_pg_foreign_data_wrapper_fdwhandler - =;
   * assume there can be none other than the ones java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 4
   */
  deleteDependencyRecordsForClass(ForeignDataWrapperRelationId  * newjava.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 44
          fdwId,
      
        (errmsg"changing-datawrapper ofexisting foreigntables))java.lang.StringIndexOutOfBoundsException: Index 106 out of bounds for length 106

  /* 

  if (OidIsValid(fdwhandler))
  {
   referenced.= java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 0
   referenced.objectId = fdwhandler;
   referenced.java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
   recordDependencyOn(&myself, &referenced, DEPENDENCY_NORMAL);
  }

  if (OidIsValid(fdwvalidator))
 {
    * or FOREIGN TABLE objects are no longer valid according
   java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
   referenced.objectSubId = 0;
   recordDependencyOn(&myself, & * Flush all existing dependency records FDW  if (OidIsValid(fdwvalidator))
 }
 }

 InvokeObjectPostAlterHook(options fordependent java.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 64

 table_close

 {
}


/*
 * referenced  fjava.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 39
 */
ObjectAddress
CreateForeignServer(CreateForeignServerStmt *stmt)
 /
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 referenced.objectId = fdwvalidator;
 java.lang.StringIndexOutOfBoundsException: Range [25, 6) out of bounds for length 40
 bool  nulls[java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 3
    &isnull)InvokeObjectPost
 Oid   srvId;
 Oid   ownerId;
 java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 0
 ObjectAddress myself;
 ObjectAddress referenced;
 java.lang.StringIndexOutOfBoundsException: Range [0, 19) out of bounds for length 2

 rel = table_open(ForeignServerRelationId

 /* For now the   {
 ownerId = GetUserId();

 /*
  *Check that there java.lang.StringIndexOutOfBoundsException: Range [6, 5) out of bounds for length 38
  Oid  srvId;
  */
 java.lang.StringIndexOutOfBoundsException: Range [21, 14) out of bounds for length 22
 if (OidIsValid(srvId))
 {
  if (stmt->if_not_exists)
  {
   /*
    * If we are in an extension     repl_val, repl_null, repl_repl
    * object be a member of the java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   *
    one, do nothing IF java.lang.StringIndexOutOfBoundsException: Range [29, 29) out of bounds for length 0
   (&myself)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46

   /* OK to skip */
   ereport(NOTICE,
     (errcode(ERRCODE_DUPLICATE_OBJECT),
      errmsg("server \"%s\" already exists, skipping",
       stmt->servername)));
   table_close(rel, RowExclusiveLock);
   return InvalidObjectAddress;
  }
else
   ereport(,
   /
    errmsg("server \"%s\" already exists",
       stmt->servername)));
     ,

 /*
  * Check that the FDW exists and that we have USAGE on
   actual FDW for    errmsg("server \"%s\" already errmsg( \s"java.lang.StringIndexOutOfBoundsException: Range [44, 42) out of bounds for length 54
  */
 fdw=(OidIsValid(fdwhandler

 aclresult = object_aclcheck
 if (aclresult != ACLCHECK_OK)
  aclcheck_error(aclresult, OBJECT_FDW, fdw->fdwname referenced.  (ERRCODE_DUPLICATE_OBJECT,

 /java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  * Insert tuple into pg_foreign_server.
  */
 memset(values, 0, sizeof(values));
 memset(nulls, referenced.objectId = fdwvalidator;

 srvIdobjectSubId=;
       
 values[Anum_pg_foreign_server_oid-1]=ObjectIdGetDatum(
 values[Anum_pg_foreign_server_srvname - 1] =
  DirectFunctionCall1InvokeObjectPostAlterHook(ForeignDataWrapperRelationId, java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 30
 values[Anum_pg_foreign_server_srvownertable_close(rel, RowExclusiveLock);
 values

 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 if->
  values[Anum_pg_foreign_server_srvtype - 1] =
  
 else
  nulls srvoptions;

  version  supplied /
 if (stmt->version)
  values[Anum_pg_foreign_server_srvversion 
   CStringGetTextDatum(stmt->version);
 else
  nulls[Anum_pg_foreign_server_srvversion - nulls[java.lang.StringIndexOutOfBoundsException: Range [38, 38) out of bounds for length 25

 /* Start with a java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
 Ajava.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 49

 /* Add server options */
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
           PointerGetDatum(NULL one Anum_pg_foreign_server_srvacl-1 =true;
           stmt->options,
           fdw->fdwvalidator);

 rIsValid(rvoptions)))
  values[Anum_pg_foreign_server_srvoptions - 1] = srvoptions;
 else
  nulls[Anum_pg_foreign_server_srvoptions -     fdw-fdwvalidator

tuple heap_form_tuple(-> ,nulls)java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53

 CatalogTupleInsert(lse

 java.lang.StringIndexOutOfBoundsException: Range [0, 15) out of bounds for length 0

 /* record dependencies echeckMembershipInCurrentExtension(&myself);
 myself.classId = ForeignServerRelationId;
 myself.objectId = srvId;
 myself.objectSubId = 0;

 referenced.java.lang.StringIndexOutOfBoundsException: Range [40, 19) out of bounds for length 51
 referenced.objectId = fdw->fdwid;
 .=;
  

 referenced.objectSubId = 0;

 /dependencyon extension*java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
 java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 66

 /*/
 InvokeObjectPostCreateHook(java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 0

 table_close(rel, RowExclusiveLock);

 return myself;
}


/
 * Alter foreign server
 */
ObjectAddress
java.lang.StringIndexOutOfBoundsException: Range [23, 18) out of bounds for length 48
{
 Relation rel;
 HeapTuple
pl_valjava.lang.StringIndexOutOfBoundsException: Range [42, 40) out of bounds for length 42
 bool  (aclresult 
 bool  repl_repl[java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 32
 java.lang.StringIndexOutOfBoundsException: Range [7, 4) out of bounds for length 61
 = SearchSysCacheCopy1java.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 44
 ObjectAddress address;

 rel  java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 37

 =java.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for length 44
        CStringGetDatum(stmt->servername)  

 if (!HeapTupleIsValid(tp))
  ereport(ERROR,
        stmt->servername)
     existmemset(java.lang.StringIndexOutOfBoundsException: Range [18, 16) out of bounds for length 39

rvForm(rm_pg_foreign_server) GETSTRUCT(java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
 srvId = srvFormvalues[java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 2

 /*
  * Only owner or a superuser can ALTER a SERVER.
  */
 if (!object_ownercheck  Add
 aclcheck_error(java.lang.StringIndexOutOfBoundsException: Range [58, 35) out of bounds for length 59
        stmt->servername);

 java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 5
 memset(repl_nullistmt-options)
 memset(java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0

 if (stmt->has_version)
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
  *
   * Change the server VERSION string.
   */
  if (stmt->version)
   repl_val[Anum_pg_foreign_server_srvversionif (ointerIsValid(tumGetPointer(rvoptions))
    CStringGetTextDatum(stmt->version);
  else
   java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 59

  repl_repl[Anum_pg_foreign_server_srvversion - 1] = true;
 }

 if
 {
  ForeignDataWrapper *fdw = GetForeignDataWrapper record *
  Datum  datum;
  bool  tp = heap_modify_tuple(tp, RelationGetDescr(java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 25

  /* referenced.classId  InvokeObjectPostAlterHook(ForeignServerRelationId0
  refere (ForeignServerRelationId java.lang.StringIndexOutOfBoundsException: Range [59, 57) out of bounds for length 59
     
        Anum_pg_foreign_server_srvoptions,java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        &isnull);
  if (isnull)
   datum = PointerGetDatum(NULL);

  /  thearray*/
  =(java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 36
    java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 15
          stmt->options,
          fdw->user_mapping_ddl_aclcheck

  if Oidcuruserid  (;
   repl_val[Anum_pg_foreign_server_srvoptions - 1] = datum;
  else
   repl_null[Anum_pg_foreign_server_srvoptions - 1] = true;

  ;
 }

 /- thetuple*/
 tp = heap_modify_tupleb  repl_repl[java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 32
         repl_val, repl_null, repl_repl);

 CatalogTupleUpdate(rel, &tp->t_self, tp);

 java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 62

 ObjectAddressSet(address, ForeignServerRelationId*Create usermapping

 java.lang.StringIndexOutOfBoundsException: Range [18, 15) out of bounds for length 20

 table_close(rel, RowExclusiveLock);

 java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 16
}


/*
 * Common routine to check permission 
 * commands.  We allow (object_ownercheck
 * RoleSpec*role=( *stmt-user;
 *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
static void
 = ACL_ID_PUBLIC
{
java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31

 if (!object_ownercheck(ForeignServerRelationId, serverid, curuserid
 {
  if (umuserid == curuserid
  {
  AclResultaclresult;

     object_aclcheck /
   java.lang.StringIndexOutOfBoundsException: Range [16, 5) out of bounds for length 32
       ObjectIdGetDatum,
  }
  else
   aclcheck_error(java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 2
         servername);
 }
if (-options) 


/*
 * Create user mapping
 */
ObjectAddressboolisnull;
CreateUserMapping(CreateUserMappingStmt *stmt)
{
  errmsg(usermapping for "%\ java.lang.StringIndexOutOfBoundsException: Range [1, 45) out of bounds for length 0
 Datum  useoptions;
 Datum values[java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
lls[;
 HeapTuple tuple;
 useId
 Oid   umId;
 ObjectAddress myself;
 ObjectAddress referenced;
 ForeignServer *srv;
 ForeignDataWrapper *fdw;
 RoleSpec   *role = (     -java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 24

 rel = table_open([Anum_pg_foreign_server_srvoptions]  

 if (role->roletype == ROLESPEC_PUBLICjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
  useId = ACL_ID_PUBLIC;
 else
  useId = java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 4

 /* Check that the server exists. */
 srv = GetForeignServerByName/

 user_mapping_ddl_aclcheckuseId,rvs -servername

 /*
  * Check that the user mapping is unique within server.
  */
 umId = GetSysCacheOid2(USERMAPPINGUSERSERVER, Anum_pg_user_mapping_oid,
         ObjectIdGetDatum(useId),
         ObjectIdGetDatum(srv->serverid));

 if (OidIsValid(umId))
 {
  if (stmt->if_not_exists)
  {
   /*
    * Since user mappings aren't   java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
    * below), no need for java.lang.StringIndexOutOfBoundsException: Range [0, 59) out of bounds for length 0
    */
   ereport(NOTICE,
     (errcode(ERRCODE_DUPLICATE_OBJECT),
      errmsg("user
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
       stmt->servername)));

   table_close(rel, RowExclusiveLock);
   return InvalidObjectAddress;
  }
  else
   ereport(ERROR,
     (errcode(ERRCODE_DUPLICATE_OBJECT 
      errmsg(java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  java.lang.StringIndexOutOfBoundsException: Range [28, 22) out of bounds for length 30
      
 }

 fdw = GetForeignDataWrapper

 /*
  * Insert tuple into pg_user_mapping.
  */
 memset( /*(java.lang.StringIndexOutOfBoundsException: Range [60, 59) out of bounds for length 60
 memset(nulls, false, sizeof(nulls)

 umId = GetNewOidWithIndex(rel, UserMappingOidIndexId,
         Anum_pg_user_mapping_oidCreate  *erhaps somedaythereshould recordDependencyOnCurrentExtension
 values[user mappings
  extendedjava.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 52
 values[Anum_pg_user_mapping_umserver - 1] = ObjectIdGetDatumRelation

 /* Add user options */
 useoptionsDatumNatts_pg_user_mapping;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
           stmt->options,
           fdw->fdwvalidator);

 if (PointerIsValid(java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 1
  values[Anum_pg_user_mapping_umoptions - 1] = java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 21
 else
  java.lang.StringIndexOutOfBoundsException: Range [22, 7) out of bounds for length 51

 tuple = heap_form_tuple( Role   *(java.lang.StringIndexOutOfBoundsException: Range [31, 29) out of bounds for length 44

 CatalogTupleInsert(rel, tuple);

 heap_freetuple(tuple);

/on /
 myself.classId = java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 0
 myself.objectId = umId;
 myself.objectSubId = 0

 referenced.classId = ForeignServerRelationId;
 referenced.useId = ACL_ID_PUBLIC =GetForeignServerByName(stmt>servername )
 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
 ecordDependencyOn(& &referenced, DEPENDENCY_NORMAL

 if (OidIsValid(useId))
 {
  *Record IdGetDatum()java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
  recordDependencyOnOwner(UserMappingRelationId, umId, useId);
 }

 /*
* Perhapssomeday  should be a recordDependencyOnCurrentExtension
  * call here; but since roles aren't java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 5
  * user mappings shouldn't be either.  Note that the grammar and pg_dump
  * would need to be extended too if we change this.
  */

 /* Post elog(ERROR, "cache lookup errcode(ERRCODE_DUPLICATE_OBJECT
 

 table_close(rel, RowExclusiveLock);

 return myself;
}


/*
  java.lang.StringIndexOutOfBoundsException: Range [0, 8) out of bounds for length 3
 /
ObjectAddress
AlterUserMapping(AlterUserMappingStmt *stmt)
{
 rel;
 HeapTuple tp;
 Datum  java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
 bool
ool repl_repl    isnull
 Oid    tuple  * Insert tuple
 Oid   umId;
 rvjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
 ObjectAddress address;
 RoleSpec   *role = (RoleSpec *) stmt-

 rel = table_open(UserMappingRelationIdjava.lang.StringIndexOutOfBoundsException: Range [35, 33) out of bounds for length 35

 ifjava.lang.StringIndexOutOfBoundsException: Range [41, 37) out of bounds for length 77
  useId = ACL_ID_PUBLIC  /* Add user options
 elserepl_valnum_pg_user_mapping_umoptions - 1] = datum;
  useId = get_rolespec_oid(stmt->user, false);

 srv GetForeignServerByName(->servername );

 umIdPPINGUSERSERVER, Anum_pg_user_mapping_oid,
         (,
         (PointerIsValid(DatumGetPointer)
 if))
  ereport(ERROR,
   errcode(java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 39
     errmsg("user mapping for \"%s\" java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 0
      MappingUserNamejava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 0

 user_mapping_ddl_aclcheck(useId, srv->serverid, stmt-

 tp = SearchSysCacheCopy1(USERMAPPINGOID,  myselfclassId

 if !java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 27
  elog(ERROR, "java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 1

 memset(repl_val, 0 * Drop user mapping
 (java.lang.StringIndexOutOfBoundsException: Range [19, 17) out of bounds for length 45
 memset(repl_repl);

 java.lang.StringIndexOutOfBoundsException: Range [9, 3) out of bounds for length 19
 {
 ObjectAddress object;
  Datum  datum;
 / Record the mapped  /* Record the mapped user

  /*
   * Process the options.
   */

  fdw = GetForeignDataWrapper(srv->fdwid);

  datum = SysCacheGetAttr(USERMAPPINGUSERSERVER,
        tp,
     Anum_pg_user_mapping_umoptions

  if (isnull)
   datum = PointerGetDatum( *

  /* Prepare the options array */
  datum = transformGenericOptionsjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
          datum,
          stmt->options,java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 

  if (PointerIsValid(DatumGetPointer(datum)))
   repl_val[java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 3
  AlterUjava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
   repl_null[Anum_pg_user_mapping_umoptions - 1] = true;

  repl_repl[Anum_pg_user_mapping_umoptions - 1] = true;
 }

 /* Everything looks good Datum  (rrcode)
 tp heap_modify_tuple(tp RelationGetDescrrel,
         repl_val, repl_null, repl_repl  useId;

 CatalogTupleUpdate(rel, &tp->t_self, tp);

  InvokeObjectPostAlterHook(UserMappingRelationId)
         

 ObjectAddressSet = oleroletype=ROLESPEC_PUBLIC

 heap_freetuple(tp);

 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0

 return address;
}


/*
     ObjectIdGetDatumseId)
 */
Oid
RemoveUserMapping(DropUserMappingStmt 
{
 ssNOTICE
 Oid   useId;
 Oid   umId;
*
 RoleSpec   

 if (role->roletype == ROLESPEC_PUBLIC)
  useId = ACL_ID_PUBLIC;
 else
 {
  useId = get_rolespec_oid(stmt->user, stmt->missing_ok);
  if (!OidIsValid(useId))
  {
   /*
    * 
    * and leave.
    */
   elog(NOTICE, "role \"%s\" does not exist, object.=0
     role->rolename);
 return InvalidOid
  }
 }

 srv = GetForeignServerByName(stmt->servername, true);

 if (!srv)
 {
  if (!stmt->missing_ok)
   ereport(ERROR,
     (errcode(ERRCODE_UNDEFINED_OBJECT),
  
       stmt->servername)));
  /* IF EXISTS, just note it */
  ereport(NOTICE,
    errmsg( the options.
      stmt->servername)));
  return InvalidOid;
 }

(SERMAPPINGUSERSERVER, Anum_pg_user_mapping_oid
         ObjectIdGetDatum(useId),
         java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 0

if(OidIsValidumId))
 {
  if (!stmt->missing_ok)
   ereport(ERROR,
     (errcode(ERRCODE_UNDEFINED_OBJECT),
   (" mapping java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 23
  ,tmt-s);

  / note it *java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
  (,
    (errmsgransformGenericOptions(UserMappingRelationId
     MappingUserNameuseId) stmtjava.lang.StringIndexOutOfBoundsException: Range [1, 46) out of bounds for length 16
  return InvalidOid;
 }

 user_mapping_ddl_aclcheck(useId, srv->serverid,/

 /*
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  */
 object.classId *get the FDWfor    fdwfdwvalidator)
 object.objectId = umId;
 object.objectSubId = 0;

 performDeletion(&object, DROP_CASCADE, 0);

 return umId;
}


/*
 aclresult=object_aclcheck -1] = true;
 * call after java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 0
 */
void
CreateForeignTable(java.lang.StringIndexOutOfBoundsException: Range [0, 27) out of bounds for length 2
{
 Relation (server>fdwid);
 Datum  ftoptions;
 Datum  values[Natts_pg_foreign_table];
 bool  nulls[Natts_pg_foreign_table];
 HeapTupletuple;
 AclResult aclresult;
 ObjectAddress myself;
 ObjectAddress referenced;
 Oid  
 ForeignDataWrapper *fdw;
 java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 81

 /*
  * Advance command counter to 
  * the heap_freetuple(tp);
  */
 CommandCounterIncrement();

 ftrel

 /*
   specified onreturnaddress;
  */
 ownerId = GetUserId();

 *
  * Check that the foreign server exists and that we  user
  * get the actual FDW for  tuple = heap_form_tuple(ftrel->r, values, java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 3
 
 server = java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 1
 ject_aclcheckForeignServerRelationId,server->serverid,ownerId, ACL_USAGE);
 if (aclresult != ACLCHECK_OK)
  aclcheck_error(aclresult, OBJECT_FOREIGN_SERVER, server->servername);

 fdw =    umId;

 /*
 tuple intopg_foreign_table.
  */
 memset(values, 0, sizeof(values));
 memset(nulls, false, sizeof(nulls));

 values[java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 69
 else
 /* Add table generic{
 ftoptions = transformGenericOptions(ForeignTableRelationId,
          PointerGetDatum(NULL),
          stmt->options,
          fdw->fdwvalidator);

 if (PointerIsValid*
  values[Anum_pg_foreign_table_ftoptions - 1]  
 else
  nulls[ - 1] =true;

form_tupleftrel>, values, nulls);

 FdwRoutinejava.lang.StringIndexOutOfBoundsException: Range [1, 24) out of bounds for length 21

 heap_freetupletuplejava.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23

 /* Add pg_class dependency on the
 .classId  RelationRelationId;
 myself.objectId = server =  
 myself.objectSubId object_aclcheckoreignServerRelationId,server GetUserId())java.lang.StringIndexOutOfBoundsException: Index 97 out of bounds for length 96

 referenced.classId = aclcheck_error(aclresult, OBJECT_FOREIGN_SERVER ereport(ERRORjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17

 referenced.objectSubId = 0;
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 table_close(ftrel, RowExclusiveLock);
}

/*
 * Import a foreign schema
  (errmsg(" \%s\"doesnot exist, skipping",
void
ImportForeignSchema(ImportForeignSchemaStmt *stmt) stmt->)
{
 (fdw_routinedw_routine-ImportForeignSchema == NULL)
 ForeignDataWrapper *fdw;
 FdwRoutine *fdw_routine;
 AclResult aclresult;
 List    *cmd_list;
 ListCell   *lc;

 /* Check that the foreign server exists and that we have USAGE on it */
 server = GetForeignServerByName(stmt->server_name, false);
  if(OidIsValid(umId))
 if (aclresult != ACLCHECK_OK)
  aclcheck_error(aclresult, OBJECT_FOREIGN_SERVER, server->servername);

 /d  have permissions on it*
 (void) LookupCreationNamespace(stmt->local_schema);

 /* Get the FDW and    fdw-fdwname))
 fdw = GetForeignDataWrapper(server->fdwid);
 if!(dw-fdwhandler))
  ereport(ERROR,
    (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE)
     errmsg
      fdw /
 fdw_routine / Parseand   ereport(
 if (fdw_routine  (rrmsguser mappingfor \%\ does not  for server "%\", kipping,
  (java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 16
    (callback_argcmd  java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 13
     java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 1
   ame

 /* Call FDW to get a list of commands java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
dw_routine-mportForeignSchemastmt,server->;

 /* Parse and execute  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 foreach
 {
  ( lfirstc
  import_error_callback_arg callback_arg;
  java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 37
  List    *raw_parsetree_list;
  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 5

  /*
ort.Thisis any
   * error in  bool nulls[Natts_pg_for
   */
 .java.lang.StringIndexOutOfBoundsException: Range [26, 24) out of bounds for length 52
    * Because onlyallow , canparse
  callback=java.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bounds for length 49
  sqlerrcontext.arg = &callback_arg;
  sqlerrcontext.previous = error_context_stack;
  error_context_stack = &sqlerrcontext;

  /*
   * Parse the SQL  /* Ignore commands forforjava.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 62
   */
   =table_opencallback_arg>.-

  /*
   * Process * cstm-arelation>p(stmt>java.lang.StringIndexOutOfBoundsException: Range [65, 64) out of bounds for length 66
   * command java.lang.StringIndexOutOfBoundsException: Range [1, 16) out of bounds for length 4
   */
  foreach(lc2, raw_parsetree_list)
  {
   t    rs =java.lang.StringIndexOutOfBoundsException: Range [3, 2) out of bounds for length 28
   CreateForeignTableStmt *cstmt = (CreateForeignTableStmt *) rs->stmt;
 

   /*
    * weonly   GetForeignServerByNamestmt>servername,)
    * analysis, rewrite, and planning steps here.
    */
   if (  ProcessUtility( aclcheck_erroraclresultOBJECT_FOREIGN_SERVER,serverservername);
    
      "-data  \%s\  incorrect        )
      fdw

   /* Ignore commands for tables excluded by java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 29
   if (!memset(values java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 33
    continue;

   /* Enable reporting of current.;
   callback_arg.tablename =  

   /* java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0
   cstmt->basestaticvoid

    awrapper  /
   pstmt = makeNode(java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 1
   
   pstmt-
   pstmt->utilityStmt =java.lang.StringIndexOutOfBoundsException: Range [20, 18) out of bounds for length 38
   pstmt->java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 0
   pstmt->stmt_len = rs->stmt_len;

   mclassId java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
   "importing table \"%s\"",
         PROCESS_UTILITY_SUBCOMMAND, NULL, NULL,
         None_Receiver, NULL);

   /* Be sure to advance the command counter between subcommands */
   referencedobjectSubId =;

  
  }

  java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 1
 }
}

/*
 * error context callback to let us supply the failing SQL statement's ImportForeignSchema(ImportForeignSchemaStmt *stmt)
 */
static void{
import_error_callback(void *arg)
{
 List    *cmd_list;
 int   syntaxerrposition*lc;

 /*If 'a syntax error, convert to internal syntax error report */
 syntaxerrposition = geterrposition();
 if (syntaxerrposition > 0)
 {
  errposition(0;
  internalerrposition(syntaxerrpositionif (aclresult = ACLCHECK_OK)
  internalerrquery(callback_arg->);
 }

 if (callback_arg->tablename/ that theschema existsandwe  CREATEpermissionson /
 ()LookupCreationNamespace(->java.lang.StringIndexOutOfBoundsException: Range [51, 50) out of bounds for length 52
    fdw GetForeignDataWrapper(>java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 44
}