def event_return(events):
    with _get_serv(events, commit=True) as cur:
        for event in events:
            tag = event.get('tag', '')
            data = event.get('data', '')
            sql = '''INSERT INTO `salt_events` (`tag`, `data`, `master_id` )
                     VALUES (%s, %s, %s)'''
            cur.execute(sql, (tag, json.dumps(data), __opts__['id']))
the primary execution method
dataset/ETHPy150Open saltstack/salt/salt/returners/mysql.py/event_return--crossover with--dataset/ETHPy150Open azoft-dev-team/imagrium/env/Lib/dbexts.py/dbexts.__execute__