alter_db_params.py 1.0 KB

123456789101112131415161718192021222324252627282930313233
  1. import mysql.connector
  2. from db import DB_CONFIG
  3. def alter_database():
  4. try:
  5. conn = mysql.connector.connect(**DB_CONFIG)
  6. cursor = conn.cursor()
  7. # Add original_params and color_name columns
  8. alter_queries = [
  9. "ALTER TABLE orders ADD COLUMN original_params JSON DEFAULT NULL AFTER updated_at",
  10. "ALTER TABLE orders ADD COLUMN color_name VARCHAR(100) DEFAULT NULL AFTER material_price"
  11. ]
  12. for query in alter_queries:
  13. try:
  14. cursor.execute(query)
  15. print(f"Executed: {query}")
  16. except mysql.connector.Error as e:
  17. print(f"Command error: {e}")
  18. conn.commit()
  19. print("Database migration completed successfully")
  20. except mysql.connector.Error as err:
  21. print(f"Error connecting to MySQL: {err}")
  22. finally:
  23. if 'conn' in locals() and conn.is_connected():
  24. cursor.close()
  25. conn.close()
  26. if __name__ == "__main__":
  27. alter_database()