mirrors/pgloader
1
0
Fork 0
mirror of https://github.com/dimitri/pgloader.git synced 2025-08-13 01:37:00 +02:00
Code Issues Projects Releases Wiki Activity

Handle CL-POSTGRES::PROTOCOL-ERROR for batch retry.

Browse Source
This commit is contained in:
Dimitri Fontaine 2013-10-04 17:18:13 +02:00
parent 165f74b197
commit 40e9c438fa
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pgsql.lisp
View File

@ -313,7 +313,8 @@ Finally returns how many rows where read and processed."
(cl-postgres:close-db-writer copier)) (cl-postgres:close-db-writer copier))
((or ((or
CL-POSTGRES-ERROR:UNIQUE-VIOLATION CL-POSTGRES-ERROR:UNIQUE-VIOLATION
CL-POSTGRES-ERROR:DATA-EXCEPTION) (e) CL-POSTGRES-ERROR:DATA-EXCEPTION
CL-POSTGRES::PROTOCOL-ERROR) (e)
(progn (progn
(log-message :debug "pgsql:copy-from-queue: ~a" e) (log-message :debug "pgsql:copy-from-queue: ~a" e)
(retry-batch dbname table-name (retry-batch dbname table-name
@ -471,7 +472,8 @@ Finally returns how many rows where read and processed."
;; the batch didn't make it, recurse ;; the batch didn't make it, recurse
((or ((or
CL-POSTGRES-ERROR:UNIQUE-VIOLATION CL-POSTGRES-ERROR:UNIQUE-VIOLATION
CL-POSTGRES-ERROR:DATA-EXCEPTION) (condition) CL-POSTGRES-ERROR:DATA-EXCEPTION
CL-POSTGRES::PROTOCOL-ERROR) (condition)
;; process bad data ;; process bad data
(if (= 1 current-batch-size) (if (= 1 current-batch-size)
(process-bad-row table-name condition (car current-batch)) (process-bad-row table-name condition (car current-batch))