Module: AssOle::Snippets::Shared::InTransactionDo

Defined in:
lib/ass_ole/snippets/shared/in_transaction_do.rb

Overview

Mixin for wrapping execution into 1C transaction.

Examples:

#!/sbin/env ruby

require 'ass_ole'
require 'ass_ole/snippets/shred/in_transaction_do'

PLATFORM_REQUIRE = '~> 8.3.10.0'

# External connection runtime for accounting infobase
module AccountingRuntime
  is_ole_runtime :external
end

# External connection runtime for HRM infobase
module HrmRuntime
  is_ole_runtime :external
end

# Worker do anything in accounting infobase
class AcctWorker
  like_ole_runtime AccountingRuntime
  include AssOle::Snipptes::Shared::InTransactionDo

  attr_reader :ib
  def initialize(connection_string)
    @ib = AssMaintainer::InfoBase
      .new('accounting', connection_string, PLATFORM_REQUIRE)
    ole_runtime_get.run ib #connect to infobase
  end

  def action_one
    #NOP
  end

  def action_two(action_one_result)
    #NOP
  end

  def make_job_in_transaction
    in_transaction do
      make_job
    end
  end

  def make_job
    action_two(action_one)
  end
end

# Worker do anything in HRM infobase
class HrmWorker
  like_ole_runtime HrmRuntime
  include AssOle::Snipptes::Shared::InTransactionDo

  attr_reader :ib
  def initialize(connection_string)
    @ib = AssMaintainer::InfoBase
      .new('accounting', connection_string, PLATFORM_REQUIRE)
    ole_runtime_get.run ib #connect to infobase
  end

  def action_one(acct_result)
    #NOP
  end

  def action_two(acct_result)
    #NOP
  end

  def make_job(acct_result)
    action_one(acct_result)
    action_two(acct_reult)
    true
  end
end

module Programm
  # It working like distributed transaction
  def self.execute_in_nested_transaction(acct_cs, hrm_cs)
    # Trasaction in HrmWorker committed  automatically
    HrmWorker.new(hrm_cs).in_transaction do |hrm_worker|
      # Trasaction in AcctWorker keep alive
      acct_result = AcctWorker.new(acct_cs).in_transaction(false) do |acct_worker|
        acct_worker.make_job
      end
      result = hrm_worker.make_job(acct_result)
      #Commit AcctWorker transaction
      acct_worker._commit_transaction_
      result
    end
  end
end

#Do in accounting infobase only
puts AcctWorker.new(ARGV[0]).make_job_in_transaction

#Do in accounting and hrm infobases
puts Programm.execute_in_nested_transaction(ARGV[0], ARGV[1])

Instance Method Summary collapse

Instance Method Details

#_begin_transaction_(managed_lock = false) ⇒ Object 



128
129
130
131
132
 
# File 'lib/ass_ole/snippets/shared/in_transaction_do.rb', line 128

def _begin_transaction_(managed_lock = false)
  ole_connector.beginTransaction unless managed_lock
  ole_connector.beginTransaction ole_connector
    .dataLockControlMode.Managed if managed_lock
end

#_commit_transaction_ ⇒ Object 



138
139
140
 
# File 'lib/ass_ole/snippets/shared/in_transaction_do.rb', line 138

def _commit_transaction_
  ole_connector.commitTransaction
end

#_rollback_transaction_ ⇒ Object 



134
135
136
 
# File 'lib/ass_ole/snippets/shared/in_transaction_do.rb', line 134

def _rollback_transaction_
  ole_connector.rollBackTransaction
end

#in_transaction(auto_commit = true, managed_lock = false) { ... } ⇒ Object

Wrap execution in 1C transaction. If execution failure transaction always rolledback!

Yields:

  • self



113
114
115
116
117
118
119
120
121
122
123
124
 
# File 'lib/ass_ole/snippets/shared/in_transaction_do.rb', line 113

def in_transaction(auto_commit = true, managed_lock = false, &block)
  fail 'Block require' unless block_given?
  _begin_transaction_ managed_lock
  begin
    result = yield self
    _commit_transaction_ if auto_commit
  rescue Exception => e
    _rollback_transaction_
    fail e
  end
  result
end