diff --git a/src/sources/mysql.lisp b/src/sources/mysql.lisp index 47e76d6..4f67e61 100644 --- a/src/sources/mysql.lisp +++ b/src/sources/mysql.lisp @@ -149,6 +149,9 @@ ;; and start another task to push that data from the queue to PostgreSQL (lp:submit-task channel #'pgloader.pgsql:copy-from-queue (target-db mysql) (target mysql) queue + :columns (mapcar #'apply-identifier-case + (mapcar #'mysql-column-name + (fields mysql))) :truncate truncate) ;; now wait until both the tasks are over