Код: Выделить всё
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()
Код: Выделить всё
for record in records:
try:
with session.begin_nested():
session.merge(record)
except:
print "Skipped record %s" % record
session.commit()
Транзакция этой сессии была отменена вложенным вызовомrollback(). Чтобы начать новую транзакцию, сначала выполните Session.rollback()
Подробнее здесь: https://stackoverflow.com/questions/130 ... -savepoint