tmp_update_schema.py 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637
  1. import mysql.connector
  2. from db import DB_CONFIG
  3. def update_schema():
  4. try:
  5. conn = mysql.connector.connect(**DB_CONFIG)
  6. cursor = conn.cursor()
  7. # Add columns if they don't exist
  8. columns_to_add = [
  9. ("first_name", "VARCHAR(100)"),
  10. ("last_name", "VARCHAR(100)"),
  11. ("phone", "VARCHAR(20)"),
  12. ("shipping_address", "TEXT")
  13. ]
  14. for col_name, col_type in columns_to_add:
  15. try:
  16. cursor.execute(f"ALTER TABLE users ADD COLUMN {col_name} {col_type};")
  17. except mysql.connector.Error as e:
  18. if e.errno == 1060: # Column already exists
  19. print(f"Column {col_name} already exists")
  20. else:
  21. print(f"Error adding {col_name}: {e}")
  22. conn.commit()
  23. print("Schema updated successfully")
  24. except mysql.connector.Error as err:
  25. print(f"Error: {err}")
  26. finally:
  27. if 'conn' in locals() and conn.is_connected():
  28. cursor.close()
  29. conn.close()
  30. if __name__ == "__main__":
  31. update_schema()