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

Fixes in mysql

Browse source
This commit is contained in:
Antonio de la Rosa 2018-02-09 21:14:03 +01:00
parent 1d03a6b772
commit de25da3773
1 changed files with 9 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

15
paramecio/cromosoma/databases/mysqldb.py
View file

@ -5,14 +5,14 @@ import MySQLdb.cursors
import sqlalchemy.pool as pool import sqlalchemy.pool as pool
import traceback import traceback
class SqlClass:
mypool=None mypool=None
class SqlClass:
def __init__(self, connection): def __init__(self, connection):
self.max_overflow=-1 self.max_overflow=-1
self.pool_size=0 self.pool_size=25
self.error_connection="" self.error_connection=""
# Data of connection # Data of connection
self.connection=connection self.connection=connection
@ -23,6 +23,8 @@ class SqlClass:
def connect(self): def connect(self):
global mypool
if self.conn==None: if self.conn==None:
try: try:
def getconn(): def getconn():
@ -33,10 +35,11 @@ class SqlClass:
charset='utf8mb4', charset='utf8mb4',
cursorclass=MySQLdb.cursors.DictCursor) cursorclass=MySQLdb.cursors.DictCursor)
if SqlClass.mypool==None: if mypool==None:
SqlClass.mypool=pool.QueuePool(getconn, max_overflow=self.max_overflow, pool_size=self.pool_size, recycle=self.pool_recycle)
self.conn=SqlClass.mypool.connect() mypool=pool.QueuePool(getconn, max_overflow=self.max_overflow, pool_size=self.pool_size, recycle=self.pool_recycle, use_threadlocal=False)
self.conn=mypool.connect()
self.conn.ping(True) self.conn.ping(True)