@@ -341,6 +341,7 @@ PathmanDoCopy(const CopyStmt *stmt, const char *queryString, uint64 *processed)
341341{
342342bool is_old_protocol = PG_PROTOCOL_MAJOR (FrontendProtocol )< 3 &&
343343stmt -> filename == NULL ;
344+ ParseState * pstate ;
344345
345346/* There should be relation */
346347if (!rel )elog (FATAL ,"No relation for PATHMAN COPY FROM" );
@@ -350,15 +351,19 @@ PathmanDoCopy(const CopyStmt *stmt, const char *queryString, uint64 *processed)
350351PreventCommandIfReadOnly ("PATHMAN COPY FROM" );
351352PreventCommandIfParallelMode ("PATHMAN COPY FROM" );
352353
353- cstate = BeginCopyFrom (NULL ,rel ,stmt -> filename ,stmt -> is_program ,
354+ pstate = make_parsestate (NULL );
355+ pstate -> p_sourcetext = queryString ;
356+ cstate = BeginCopyFrom (pstate ,rel ,stmt -> filename ,stmt -> is_program ,
354357stmt -> attlist ,stmt -> options );
355358* processed = PathmanCopyFrom (cstate ,rel ,range_table ,is_old_protocol );
356359EndCopyFrom (cstate );
360+ free_parsestate (pstate );
357361}
358362/* COPY ... TO ... */
359363else
360364{
361365CopyStmt modified_copy_stmt ;
366+ ParseState * pstate ;
362367
363368/* We should've created a query */
364369Assert (query );
@@ -367,9 +372,13 @@ PathmanDoCopy(const CopyStmt *stmt, const char *queryString, uint64 *processed)
367372modified_copy_stmt = * stmt ;
368373modified_copy_stmt .relation = NULL ;
369374modified_copy_stmt .query = query ;
375+ pstate = make_parsestate (NULL );
376+ pstate -> p_sourcetext = queryString ;
377+
370378
371379/* Call standard DoCopy using a new CopyStmt */
372- DoCopy (NULL ,& modified_copy_stmt ,processed );
380+ DoCopy (pstate ,& modified_copy_stmt ,processed );
381+ free_parsestate (pstate );
373382}
374383
375384/*