mirrors/pgloader
1
0
Fork 0
mirror of https://github.com/dimitri/pgloader.git synced 2026-05-04 10:31:02 +02:00
Code Issues Projects Releases Wiki Activity

Fix bug in max-parallel-create-index (#398)

Browse Source 
Fixes #395
This commit is contained in:
leonardsson 2016-05-05 22:00:38 +02:00 committed by Dimitri Fontaine
parent 65e08fe187
commit 826d975985
3 changed files with 20 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/parsers/command-copy.lisp
View File

@ -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")))))

13
src/parsers/command-csv.lisp
View File

@ -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")))))

8
src/parsers/command-fixed.lisp
View File

@ -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")))))