bool pipe = (stmt->filename == NULL);
Relation rel;
uint64 processed;
- RangeTblEntry *rte;
+ List *range_table = NIL;
/* Disallow file COPY except to superusers. */
if (!pipe && !superuser())
AclMode required_access = (is_from ? ACL_INSERT : ACL_SELECT);
List *attnums;
ListCell *cur;
+ RangeTblEntry *rte;
Assert(!stmt->query);
rte->relid = RelationGetRelid(rel);
rte->relkind = rel->rd_rel->relkind;
rte->requiredPerms = required_access;
+ range_table = list_make1(rte);
tupDesc = RelationGetDescr(rel);
attnums = CopyGetAttnums(tupDesc, rel, stmt->attlist);
else
rte->selectedCols = bms_add_member(rte->selectedCols, attno);
}
- ExecCheckRTPerms(list_make1(rte), true);
+ ExecCheckRTPerms(range_table, true);
}
else
{
cstate = BeginCopyFrom(rel, stmt->filename,
stmt->attlist, stmt->options);
- cstate->range_table = list_make1(rte);
+ cstate->range_table = range_table;
processed = CopyFrom(cstate); /* copy from file to database */
EndCopyFrom(cstate);
}
{
cstate = BeginCopyTo(rel, stmt->query, queryString, stmt->filename,
stmt->attlist, stmt->options);
- cstate->range_table = list_make1(rte);
processed = DoCopyTo(cstate); /* copy from database to file */
EndCopyTo(cstate);
}