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()