tornado_mysql事务_tornado_mysql的pool使用事务的方法。

在使用`tornado_mysql`的连接池时，可以使用以下代码来执行事务:

import tornado.ioloop
import tornado.web
import tornado.gen
import tornado_mysql

class MainHandler(tornado.web.RequestHandler):
    async def get(self):
        db = self.application.db
        async with db.pool.acquire() as conn:
            async with conn.cursor() as cur:
                try:
                    await cur.execute("START TRANSACTION")
                    await cur.execute("INSERT INTO table_name (column1, column2) VALUES (%s, %s)", (value1, value2))
                    await cur.execute("UPDATE table_name SET column3 = %s WHERE id = %s", (value3, id))
                    await cur.execute("COMMIT")
                    self.write("Transaction completed successfully!")
                except:
                    await cur.execute("ROLLBACK")
                    self.write("Transaction failed")

class Application(tornado.web.Application):
    def __init__(self):
        handlers = [
            (r"/", MainHandler),
        ]
        self.db = tornado_mysql.Pool(
            dict(host='localhost', port=3306, user='root', passwd='password', db='database_name'),
            max_size=10,
            autocommit=True
        )
        super(Application, self).__init__(handlers)

if __name__ == "__main__":
    app = Application()
    app.listen(8888)
    tornado.ioloop.IOLoop.current().start()

在上述代码中，我们首先创建了一个`Pool`对象，它包含了数据库的连接参数和连接池的最大连接数。然后，在我们的请求处理程序中，我们通过`pool.acquire()`方法获取一个连接。我们使用`async with`来确保在完成事务后自动释放该连接。

在使用的连接上创建一个`cursor`来执行事务中的SQL语句。在使用`try/except`块执行SQL语句时，如果任何一个语句失败，我们将立即回滚整个事务。如果所有语句都成功执行，则提交事务。

总之，使用`tornado_mysql`的连接池和事务非常简单，只需要在您的代码中添加一些额外的异步语句即可。