Method raw

tests/select_for_update/tests.py:620–639

(status)

        self.start_blocking_transaction()

        def raw(status):
            try:
                list(
                    Person.objects.raw(
                        class="st">"SELECT * FROM %s %s"
                        % (
                            Person._meta.db_table,
                            connection.ops.for_update_sql(nowait=True),
                        )
                    )
                )
            except DatabaseError as e:
                status.append(e)
            finally:
                class="cm"># This method is run in a separate thread. It uses its own
                class="cm"># database connection. Close it without waiting for the GC.
                class="cm"># Connection cannot be closed on Oracle because cursor is still
                class="cm"># open.
                if connection.vendor != class="st">"oracle":
                    connection.close()

        status = []
        thread = threading.Thread(target=raw, kwargs={class="st">"status": status})