Revision 2150
Added by Aaron Marcuse-Kubitza over 12 years ago
lib/sql.py | ||
---|---|---|
697 | 697 |
join_cols = util.dict_subset_right_join(mapping, e.cols) |
698 | 698 |
joins = in_joins + [(out_table, join_cols)] |
699 | 699 |
run_query_into(db, *mk_select(db, joins, pkeys_cols, |
700 |
table_is_esc=table_is_esc), into=pkeys) |
|
700 |
table_is_esc=table_is_esc), into=pkeys, recover=True)
|
|
701 | 701 |
|
702 | 702 |
return (pkeys, out_pkey) |
703 | 703 |
|
Also available in: Unified diff
sql.py: put_table(): If DuplicateKeyException: run_query_into() recoverably, so that DB errors such as DuplicateTableException will be parsed