dataimport.py
changeset 10971 de59a60a9e40
parent 10295 080ac14df6fa
child 11400 5a366414d904
--- a/dataimport.py	Mon Dec 14 12:11:44 2015 +0100
+++ b/dataimport.py	Mon Dec 14 16:19:52 2015 +0100
@@ -380,8 +380,9 @@
                                columns, encoding='utf-8'):
     """ Execute thread with copy from
     """
-    buf = _create_copyfrom_buffer(data, columns, encoding=encoding)
-    if buf is None:
+    try:
+        buf = _create_copyfrom_buffer(data, columns, encoding=encoding)
+    except ValueError:
         _execmany_thread_not_copy_from(cu, statement, data)
     else:
         if columns is None: