Python MySQLdb pusty kwerenda wybierająca natomiast ręczne wykonanie kwerendy dostarcza wyniki

Question

Pisałem demona Pythona, który nieustannie sonduje bazy danych MySQL. To działa dobrze, kiedy ciągły łączyć się i ponownie połączyć się z bazą danych między zapytaniami następująco:

def connect(self): 
    self.connection = MySQLdb.connect(...) 
    self.cursor = self.connection.cursor() 
    return self.cursor 

def disconnect(self): ... 
    self.cursor.close() 
    self.connection.close() 

def getData(); .... 
    sqlcmd = """SELECT ....""" 
    self.cursor.execute (sqlcmd % (params)) 
    result = self.cursor.fetchall() 
    return result 

if __name__ == "__main__": 
    db = prepaid_db.Database() 
    while 1: 
     dbConnection = db.connect() 
     data = db.getData() 
     ... do stuff 
     db.disconnect 

Ale gdy próbuję utrzymać połączenie z bazą danych open (jak poniżej) pojawia się pusty zapytanie, chociaż, gdy jest Uruchamianie Mogę wykonać zapytanie do bazy danych ręcznie, podać to samo zapytanie i uzyskać wynik, którego oczekuję.

if __name__ == "__main__": 
    db = prepaid_db.Database() 
    dbConnection = db.connect() 
    while 1: 
     data = db.getData() 
     ... do stuff 
    db.disconnect 

Próbowałem wszystkiego, aby zrozumieć, dlaczego miałby to zrobić:

• cache zapytań niepełnosprawnych i dodaje losowe X = x do zapytania w sprawie mysql cache był zdezorientowany podobnych zapytań
• włączone rejestrowanie zapytań mysql: zapytanie przychodzi, ale nadal zwraca pusty zestaw
• przeniesione cursor.connect do database.connect iz powrotem do getData(), bez różnicy

Chciałbym wskazówkę, czego nie rozumiem.

Answer 1

Pewnie zapytań tabelę InnoDB, gdzie inny proces wstawia nowe dane w międzyczasie. Jeśli tak jest, MySQL zerwać automatycznie rozpoczyna nową transakcję połączenia, a ponieważ nie nazywają dbConnection.commit() lub .rollback() wszędzie, jesteś zawsze tkwi w tej transakcji. Domyślne ustawienia InnoDB gwarantują, że za każdym razem, gdy będziesz wyszukiwać dane, zawsze zobaczysz ten sam wynik w ramach jednej transakcji. A więc to, co jakiś inny proces wstawia do tabeli, jest ukryte przed połączeniem demona.

Rozwiązanie jest proste: zamiast dzwonić pod numer db.disconnect(), należy zadzwonić pod numer dbConnection.commit(), który kończy bieżące połączenie i rozpoczyna nową transakcję.

Answer 2

MySQLdb.cursor przedmiot prawdopodobnie nie obsługują popełnić jak podano w MySQLDB manual. Z drugiej strony, obiekty połączeń.

Od obsługiwać wszystko przez klasy Database, myślę kod popełnić można tam iść.

Wystarczy podać kod co Simon powiedział

def connect(self): 
     self.connection = MySQLdb.connect(...) 
     self.cursor = self.connection.cursor() 

    def disconnect(self): ... 
     self.cursor.close() 
     self.connection.commit() 
     self.connection.close() 

    def commit(self): 
     self.connection.commit() 

    def getData(self): .... 
     sqlcmd = """SELECT ....""" 
     self.cursor.execute (sqlcmd % (params)) 
     result = self.cursor.fetchall() 
     return result 

if __name__ == "__main__": 
    db = prepaid_db.Database() 
    db.connect() 
    while 1: 
     data = db.getData() 
     ... do stuff 
     db.commit() 
    db.disconnect() 

Nie jestem pewien, ale prawdopodobnie można też zrobić coś podobnego

db.connection.commit() 

w pętli while zamiast dzwonić nowo zdefiniowana funkcja