Revision 2244
Added by Aaron Marcuse-Kubitza over 12 years ago
| sql.py | ||
|---|---|---|
| 846 | 846 |
into_ref=existing_pkeys_ref) |
| 847 | 847 |
# need table_is_esc=True to make table name case-insensitive |
| 848 | 848 |
|
| 849 |
# Insert new rows |
|
| 850 |
input_join_cols = join_cols.values() |
|
| 851 |
distinct_on = filter(util.is_str, input_join_cols) |
|
| 852 |
insert_joins.append((existing_pkeys_ref[0], {in_pkey: filter_out}))
|
|
| 853 |
|
|
| 849 | 854 |
# rerun loop with additional constraints |
| 850 |
break # but until NullValueExceptions are handled, end loop here |
|
| 851 | 855 |
except NullValueException, e: |
| 852 | 856 |
out_col, = e.cols |
| 853 | 857 |
try: in_col = mapping[out_col] |
Also available in: Unified diff
sql.py: put_table(): After getting pkeys of already existing rows, insert new rows