paramecio/parameciofm
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix in pymysql

Browse source
This commit is contained in:
Antonio de la Rosa 2018-01-21 03:39:02 +01:00
parent 6681286392
commit 3c6288a097
1 changed files with 14 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

19
paramecio/cromosoma/databases/pymysql.py
View file

@ -20,6 +20,7 @@ class SqlClass:
# Sql connection
self.conn=None
self.connected=False
self.pool_recycle=3600
def connect(self):
@ -34,9 +35,12 @@ class SqlClass:
cursorclass=pymysql.cursors.DictCursor)
if SqlClass.mypool==None:
SqlClass.mypool=pool.QueuePool(getconn, max_overflow=self.max_overflow, pool_size=self.pool_size)
SqlClass.mypool=pool.QueuePool(getconn, max_overflow=self.max_overflow, pool_size=self.pool_size, recycle=self.pool_recycle)
self.conn=SqlClass.mypool.connect()
while not self.conn.open:
self.conn=SqlClass.mypool.connect()
self.conn.ping(True)
@ -48,6 +52,8 @@ class SqlClass:
self.error_connection="Error in connection: %s %s" % (e, v)
self.conn.close()
raise NameError(self.error_connection)
@ -69,6 +75,7 @@ class SqlClass:
self.conn.commit()
return cursor
except:
e = sys.exc_info()[0]
@ -87,17 +94,19 @@ class SqlClass:
#def fetch(self, cursor):
#return cursor.fetchone()
"""
def __del__(self):
self.close()
"""
if self.conn:
self.conn.close()
def close(self, name_connection="default"):
if self.conn:
self.conn.close()
#self.conn=False
self.conn=None
pass