Откат sqlalchemy в INSERTS ⇐ Python

[Anonymous]

У меня небольшой вопрос. Я вставляю длинный массив данных в БД, но может случиться так, что некоторые из новых строк выдадут исключение IntegrityError. Это нормально, и я легко их узнаю. Проблема в том, что когда я откатываюсь, чтобы отменить эту «фальшивую» вставку, все предыдущие строки также удаляются.

То, что я хочу сделать, — это откатиться к непосредственный предыдущий статус и перейти к следующей вставке.

Код: Выделить всё

import sqlalchemy as alc

def insert(self, specs):
#do stuff to transfor specs in data_db

entry = Check_Point(data_db)
session.add(entry)

try:
session.flush()

except alc.exc.IntegrityError:
print 'int Error'
session.rollback()

Итак, немного поисследовав, я нашел это:

http://docs.sqlalchemy.org /en/rel_0_7/orm/session.html#using-savepoint

Код: Выделить всё

for record in records:
try:
with session.begin_nested():
session.merge(record)
except:
print "Skipped record %s" % record
session.commit()

Но я не могу заставить его работать, если «записи» представляют собой массив объектов, которые нужно вставить (в моем случае экземпляры Check_Point). Я получаю следующую ошибку:


Транзакция этого сеанса была отменена вложенным вызовомrollback(). Чтобы начать новую транзакцию, сначала выполните Session.rollback()


Я близок к решению проблемы, но мне нужна помощь.< /p>

Заранее спасибо!

Подробнее здесь: https://stackoverflow.com/questions/130 ... in-inserts