function.py 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. from connect import connect
  2. conn = connect()
  3. class MyQueryClass:
  4. def query_select(self, query, args=(), one=False):
  5. try:
  6. with conn.cursor() as cursor:
  7. cursor.execute(query, args)
  8. r = [dict((cursor.description[i][0], value) \
  9. for i, value in enumerate(row)) for row in cursor.fetchall()]
  10. return (r[0] if r else None) if one else r
  11. except:
  12. return False
  13. def query_insert(self, query, args=()):
  14. try:
  15. with conn.cursor() as cursor:
  16. cursor.execute(query, args)
  17. conn.commit()
  18. return cursor.fetchone()[0]
  19. except:
  20. return False
  21. def query_delete(self, query, args=()):
  22. try:
  23. with conn.cursor() as cursor:
  24. cursor.execute(query, args)
  25. if(cursor.rowcount != 0):
  26. conn.commit()
  27. return True
  28. return False
  29. except:
  30. return False
  31. def query_update(self, query, args=()):
  32. try:
  33. with conn.cursor() as cursor:
  34. cursor.execute(query, args)
  35. if(cursor.rowcount != 0):
  36. conn.commit()
  37. return True
  38. return False
  39. except:
  40. return False
  41. def query_proverka(self, query, args=()):
  42. try:
  43. with conn.cursor() as cursor:
  44. cursor.execute(query, args)
  45. if(cursor.rowcount > 0):
  46. return True
  47. return False
  48. except:
  49. return False