Unconditionally remove all lock records. Returns: Number of lock rows removed
(self)
| 390 | return removed_count |
| 391 | |
| 392 | def force_break_all(self) -> int: |
| 393 | """Unconditionally remove all lock records. |
| 394 | |
| 395 | Returns: |
| 396 | Number of lock rows removed |
| 397 | """ |
| 398 | conn = self._get_connection() |
| 399 | try: |
| 400 | cursor = conn.cursor() |
| 401 | cursor.execute("SELECT COUNT(*) FROM lock_holders") |
| 402 | row = cursor.fetchone() |
| 403 | count = row[0] if row else 0 |
| 404 | cursor.execute("DELETE FROM lock_holders") |
| 405 | conn.commit() |
| 406 | return count |
| 407 | finally: |
| 408 | conn.close() |
| 409 | |
| 410 | |
| 411 | # Module-level cache for LockDatabase instances |
no test coverage detected