Revision 5578
Added by Aaron Marcuse-Kubitza over 12 years ago
| lib/sql_io.py | ||
|---|---|---|
| 254 | 254 |
copy_from += ';\n' |
| 255 | 255 |
|
| 256 | 256 |
log(copy_from, level=2) |
| 257 |
db.db.cursor().copy_expert(copy_from, stream) |
|
| 257 |
try: db.db.cursor().copy_expert(copy_from, stream) |
|
| 258 |
except Exception, e: sql.parse_exception(db, e, recover=True) |
|
| 258 | 259 |
else: |
| 259 | 260 |
log('Using INSERT')
|
| 260 | 261 |
cols_ct = len(stream_info.header) |
Also available in: Unified diff
sql_io.py: append_csv(): Parse any exceptions generated by the COPY FROM using new sql.parse_exception()