Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import mysql.connector
- import threading
- import time
- def updateA(conn, data, idd):
- cursor = conn.cursor()
- cursor.execute ("UPDATE A SET data=%s WHERE id=%s", (data, idd))
- conn.commit()
- def updateB(conn, data, idd):
- cursor = conn.cursor()
- cursor.execute ("UPDATE B SET data=%s WHERE id=%s", (data, idd))
- conn.commit()
- def proc1():
- 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, 2, 1)
- def proc2():
- 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, 2, 1)
- #conn = mysql.connector.connect(host='127.0.0.1',database='ae.udnikov',user='ae.udnikov',password='ae.udnikov')
- #print(conn.is_connected())
- #conn2 = mysql.connector.connect(host='127.0.0.1',database='ld.sinitsyna',user='ld.sinitsyna',password='ld.sinitsyna')
- t1 = threading.Thread(target=proc1, args=())
- t2 = threading.Thread(target=proc2, args=())
- # start threads
- t1.start()
- #time.sleep(1)
- t2.start()
- # join threads to the main thread
- t1.join()
- t2.join()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement