Commit f116fc37 authored by 金凯强's avatar 金凯强 🎨

修复事务不回滚问题

parent f51931ee
...@@ -48,14 +48,14 @@ class DBDriver: ...@@ -48,14 +48,14 @@ class DBDriver:
def cerateDB(self): def cerateDB(self):
self.conn = sqlite3.connect(self.dbfile) self.conn = sqlite3.connect(self.dbfile)
self.conn.isolation_level = None # self.conn.isolation_level = None
for create_table_sql in create_table_sql_list: for create_table_sql in create_table_sql_list:
self.conn.execute(create_table_sql) ####create new table self.conn.execute(create_table_sql) ####create new table
return return
def execDB(self, execsql): def execDB(self, execsql):
self.conn.execute(execsql) self.conn.execute(execsql)
self.conn.commit() # self.conn.commit()
return return
def exec_sql(self, sql, *args, **kwargs): def exec_sql(self, sql, *args, **kwargs):
...@@ -71,7 +71,7 @@ class DBDriver: ...@@ -71,7 +71,7 @@ class DBDriver:
return res return res
res_dict = dict(map(lambda x, y: [x, y], fields, res)) res_dict = dict(map(lambda x, y: [x, y], fields, res))
cur.close()
return res_dict return res_dict
def query_sql(self, sql, *args, **kwargs): def query_sql(self, sql, *args, **kwargs):
...@@ -82,7 +82,7 @@ class DBDriver: ...@@ -82,7 +82,7 @@ class DBDriver:
for r in res: for r in res:
res_dict = OrderedDict(map(lambda x, y: [x, y], fields, r)) res_dict = OrderedDict(map(lambda x, y: [x, y], fields, r))
res_list.append(res_dict) res_list.append(res_dict)
cur.close()
return res_list return res_list
def __enter__(self): def __enter__(self):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment