'Queries mysql and returns a cursor to the results.'

def _query_mysql(self):

    mysql = MySqlHook(mysql_conn_id=self.mysql_conn_id)
    conn = mysql.get_conn()
    cursor = conn.cursor()
    cursor.execute(self.sql)
    return cursor
