diff --git a/src/parsers/command-copy.lisp b/src/parsers/command-copy.lisp index 997522f..6ca052b 100644 --- a/src/parsers/command-copy.lisp +++ b/src/parsers/command-copy.lisp @@ -119,8 +119,9 @@ ,(sql-code-block pg-db-conn :pre before "before load") (let ((truncate ,(getf options :truncate)) - (disable-triggers (getf ',options :disable-triggers)) - (drop-indexes (getf ',options :drop-indexes)) + (disable-triggers (getf ',options :disable-triggers)) + (drop-indexes (getf ',options :drop-indexes)) + (max-parallel-create-index (getf ',options :max-parallel-create-index)) (source (make-instance 'pgloader.copy:copy-copy :target-db ,pg-db-conn @@ -135,7 +136,8 @@ :concurrency :truncate :drop-indexes - :disable-triggers))))) + :disable-triggers + :max-parallel-create-index))))) (pgloader.sources:copy-database source ,@ (when worker-count (list :worker-count worker-count)) @@ -143,7 +145,8 @@ (list :concurrency concurrency)) :truncate truncate :drop-indexes drop-indexes - :disable-triggers disable-triggers)) + :disable-triggers disable-triggers + :max-parallel-create-index max-parallel-create-index)) ,(sql-code-block pg-db-conn :post after "after load"))))) diff --git a/src/parsers/command-csv.lisp b/src/parsers/command-csv.lisp index 2dec5e2..c50c084 100644 --- a/src/parsers/command-csv.lisp +++ b/src/parsers/command-csv.lisp @@ -420,9 +420,10 @@ (progn ,(sql-code-block pg-db-conn :pre before "before load") - (let ((truncate (getf ',options :truncate)) - (disable-triggers (getf ',options :disable-triggers)) - (drop-indexes (getf ',options :drop-indexes)) + (let ((truncate (getf ',options :truncate)) + (disable-triggers (getf ',options :disable-triggers)) + (drop-indexes (getf ',options :drop-indexes)) + (max-parallel-create-index (getf ',options :max-parallel-create-index)) (source (make-instance 'pgloader.csv:copy-csv :target-db ,pg-db-conn @@ -437,7 +438,8 @@ :concurrency :truncate :drop-indexes - :disable-triggers))))) + :disable-triggers + :max-parallel-create-index))))) (pgloader.sources:copy-database source ,@ (when worker-count (list :worker-count worker-count)) @@ -445,7 +447,8 @@ (list :concurrency concurrency)) :truncate truncate :drop-indexes drop-indexes - :disable-triggers disable-triggers)) + :disable-triggers disable-triggers + :max-parallel-create-index max-parallel-create-index)) ,(sql-code-block pg-db-conn :post after "after load"))))) diff --git a/src/parsers/command-fixed.lisp b/src/parsers/command-fixed.lisp index 92a2cb7..ef3e22e 100644 --- a/src/parsers/command-fixed.lisp +++ b/src/parsers/command-fixed.lisp @@ -127,8 +127,9 @@ ,(sql-code-block pg-db-conn :pre before "before load") (let ((truncate ,(getf options :truncate)) - (disable-triggers ,(getf options :disable-triggers)) - (drop-indexes ,(getf options :drop-indexes)) + (disable-triggers ,(getf options :disable-triggers)) + (drop-indexes ,(getf options :drop-indexes)) + (max-parallel-create-index ,(getf options :max-parallel-create-index)) (source (make-instance 'pgloader.fixed:copy-fixed :target-db ,pg-db-conn @@ -147,7 +148,8 @@ (list :concurrency concurrency)) :truncate truncate :drop-indexes drop-indexes - :disable-triggers disable-triggers)) + :disable-triggers disable-triggers + :max-parallel-create-index max-parallel-create-index)) ,(sql-code-block pg-db-conn :post after "after load")))))