Transações

Visão geral

Neste guia, você aprenderá como usar as transações com o driver Go do MongoDB . Astransaçõ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 qualquer operação da transação falhar, o driver abortará 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 escrita 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 ACID transaction. O MongoDB garante que os dados envolvidos em suas operações de transação permaneçam , mesmo que as operações encontrem erros inesperados.

Com o driver Go, você pode criar uma nova sessão a partir de uma instância Client como tipo Session .

Métodos

Após iniciar uma sessão utilizando o método StartSession() , você pode modificar o estado da sessão utilizando o conjunto de métodos fornecido pela interface do Session . A tabela a seguir descreve esses métodos:

A interface do Session também tem métodos para recuperar propriedades da sessão e modificar propriedades da sessão mutáveis. Encontre mais informações na documentação da API.

Exemplo

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 utilizando 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.New(writeconcern.WMajority())
txnOptions := options.Transaction().SetWriteConcern(wc)
session, err := client.StartSession()
if err != nil {
	panic(err)
}
defer session.EndSession(context.TODO())
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)

Se você precisar de mais controle sobre suas transações, poderá encontrar um exemplo mostrando como criar, confirmar e cancelar transações manualmente no exemplo de código completo.

Informações adicionais

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

Para obter mais informações sobre write concerns, consulte a página de fundamentos do Modify Execution of CRUD Operations .

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.