mirror/librenms-librenms
1
0
Fork 0
mirror of https://github.com/librenms/librenms.git synced 2024-10-07 16:52:45 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

close cursor after query

Browse Source
This commit is contained in:
Clint Armstrong
2015-09-09 09:20:03 -04:00
parent 201f516a76
commit 004111574a
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
poller-service.py
View File

@@ -61,23 +61,25 @@ class DB:
self.conn = MySQLdb.connect(host=db_server, port=db_port, user=db_username, passwd=db_password, db=db_dbname) self.conn = MySQLdb.connect(host=db_server, port=db_port, user=db_username, passwd=db_password, db=db_dbname)
break break
except (AttributeError, MySQLdb.OperationalError): except (AttributeError, MySQLdb.OperationalError):
log.warning('WARNING: MySQL Error during connect, reconnecting.') log.warning('WARNING: MySQL Error, reconnecting.')
time.sleep(.5) time.sleep(.5)
pass
self.conn.autocommit(True) self.conn.autocommit(True)
self.conn.ping(True) self.conn.ping(True)
def query(self, sql): def query(self, sql):
try: while True:
cursor = self.conn.cursor() try:
cursor.execute(sql) cursor = self.conn.cursor()
except (AttributeError, MySQLdb.OperationalError): cursor.execute(sql)
log.warning('WARNING: MySQL Error during query, reconnecting.') ret = cursor.fetchall()
self.connect() cursor.close()
cursor = self.conn.cursor() return ret
cursor.execute(sql) except (AttributeError, MySQLdb.OperationalError):
return cursor log.warning('WARNING: MySQL Operational Error during query, reconnecting.')
self.connect()
except (AttributeError, MySQLdb.ProgrammingError):
log.warning('WARNING: MySQL Programming Error during query, attempting query again.')
def get_config_data(): def get_config_data():