From 9bc038c5ac692a30b0220892f9e17ee90b622f79 Mon Sep 17 00:00:00 2001 From: Wei Zang Date: Thu, 9 Apr 2026 08:58:46 +0100 Subject: [PATCH] Add migrations to rename prospects columns Add three SQL migration files and corresponding Python runner scripts under app/api/prospects/sql to rename columns on the prospects table. Renames: company_name -> company, primary_email_last_verified_at -> sell_by_date, and primary_email_source -> source. The Python scripts use app.utils.db.get_db_connection_direct to execute the ALTER TABLE statements and print a completion message. --- .../sql/alter_rename_company_name_to_company.sql | 2 ++ ...mary_email_last_verified_at_to_sell_by_date.sql | 2 ++ ...alter_rename_primary_email_source_to_source.sql | 2 ++ .../run_alter_rename_company_name_to_company.py | 14 ++++++++++++++ ...imary_email_last_verified_at_to_sell_by_date.py | 14 ++++++++++++++ ..._alter_rename_primary_email_source_to_source.py | 14 ++++++++++++++ 6 files changed, 48 insertions(+) create mode 100644 app/api/prospects/sql/alter_rename_company_name_to_company.sql create mode 100644 app/api/prospects/sql/alter_rename_primary_email_last_verified_at_to_sell_by_date.sql create mode 100644 app/api/prospects/sql/alter_rename_primary_email_source_to_source.sql create mode 100644 app/api/prospects/sql/run_alter_rename_company_name_to_company.py create mode 100644 app/api/prospects/sql/run_alter_rename_primary_email_last_verified_at_to_sell_by_date.py create mode 100644 app/api/prospects/sql/run_alter_rename_primary_email_source_to_source.py diff --git a/app/api/prospects/sql/alter_rename_company_name_to_company.sql b/app/api/prospects/sql/alter_rename_company_name_to_company.sql new file mode 100644 index 0000000..cf0c871 --- /dev/null +++ b/app/api/prospects/sql/alter_rename_company_name_to_company.sql @@ -0,0 +1,2 @@ +-- Migration: Rename company_name column to company in prospects table +ALTER TABLE prospects RENAME COLUMN company_name TO company; \ No newline at end of file diff --git a/app/api/prospects/sql/alter_rename_primary_email_last_verified_at_to_sell_by_date.sql b/app/api/prospects/sql/alter_rename_primary_email_last_verified_at_to_sell_by_date.sql new file mode 100644 index 0000000..0ad5b71 --- /dev/null +++ b/app/api/prospects/sql/alter_rename_primary_email_last_verified_at_to_sell_by_date.sql @@ -0,0 +1,2 @@ +-- Migration: Rename primary_email_last_verified_at column to sell_by_date in prospects table +ALTER TABLE prospects RENAME COLUMN primary_email_last_verified_at TO sell_by_date; \ No newline at end of file diff --git a/app/api/prospects/sql/alter_rename_primary_email_source_to_source.sql b/app/api/prospects/sql/alter_rename_primary_email_source_to_source.sql new file mode 100644 index 0000000..7e01ea9 --- /dev/null +++ b/app/api/prospects/sql/alter_rename_primary_email_source_to_source.sql @@ -0,0 +1,2 @@ +-- Migration: Rename primary_email_source column to source in prospects table +ALTER TABLE prospects RENAME COLUMN primary_email_source TO source; \ No newline at end of file diff --git a/app/api/prospects/sql/run_alter_rename_company_name_to_company.py b/app/api/prospects/sql/run_alter_rename_company_name_to_company.py new file mode 100644 index 0000000..5e837e3 --- /dev/null +++ b/app/api/prospects/sql/run_alter_rename_company_name_to_company.py @@ -0,0 +1,14 @@ +import os +import sys +sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '../../../..'))) +from app.utils.db import get_db_connection_direct + +if __name__ == "__main__": + sql = "ALTER TABLE prospects RENAME COLUMN company_name TO company;" + conn = get_db_connection_direct() + cur = conn.cursor() + cur.execute(sql) + conn.commit() + cur.close() + conn.close() + print("Migration complete: company_name column renamed to company in prospects table.") diff --git a/app/api/prospects/sql/run_alter_rename_primary_email_last_verified_at_to_sell_by_date.py b/app/api/prospects/sql/run_alter_rename_primary_email_last_verified_at_to_sell_by_date.py new file mode 100644 index 0000000..7029d3b --- /dev/null +++ b/app/api/prospects/sql/run_alter_rename_primary_email_last_verified_at_to_sell_by_date.py @@ -0,0 +1,14 @@ +import os +import sys +sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '../../../..'))) +from app.utils.db import get_db_connection_direct + +if __name__ == "__main__": + sql = "ALTER TABLE prospects RENAME COLUMN primary_email_last_verified_at TO sell_by_date;" + conn = get_db_connection_direct() + cur = conn.cursor() + cur.execute(sql) + conn.commit() + cur.close() + conn.close() + print("Migration complete: primary_email_last_verified_at column renamed to sell_by_date in prospects table.") diff --git a/app/api/prospects/sql/run_alter_rename_primary_email_source_to_source.py b/app/api/prospects/sql/run_alter_rename_primary_email_source_to_source.py new file mode 100644 index 0000000..5f63d4f --- /dev/null +++ b/app/api/prospects/sql/run_alter_rename_primary_email_source_to_source.py @@ -0,0 +1,14 @@ +import os +import sys +sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '../../../..'))) +from app.utils.db import get_db_connection_direct + +if __name__ == "__main__": + sql = "ALTER TABLE prospects RENAME COLUMN primary_email_source TO source;" + conn = get_db_connection_direct() + cur = conn.cursor() + cur.execute(sql) + conn.commit() + cur.close() + conn.close() + print("Migration complete: primary_email_source column renamed to source in prospects table.")