Python

Version History (0.4.3)

Report an Issue

Source code for gcloud.datastore.transaction

# Copyright 2014 Google Inc. All rights reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

"""Create / interact with gcloud datastore transactions."""

from gcloud.datastore.batch import Batch


class Transaction(Batch):
    """An abstraction representing datastore Transactions.

    Transactions can be used to build up a bulk mutuation as well as
    provide isolation.

    For example, the following snippet of code will put the two ``save``
    operations (either ``insert_auto_id`` or ``upsert``) into the same
    mutation, and execute those within a transaction::

      >>> from gcloud import datastore

      >>> with datastore.Transaction():
      ...     datastore.put([entity1, entity2])

    Because it derives from :class:`Batch`, :class`Transaction` also provides
    :meth:`put` and :meth:`delete` methods::

      >>> with datastore.Transaction() as xact:
      ...     xact.put(entity1)
      ...     xact.delete(entity2.key)

    By default, the transaction is rolled back if the transaction block
    exits with an error::

      >>> with datastore.Transaction():
      ...     do_some_work()
      ...     raise SomeException()  # rolls back

    If the transaction block exists without an exception, it will commit
    by default.

    .. warning:: Inside a transaction, automatically assigned IDs for
       entities will not be available at save time!  That means, if you
       try::

         >>> with datastore.Transaction():
         ...     entity = datastore.Entity(key=Key('Thing'))
         ...     datastore.put([entity])

       ``entity`` won't have a complete Key until the transaction is
       committed.

       Once you exit the transaction (or call ``commit()``), the
       automatically generated ID will be assigned to the entity::

         >>> with datastore.Transaction():
         ...     entity = datastore.Entity(key=Key('Thing'))
         ...     datastore.put([entity])
         ...     assert entity.key.is_partial  # There is no ID on this key.
         ...
         >>> assert not entity.key.is_partial  # There *is* an ID.

       After completion, you can determine if a commit succeeded or failed.
       For example, trying to delete a key that doesn't exist::

         >>> with datastore.Transaction() as xact:
         ...     xact.delete(key)
         ...
         >>> xact.succeeded
         False

       or successfully storing two entities:

         >>> with datastore.Transaction() as xact:
         ...     datastore.put([entity1, entity2])
         ...
         >>> xact.succeeded
         True

    If you don't want to use the context manager you can initialize a
    transaction manually::

      >>> transaction = datastore.Transaction()
      >>> transaction.begin()

      >>> entity = datastore.Entity(key=Key('Thing'))
      >>> transaction.put(entity)

      >>> if error:
      ...     transaction.rollback()
      ... else:
      ...     transaction.commit()

    :type dataset_id: string
    :param dataset_id: The ID of the dataset.

    :type connection: :class:`gcloud.datastore.connection.Connection`
    :param connection: The connection used to connect to datastore.

    :raises: :class:`ValueError` if either a connection or dataset ID
             are not set.
    """

    _INITIAL = 0
    """Enum value for _INITIAL status of transaction."""

    _IN_PROGRESS = 1
    """Enum value for _IN_PROGRESS status of transaction."""

    _ABORTED = 2
    """Enum value for _ABORTED status of transaction."""

    _FINISHED = 3
    """Enum value for _FINISHED status of transaction."""

    def __init__(self, dataset_id=None, connection=None):
        super(Transaction, self).__init__(dataset_id, connection)
        self._id = None
        self._status = self._INITIAL

    @property
    def id(self):
        """Getter for the transaction ID.

        :rtype: string
        :returns: The ID of the current transaction.
        """
        return self._id

    @staticmethod
    def current():
        """Return the topmost transaction.

        .. note:: if the topmost element on the stack is not a transaction,
                  returns None.

        :rtype: :class:`gcloud.datastore.transaction.Transaction` or None
        """
        top = Batch.current()
        if isinstance(top, Transaction):
            return top

    def begin(self):
        """Begins a transaction.

        This method is called automatically when entering a with
        statement, however it can be called explicitly if you don't want
        to use a context manager.

        :raises: :class:`ValueError` if the transaction has already begun.
        """
        if self._status != self._INITIAL:
            raise ValueError('Transaction already started previously.')
        self._status = self._IN_PROGRESS
        self._id = self.connection.begin_transaction(self._dataset_id)

    def rollback(self):
        """Rolls back the current transaction.

        This method has necessary side-effects:

        - Sets the current connection's transaction reference to None.
        - Sets the current transaction's ID to None.
        """
        try:
            self.connection.rollback(self._dataset_id, self._id)
        finally:
            self._status = self._ABORTED
            # Clear our own ID in case this gets accidentally reused.
            self._id = None

    def commit(self):
        """Commits the transaction.

        This is called automatically upon exiting a with statement,
        however it can be called explicitly if you don't want to use a
        context manager.

        This method has necessary side-effects:

        - Sets the current transaction's ID to None.
        """
        try:
            super(Transaction, self).commit()
        finally:
            self._status = self._FINISHED
            # Clear our own ID in case this gets accidentally reused.
            self._id = None