Commit a two phase transaction on the given connection. :param connection: a :class:`_engine.Connection`. :param xid: xid :param is_prepared: whether or not :meth:`.TwoPhaseTransaction.prepare` was called. :param recover: if the recover flag was passed.
(
self,
connection: Connection,
xid: Any,
is_prepared: bool = True,
recover: bool = False,
)
| 2189 | raise NotImplementedError() |
| 2190 | |
| 2191 | def do_commit_twophase( |
| 2192 | self, |
| 2193 | connection: Connection, |
| 2194 | xid: Any, |
| 2195 | is_prepared: bool = True, |
| 2196 | recover: bool = False, |
| 2197 | ) -> None: |
| 2198 | """Commit a two phase transaction on the given connection. |
| 2199 | |
| 2200 | |
| 2201 | :param connection: a :class:`_engine.Connection`. |
| 2202 | :param xid: xid |
| 2203 | :param is_prepared: whether or not |
| 2204 | :meth:`.TwoPhaseTransaction.prepare` was called. |
| 2205 | :param recover: if the recover flag was passed. |
| 2206 | |
| 2207 | """ |
| 2208 | |
| 2209 | raise NotImplementedError() |
| 2210 | |
| 2211 | def do_recover_twophase(self, connection: Connection) -> List[Any]: |
| 2212 | """Recover list of uncommitted prepared two phase transaction |
no outgoing calls