Add migrations to drop and rename prospect columns

app/api/prospects/sql/alter_drop_primary_email_verification_source.sql

@@ -0,0 +1,2 @@
+-- Migration: Remove primary_email_verification_source column from prospects table
+ALTER TABLE prospects DROP COLUMN IF EXISTS primary_email_verification_source;

app/api/prospects/sql/alter_rename_corporate_phone_to_phone.sql

@@ -0,0 +1,2 @@
+-- Migration: Rename corporate_phone column to phone in prospects table
+ALTER TABLE prospects RENAME COLUMN corporate_phone TO phone;

app/api/prospects/sql/run_alter_drop_primary_email_verification_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 DROP COLUMN IF EXISTS primary_email_verification_source;"
+    conn = get_db_connection_direct()
+    cur = conn.cursor()
+    cur.execute(sql)
+    conn.commit()
+    cur.close()
+    conn.close()
+    print("Migration complete: primary_email_verification_source column dropped from prospects table.")

app/api/prospects/sql/run_alter_rename_corporate_phone_to_phone.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 corporate_phone TO phone;"
+    conn = get_db_connection_direct()
+    cur = conn.cursor()
+    cur.execute(sql)
+    conn.commit()
+    cur.close()
+    conn.close()
+    print("Migration complete: corporate_phone column renamed to phone in prospects table.")