sql.py 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. from datetime import datetime
  2. from application.config.common.mysql import MysqlHelper
  3. class Sql:
  4. """
  5. 修改用户名+头像
  6. """
  7. def update_name_url(self, mid, avatar_url, user_name):
  8. sql = f""" update xng_uid set avatar_url = "{avatar_url}", user_name="{user_name}" where uid = "{mid}"; """
  9. db = MysqlHelper()
  10. repeat_video = db.update(sql=sql)
  11. if repeat_video:
  12. return True
  13. return False
  14. """
  15. 插入 用户名 头像 用户id
  16. """
  17. def insert_name_url(self, uid, avatar_url, user_name):
  18. current_time = datetime.now()
  19. formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
  20. insert_sql = f"""INSERT INTO xng_uid (uid, avatar_url, user_name, data_time) values ('{uid}' ,'{avatar_url}','{user_name}', '{formatted_time}')"""
  21. db = MysqlHelper()
  22. repeat_video = db.update(sql=insert_sql)
  23. if repeat_video:
  24. return True
  25. return False
  26. """
  27. 查询用户id是否存在
  28. """
  29. def select_id(self, uid):
  30. sql = f""" select uid from xng_uid where uid = "{uid}"; """
  31. db = MysqlHelper()
  32. repeat_video = db.select(sql=sql)
  33. if repeat_video:
  34. return True
  35. return False
  36. """
  37. 查询用户id是否之前已添加过
  38. """
  39. def select_id_status(self, uid):
  40. sql = f""" select uid from crawler_user_v3 where link = "{uid}"; """
  41. db = MysqlHelper()
  42. repeat_video = db.select(sql=sql)
  43. if repeat_video:
  44. return False
  45. return True