Class: Honker::Transaction

Inherits:
Object
  • Object
show all
Defined in:
lib/honker/transaction.rb

Overview

Wraps a SQLite transaction with helpers that thread SQL through a stable connection handle. Matches the shape of the Rust binding's Transaction — execute and query_row route to the underlying connection, which *_tx methods (Queue#enqueue_tx, Stream#publish_tx, Stream#save_offset_tx, Database#notify_tx) use to stay inside the open transaction.

Obtain one via Database#transaction do |tx| ... end. The block auto-commits on normal return and auto-rolls-back on exception; the wrapping sqlite3 gem handles the BEGIN/COMMIT/ROLLBACK for us. Callers may also invoke tx.rollback! mid-block to abort without raising.

Defined Under Namespace

Classes: Rollback

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(conn) ⇒ Transaction

Returns a new instance of Transaction.



22
23
24
25
 
# File 'lib/honker/transaction.rb', line 22

def initialize(conn)
  @conn = conn
  @rolled_back = false
end

Instance Attribute Details

#conn ⇒ Object (readonly)

The raw SQLite3::Database underneath. Exposed as conn to mirror the Rust shape for advanced users who need prepare or other APIs not wrapped here.



20
21
22
 
# File 'lib/honker/transaction.rb', line 20

def conn
  @conn
end

Instance Method Details

#execute(sql, params = []) ⇒ Object

Execute a SQL statement inside the transaction.



28
29
30
 
# File 'lib/honker/transaction.rb', line 28

def execute(sql, params = [])
  @conn.execute(sql, params)
end

#query_row(sql, params = []) ⇒ Object

Run a query and return the first row (or nil).



33
34
35
 
# File 'lib/honker/transaction.rb', line 33

def query_row(sql, params = [])
  @conn.get_first_row(sql, params)
end

#rollback! ⇒ Object

Abort the transaction early. Raises Transaction::Rollback internally so the outer sqlite3-gem block sees an exception and rolls back; we then swallow it at the Database#transaction boundary.

Raises:



41
42
43
44
 
# File 'lib/honker/transaction.rb', line 41

def rollback!
  @rolled_back = true
  raise Rollback
end

#rolled_back? ⇒ Boolean

Returns:

  • (Boolean) 


46
47
48
 
# File 'lib/honker/transaction.rb', line 46

def rolled_back?
  @rolled_back
end