Transacciones

Overview

En esta guía, aprenderás a usar el MongoDB Go Driver para realizar transacciones. Transacciones que te permiten ejecutar una serie de operaciones que no cambian ningún dato hasta que la transacción se confirme. Si alguna operación en la transacción devuelve un error, el controlador cancela la transacción y descarta todos los cambios de datos antes de que lleguen a ser visibles.

En MongoDB, las transacciones se ejecutan dentro de sesiones lógicas. Una sesión es un agrupamiento de operaciones de lectura o escritura relacionadas que usted planea ejecutar secuencialmente. Las sesiones habilitan la coherencia causal para un conjunto de operaciones o te permiten ejecutar operaciones en una ACID transaction. MongoDB garantiza que los datos involucrados en sus operaciones de transacción permanezcan coherentes, incluso si las operaciones encuentran errores inesperados.

Al usar el controlador de Go, puedes crear una nueva sesión desde una instancia Client como un tipo Session. Recomendamos reutilizar su cliente para múltiples sesiones y transacciones en lugar de crear una nueva instancia de cliente cada vez.

Métodos

Después de iniciar una sesión utilizando el método StartSession(), puedes modificar el estado de la sesión utilizando el conjunto de métodos proporcionados por la interfaz Session. La siguiente tabla describe estos métodos:

La interfaz Session también tiene métodos para recuperar las propiedades de la sesión y modificar las propiedades mutables de la sesión. Encuentra más información en la documentación de la API.

Ejemplo

El siguiente ejemplo muestra cómo puedes crear una sesión, crear una transacción y confirmar una operación de inserción de varios documentos mediante los siguientes pasos:

1. Crear una sesión desde el cliente utilizando el método StartSession().

2. Utiliza el método WithTransaction() para iniciar una transacción.

3. Inserte varios documentos. El método WithTransaction() ejecuta la inserción y confirma la transacción. Si alguna operación resulta en errores, WithTransaction() gestiona la cancelación de la transacción.

4. Cierra la transacción y la sesión usando el método EndSession().

wc := writeconcern.Majority()
txnOptions := options.Transaction().SetWriteConcern(wc)
// Starts a session on the client
session, err := client.StartSession()
if err != nil {
	panic(err)
}
// Defers ending the session after the transaction is committed or ended
defer session.EndSession(context.TODO())
// Inserts multiple documents into a collection within a transaction,
// then commits or ends the transaction
result, err := session.WithTransaction(context.TODO(), func(ctx mongo.SessionContext) (interface{}, error) {
	result, err := coll.InsertMany(ctx, []interface{}{
		bson.D{{"title", "The Bluest Eye"}, {"author", "Toni Morrison"}},
		bson.D{{"title", "Sula"}, {"author", "Toni Morrison"}},
		bson.D{{"title", "Song of Solomon"}, {"author", "Toni Morrison"}},
	})
	return result, err
}, txnOptions)

Si necesitas más control sobre tus transacciones, puedes encontrar un ejemplo donde se muestra cómo crear, confirmar y finalizar transacciones manualmente en el ejemplo de código completo.

Información Adicional

Para obtener más información sobre las operaciones de inserción, consulta la página básica Insertar un documento.

Para obtener más información sobre cómo especificar write concerns en el driver de Go, consulta Nivel de confirmación de escritura (write concern).

Para un ejemplo adicional utilizando sesiones y transacciones con el controlador Go, consulta la entrada de blog para desarrollador sobre Transacciones ACID Multidocumento.