Class: PgPipeline::Session

Inherits:
Object
  • Object
show all
Defined in:
lib/pg_pipeline/session.rb

Direct Known Subclasses

Transaction

Constant Summary collapse

EMPTY_PARAMS = 
[].freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(conn) ⇒ Session

Returns a new instance of Session.



11
12
13
14
15
 
# File 'lib/pg_pipeline/session.rb', line 11

def initialize(conn)
  @conn = conn
  @active = true
  @owner_fiber = Fiber.current
end

Instance Attribute Details

#owner_fiber ⇒ Object (readonly)

Returns the value of attribute owner_fiber.



9
10
11
 
# File 'lib/pg_pipeline/session.rb', line 9

def owner_fiber
  @owner_fiber
end

Instance Method Details

#active? ⇒ Boolean

Returns:

  • (Boolean) 


21
 
# File 'lib/pg_pipeline/session.rb', line 21

def active? = @active

#exec(sql, params = nil) ⇒ Object 



18
 
# File 'lib/pg_pipeline/session.rb', line 18

def exec(sql, params = nil) = SessionOps.exec(self, sql, params)

#exec_prepared(name, params = EMPTY_PARAMS) ⇒ Object 



20
 
# File 'lib/pg_pipeline/session.rb', line 20

def exec_prepared(name, params = EMPTY_PARAMS) = SessionOps.exec_prepared(self, name, params)

#prepare(name, sql, param_types = nil) ⇒ Object 



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

def prepare(name, sql, param_types = nil) = SessionOps.prepare(self, name, sql, param_types)

#query(sql, params = EMPTY_PARAMS) ⇒ Object 



17
 
# File 'lib/pg_pipeline/session.rb', line 17

def query(sql, params = EMPTY_PARAMS) = SessionOps.query(self, sql, params)