def execute_with_params(queries, params):
	conn = await aiomysql.connect(.....)

    async with conn.cursor() as cursor:
		try:
        	for query, param in queries, params:
        		await cursor.execute(query, param)
        	await conn.commit()
		except:
			await conn.rollback()