Method do_commit_twophase

lib/sqlalchemy/dialects/postgresql/base.py:3754–3768

(
        self, connection, xid, is_prepared=True, recover=False
    )

            self.do_rollback(connection.connection)

    def do_commit_twophase(
        self, connection, xid, is_prepared=True, recover=False
    ):
        if is_prepared:
            if recover:
                connection.exec_driver_sql("ROLLBACK")
            connection.execute(
                sql.text("COMMIT PREPARED :xid").bindparams(
                    sql.bindparam("xid", xid, literal_execute=True)
                )
            )
            connection.exec_driver_sql("BEGIN")
            self.do_rollback(connection.connection)
        else:
            self.do_commit(connection.connection)

    def do_recover_twophase(self, connection):
        return connection.scalars(