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.")