33 lines
1.1 KiB
Python
33 lines
1.1 KiB
Python
import os
|
|
import psycopg2
|
|
import glob
|
|
|
|
def apply_migrations():
|
|
conn_str = "postgres://postgres:123@152.53.120.181:55432/saveinmed"
|
|
try:
|
|
conn = psycopg2.connect(conn_str)
|
|
conn.autocommit = True
|
|
cur = conn.cursor()
|
|
|
|
# Pasta de migrations local
|
|
migration_dir = r"C:\dev\saveinmed\backend\internal\repository\postgres\migrations"
|
|
sql_files = sorted(glob.glob(os.path.join(migration_dir, "*.sql")))
|
|
|
|
for sql_file in sql_files:
|
|
print(f"Aplicando {os.path.basename(sql_file)}...")
|
|
with open(sql_file, 'r', encoding='utf-8') as f:
|
|
sql = f.read()
|
|
try:
|
|
cur.execute(sql)
|
|
print(f" OK: {os.path.basename(sql_file)}")
|
|
except Exception as e:
|
|
print(f" Erro em {os.path.basename(sql_file)}: {e}")
|
|
|
|
cur.close()
|
|
conn.close()
|
|
print("Migrações concluídas!")
|
|
except Exception as e:
|
|
print(f"Erro ao conectar: {e}")
|
|
|
|
if __name__ == "__main__":
|
|
apply_migrations()
|