Skip to content

Commit 03de421

Browse files
committed
chore: add delete all db
1 parent ddf95da commit 03de421

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

src/db/conn.py

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,13 @@ def get_all_reserve_for_fixing_queue():
9797
db.close()
9898
return result
9999

100+
def delete_all_queue():
101+
db = connect()
102+
cursor = db.cursor()
103+
cursor.execute("delete from upload_queue;")
104+
db.commit()
105+
db.close()
106+
100107
if __name__ == "__main__":
101108
# Create Table
102109
# create_table()
@@ -113,4 +120,6 @@ def get_all_reserve_for_fixing_queue():
113120
# Delete the upload queue
114121
# delete_upload_queue('')
115122
# Get the single upload queue after delete, should be None
116-
print(get_single_upload_queue())
123+
# print(get_single_upload_queue())
124+
# Delete all queue
125+
delete_all_queue()

0 commit comments

Comments
 (0)