Class: PgPipeline::Transaction

Inherits:

Session

• Object
• Session
• PgPipeline::Transaction

Defined in:

lib/pg_pipeline/transaction.rb

Instance Attribute Summary

Attributes inherited from Session

#owner_fiber

Instance Method Summary

• #initialize(conn) ⇒ Transaction constructor

  A new instance of Transaction.

• #open? ⇒ Boolean
• #run(&block) ⇒ Object
• #savepoint(name = nil, &block) ⇒ Object

Methods inherited from Session

#active?, #exec, #exec_prepared, #prepare, #query

Constructor Details

#initialize(conn) ⇒ Transaction

Returns a new instance of Transaction.

# File 'lib/pg_pipeline/transaction.rb', line 9

def initialize(conn)
  super
  @open = false
  @savepoint_seq = 0
end

Instance Method Details

#open? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/pg_pipeline/transaction.rb', line 23

def open? = @open

#run(&block) ⇒ Object

# File 'lib/pg_pipeline/transaction.rb', line 15

def run(&block)
  TransactionOps.run(self, &block)
end

#savepoint(name = nil, &block) ⇒ Object

# File 'lib/pg_pipeline/transaction.rb', line 19

def savepoint(name = nil, &block)
  TransactionOps.savepoint(self, name, &block)
end