Fixes in close mysql connections
This commit is contained in:
parent
46a58d0bc9
commit
6c437d4cac
3 changed files with 27 additions and 2 deletions
|
|
@ -13,4 +13,11 @@ except:
|
||||||
|
|
||||||
|
|
||||||
def get_session():
|
def get_session():
|
||||||
|
|
||||||
|
try:
|
||||||
|
|
||||||
return request.environ.get(config.cookie_name)
|
return request.environ.get(config.cookie_name)
|
||||||
|
|
||||||
|
except:
|
||||||
|
|
||||||
|
return {}
|
||||||
|
|
|
||||||
|
|
@ -184,9 +184,14 @@ class WebModel:
|
||||||
|
|
||||||
self.last_id=cursor.lastrowid
|
self.last_id=cursor.lastrowid
|
||||||
|
|
||||||
|
cursor.close()
|
||||||
|
|
||||||
return True
|
return True
|
||||||
else:
|
else:
|
||||||
self.query_error='Cannot insert the new row'
|
self.query_error='Cannot insert the new row'
|
||||||
|
|
||||||
|
cursor.close()
|
||||||
|
|
||||||
return False
|
return False
|
||||||
|
|
||||||
# Update method. For update one or many rows.
|
# Update method. For update one or many rows.
|
||||||
|
|
@ -223,6 +228,8 @@ class WebModel:
|
||||||
if self.yes_reset_conditions:
|
if self.yes_reset_conditions:
|
||||||
self.reset_conditions()
|
self.reset_conditions()
|
||||||
|
|
||||||
|
cursor.close()
|
||||||
|
|
||||||
return True
|
return True
|
||||||
|
|
||||||
"""
|
"""
|
||||||
|
|
@ -339,6 +346,7 @@ class WebModel:
|
||||||
|
|
||||||
if cursor==False:
|
if cursor==False:
|
||||||
self.query_error=SqlClass.error_connection
|
self.query_error=SqlClass.error_connection
|
||||||
|
cursor.close()
|
||||||
return False
|
return False
|
||||||
else:
|
else:
|
||||||
return cursor
|
return cursor
|
||||||
|
|
@ -385,6 +393,8 @@ class WebModel:
|
||||||
if row==None:
|
if row==None:
|
||||||
row=False
|
row=False
|
||||||
|
|
||||||
|
cursor.close()
|
||||||
|
|
||||||
return row
|
return row
|
||||||
|
|
||||||
def select_a_row_where(self, fields_selected=[], raw_query=0):
|
def select_a_row_where(self, fields_selected=[], raw_query=0):
|
||||||
|
|
@ -398,6 +408,8 @@ class WebModel:
|
||||||
if row==None:
|
if row==None:
|
||||||
row=False
|
row=False
|
||||||
|
|
||||||
|
cursor.close()
|
||||||
|
|
||||||
return row
|
return row
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -423,6 +435,8 @@ class WebModel:
|
||||||
results[row[self.name_field_id]]=row
|
results[row[self.name_field_id]]=row
|
||||||
del_row_id(results[row[self.name_field_id]])
|
del_row_id(results[row[self.name_field_id]])
|
||||||
|
|
||||||
|
cursor.close()
|
||||||
|
|
||||||
return results
|
return results
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -467,6 +481,8 @@ class WebModel:
|
||||||
if self.yes_reset_conditions:
|
if self.yes_reset_conditions:
|
||||||
self.reset_conditions()
|
self.reset_conditions()
|
||||||
|
|
||||||
|
cursor.close()
|
||||||
|
|
||||||
return count
|
return count
|
||||||
|
|
||||||
#+' ORDER BY '+self.order_by+' '+self.limit).strip()
|
#+' ORDER BY '+self.order_by+' '+self.limit).strip()
|
||||||
|
|
@ -488,9 +504,11 @@ class WebModel:
|
||||||
|
|
||||||
if result.rowcount>0:
|
if result.rowcount>0:
|
||||||
|
|
||||||
|
result.close()
|
||||||
return True
|
return True
|
||||||
else:
|
else:
|
||||||
|
|
||||||
|
result.close()
|
||||||
return False
|
return False
|
||||||
|
|
||||||
def set_conditions(self, sql_text, values:list) -> None:
|
def set_conditions(self, sql_text, values:list) -> None:
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue