Add prospect migrations: name & drop phones

Add SQL migrations to modify the prospects table: add a nullable name column and populate it from first_name + last_name, and remove mobile_phone and other_phone columns. Include Python runner scripts that execute these migrations using app.utils.db.get_db_connection_direct. SQL uses IF NOT EXISTS / IF EXISTS to make the changes idempotent.

Author: goldlabelapps

app/api/prospects/sql/alter_add_name_and_populate.sql

@@ -0,0 +1,3 @@
+-- Migration: Add name column and populate with first_name + ' ' + last_name
+ALTER TABLE prospects ADD COLUMN IF NOT EXISTS name TEXT;
+UPDATE prospects SET name = CONCAT_WS(' ', first_name, last_name);

app/api/prospects/sql/alter_drop_mobile_phone.sql

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

app/api/prospects/sql/alter_drop_other_phone.sql

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

app/api/prospects/sql/run_alter_add_name_and_populate.py

@@ -0,0 +1,17 @@
+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 ADD COLUMN IF NOT EXISTS name TEXT;
+    UPDATE prospects SET name = CONCAT_WS(' ', first_name, last_name);
+    """
+    conn = get_db_connection_direct()
+    cur = conn.cursor()
+    cur.execute(sql)
+    conn.commit()
+    cur.close()
+    conn.close()
+    print("Migration complete: name column added and populated in prospects table.")

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

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