| 12345678910111213141516171819202122232425262728293031323334353637 |
- import mysql.connector
- from db import DB_CONFIG
- def update_schema():
- try:
- conn = mysql.connector.connect(**DB_CONFIG)
- cursor = conn.cursor()
-
- # Add columns if they don't exist
- columns_to_add = [
- ("first_name", "VARCHAR(100)"),
- ("last_name", "VARCHAR(100)"),
- ("phone", "VARCHAR(20)"),
- ("shipping_address", "TEXT")
- ]
-
- for col_name, col_type in columns_to_add:
- try:
- cursor.execute(f"ALTER TABLE users ADD COLUMN {col_name} {col_type};")
- except mysql.connector.Error as e:
- if e.errno == 1060: # Column already exists
- print(f"Column {col_name} already exists")
- else:
- print(f"Error adding {col_name}: {e}")
-
- conn.commit()
- print("Schema updated successfully")
-
- except mysql.connector.Error as err:
- print(f"Error: {err}")
- finally:
- if 'conn' in locals() and conn.is_connected():
- cursor.close()
- conn.close()
- if __name__ == "__main__":
- update_schema()
|