Add scripts to drop deprecated prospect columns

Add four standalone Python migration scripts to remove deprecated columns from the prospects table: do_not_call, email_confidence, home_phone, and work_direct_phone. Each script uses get_db_connection_direct to execute an ALTER TABLE ... DROP COLUMN IF EXISTS statement, commits the change, closes the DB connection, and prints a completion message. The DROP COLUMN IF EXISTS makes the scripts safe to run idempotently.

Author: goldlabelapps

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

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

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

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