i/Aether
1
0
Fork 0
mirror of https://github.com/fawney19/Aether.git synced 2026-09-02 01:10:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: 修复迁移脚本

Browse Source
This commit is contained in:
fawney19
2026-02-28 15:33:43 +08:00
parent 27047e5880
commit 9d751e3525
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
alembic/versions/20260228_1238_48afe197cc15_proxy_node_metrics_and_events.py
View File

@@ -50,10 +50,13 @@ def upgrade() -> None:
op.execute("UPDATE proxy_nodes SET status = 'offline' WHERE status = 'unhealthy'") op.execute("UPDATE proxy_nodes SET status = 'offline' WHERE status = 'unhealthy'")
op.execute("ALTER TYPE proxynodestatus RENAME TO proxynodestatus_old") op.execute("ALTER TYPE proxynodestatus RENAME TO proxynodestatus_old")
op.execute("CREATE TYPE proxynodestatus AS ENUM ('online', 'offline')") op.execute("CREATE TYPE proxynodestatus AS ENUM ('online', 'offline')")
# 必须先移除旧枚举类型的 DEFAULT，否则 ALTER TYPE 会因无法转换默认值而报错
op.execute("ALTER TABLE proxy_nodes ALTER COLUMN status DROP DEFAULT")
op.execute( op.execute(
"ALTER TABLE proxy_nodes ALTER COLUMN status TYPE proxynodestatus" "ALTER TABLE proxy_nodes ALTER COLUMN status TYPE proxynodestatus"
" USING status::text::proxynodestatus" " USING status::text::proxynodestatus"
) )
op.execute("ALTER TABLE proxy_nodes ALTER COLUMN status SET DEFAULT 'online'::proxynodestatus")
op.execute("DROP TYPE proxynodestatus_old") op.execute("DROP TYPE proxynodestatus_old")
# proxy_nodes: 新增错误指标字段 # proxy_nodes: 新增错误指标字段
@@ -130,10 +133,12 @@ def downgrade() -> None:
if not _enum_has_value("proxynodestatus", "unhealthy"): if not _enum_has_value("proxynodestatus", "unhealthy"):
op.execute("ALTER TYPE proxynodestatus RENAME TO proxynodestatus_old") op.execute("ALTER TYPE proxynodestatus RENAME TO proxynodestatus_old")
op.execute("CREATE TYPE proxynodestatus AS ENUM ('online', 'unhealthy', 'offline')") op.execute("CREATE TYPE proxynodestatus AS ENUM ('online', 'unhealthy', 'offline')")
op.execute("ALTER TABLE proxy_nodes ALTER COLUMN status DROP DEFAULT")
op.execute( op.execute(
"ALTER TABLE proxy_nodes ALTER COLUMN status TYPE proxynodestatus" "ALTER TABLE proxy_nodes ALTER COLUMN status TYPE proxynodestatus"
" USING status::text::proxynodestatus" " USING status::text::proxynodestatus"
) )
op.execute("ALTER TABLE proxy_nodes ALTER COLUMN status SET DEFAULT 'online'::proxynodestatus")
op.execute("DROP TYPE proxynodestatus_old") op.execute("DROP TYPE proxynodestatus_old")
if _table_exists("proxy_node_events"): if _table_exists("proxy_node_events"):