@@ -341,7 +341,6 @@ 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 ;
345344
346345/* There should be relation */
347346if (!rel )elog (FATAL ,"No relation for PATHMAN COPY FROM" );
@@ -351,19 +350,15 @@ PathmanDoCopy(const CopyStmt *stmt, const char *queryString, uint64 *processed)
351350PreventCommandIfReadOnly ("PATHMAN COPY FROM" );
352351PreventCommandIfParallelMode ("PATHMAN COPY FROM" );
353352
354- pstate = make_parsestate (NULL );
355- pstate -> p_sourcetext = queryString ;
356- cstate = BeginCopyFrom (pstate ,rel ,stmt -> filename ,stmt -> is_program ,
353+ cstate = BeginCopyFrom (rel ,stmt -> filename ,stmt -> is_program ,
357354stmt -> attlist ,stmt -> options );
358355* processed = PathmanCopyFrom (cstate ,rel ,range_table ,is_old_protocol );
359356EndCopyFrom (cstate );
360- free_parsestate (pstate );
361357}
362358/* COPY ... TO ... */
363359else
364360{
365361CopyStmt modified_copy_stmt ;
366- ParseState * pstate ;
367362
368363/* We should've created a query */
369364Assert (query );
@@ -372,13 +367,10 @@ PathmanDoCopy(const CopyStmt *stmt, const char *queryString, uint64 *processed)
372367modified_copy_stmt = * stmt ;
373368modified_copy_stmt .relation = NULL ;
374369modified_copy_stmt .query = query ;
375- pstate = make_parsestate (NULL );
376- pstate -> p_sourcetext = queryString ;
377370
378371
379372/* Call standard DoCopy using a new CopyStmt */
380- DoCopy (pstate ,& modified_copy_stmt ,processed );
381- free_parsestate (pstate );
373+ DoCopy (& modified_copy_stmt ,queryString ,processed );
382374}
383375
384376/*