更新数据库操作逻辑

ZhiqiKou · Nov 8, 2017 · 0184045 · 0184045
1 parent 5af0982
commit 0184045
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/豆瓣影评/锤神3/stroe.py b/豆瓣影评/锤神3/stroe.py
@@ -63,6 +63,8 @@ def save_one_data(self, table, data,):
         except:
             print('数据库保存错误')
             return -1
+        finally:
+            self.close()
 
     def find_all(self, table, limit):
         '''
@@ -83,6 +85,8 @@ def find_all(self, table, limit):
         except:
             print('数据查询存错误')
             return -1
+        finally:
+            self.close()
 
     def find_by_field(self, table, field, field_value):
         '''
@@ -105,6 +109,8 @@ def find_by_field(self, table, field, field_value):
         except:
             print('数据查询存错误')
             return -1
+        finally:
+            self.close()
 
     def find_by_fields(self, table, queryset={}):
         '''
@@ -124,13 +130,15 @@ def find_by_fields(self, table, queryset={}):
                     querrys += "{} = '{}' and ".format(k, v)
                 sql = "select * from {} where {} ".format(
                     table, querrys[:-4])
-                print(sql)
                 cursor.execute(sql)
                 res = cursor.fetchall()
                 return res
         except:
             print('数据查询存错误')
             return -1
+        finally:
+            self.close()
+
 
     def find_by_sort(self, table, field, limit=1000, order='DESC'):
         '''
@@ -154,3 +162,5 @@ def find_by_sort(self, table, field, limit=1000, order='DESC'):
         except:
             print('数据查询存错误')
             return -1
+        finally:
+            self.close()