Jun-30-2017, 11:02 PM (This post was last modified: Jun-30-2017, 11:33 PM by sparkz_alot.)
Hello guys. I hope you can help me with the following issue:
I am working with python, MySQL and multithreading, and really newbie in all of this; however, I am trying to do multiple sql queries at 3 threadings I have. That threads consist in general loop that is reading a specific table from database.
I am using just one database. I use mysql.connector provided by MySQL for Windows. Here is my code:
(I can't post the image url)
I don't know if there are problem with MySQL, I was searching about initialize more MySQL instances but I don't find anything that show how to do this in Windows.
So, I don't know, I believe too that is a problem with MySQL ports. I don't know what is the problem, for this reason, I hope that you can help me guys.
If you see multiple source code errors, notify me, I am a new programmer on python and newbie (x1000) working with multi-threading, so, if there are ways the optimize that source code with inheritance or oop programming, notify me, I want to learn python at pro level. Thank you for help.
There is the issue image:
https://imgur.com/a/OPhpF
I am working with python, MySQL and multithreading, and really newbie in all of this; however, I am trying to do multiple sql queries at 3 threadings I have. That threads consist in general loop that is reading a specific table from database.
I am using just one database. I use mysql.connector provided by MySQL for Windows. Here is my code:
# -*- coding: utf-8 -*- import threading import mysql.connector import win32con import sys, os import struct import time from win32api import * from win32gui import * from mysql.connector import Error from threading import Thread cnx = mysql.connector.connect(host="localhost", user="root", password="1234", database="gammu") cnx2 = mysql.connector.connect(host="localhost", user="root", password="1234", database="gammu") cnx3 = mysql.connector.connect(host="localhost", user="root", password="1234", database="gammu") cursor = cnx.cursor() cursor2 = cnx.cursor() cursor3 = cnx.cursor() global errKey global errHash class WindowsBalloonTip: def __init__(self, title, msg): message_map= { win32con.WM_DESTROY: self.OnDestroy, } wc = WNDCLASS() hinst = wc.hInstance = GetModuleHandle(None) wc.lpszClassName = "NotificationTaskR" wc.lpfnWndProc = message_map classAtom = RegisterClass(wc) style = win32con.WS_OVERLAPPED | win32con.WS_SYSMENU self.hwnd = CreateWindow(classAtom, "Taskbar", style, 0, 0, \ wind32con.CW_USEDEFAULT, win32con.CW_USEDEFAULT, \ 0, 0, hinst, None) UpdateWindw(self.hwnd) iconPathName = os.path.abspath(os.path.join(sys.path[0], 'balloontip.ico')) icon_flags = win32con.LR_LOADFROMFILE | win32con.LR_DEFAULTSIZE try: hicon = LoadImage(hinst, iconPathName, win32con.IMAGE_ICON, 0,0, icon_flags) except: hicon = LoadIcon(0, win32con.IDI_APPLICATION) flags = NIF_ICON | NIF_MESSAGE | NIF_TIP nid = (self.hwnd, 0, flags, win32con.WM_USER+20, hicon, "New message received") Shell_NotifyIcon(NIM_ADD, nid) Shell_NotifyIcon(NIM_MODIFY, (self.hwnd, 0, NIF_INFO, win32con.WIM_USER+20, \ hicon, "Balloon tooltip", msg, 200, title)) time.sleep(3) DestroyWindow(self.hwnd) classAtom = UnregisterClass(classAtom, hinst) def OnDestroy(self, hwnd, msg, wparam, lparam): nid = (self.hwnd, 0) Shell_NotifyIcon(NIM_DELETE, nid) PostQuitMessage(0) def balloon_tip(title, msg): w = WindowsBalloonTip(title, msg) def newWh(): while True: cnx.connect() lastRquery = ("select UpdatedInDB, AES_DECRYPT(TextDecoded, (select AES_DECRYPT(cryptkey, '373630303a3a3') from decryptkey)), " "AES_DECRYPT(SenderNumber, (select AES_DECRYPT(cryptkey, '373630303a3a3') from decryptkey)), ID from inboxencrypt where " "chck=0 order by UpdatedInDB asc limit 1") cursor.execute(lastRquery) regL = cursor.fetchall() if not regL: cnx.close() import time time.sleep(3) continue else: for row in regL: time = row[0] timeC = str(time) timeO = timeC[10:] message = row[1] telephone = row[2] toUR = row[3] lengM = len(message) smsDetect = message[27:] procMR = message.split() if procMR[0] == "\send": #Detect first command cnx.close() cnx.connect() queryAuth = ("SELECT privkey FROM transferauth WHERE " "privkey=sha(%s)", procMR[1]) cursor.execute(queryAuth) authStorage = cursor.fetchall() for row in authStorage: key = authStorage[0] if procMR[1] == key: #Detect authentication key if procMR[2] == "\a": #Detect command to send multiple messages to all contact list print("Ok") elif len(procMR[2]) == 13: #Send message to specific contact if telpComm[0] == "+" and telpComm [1:3] == "58": #Verifying international code telpComm == procMR[2] if len(smsDetect) > 3: #Verifying minimum message length if smsDetect[-1] == '"' and smsDetect[0] == '"': #Verifying message format and sending message msgToSend = smsDetetct[1:-1] cnx.close() cnx.connect() sendQuerExt = ("insert into outbox(DestinationNumber, " "TextDecoded, CreatorID) values " "('%s','%s','PwC')" % (telpComm, msgToSend)) cursor.execute(sendQuerExt) cnx.commit() cnx.close() #Reconnecting to database and ipdating message status cnx.connect() updateRquery = ("update inbox set chck=1 where " "ID=%s" % toUR) cursor.execute(updateRquery) cnx.commit() cnx.close() #Wait for re-establish loop import time time.sleep(3) print("~~~Send message is required for: "+telephone) print("~~~Send message in required for: "+telpComm+"\n\n") continue else: #Invalid message format => ERR_FORMATSMS_INVALID cnx.connect() srcErrorSource = ("select errordesc, hexcode from transfererrors " "where cause='ERR_FORMATSMS_INVALID'") cursor.execute(srcErrorSource) errStorageA = cursor.fetchall() for row in errStorageA: errKey = row[0] errHash = row[1] cnx.close() cnx.connect() recQueryErrorNumb = ("insert into outbox(Text, DestinationNumber, " "TextDecoded, CreatorID) values " "('%s','%s','%s','PwC')" % (errHash, telephone, errKey)) cursor.execute(recQueryErrorNumb) cnx.commit() cnx.close() #Reconnecting to database and updating message status cnx.connect() updateRquery = ("update inbox set chck=1 where " "ID=%s" % toUR) cursor.execute(updateRquery) cnx.commit() cnx.close() #Wait for re-establish loop import time time.sleep(3) continue else: #Minimum message length required => ERR_LENGTHSMS_INVALID srcErrorSource = ("select errordesc, hexcode from transferrors " "where cause='ERR_LENGTH_INVALID'") cursor.execute(srcErrorSource) errStorageA = cursor.fetchall() for row in errStorageA: errKey = row[0] errHash = row[1] cnx.close() cnx.connect() recQueryErrorNumb = ("insert into outbox(Text, DestinationNumber, " "TextDecoded, CreatorID) values " "('%s','%s','%s','PwC')" % (errHash, telephone, errKey)) cursor.execute(recQueryErrorNumb) cnx.commit() cnx.close() #Reconnecting to database and updating message status cnx.connect() updateRquery = ("update inbox set chck=1 where " "ID=%s" % toUR) cursor.execute(updateRquery) cnx.commit() cnx.close() #Wait for re-establish loop import time time.sleep(3) continue else: #Wrong international telephone format => ERR_FORMATNUMBER_INVALID srcErrorSource = ("select errordesc, hexcode from transfererrors " "where cause='ERR_FORMATNUMBER_INVALID'") cursor.execute(srcErrorSource) errStorageA = cursor.fetchall() for row in errStorageA: errKey = row[0] errHash = row[1] cnx.connect() recQueryErrorNumb = ("insert into outbox(Text, DestinationNumber, " "TextDecoded, CreatorID) values " "('%s','%s','%s','PwC')" % (errHash, telephone, errKey)) cursor.execute(recQueryErrorNumb) cnx.commit() cnx.close() #Reconnecting to database and updating message status cnx.connect() updateRquery = ("update inbox set chck=1 where " "ID=%s" % toUR) cursor.execute(updateRquery) cnx.commit() cnx.close() #Wait for re-establish loop import time time.sleep(3) continue else: #Unknown message or command => ERR_TLPNUMBER_INVALID srcErrorSource = ("select errordesc, hexcode from transfererrors " "where cause='ERR_TLPNUMBER_INVALID'") cursor.execute(srcErrorSource) errStorageA = cursor.fetchall() for row in errStorageA: errKey = row[0] errHash = row[1] cnx.close() cnx.connect() recQueryErrorNumb = ("insert into outbox(Text, DestinationNumber, " "TextDecoded, CreatorID) values " "('%s','%s','%s','PwC')" % (errHash, telephone, errKey)) cursor.execute(recQueryErrorNumb) cnx.commit() cnx.close() #Reconnecting to database and updating message status cnx.connect() updateRquery = ("update inbox set chck=1 where " "ID=%s" % toUR) cursor.execute(updateRquery) cnx.commit() cnx.close() #Wait for re-establish loop import time time.sleep() continue else: #Authetication error, wron key => ERR_AUTHKEY_INVALID srcErrorSource = ("select errordesc, hexcode from transfererrors " "where cause='ERR_AUTHKEY_INVALID'") cursor.execute(srcErrorSource) errStorageA = cursor.fetchall() for row in errStorageA: errKey = row[0] errHash = row[1] cnx.close() cnx.connect() recQueryErrorNumb = ("insert into outbox(Text, DestinationNumber, " "TextDecoded, CreatorID) values " "('%s','%s','%s','PwC')" % (errHash, telephone, errKey)) cursor.execute(recQueryErrorNumb) cnx.commit() cnx.close() #Reconnecting to database and updating message status cnx.connect() recQueryErrorNumb = ("update inbox set chck=1 where " "ID=%s" % toUR) cursor.execute(updateRquery) cnx.commit() cnx.close() #Wait for re-establish loop import time time.sleep() continue else: print("|| "+telephone+"\t\t"+timeO) print("|| "+message+"\n\n") balloon_tip("Mensaje recibido",message+"\nDe: "+telephone+"\t"+timeO) file = open("smscenter.log","a") file.write("Message was received at: "+timeO+"\n") file.write("----------------------------------------\n") file.write("|| "+telephone+"\n") file.write("|| "+message.encode("utf8")+"\n") file.write("-----Length of sms: "+str(lengM)+"\n") file.write("-----Recognize: \n\n\n") file.close() cnx.close() cnx.connect() updateRquery = ("update inbox set chck=1 where ID=%s" % toUR) cursor.execute(updateRquery) cnx.commit() cnx.close() import time time.sleep(3) continue def readWh(): while True: cnx2.connect() lastRquery2 = ("select UpdatedInDB, TextDecoded, SenderNumber, ID from inbox where " "chck=0 order by UpdatedInDB asc limit 1") cursor2.execute(lastRquery2) regL2 = cursor2.fetchall() if not regL2: cnx2.close() cnx2.connect() queryTrunc = ("delete from inbox where chck=1") cursor2.execute(queryTrunc) cnx2.commit() cnx2.close() import time time.sleep(3) continue else: for row in regL2: timeReceived = row[0] timeReceivedC = str(timeReceived) timeReceivedO = timeReceivedC[10:] messageRec = row[1] telephoneRec = row[2] idRec = row[3] cnx2.close() print("Hola menor") cnx2.connect() queryA = ("insert into inboxencrypt(id, UpdatedInDB, TextDecoded, SenderNumber) " "values (%s, %s, AES_ENCRYPT('%s', (select AES_DECRYPT(cryptkey, '373630303a3a3') from decrypkey)), " "AES_ENCRYPT('%s', (select AES_DECRYPT(cryptkey, '373630303a3a3') from decrypkey)))") cursor2.execute(queryA) cnx2.commit() cnx2.close() #Drop message cnx2.connect() queryB = ("update inbox set chck=1 where " "ID=%s" % idRec) cursor2.execute(queryB) cnx2.commit() cnx2.close() cnx2.connect() queryC = ("delete from inbox where chck=1") cursor2.execute(queryC) cnx2.commit() cnx2.close() continue def sentWh(): while True: cnx3.connect() lastRquery3 = ("select UpdatedInDB, InsertIntoDB, SendingDateTime, DestinationNumber, " "TextDecoded, ID, Status, CreatorID from sentitems where chck=0 order by UpdatedInDB asc limit 1") cursor3.execute(lastRquery3) regL3= cursor3.fetchall() if not regLr: cnx3.close() cnx3.connect() queryTrunc1 = ("delete from sentitems where chck=1") cursor3.execute(queryTrunc1) cnx3.commit() cnx3.close() import time time.sleep(3) print("Hola menor") continue else: for row in regL3: timeUpdated = row[0] timeInsert = row[1] timeSent = row[2] telephoneSent = row[3] messageSent = row[4] idSent = row[5] status = row[6] creator = row[7] cnx3.close() cnx3.connect() print("Hola menor") queryD = ("insert into sentencrypt(id, UpdatedInDB, InsertIntoDB, SendingDateTime, " "DestinationNumber, TextDecoded, Status, CreatorID) values " "(%s, '%s', '%s', '%s', " "AES_ENCRYPT('%s', (select AES_DECRYPT(cryptkey, '373630303a3a3') from decrypkey)), " "AES_ENCRYPT('%s', (select AES_DECRYPT(cryptkey, '373630303a3a3') from decrypkey)), " "'%s', AES_ENCRYPT('%s', (select AES_DECRYPT(cryptkey, '373630303a3a3') from decrypkey)))" % (idSent, timeUpdated, timeInsert, timeSent, telephoneSent, messageSent, status, creator)) cursor3.execute(queryD) cnx3.commit() cnx3.close() #Drop message cnx3.connect() queryZ = ("update sentitems set chck=1 where " "ID=%s" % idSent) cursor3.execute(queryZ) cnx3.commit() cnx3.close() cnx3.connect() queryE = ("delete from sentitems where chck=1") cursor.execute(queryE) cnx3.commit() cnx3.close() import time time.sleep(3) continue if __name__ == '__main__': print("Be sure you have Windows pop-ups notifications enabled.\n\n") print("SMS Center will show pop-ups notifications when message is being received." "\nThis window need to be open at anytime.") Thread(target = newWh).start() Thread(target = readWh).start() Thread(target = sentWh).start()As you can see, I have 3 functions that have a loop (newWh, readWh and sentWh = these are the three functions, their loops are infinite). But, when I execute it, I obtain the following error:(I can't post the image url)
I don't know if there are problem with MySQL, I was searching about initialize more MySQL instances but I don't find anything that show how to do this in Windows.
So, I don't know, I believe too that is a problem with MySQL ports. I don't know what is the problem, for this reason, I hope that you can help me guys.
If you see multiple source code errors, notify me, I am a new programmer on python and newbie (x1000) working with multi-threading, so, if there are ways the optimize that source code with inheritance or oop programming, notify me, I want to learn python at pro level. Thank you for help.
There is the issue image:
https://imgur.com/a/OPhpF
