Transações

Visão geral

Neste guia, você pode aprender como usar o driver Kotlin para executar 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 qualquer 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 Kotlin , você pode criar uma nova sessão a partir de uma instância MongoClient como ClientSession. 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

Crie um ClientSession utilizando o método startSession() na sua instância do Client . Você pode então modificar o estado da sessão usando os seguintes métodos:

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

Exemplo

Este exemplo utiliza a seguinte classe de dados Kotlin para modelar seus documentos:

data class Account(
    val accountId: String,
    val amount: Int
)

O exemplo a seguir demonstra como criar uma sessão, criar uma transação e confirmar alterações em documentos existentes:

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

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

3. Atualize os documentos especificados e, em seguida, use o método commitTransaction() se todas as operações forem bem-sucedidas ou abortTransaction() se alguma operação falhar.

// Set up the session
val session = client.startSession()
try {
    session.startTransaction()
    val savingsColl = database
        .getCollection<Account>("savings_accounts")
    val checkingColl = database
        .getCollection<Account>("checking_accounts")
    savingsColl.findOneAndUpdate(
        session,
        eq(Account::accountId.name, "9876"),
        inc(Account::amount.name, -100),
    )
    checkingColl.findOneAndUpdate(
        session,
        eq(Account::accountId.name, "9876"),
        inc(Account::amount.name, 100)
    )
    // Commit the transaction
    val result = session.commitTransaction()
    println("Transaction committed.")
} catch (error: Exception) {
    println("An error occurred during the transaction: ${error.message}")
    // Abort the transaction
    session.abortTransaction()
}

Informações adicionais

Para saber mais sobre os conceitos mencionados neste guia, consulte as seguintes páginas no manual do servidor:

• Transações

• Sessões do servidor

• Isolamento de leitura, consistência e atualidade

Para saber mais sobre a ACID compliance, consulte Quais são as propriedades ACID nos sistemas de gerenciamento de banco de dados? artigo no site do MongoDB .