Function _replace_bindmarkers

lib/sqlalchemy/sql/crud.py:459–495

(
    compiler, _column_as_key, bindmarkers, compile_state, values, kw
)

def _replace_bindmarkers(
    compiler, _column_as_key, bindmarkers, compile_state, values, kw
):
    _expr_by_col_key = {
        _column_as_key(col): compiled_str for col, _, compiled_str, _ in values
    }

    def replace_marker(m):
        try:
            return _expr_by_col_key[m.group(1)]
        except KeyError as ke:
            if dml.isupdate(compile_state):
                return compiler.process(bindmarkers[m.group(1)].column, **kw)
            else:
                raise exc.CompileError(
                    f"Can't resolve referenced column name in "
                    f"INSERT statement: {m.group(1)!r}"
                ) from ke

    values[:] = [
        (
            col,
            col_value,
            re.sub(
                r"__BINDMARKER_~~(.+?)~~",
                replace_marker,
                compiled_str,
            ),
            accumulated_bind_names,
        )
        for (
            col,
            col_value,
            compiled_str,
            accumulated_bind_names,
        ) in values
    ]


@overload