Class: MiniSql::Mysql::Connection

Inherits:
Connection show all
Defined in:
lib/mini_sql/mysql/connection.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from Connection

get

Constructor Details

#initialize(raw_connection, args = nil) ⇒ Connection

Returns a new instance of Connection.



8
9
10
11
12
 
# File 'lib/mini_sql/mysql/connection.rb', line 8

def initialize(raw_connection, args = nil)
  @raw_connection = raw_connection
  @param_encoder = (args && args[:param_encoder]) || InlineParamEncoder.new(self)
  @deserializer_cache = (args && args[:deserializer_cache]) || DeserializerCache.new
end

Instance Attribute Details

#deserializer_cache ⇒ Object (readonly)

Returns the value of attribute deserializer_cache.



6
7
8
 
# File 'lib/mini_sql/mysql/connection.rb', line 6

def deserializer_cache
  @deserializer_cache
end

#param_encoder ⇒ Object (readonly)

Returns the value of attribute param_encoder.



6
7
8
 
# File 'lib/mini_sql/mysql/connection.rb', line 6

def param_encoder
  @param_encoder
end

#raw_connection ⇒ Object (readonly)

Returns the value of attribute raw_connection.



6
7
8
 
# File 'lib/mini_sql/mysql/connection.rb', line 6

def raw_connection
  @raw_connection
end

Instance Method Details

#build(sql) ⇒ Object 



37
38
39
 
# File 'lib/mini_sql/mysql/connection.rb', line 37

def build(sql)
  Builder.new(self, sql)
end

#escape_string(str) ⇒ Object 



33
34
35
 
# File 'lib/mini_sql/mysql/connection.rb', line 33

def escape_string(str)
  raw_connection.escape(str)
end

#exec(sql, *params) ⇒ Object 



23
24
25
26
 
# File 'lib/mini_sql/mysql/connection.rb', line 23

def exec(sql, *params)
  run(sql, :array, params)
  raw_connection.affected_rows
end

#query(sql, *params) ⇒ Object 



28
29
30
31
 
# File 'lib/mini_sql/mysql/connection.rb', line 28

def query(sql, *params)
  result = run(sql, :array, params)
  @deserializer_cache.materialize(result)
end

#query_hash(sql, *params) ⇒ Object 



18
19
20
21
 
# File 'lib/mini_sql/mysql/connection.rb', line 18

def query_hash(sql, *params)
  result = run(sql, :hash, params)
  result.to_a
end

#query_single(sql, *params) ⇒ Object 



14
15
16
 
# File 'lib/mini_sql/mysql/connection.rb', line 14

def query_single(sql, *params)
  run(sql, :array, params).to_a.flatten!
end