Advertisement
Guest User

Untitled

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