Transacciones y Sesiones

Overview

En esta guía, aprenderá a usar Mongoid para realizar transacciones. Las transacciones permiten realizar una serie de operaciones que modifican los datos solo si se confirma la transacción completa. Si alguna operación de la transacción no se realiza correctamente, el controlador la detiene y descarta todos los cambios de datos antes de que sean visibles. Esta función se denomina atomicidad.

En MongoDB, las transacciones se ejecutan en sesiones lógicas. Una sesión es una agrupación de operaciones de lectura o escritura relacionadas que se ejecutan secuencialmente. Las sesiones permiten la coherencia causal para un grupo de operaciones, lo que significa que todos los procesos de la aplicación coinciden en el orden de las operaciones causalmente relacionadas.

Las sesiones permiten ejecutar operaciones en una transacción compatible con ACID que cumple con las expectativas de atomicidad, consistencia, aislamiento y durabilidad. MongoDB garantiza que los datos involucrados en las operaciones de transacción se mantengan consistentes, incluso si las operaciones presentan errores inesperados.

En Mongoid, puedes realizar transacciones utilizando cualquiera de las siguientes API:

• API de transacciones de alto nivel: Mongoid gestiona el ciclo de vida de las transacciones. Puede usar esta API en Mongoid v9.0 y versiones posteriores.

• API de transacciones de bajo nivel: Debe gestionar el ciclo de vida de la transacción. Puede usar esta API en Mongoid v6.4 y versiones posteriores.

La sección API de sesión describe cómo realizar cambios en tus datos desde dentro de una sesión sin realizar una transacción.

API de transacciones de alto nivel

Puede usar la API de Transacciones de Alto Nivel para gestionar internamente el ciclo de vida de su transacción. Esta API confirma o finaliza la transacción e incorpora lógica de gestión de errores.

Puede iniciar una transacción llamando al transaction método en una instancia de un modelo, en la clase del modelo o en un módulo Mongoid.

Cuando llama al método transaction, Mongoid realiza las siguientes tareas:

1. Crea una sesión en el cliente.

2. Inicia una transacción en la sesión.

3. Realiza los cambios de datos especificados.

4. Confirma la transacción en la base de datos si no se producen errores o finaliza la transacción si hay un error.

5. Cierra la sesión.

Si su transacción se confirma, Mongoid invoca cualquier after_commit devolución de llamada para todos los objetos modificados dentro de la transacción. Si se produce un error y la transacción se revierte, Mongoid invoca cualquier after_rollback devolución de llamada para todos los objetos modificados dentro de la transacción. Para obtener más información sobre estas devoluciones de llamada y su comportamiento, consulte la sección "Devoluciones de llamada" de esta guía.

class Book
  include Mongoid::Document
  field :title, type: String
  field :author, type: String
  field :length, type: Integer
end
class Film
  include Mongoid::Document
  field :title, type: String
  field :year, type: Integer
end

# Starts a transaction from the model class
Book.transaction do
  # Saves new Book and Film instances to MongoDB
  Book.create(title: 'Covert Joy', author: 'Clarice Lispector')
  Film.create(title: 'Nostalgia', year: 1983)
end
# Starts a transaction from an instance of Book
book = Book.create(title: 'Sula', author: 'Toni Morrison')
book.transaction do
  # Saves a new field value to the Book instance
  book.length = 192
  book.save!
end
# Starts a transaction from the Mongoid instance
Mongoid.transaction do
  # Deletes the Book instance in MongoDB
  book.destroy
end

# Defines a class by using the :default client
class Post
  include Mongoid::Document
end
  
# Defines a class by using the :encrypted_client
class User
  include Mongoid::Document
  store_in client: :encrypted_client
end
# Starts a transaction on the :encrypted_client
User.transaction do
  # Uses the same client, so the operation is in the transaction
  User.create!
  # Uses a different client, so it is *not* in the transaction
  Post.create!
end

API de Transacción de bajo nivel

Al usar la API de bajo nivel, debe crear una sesión antes de iniciar una transacción. Puede crear una sesión llamando al método with_session en una clase de modelo o en una instancia de un modelo.

Luego, puede iniciar una transacción llamando al método start_transaction en una sesión. Al usar esta API, debe confirmar o finalizar la transacción manualmente. Puede usar los métodos commit_transaction y abort_transaction en la instancia de sesión para administrar el ciclo de vida de la transacción.

# Starts a session from the model class
Book.with_session do |session|
  session.start_transaction 
  # Creates a Book
  Book.create(title: 'Siddhartha', author: 'Hermann Hesse')
  # Commits the transaction
  session.commit_transaction
rescue StandardError
  # Ends the transaction if there is an error
  session.abort_transaction
end

begin
  session.commit_transaction
rescue Mongo::Error => e
  if e.label?(Mongo::Error::UNKNOWN_TRANSACTION_COMMIT_RESULT_LABEL)
    retry
  else
    raise
  end
end

session.start_transaction(
    read_concern: {level: :majority},
    write_concern: {w: 3},
    read: {mode: :primary}
)

# Specifies that the operation should use the "other" client instead of
# the default client
User.with(client: :other) do
  Post.with(client: :other) do
    Post.with_session do |session|
      session.start_transaction
      Post.create!
      Post.create!
      User.create!
      session.commit_transaction
    end
  end
end

Session API

Puedes usar sesiones en Mongoid de forma similar a como se realiza una transacción. Puedes llamar al método with_session en una clase de modelo o en una instancia de un modelo y realizar operaciones en un bloque. Todas las operaciones del bloque se realizarán en el contexto de una sola sesión.

Se aplican las siguientes limitaciones al utilizar sesiones:

• No se puede compartir una sesión entre subprocesos. Las sesiones no son seguras para subprocesos.

• No se pueden anidar sesiones. Por ejemplo, no se puede llamar al método with_session de una clase de modelo dentro del bloque pasado al método with_session de otra clase de modelo. El siguiente código muestra una sesión anidada que genera un error:

  Book.with_session(causal_consistency: true) do
    # Nesting sessions results in errors
    Film.with_session(causal_consistency: true) do
      ...
    end
  end

• Todas las clases e instancias de modelo utilizadas en el bloque de sesión deben usar el mismo cliente controlador. Por ejemplo, si especifica un cliente distinto para un modelo utilizado en el bloque que el del modelo o la instancia en la que se invocó with_session, Mongoid devuelve un error.

Book.with_session(causal_consistency: true) do
  Book.create!
  book = Person.first
  book.title = "Swann's Way"
  book.save
end

book = Book.new
book.with_session(causal_consistency: true) do
  book.title = 'Catch-22'
  book.save
  book.sellers << Shop.create!
end

Información Adicional

Para obtener más información sobre las transacciones, consulte Transacciones en el manual del servidor.

Para obtener más información sobre cómo realizar operaciones CRUD, consulta la guía Realiza operaciones de datos.