function.py 1.2 KB

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