Add prospects table migrations and runners

Add SQL migration files and small runner scripts to modify the prospects table. New SQL files drop columns other_photne, subsidiary_of, and subsidiary_of_organization_id, and rename sub_departments and two variants of the person LinkedIn column to linkedin. Corresponding Python runners (using app.utils.db.get_db_connection_direct) execute each ALTER statement and commit the change. Note: both spelled variants of the LinkedIn column and a misspelled other_photne file are included to handle existing inconsistencies.

Author: goldlabelapps

app/api/prospects/sql/alter_drop_other_photne.sql

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

app/api/prospects/sql/alter_drop_subsidiary_of.sql

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

app/api/prospects/sql/alter_drop_subsidiary_of_organization_id.sql

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

app/api/prospects/sql/alter_rename_person_linkinkedin_url_to_linkedin.sql

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

app/api/prospects/sql/alter_rename_sub_departments_to_department.sql

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

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

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

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

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

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