@@ -341,7 +341,6 @@ PathmanDoCopy(const CopyStmt *stmt, const char *queryString, uint64 *processed)
341
341
{
342
342
bool is_old_protocol = PG_PROTOCOL_MAJOR (FrontendProtocol ) < 3 &&
343
343
stmt -> filename == NULL ;
344
- ParseState * pstate ;
345
344
346
345
/* There should be relation */
347
346
if (!rel ) elog (FATAL , "No relation for PATHMAN COPY FROM" );
@@ -351,19 +350,15 @@ PathmanDoCopy(const CopyStmt *stmt, const char *queryString, uint64 *processed)
351
350
PreventCommandIfReadOnly ("PATHMAN COPY FROM" );
352
351
PreventCommandIfParallelMode ("PATHMAN COPY FROM" );
353
352
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 ,
357
354
stmt -> attlist , stmt -> options );
358
355
* processed = PathmanCopyFrom (cstate , rel , range_table , is_old_protocol );
359
356
EndCopyFrom (cstate );
360
- free_parsestate (pstate );
361
357
}
362
358
/* COPY ... TO ... */
363
359
else
364
360
{
365
361
CopyStmt modified_copy_stmt ;
366
- ParseState * pstate ;
367
362
368
363
/* We should've created a query */
369
364
Assert (query );
@@ -372,13 +367,10 @@ PathmanDoCopy(const CopyStmt *stmt, const char *queryString, uint64 *processed)
372
367
modified_copy_stmt = * stmt ;
373
368
modified_copy_stmt .relation = NULL ;
374
369
modified_copy_stmt .query = query ;
375
- pstate = make_parsestate (NULL );
376
- pstate -> p_sourcetext = queryString ;
377
370
378
371
379
372
/* 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 );
382
374
}
383
375
384
376
/*
0 commit comments