4 
class MySQL(object):

    def __init__(self):
        self.dbpool = adbapi.ConnectionPool(
            'MySQLdb',
            db='dummy',
            user='root',
            passwd='',
            host = 'localhost',
            cp_reconnect = True,
            cursorclass=MySQLdb.cursors.DictCursor,
            charset='utf8',
            use_unicode=True
        )

    def process(self, item):
        query = self.dbpool.runInteraction(self.conditionalInsert, item).addErrback(self.handle_error)        
        return item


    def conditionalInsert(self, tx, item):
        tx.execute("INSERT INTO User (user_name) VALUES (%s)",(name))
        tx.execute("SELECT LAST_INSERT_ID()")
        lastID = getID(tx.fetchone())
        # DO SOMETHING USING lasID
        ...
        ...
    def handle_error(self, e):
        log.err(e)

我们下面第二行的lastID对应第一行的插入？或者它可能来自任何 runInteraction 线程？

    tx.execute("INSERT INTO User (user_name) VALUES (%s)",(name))
    tx.execute("SELECT LAST_INSERT_ID()")
4

1 回答 1

1

最后一个 id 将是同一事务中最后插入的行的 id。

我已经使用以下操作对其进行了测试：

  1. 使用 runInteraction(...) 函数开始事务并插入一行

  2. 获取最后一个插入 id，例如它是 18

  3. 在事务运行的函数中休眠 30 秒

  4. 使用 mysql 客户端或 phpMyAdmin 在同一个表中插入一行

  5. 从第 4 步获取最后一个插入 id，例如它是 19

  6. sleep函数返回并查询最后插入id再次使用同一个Transaction对象，最后插入id还是18

于 2016-02-27T08:57:36.977 回答