(existing_stmt=None)
| 751 | execution_options = {"compiled_cache": base_mapper._compiled_cache} |
| 752 | |
| 753 | def update_stmt(existing_stmt=None): |
| 754 | clauses = BooleanClauseList._construct_raw(operators.and_) |
| 755 | |
| 756 | for col in mapper._pks_by_table[table]: |
| 757 | clauses._append_inplace( |
| 758 | col == sql.bindparam(col._label, type_=col.type) |
| 759 | ) |
| 760 | |
| 761 | if needs_version_id: |
| 762 | clauses._append_inplace( |
| 763 | mapper.version_id_col |
| 764 | == sql.bindparam( |
| 765 | mapper.version_id_col._label, |
| 766 | type_=mapper.version_id_col.type, |
| 767 | ) |
| 768 | ) |
| 769 | |
| 770 | if existing_stmt is not None: |
| 771 | stmt = existing_stmt.where(clauses) |
| 772 | else: |
| 773 | stmt = table.update().where(clauses) |
| 774 | return stmt |
| 775 | |
| 776 | if use_orm_update_stmt is not None: |
| 777 | cached_stmt = update_stmt(use_orm_update_stmt) |
no test coverage detected