Как сделать rollback транзакции?

Question

[beduin01]

Предположим у меня запрос не сработал, как сделать rollback? tr же у меня в цикле идет.

tr_list = []
try:
	for tr in ready_query.all():
		tr_list.append(tr.asdict(follow=follow_list, exclude=exclude_columns))
except SQLAlchemyError as e:
	# как сделать rollback ?

Comments

[sim3x]

Роллбек какого конкретно блока скуля?

Укажите что такое tr_list и как он коммитится

[beduin01]

sim3x, tr_list это просто список. Падает в цикле при первом же запросе ( при условии что прилетели некорректные данные), но корректность данных не могу обеспечить, поэтому нужно как-то ролбек сделать.

[sim3x]

beduin01, проведите валидацию перед вставкой

[beduin01]

sim3x, иначе никак?

[sim3x]

beduin01, а зачем делать криво?

Answer 1

[techkuz]

rollback нужен, если у вас происходят изменения данных в БД на момент падения. В вашем коде в for loop идёт вставка элементов в лист (без связки с БД). Если и выпадет исключение SQLalchemy, то на момент выполнения all(), при получении элементов. Но тогда и rollback делать не на что будет, т.к. вы сами никаких изменений (другими словами set операций) не производите, только get.

Если вы хотите rollback, чтобы вернуть хоть часть элементов из all() запроса, то не получится, т.к. этот get выполняется один раз и возвращается сразу все элементы, поэтому он или завершится успешно, или упадёт с исключением (в случае последнего откатываться (=rollback) будет, опять же, некуда)