def METHOD_NAME(self, connection):
    foos = self.tables.foos
    conn = connection
    conn.execute(insert(foos).values(dict(id=1, bar="b", baz="bz")))
    stmt = insert(foos).values([dict(id=1, bar="ab"), dict(id=2, bar="b")])
    stmt = stmt.on_duplicate_key_update(
        bar=func.concat(stmt.inserted.bar, "_foo"),
        baz=func.concat(stmt.inserted.bar, "_", foos.c.baz),
    )
    result = conn.execute(stmt)
    eq_(result.inserted_primary_key, (None,))
    eq_(
        conn.execute(foos.select()).fetchall(),
        [
            # first entry triggers ON DUPLICATE
            (1, "ab_foo", "ab_bz", False),
            # second entry must be an insert
            (2, "b", None, False),
        ],
    )