A minha sugestão é a adoção do padrão Unidade de Trabalho (Unit of Work). A sua definição é basicamente:
Mantém uma lista de objetos afetados por uma transação de objetos de negócio e coordena a escrita de mudanças e a resolução de problemas de concorrência.
Vou dar um exemplo simplificado de implementação desse padrão aqui, sei que ele é muito mais complexo e extenso, mas acho que isso atenderá suas necessidades. Estarei utilizando junto o padrão de repositório também, mas acredito que seja facilmente adaptável a outros padrões de acesso a dados como DAL.
Começamos definindo uma interface para a Unidade de Trabalho. Isso porque acessos a diferentes banco de dados ou diferentes formas de acesso a dados (ADO.Net direto ou ORM) iriam mudar a implementação concreta da Unidade de Tranalho.
Public Interface IUnidadeTrabalho
Inherits IDisposable
Sub Commit()
Sub Rollback()
Function CreateCommand() As IDbCommand
End Interface
Então, para instanciar a Unidade de Trabalho, utilizamos um Factory, no qual já definimos a conexão e a deixamos pronta para uso.
Public Class UnidadeTrabalhoFactory
Public Shared Function Criar() As IUnidadeTrabalho
Dim conexao As MySqlConnection = New MySqlConnection("MinhaConexao")
conexao.Open()
Return New UnidadeTrabalhoAdo(conexao, True)
End Function
End Class
E aqui a implementação concreta da Unidade de Trabalho, utilizando ADO.Net. Sua função é bem simples: Recebe a conexão por parâmetro e abre uma transação. A partir daí, o controle do que vai ou não ser executado no banco de dados depende dela, com as ações Commit
ou Rollback
. Ela também é responsável por retornar o DbCommand
que será executado no banco, que já estará ligado à transação aberta:
Public Class UnidadeTrabalhoAdo
Implements IUnidadeTrabalho
Private _conexao As IDbConnection
Private _transacao As IDbTransaction
Public Sub New(ByRef conexao As IDbConnection)
Me._conexao = conexao
Me._transacao = conexao.BeginTransaction()
End Sub
Public Function CreateCommand() As IDbCommand Implements IUnidadeTrabalho.CreateCommand
Dim command As IDbCommand = _conexao.CreateCommand()
command.Transaction = _transacao
Return command
End Function
Public Sub Commit() Implements IUnidadeTrabalho.Commit
If (IsNothing(_transacao)) Then
Throw New InvalidOperationException("Não há transação aberta.")
End If
_transacao.Commit()
_transacao = Nothing
End Sub
Public Sub Rollback() Implements IUnidadeTrabalho.Rollback
If (IsNothing(_transacao)) Then
Throw New InvalidOperationException("Não há transação aberta.")
End If
_transacao.Rollback()
_transacao = Nothing
End Sub
Public Sub Dispose() Implements IDisposable.Dispose
If (Not IsNothing(_transacao)) Then
_transacao.Dispose()
_transacao = Nothing
End If
If (Not IsNothing(_conexao)) Then
Me._conexao.Close()
Me._conexao = Nothing
End If
End Sub
End Class
Aqui estou sugerindo a implementação de repositório para o seu negócio. A unidade de trabalho é injetada via construtor e o comando do banco deve ser feito a partir dela.
Public Class EstoqueRepositorio
Private _unidadeTrabalho As IUnidadeTrabalho
Public Sub New(ByRef unidadeTrabalho As IUnidadeTrabalho)
Me._unidadeTrabalho = unidadeTrabalho
End Sub
Function DarBaixaNoEstoque()
Dim command As IDbCommand = Me._unidadeTrabalho.CreateCommand()
command.CommandText = "INSERT INTO ..."
REM código aqui
End Function
End Class
Public Class CaixaRepositorio
Private _unidadeTrabalho As IUnidadeTrabalho
Public Sub New(ByRef unidadeTrabalho As IUnidadeTrabalho)
Me._unidadeTrabalho = unidadeTrabalho
End Sub
Function AdicionarDinheiroAoCaixa()
REM código aqui
End Function
End Class
Public Class ClienteRepositorio
Private _unidadeTrabalho As IUnidadeTrabalho
Public Sub New(ByRef unidadeTrabalho As IUnidadeTrabalho)
Me._unidadeTrabalho = unidadeTrabalho
End Sub
Function AdicionarProdutoAoCliente()
REM código aqui
End Function
End Class
E aqui finalmente onde tudo acontece de verdade. Quando chamar a ação de vender, uma nova instância da Unidade de Trabalho deve ser criada e injetada em cada um dos repositórios. Enquanto o método Commit
da Unidade de Trabalho não for chamado, nada irá ser enviado ao banco. Caso haja algum erro, o bloco Catch
será o lugar para fazer o Rollback
. Por fim, deve ser chamado o Dispose
para liberar a conexão.
Public Sub Vender()
Dim unidadeTrabalho As IUnidadeTrabalho = UnidadeTrabalhoFactory.Criar()
Try
Dim repositorioEstoque = New EstoqueRepositorio(unidadeTrabalho)
Dim repositorioCaixa = New CaixaRepositorio(unidadeTrabalho)
Dim repositorioCliente = New ClienteRepositorio(unidadeTrabalho)
repositorioEstoque.DarBaixaNoEstoque()
repositorioCaixa.AdicionarDinheiroAoCaixa()
repositorioCliente.AdicionarProdutoAoCliente()
unidadeTrabalho.Commit()
Catch ex As Exception
unidadeTrabalho.Rollback()
Finally
unidadeTrabalho.Dispose()
End Try
End Sub