Module: Apartment::Adapters::PostgresqlTransactionState

Included in:
PostgresqlDatabaseAdapter, PostgresqlSchemaAdapter
Defined in:
lib/apartment/adapters/postgresql_transaction_state.rb

Overview

PostgreSQL's aborted-transaction state, shared by both PG adapters (schema-per-tenant and database-per-tenant). Their implementations are identical, so this is the DRY seam rather than two copies.

A failed statement inside a transaction moves the connection to PQTRANS_INERROR, where every subsequent statement raises PG::InFailedSqlTransaction until the transaction ends. Apartment heals this at pool checkin; see docs/designs/transaction-taint-detection.md.

Instance Method Summary collapse

Instance Method Details

#aborted_transaction?(conn) ⇒ Boolean

Returns:

  • (Boolean) 


14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
# File 'lib/apartment/adapters/postgresql_transaction_state.rb', line 14

def aborted_transaction?(conn)
  # NOT conn.raw_connection. That is the escape hatch for code about to *use*
  # the driver, so it materializes lazy transactions, marks the connection
  # dirty, and CONNECTS one that was never connected — at every checkin, on
  # every pooled connection, which defeats Rails' lazy connect and burns a
  # backend per tenant pool. We only read a status flag, so we take the handle
  # directly. `connected?` keeps us off the never-connected path.
  return false unless conn.connected?

  raw = conn.instance_variable_get(:@raw_connection)
  return false unless raw.respond_to?(:transaction_status)

  raw.transaction_status == ::PG::PQTRANS_INERROR
rescue StandardError
  # A connection too broken to report its own status is not ours to classify;
  # AR's own verify!/reconnect path owns that case.
  false
end