Revision 5027
Added by Aaron Marcuse-Kubitza about 12 years ago
| csv2db | ||
|---|---|---|
| 56 | 56 |
line_in = streams.ProgressInputStream(in_, sys.stderr, n=1000) |
| 57 | 57 |
|
| 58 | 58 |
# Import data |
| 59 |
try: sql_io.import_csv(db, table, line_in, use_copy_from, has_row_num)
|
|
| 59 |
try: sql_io.import_csv(db, table, line_in, use_copy_from) |
|
| 60 | 60 |
finally: |
| 61 | 61 |
line_in.close() # also closes proc.stdout |
| 62 | 62 |
proc.wait() |
Also available in: Unified diff
sql_io.py: import_csv(): Don't add a row number column to the created table because it is now added automatically to the temp table by column-based import (row-based import now also does not require a pkey for DB inputs)