()
| 1420 | ) |
| 1421 | |
| 1422 | def delete_stmt(): |
| 1423 | clauses = BooleanClauseList._construct_raw(operators.and_) |
| 1424 | |
| 1425 | for col in mapper._pks_by_table[table]: |
| 1426 | clauses._append_inplace( |
| 1427 | col == sql.bindparam(col.key, type_=col.type) |
| 1428 | ) |
| 1429 | |
| 1430 | if need_version_id: |
| 1431 | clauses._append_inplace( |
| 1432 | mapper.version_id_col |
| 1433 | == sql.bindparam( |
| 1434 | mapper.version_id_col.key, type_=mapper.version_id_col.type |
| 1435 | ) |
| 1436 | ) |
| 1437 | |
| 1438 | return table.delete().where(clauses) |
| 1439 | |
| 1440 | statement = base_mapper._memo(("delete", table), delete_stmt) |
| 1441 | for connection, recs in groupby(delete, lambda rec: rec[1]): # connection |
nothing calls this directly
no test coverage detected