Question

我尝试使用下面的代码：

from twisted.enterprise import adbapi 

    dbpool = adbapi.ConnectionPool(
         "MySQLdb", 
         db='test_db', 
         port='3306', 
         user='tester', 
         passwd='some_pass', 
         host='localhost', 
         cp_reconnect=True 
        ) 

    dbpool.runQuery("INSERT INTO `htp_test` VALUES(NULL, 25, 'test')") 

但数据不能在MySQL中插入，也没有显示任何错误。数据连接很好。

Answer 1

您需要启动反应器。 adbapi中的“a”用于“异步”，就像扭曲的其他所有内容一样。当你打电话给ConnectionPool.runQuery()时，你已经要求在后台进行一些工作，并且在完成后，给你在延期中由runQuery返回的那个动作的结果。

但是，为了扭曲“做”任何事情，您有义务启动其事件循环。在最简单的情况下，您可以：

from twisted.internet import reactor 
from twisted.enterprise import adbapi 

def got_result(value): 
    # do something, value won't be interesting on insert statements, though 
    print "Horray"  
    # since this is all we want to do, stop the reactor 
    reactor.stop() 

d = dbpool.runQuery("INSERT INTO `htp_test` VALUES(NULL, 25, 'test')") 
d.addCallback(got_result) 

reactor.run()