async def fish_thing(rarity, message):
    query = "INSERT INTO fish_command (discord_user_id, fish_amount_rarity_" + str(rarity) + ") VALUES ('" + message.author.id + "', 1) ON DUPLICATE KEY UPDATE `fish_amount_rarity_" + str(rarity) + "`=`fish_amount_rarity_" + str(
        rarity) + "` + 1"
    print(query)
    cursor.execute(query)
    conn.commit()

    query = "SELECT discord_user_id, fish_amount_rarity_" + str(rarity) + " FROM fish_command WHERE discord_user_id = '" + message.author.id + "'"
    cursor.execute(query)

    for (discord_user_id, fish_amount) in cursor:
        await client.send_message(message.channel,
                                  "{} has caught another rarity {} level fish! {} in total.".format(message.author.name,
                                                                                       rarity, fish_amount))