Class: MiniSql::Sqlite::Connection
- Inherits:
-
Connection
- Object
- Connection
- MiniSql::Sqlite::Connection
- Defined in:
- lib/mini_sql/sqlite/connection.rb
Instance Attribute Summary collapse
-
#deserializer_cache ⇒ Object
readonly
Returns the value of attribute deserializer_cache.
-
#param_encoder ⇒ Object
readonly
Returns the value of attribute param_encoder.
-
#raw_connection ⇒ Object
readonly
Returns the value of attribute raw_connection.
Instance Method Summary collapse
- #escape_string(str) ⇒ Object
- #exec(sql, *params) ⇒ Object
-
#initialize(raw_connection, args = nil) ⇒ Connection
constructor
A new instance of Connection.
- #query(sql, *params) ⇒ Object
- #query_hash(sql, *params) ⇒ Object
- #query_single(sql, *params) ⇒ Object
Methods inherited from Connection
Constructor Details
#initialize(raw_connection, args = nil) ⇒ Connection
Returns a new instance of Connection.
8 9 10 11 12 |
# File 'lib/mini_sql/sqlite/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/sqlite/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/sqlite/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/sqlite/connection.rb', line 6 def raw_connection @raw_connection end |
Instance Method Details
#escape_string(str) ⇒ Object
49 50 51 |
# File 'lib/mini_sql/sqlite/connection.rb', line 49 def escape_string(str) str.gsub("'","''") end |
#exec(sql, *params) ⇒ Object
29 30 31 32 33 34 35 36 37 38 39 40 41 |
# File 'lib/mini_sql/sqlite/connection.rb', line 29 def exec(sql, *params) start = raw_connection.total_changes r = run(sql, *params) # this is not safe for multithreading, also for DELETE from TABLE will return # incorrect data if r.length > 0 r.length else raw_connection.total_changes - start end end |
#query(sql, *params) ⇒ Object
43 44 45 46 47 |
# File 'lib/mini_sql/sqlite/connection.rb', line 43 def query(sql, *params) run(sql, *params) do |set| deserializer_cache.materialize(set) end end |
#query_hash(sql, *params) ⇒ Object
19 20 21 22 23 24 25 26 27 |
# File 'lib/mini_sql/sqlite/connection.rb', line 19 def query_hash(sql, *params) r = [] run(sql, *params) do |set| set.each_hash do |h| r << h end end r end |
#query_single(sql, *params) ⇒ Object
14 15 16 17 |
# File 'lib/mini_sql/sqlite/connection.rb', line 14 def query_single(sql, *params) # a bit lazy can be optimized run(sql, *params).flatten! end |