Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import mysql.connector
- import threading
- from multiprocessing import Process
- import time
- def updateA(conn, idd, data):
- conn.cursor().execute ("UPDATE A SET data=%s WHERE id=%s", (data, idd))
- conn.commit()
- def updateB(conn, idd, data):
- conn.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, 1, 2)
- print('allo')
- 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, 1, 5)
- print('allo2')
- t1 = Process(target=proc1, args=())
- t2 = Process(target=proc2, args=())
- t1.start()
- t2.start()
- t1.join()
- t2.join()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement