| 212 | | try: |
|---|
| 213 | | insert_result = insert_table.insert(values).execute() |
|---|
| 214 | | except exceptions.SQLError, e: |
|---|
| 215 | | # TODO: Make sure this wasn't a terrible mistake. |
|---|
| 216 | | # We want to catch this so that revisioned tables |
|---|
| 217 | | # referring to existing content records (such as containers) |
|---|
| 218 | | # won't cause integrity errors. |
|---|
| 219 | | pass |
|---|
| 220 | | else: |
|---|
| 221 | | inserted_keys = dict( |
|---|
| 222 | | zip( |
|---|
| 223 | | primary_keys, |
|---|
| 224 | | insert_result.last_inserted_ids() |
|---|
| 225 | | ) |
|---|
| 226 | | ) |
|---|
| 227 | | for key, value in inserted_keys.iteritems(): |
|---|
| 228 | | setattr(instance, key.name, value) |
|---|
| | 212 | insert_result = insert_table.insert(values).execute() |
|---|
| | 213 | inserted_keys = dict( |
|---|
| | 214 | zip(primary_keys, insert_result.last_inserted_ids()) |
|---|
| | 215 | ) |
|---|
| | 216 | for key, value in inserted_keys.iteritems(): |
|---|
| | 217 | setattr(instance, key.name, value) |
|---|
