fix_users_table.py 1.1 KB

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