#!/usr/bin/python3.4
import mysql.connector
import time
import subprocess
import getopt
import sys
import mysql.connector
import time
import re
import os
from subprocess import check_output

def main():
        """Handy mysql-load monitor"""
        ####################
        #default values
        ####################
        outfile = "/var/log/blah2.log"
        loadlimit = float(0)
        ####################
        #end default vaues
        ####################


        try:
                opts, args = getopt.getopt(sys.argv[1:], "o:l:", ["outfile=", "load="])
        except getopt.GetoptError as err:
                print (str(err))
                usage()
                sys.exit(2)
        for o, a in opts:
                if o in ("-o", "--outfile"):
                        outfile = a
                elif o in ("-l", "--loadlimit"):
                        loadlimit = float(a)
                else:
                        assert False, "a more sofisticated, personalized error msg for dvlahov"

        cnx = mysql.connector.connect(user='root', password='mbREGGYjEeiA', host='localhost')
        cursor = cnx.cursor()

        if os.path.exists(outfile):
            append_write = 'a' # append if already exists
        else:
            append_write = 'w' # make a new file if not

        result_file = open(outfile, append_write)

        p = re.compile("load average: ([0-9]*[.][0-9]+)")

        while True:
                cursor.execute("show full processlist")
                processlist = cursor.fetchall()
                uptime = check_output(["uptime"])
                time.sleep(1);
                ldresult = p.search(uptime.decode('ascii'))
                if(float(ldresult.group(1)) >= loadlimit):
                        result_file.write(str(processlist))
                        result_file.write('\n')
                        result_file.write(str(uptime))
                        result_file.write('\n')


if __name__ == "__main__":
        while True:
                try:
                        main()
                except(mysql.connector.errors.InterfaceError):
                        # reconnect code goes here
                        print("Exiting, lost conn!")
                        pass