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