Transações

Visão geral

Neste guia, você pode aprender como usar o MongoDB Go Driver para realizar transações. As transações permitem que você execute uma série de operações que não alteram nenhum dado até que a transação seja confirmada. Se alguma operação na transação retornar um erro, o driver cancelará a transação e descartará todas as alterações de dados antes que elas se tornem visíveis.

No MongoDB, as transações são executadas dentro de sessões lógicas. Uma sessão é um agrupamento de operações de leitura ou gravação relacionadas que você pretende executar sequencialmente. As sessões permitem consistência causal para um grupo de operações ou permitem que você execute operações em uma transação ACID. O MongoDB garante que os dados envolvidos em suas operações de transação permaneçam consistentes, mesmo que as operações encontrem erros inesperados.

Ao usar o driver Go, você pode criar uma nova sessão a partir de uma instância Client como tipo Session . Recomendamos que você reutilize seu cliente para várias sessões e transações, em vez de fazer a instância de um novo cliente a cada vez.

Métodos de sessão

Depois de iniciar uma sessão usando o método StartSession() em seu cliente, você pode modificar o estado da sessão usando o conjunto de métodos fornecido pelo Session retornado. A tabela a seguir descreve esses métodos:

Um Session também tem métodos para recuperar propriedades da sessão e modificar propriedades da sessão mutáveis. Consulte a documentação da API para saber mais sobre esses métodos.

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

Exemplo

Os exemplos nesta seção usam o seguinte struct Book como o modelo de dados para os documentos inserir em uma coleção:

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

O exemplo a seguir mostra como você pode criar uma sessão, criar uma transação e confirmar uma operação de inserção de vários documentos por meio das seguintes etapas:

1. Crie uma sessão a partir do cliente usando o método StartSession().

2. Use o método WithTransaction() para iniciar uma transação.

3. Insere vários documentos. O método WithTransaction() executa a inserção e confirma a transação. Se qualquer operação resultar em erros, o WithTransaction() lida com o cancelamento da transação.

4. Feche a transação e a sessão usando o 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)
}

Informações adicionais

Para obter mais informações sobre operações de inserção, consulte a página de fundamentos de Inserir Documentos.

Para obter mais informações sobre a especificação de write concerns no driver Go, consulte write concern.

Para obter um exemplo adicional usando sessões e transações com o driver Go, consulte a postagem do blog do desenvolvedor sobre Transações ACID de vários documentos.