Skip to content

Commit c3f49c8

Browse files
committed
Fix pathman to support new Copy API introduced by scram patch
1 parent 828b64f commit c3f49c8

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

contrib/pg_pathman/src/copy_stmt_hooking.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -341,7 +341,7 @@ PathmanDoCopy(const CopyStmt *stmt, const char *queryString, uint64 *processed)
341341
PreventCommandIfReadOnly("PATHMAN COPY FROM");
342342
PreventCommandIfParallelMode("PATHMAN COPY FROM");
343343

344-
cstate = BeginCopyFrom(rel, stmt->filename, stmt->is_program,
344+
cstate = BeginCopyFrom(NULL,rel, stmt->filename, stmt->is_program,
345345
stmt->attlist, stmt->options);
346346
*processed = PathmanCopyFrom(cstate, rel, range_table, is_old_protocol);
347347
EndCopyFrom(cstate);
@@ -360,7 +360,7 @@ PathmanDoCopy(const CopyStmt *stmt, const char *queryString, uint64 *processed)
360360
modified_copy_stmt.query = query;
361361

362362
/* Call standard DoCopy using a new CopyStmt */
363-
DoCopy(&modified_copy_stmt, queryString, processed);
363+
DoCopy(NULL,&modified_copy_stmt, processed);
364364
}
365365

366366
/*

0 commit comments

Comments
 (0)