fix 部分数据库操作没有Commit

app/db/__init__.py

@@ -8,8 +8,9 @@ Engine = create_engine(f"sqlite:///{settings.CONFIG_PATH}/user.db",
                        pool_pre_ping=True,
                        echo=False,
                        poolclass=QueuePool,
-                       pool_size=1000,
+                       pool_size=1024,
-                       pool_recycle=60 * 10,
+                       pool_recycle=600,
+                       pool_timeout=180,
                        max_overflow=0)
 # 会话工厂
 SessionFactory = sessionmaker(autocommit=False, autoflush=False, bind=Engine)
@@ -33,7 +34,6 @@ def get_db():
 
 
 class DbOper:
-
     _db: Session = None
 
     def __init__(self, db: Session = None):

app/db/models/downloadhistory.py

@@ -130,9 +130,10 @@ class DownloadFiles(Base):
 
     @staticmethod
     def delete_by_fullpath(db: Session, fullpath: str):
-        return db.query(DownloadFiles).filter(DownloadFiles.fullpath == fullpath,
+        db.query(DownloadFiles).filter(DownloadFiles.fullpath == fullpath,
-                                              DownloadFiles.state == 1).update(
+                                       DownloadFiles.state == 1).update(
             {
                 "state": 0
             }
         )
+        db.commit()

app/db/models/plugin.py

@@ -23,7 +23,8 @@ class PluginData(Base):
 
     @staticmethod
     def del_plugin_data_by_key(db: Session, plugin_id: str, key: str):
-        return db.query(PluginData).filter(PluginData.plugin_id == plugin_id, PluginData.key == key).delete()
+        db.query(PluginData).filter(PluginData.plugin_id == plugin_id, PluginData.key == key).delete()
+        db.commit()
 
     @staticmethod
     def get_plugin_data_by_plugin_id(db: Session, plugin_id: str):

app/db/models/transferhistory.py

@@ -122,3 +122,4 @@ class TransferHistory(Base):
                 "download_hash": download_hash
             }
         )
+        db.commit()