как да извършвам транзакции с ruby ​​mysql2

Започнах да използвам mysql2 gem. Опитвам се да разбера няколко основни неща - едно от тях е как изрично да изпълнявам транзакции (за пакетни операции, като множество заявки INSERT/UPDATE).

В стария ruby-mysql това беше моят подход:

client  = Mysql.real_connect(...)
inserts = [
  "INSERT INTO ...",
  "UPDATE .. WHERE id=..",
  # etc
]

client.autocommit(false)
inserts.each do |ins|  
  begin
    client.query(ins)
  rescue
    # handle errors or abort entirely
  end
end
client.commit

Не можах да намеря много в документите - как може да се направи същото с mysql2?


ruby transactions batch-processing mysql2
person sa125    schedule 15.02.2012    source източник

Отговори (3)


arrow_upward
10
arrow_downward

Току-що направих внедряване:

class DBConnector
  def transaction(&block)
    raise ArgumentError, "No block was given" unless block_given?
    begin
      client.query("BEGIN")
      yield
      client.query("COMMIT")
    rescue
      client.query("ROLLBACK")
    end
  end
end

Така че можете да използвате така:

DBConnector.transaction do
  # your db queries here
end
person Bruno Coimbra    schedule 25.05.2012

arrow_upward
2
arrow_downward

Този въпрос ме направи любопитен, така че проследих как Ruby on Rails обработва транзакции и открих този код:

def begin_db_transaction
  execute "BEGIN"
rescue Exception
  # Transactions aren't supported
end

def commit_db_transaction #:nodoc:
  execute "COMMIT"
rescue Exception
  # Transactions aren't supported
end

def rollback_db_transaction #:nodoc:
  execute "ROLLBACK"
rescue Exception
  # Transactions aren't supported
end

Опитвали ли сте да изпълните израз begin и commit около другите си оператори?

client.query('begin')

inserts.each do |ins|  
  begin
    client.query(ins)
  rescue
    client.query('rollback')
    return
  end
end

client.query('commit')
person Michelle Tilley    schedule 15.02.2012

arrow_upward
0
arrow_downward

Използване на шаблона на Bruno, след което добавяне на индикатор за състояние на транзакция:

def transaction(&block)
    raise ArgumentError, "No block was given" unless block_given?
    begin
      raw_query("BEGIN")
      yield
      raw_query("COMMIT")
      return true # Successful Transaction
    rescue
      raw_query("ROLLBACK")
      return false # Failed Transaction
    end
end

Взаимодействие с #transaction:

def run_queries(queries)
    raise ArgumentError, "Invalid Queries Argument: #{queries}" unless queries.respond_to?(:each)
    success = transaction do
        queries.each do |q|
            raw_query(q)
        end
    end
    raise RuntimeError, "Transaction Failed for Queries: #{queries}" unless success
end
person Garren S    schedule 21.06.2013