From f0a780fecb0e5799f6427cc89da8e5600edc71a2 Mon Sep 17 00:00:00 2001
From: zhaoqingang <zhaoqg0118@163.com>
Date: 星期五, 10 一月 2025 09:53:20 +0800
Subject: [PATCH] 节点返回错误日志
---
app/models/base_model.py | 21 +++++++++++++++++----
1 files changed, 17 insertions(+), 4 deletions(-)
diff --git a/app/models/base_model.py b/app/models/base_model.py
index 969c9c3..470f473 100644
--- a/app/models/base_model.py
+++ b/app/models/base_model.py
@@ -1,10 +1,12 @@
-from sqlalchemy import create_engine
+import os
+
+from sqlalchemy import create_engine, text
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker, Session
-
from app.config.config import settings
+# from app.models.agent_model import AgentModel
-DATABASE_URL = settings.database_url
+DATABASE_URL = os.getenv('DATABASE_URL') or settings.database_url
engine = create_engine(DATABASE_URL)
SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
@@ -14,6 +16,12 @@
# 鍒涘缓鎵�鏈夎〃锛堝鏋滄湁鏂扮殑妯″瀷绫伙紝浼氳嚜鍔ㄥ垱寤虹浉搴旂殑琛級
def init_db():
+ try:
+ sql = text('DROP TABLE IF EXISTS agent;')
+ engine.execute(sql)
+ except Exception as e:
+ print(e)
+
Base.metadata.create_all(bind=engine)
@@ -22,4 +30,9 @@
try:
yield db
finally:
- db.close()
\ No newline at end of file
+ db.close()
+
+
+# def drop_table():
+# sql = text('DROP TABLE IF EXISTS agent;')
+# engine.execute(sql)
\ No newline at end of file
--
Gitblit v1.8.0