Make sure to commit before vacuum
This commit is contained in:
parent
a9368bb3c8
commit
62a2ec7254
1 changed files with 2 additions and 2 deletions
|
@ -83,8 +83,6 @@ class DbCursor:
|
||||||
return query, params
|
return query, params
|
||||||
|
|
||||||
def execute(self, query, params=None):
|
def execute(self, query, params=None):
|
||||||
if query.upper().strip("; ") == "VACUUM":
|
|
||||||
self.db.commit("vacuum called")
|
|
||||||
query = query.strip()
|
query = query.strip()
|
||||||
while self.db.progress_sleeping or self.db.commiting:
|
while self.db.progress_sleeping or self.db.commiting:
|
||||||
time.sleep(0.1)
|
time.sleep(0.1)
|
||||||
|
@ -101,6 +99,8 @@ class DbCursor:
|
||||||
try:
|
try:
|
||||||
s = time.time()
|
s = time.time()
|
||||||
self.db.lock.acquire(True)
|
self.db.lock.acquire(True)
|
||||||
|
if query.upper().strip("; ") == "VACUUM":
|
||||||
|
self.db.commit("vacuum called")
|
||||||
if params:
|
if params:
|
||||||
res = cursor.execute(query, params)
|
res = cursor.execute(query, params)
|
||||||
else:
|
else:
|
||||||
|
|
Loading…
Reference in a new issue