Class: PgPipeline::Session

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

Direct Known Subclasses

Transaction

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(conn) ⇒ Session

Returns a new instance of Session.



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

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.



7
8
9
 
# File 'lib/pg_pipeline/session.rb', line 7

def owner_fiber
  @owner_fiber
end

Instance Method Details

#active? ⇒ Boolean

Returns:

  • (Boolean) 


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

def active? = @active

#exec(sql, params = nil) ⇒ Object 



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

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

#exec_prepared(name, params = []) ⇒ Object 



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

def exec_prepared(name, params = []) = SessionOps.exec_prepared(self, name, params)

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



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

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

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



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

def query(sql, params = []) = SessionOps.query(self, sql, params)