Guest User

Untitled

a guest
May 18th, 2017
29
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.00 KB | None | 0 0
  1. import mysql.connector
  2. import threading
  3. import time
  4.  
  5. def updateA(conn, idd, data):
  6. conn.cursor().execute ("UPDATE A SET data=%s WHERE id=%s", (data, idd))
  7. #conn.cursor(buffered=True).execute ("SELECT * FROM A")
  8.  
  9. def updateB(conn, idd, data):
  10. conn.cursor().execute ("UPDATE B SET data=%s WHERE id=%s", (data, idd))
  11. #conn.cursor(buffered=True).execute ("SELECT id FROM B")
  12.  
  13. def zapros1():
  14. conn = mysql.connector.connect(host='127.0.0.1',database='ae.udnikov',user='ae.udnikov',password='ae.udnikov')
  15. print(conn.is_connected())
  16. updateA(conn, 1, 1)
  17. updateB(conn, 1, 2)
  18. print('allo')
  19.  
  20. def zapros2():
  21. conn = mysql.connector.connect(host='127.0.0.1',database='ae.udnikov',user='ae.udnikov',password='ae.udnikov')
  22. print(conn.is_connected())
  23. updateB(conn, 1, 1)
  24. updateA(conn, 1, 5)
  25. print('allo2')
  26.  
  27. t1 = threading.Thread(target=zapros1, args=())
  28. t2 = threading.Thread(target=zapros2, args=())
  29.  
  30. t1.start()
  31. t2.start()
  32.  
  33. t1.join()
  34. t2.join()
Add Comment
Please, Sign In to add comment