Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import mysql.connector
- import threading
- import time
- def updateA(conn, idd, data):
- conn.cursor().execute ("UPDATE A SET data=%s WHERE id=%s", (data, idd))
- #conn.cursor(buffered=True).execute ("SELECT * FROM A")
- def updateB(conn, idd, data):
- conn.cursor().execute ("UPDATE B SET data=%s WHERE id=%s", (data, idd))
- #conn.cursor(buffered=True).execute ("SELECT id FROM B")
- def zapros1():
- conn = mysql.connector.connect(host='127.0.0.1',database='ae.udnikov',user='ae.udnikov',password='ae.udnikov')
- print(conn.is_connected())
- updateA(conn, 1, 1)
- updateB(conn, 1, 2)
- print('allo')
- def zapros2():
- conn = mysql.connector.connect(host='127.0.0.1',database='ae.udnikov',user='ae.udnikov',password='ae.udnikov')
- print(conn.is_connected())
- updateB(conn, 1, 1)
- updateA(conn, 1, 5)
- print('allo2')
- t1 = threading.Thread(target=zapros1, args=())
- t2 = threading.Thread(target=zapros2, args=())
- t1.start()
- t2.start()
- t1.join()
- t2.join()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement