Revision 2904
Added by Aaron Marcuse-Kubitza about 12 years ago
| sql.py | ||
|---|---|---|
| 1261 | 1261 |
insert_out_pkeys = insert_pkeys_table('out')
|
| 1262 | 1262 |
insert_in_pkeys = insert_pkeys_table('in')
|
| 1263 | 1263 |
|
| 1264 |
log_debug('Locking output tables to prevent concurrent duplicate keys')
|
|
| 1265 |
for table in [out_table, errors_table_]: lock_table(db, table, 'EXCLUSIVE') |
|
| 1266 |
|
|
| 1267 | 1264 |
# Do inserts and selects |
| 1268 | 1265 |
join_cols = sql_gen.ColDict(db, out_table) |
| 1269 | 1266 |
while True: |
Also available in: Unified diff
sql.py: put_table(): Removed locking output tables to prevent concurrent duplicate keys because that is now done automatically by mk_select()