database.py 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. import mysql.connector
  2. from bot import config as conf
  3. class Database:
  4. def __init__(self):
  5. self.connection = mysql.connector.connect(host=conf.DB_HOST,
  6. user=conf.DB_USER,
  7. password=conf.DB_PASS,
  8. database=conf.DB_NAME)
  9. self.cursor = self.connection.cursor(dictionary=True)
  10. def cursor(self):
  11. return self.cursor
  12. def commit(self):
  13. self.connection.commit()
  14. def close(self, commit=True):
  15. if commit:
  16. self.commit()
  17. self.connection.close()
  18. def fetchone(self):
  19. return self.cursor.fetchone()
  20. def fetchall(self):
  21. return self.cursor.fetchall()
  22. def execute(self, sql, params=None):
  23. return self.cursor.execute(sql, params or ())
  24. def sql_fetchone(self, sql: str):
  25. self.execute(sql)
  26. response = self.fetchone()
  27. if response is None:
  28. return False
  29. else:
  30. for v in response.values():
  31. return v
  32. def sql_fetchall(self, sql: str):
  33. self.execute(sql)
  34. result_set = self.fetchall()
  35. return result_set
  36. def sql_query_send(self, sql: str):
  37. self.execute(sql)
  38. self.commit()
  39. self.close()
  40. def sql_parse_users(self, sql: str):
  41. self.execute(sql)
  42. result_set = self.fetchall()
  43. users_list = []
  44. if len(result_set) == 0:
  45. return False
  46. elif len(result_set) > 0:
  47. for row in result_set:
  48. users_data = {"ID": row['id'], "ФИО": row['name'], "Номер телефона": row['phone']}
  49. users_list.append(users_data)
  50. return users_list
  51. def sql_parse_user_events(self, sql: str):
  52. self.execute(sql)
  53. result_set = self.fetchall()
  54. events_list = []
  55. if len(result_set) == 0:
  56. return False
  57. elif len(result_set) > 0:
  58. for row in result_set:
  59. event_data = f"Описание {row['description']}\n Дата {row['dat']}"
  60. events_list.append(event_data)
  61. return events_list