MySQL транзакции и врапер, как организовать?

#!/usr/local/bin/python
# coding: utf-8
__author__ = 'spouk'
 
# да если честно . то весь день гугл шуршал но так и не понял как организовать. В тупую выполнить несколько запросов и потом выполнить коммит или ролбек это я сделал... все екзепшены и условия.
# Не могли бы Вы какой-то пример как для идиота привести?
# напрмер мне нужно реализовать следующее
# - добавление ордера в БД
# - далее беру номер ордера генерирую хеш, добавляю к в словарь с данными ордера (выходит в словаре + айди ордера и хеш)
# - далее шлю эту муть на сервер, на серваке сверяю все если проканало верну Тру если нет Фолс
# -далее в апликухе если пришел фолс то Ролбэк если Тру - коммит.
#
# Как это организовать если юзать враппер. У меня все методы для работы с бд вынесены в него и после каждого запроса на добавление или апдейт идет коммит. + в врапере обрабатываю исключения.
#
 
#  peewee - ORM ( враппер ) - для базы данных
#  flask - http-сервер в данном случае, для примера сессий
 
from flask import Flask, redirect, request, url_for, render_template, session
from peewee import MySQLDatabase, Model, PrimaryKeyField, TextField, DateTimeField, BooleanField, IntegerField
from datetime import datetime
from hashlib import md5
from wtforms import Form, StringField
from wtforms.validators import DataRequired
 
app=Flask(__name__)
 
app.secret_key ='simple secretkey'
 
#  определение секции для работы с базой данных
 
db = MySQLDatabase(
    database='test',
    threadlocals=True,
    autocommit=True,
    autorollback=False,
    user='user',
    passwd='user',
)
 
class Core(Model):
    class Meta:
        database = db
 
class OrderTable(Core):
    """ таблица с заказами """
    id = PrimaryKeyField()
    name_order = TextField()
    price = IntegerField(default=0)
    hash_order = TextField(default=None)
    count_order = IntegerField(default=0)
    create_time = DateTimeField(default=datetime.today())
 
    @classmethod
    def order_add_new(cls, name_order, price, count_order):
        """ добавляем новый заказик """
        new_order = OrderTable(
            name_order = name_order,
            price = price,
            hash_order = md5(name_order).hexdigest(),
            count_order = count_order,
        )
        new_order.save()
        return True
 
    @classmethod
    def order_check_exists(cls, name_order=None, order_id=None, hash_order=None):
        """проверка наличия такого заказа"""
        if name_order:
            return OrderTable.select().where(OrderTable.name_order == name_order).first()
        if hash_order:
            return OrderTable.select().where(OrderTable.hash_order == hash_order).first()
        if order_id:
            return OrderTable.select().where(OrderTable.id == order_id).first()
        return False
 
 
list_table = [Core, OrderTable]
 
def make_table(list_table):
    try:
        db.connect()
        db.create_tables(list_table)
    except:
        pass
 
make_table(list_table)
 
#  секция определения форм
#  по валидации, обработчики как правило пишутся тут, однако я для простоты и лучшего понимания оставил
# дефолтные общие, самый минимум
 
class OrderForm(Form):
    order_id = StringField(u'Номер заказа')
    name_order = StringField(u'Имя заказа')
 
class AddOrder(Form):
    name_order = StringField(u'Имя заказа', validators=[DataRequired()])
    price = StringField(u'Цена заказа', validators=[DataRequired()])
    count_order = StringField(u'Количество', validators=[DataRequired()])
 
 
#  секция обработчиков реквестов
@app.before_request
def reconnect():
    db.connect()
 
 
@app.route('/', methods=['GET'])
def root_get():
    form = OrderForm(request.form)
    return render_template('order.html',
                           form=form)
 
@app.route('/', methods=['POST'])
def root_post():
    form = OrderForm(request.form)
    if form.validate():
        order = OrderTable.order_check_exists(name_order=form.name_order.data)
        if order:
            print 'Bingo ==>', order.id, order.name_order, order.create_time
        else:
            print '--> Order not created <--'
    return redirect(url_for('root_get'))
 
@app.route('/add_order', methods=['GET'])
def root_order_add():
    form = AddOrder(request.form)
    return render_template('add_order.html',
                           form=form)
 
@app.route('/add_order', methods=['POST'])
def root_order_add_post():
    form = AddOrder(request.form)
    if form.validate():
        order = OrderTable.order_add_new(
            name_order=form.name_order.data,
            price=int(form.price.data),
            count_order=int(form.count_order.data),
        )
        if order:
            print '--> New order creating <--'
        else:
            print ' Found some errors in during make new order '
 
    return redirect(url_for('root_order_add'))
 
app.run(
    host='0.0.0.0',
    port=20000,
    debug=True
)