Transacciones

Overview

En esta guía, puede aprender a utilizar el controlador MongoDB Go para realizar transacciones. Las transacciones permiten ejecutar una serie de operaciones que no modifican ningún dato hasta que se confirma la transacción. Si alguna operación de la transacción devuelve un error, el controlador la cancela y descarta todos los cambios de datos antes de que sean visibles.

En MongoDB, las transacciones se ejecutan dentro de 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 consistencia causal para un grupo de operaciones o ejecutar operaciones en una transacción ACID. MongoDB garantiza que los datos involucrados en las transacciones se mantengan consistentes, incluso si se producen errores inesperados.

Al utilizar el controlador Go, puede crear una nueva sesión desde una Client Instancia de tipo Session. Recomendamos reutilizar el cliente para múltiples sesiones y transacciones en lugar de instanciar un nuevo cliente cada vez.

Métodos de sesión

Después de iniciar una sesión con el método StartSession() en su cliente, puede modificar el estado de la sesión mediante el conjunto de métodos proporcionado por el Session ​​devuelto. La siguiente tabla describe estos métodos:

Un Session también tiene métodos para recuperar propiedades de sesión y modificar propiedades de sesión mutables. Consulte la documentación de la API para obtener más información sobre estos métodos.

txnOpts := options.Transaction().SetReadConcern(readconcern.Majority())
sessOpts := options.Session().SetDefaultTransactionOptions(txnOpts)
session, err := client.StartSession(sessOpts)
if err != nil {
	return err
}

Ejemplo

Los ejemplos de esta sección usan la siguiente estructura de Book como el modelo de datos para los documentos que se insertarían en una colección:

type Book struct {
	Title  string `bson:"title"`
	Author string `bson:"author"`
}

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. Cree una sesión desde el cliente utilizando el método StartSession().

2. Utilice 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. Cierre la transacción y la sesión utilizando 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 context.Context) (any, error) {
	result, err := coll.InsertMany(ctx, []any{
		Book{Title: "The Bluest Eye", Author: "Toni Morrison"},
		Book{Title: "Sula", Author: "Toni Morrison"},
		Book{Title: "Song of Solomon", Author: "Toni Morrison"},
	})
	return result, err
}, txnOptions)

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())
err = mongo.WithSession(context.TODO(), session, func(ctx context.Context) error {
	if err = session.StartTransaction(txnOptions); err != nil {
		return err
	}
	docs := []any{
		Book{Title: "The Year of Magical Thinking", Author: "Joan Didion"},
		Book{Title: "Play It As It Lays", Author: "Joan Didion"},
		Book{Title: "The White Album", Author: "Joan Didion"},
	}
	result, err := coll.InsertMany(ctx, docs)
	if err != nil {
		return err
	}
	if err = session.CommitTransaction(ctx); err != nil {
		return err
	}
	fmt.Println(result.InsertedIDs)
	return nil
})
if err != nil {
	if err := session.AbortTransaction(context.TODO()); err != nil {
		panic(err)
	}
	panic(err)
}

Información Adicional

Para obtener más información sobre las operaciones de inserción, consulte la página Fundamentos de Insertar documentos.

Para obtener más información sobre cómo especificar inquietudes de escritura en el controlador Go,consulte Inquietud de escritura.

Para obtener un ejemplo adicional del uso de sesiones y transacciones con el controlador Go, consulte la publicación del blog para desarrolladores sobre transacciones ACID de múltiples documentos.