diff --git a/warden3/warden_server/warden_server.py b/warden3/warden_server/warden_server.py index 1caa425b7ba8592e8b811cda59f862a7d66dbd1b..2c38a36df9c3686e45ea42c5a96f7bd410420dda 100755 --- a/warden3/warden_server/warden_server.py +++ b/warden3/warden_server/warden_server.py @@ -561,12 +561,13 @@ class MySQL(ObjectReq): def insertLastReceivedId(self, client, id): logging.debug("insertLastReceivedId: id %i for client %i(%s)" % (id, client.id, client.hostname)) self.crs.execute("INSERT INTO last_events(client_id, event_id, timestamp) VALUES(%s, %s, NOW())", (client.id, id)) + self.con.commit() def getLastEventId(self): self.crs.execute("SELECT MAX(id) as id FROM events") row = self.crs.fetchone() - return row['id'] if row['id'] is not None else 0 + return row['id'] or 0 def getLastReceivedId(self, client): self.crs.execute("SELECT MAX(event_id) as id FROM last_events WHERE client_id = %s", client.id)