import MySQLdb

def __run__(params):

    try:
        if not params.get("default_file"):
            return([2, "Critical:" "connection file not informed"])
        else:
            min_node = params.get("mysql_min_node")

            connection =  MySQLdb.connect(read_default_file=params.get("default_file"))
            cursor = connection.cursor()
            cursor.execute("show status like 'wsrep_cluster_size';")
            result = cursor.fetchone()
            field, value = result

            if not result:
                return([2, "Critical: MySQL query error!"])
            elif int(value) < min_node:
                return([2, "Critical: MySQL cluster whitout minimal nodes"])
            elif int(value) == min_node:
                return([0, "OK"])
            else:
                return([2, "Unknown status"])

    except Exception, err:
        return([2, "Error: %s" % err])