add_super_admin.py 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. import pymysql
  2. db_host = "rm-f8ze60yirdj8786u2wo.mysql.rds.aliyuncs.com"
  3. db_user = "root"
  4. db_pass = "csqz@20255"
  5. db_name = "csqz-client"
  6. def add_super_admin_column():
  7. try:
  8. conn = pymysql.connect(
  9. host=db_host,
  10. user=db_user,
  11. password=db_pass,
  12. db=db_name,
  13. port=3306,
  14. charset='utf8mb4'
  15. )
  16. cur = conn.cursor()
  17. # Check if column exists
  18. cur.execute("""
  19. SELECT COLUMN_NAME
  20. FROM INFORMATION_SCHEMA.COLUMNS
  21. WHERE TABLE_NAME = 'users' AND COLUMN_NAME = 'is_super_admin'
  22. """)
  23. if cur.fetchone():
  24. print("Column 'is_super_admin' already exists")
  25. else:
  26. # Add is_super_admin column with default 0
  27. cur.execute("""
  28. ALTER TABLE users
  29. ADD COLUMN is_super_admin TINYINT(1) DEFAULT 0 NOT NULL
  30. """)
  31. print("Added column 'is_super_admin'")
  32. # Set lihai and liuyue as super admins
  33. cur.execute("UPDATE users SET is_super_admin = 1 WHERE username IN ('linhai', 'liuyue')")
  34. affected = cur.rowcount
  35. print(f"Updated {affected} users as super admins")
  36. conn.commit()
  37. print("Operation complete.")
  38. return True
  39. except Exception as e:
  40. print(f"Error: {e}")
  41. return False
  42. finally:
  43. if 'conn' in locals() and conn.open:
  44. conn.close()
  45. if __name__ == "__main__":
  46. if add_super_admin_column():
  47. print("SUCCESS")
  48. else:
  49. import sys
  50. sys.exit(1)