all

report_sql.py

@@ -73,18 +73,16 @@ class reportClient(NetstringReceiver):
         if len(datalist) > 9:
             event['duration'] = datalist[9]
         
-        if event['event'] == 'END' and event['trx'] == 'RX':
+        while not self.db.is_connected():
-            
+            self.db.reconnect()
-            while not self.db.is_connected():
+        print("{} {} {} {} {} {} {} {} {}".format(event['type'],event['event'], event['trx'],event['system'],event['streamid'],event['peerid'],event['subid'],event['slot'],event['dstid'],event['duration']))
-                self.db.reconnect()
+        _cursor = self.db.cursor()
-            print("{} {} {} {} {} {} {} {} {}".format(event['type'],event['event'], event['trx'],event['system'],event['streamid'],event['peerid'],event['subid'],event['slot'],event['dstid'],event['duration']))
+        try:
-            _cursor = self.db.cursor()
+            _cursor.execute("insert into feed values (NULL,'{}','{}','{}','{}','{}','{}','{}','{}','{}','{}')".format(event['type'],event['event'], event['trx'],event['system'],event['streamid'],event['peerid'],event['subid'],event['slot'],event['dstid'],event['duration']))
-            try:
+            self.db.commit()
-                _cursor.execute("insert into feed values (NULL,'{}','{}','{}','{}','{}','{}','{}','{}','{}','{}')".format(event['type'],event['event'], event['trx'],event['system'],event['streamid'],event['peerid'],event['subid'],event['slot'],event['dstid'],event['duration']))
+        except mysql.connector.Error as err:
-                self.db.commit()
+            _cursor.close()
-            except mysql.connector.Error as err:
+            print('(MYSQL) error, problem with cursor execute: {}'.format(err))
-                _cursor.close()
-                print('(MYSQL) error, problem with cursor execute: {}'.format(err))
             
         
     def bridgeSend(self,data):