fix(ci): 修复CI rerun时数据库命名冲突问题

在CREATE DATABASE前先执行DROP DATABASE IF EXISTS WITH (FORCE)，防止rerun同一run_id时因数据库已存在而失败。影响：validate_migration.sh / run_integration_tests.sh / run_validate.sh
2026-07-22 17:43:48 +08:00
parent fde3ab3063
commit 34e5b18a30
3 changed files with 3 additions and 0 deletions
@@ -196,6 +196,7 @@ import psycopg2
 conn = psycopg2.connect(host='$SHARED_PG_HOST', port=$SHARED_PG_PORT, user='$SHARED_PG_USER', password='$SHARED_PG_PASSWORD', dbname='postgres')
 conn.autocommit = True
 cur = conn.cursor()
+cur.execute(f'DROP DATABASE IF EXISTS \"$CI_DB_NAME\" WITH (FORCE)')
 cur.execute(f'CREATE DATABASE \"$CI_DB_NAME\"')
 cur.close()
 conn.close()
@@ -408,6 +408,7 @@ import psycopg2
 conn = psycopg2.connect(host='$SHARED_PG_HOST', port=$SHARED_PG_PORT, user='$SHARED_PG_USER', password='$SHARED_PG_PASSWORD', dbname='postgres')
 conn.autocommit = True
 cur = conn.cursor()
+cur.execute(f'DROP DATABASE IF EXISTS \"$CI_DB_NAME\" WITH (FORCE)')
 cur.execute(f'CREATE DATABASE \"$CI_DB_NAME\"')
 cur.close()
 conn.close()
@@ -112,6 +112,7 @@ import psycopg2
 conn = psycopg2.connect(host='$SHARED_PG_HOST', port=$SHARED_PG_PORT, user='$SHARED_PG_USER', password='$SHARED_PG_PASSWORD', dbname='postgres')
 conn.autocommit = True
 cur = conn.cursor()
+cur.execute(f'DROP DATABASE IF EXISTS \"$CI_DB_NAME\" WITH (FORCE)')
 cur.execute(f'CREATE DATABASE \"$CI_DB_NAME\"')
 cur.close()
 conn.close()