Class: Pgtk::Pool::Txn
- Inherits:
-
Object
- Object
- Pgtk::Pool::Txn
- Defined in:
- lib/pgtk/pool.rb
Overview
A temporary class to execute a single SQL request.
Instance Method Summary collapse
-
#exec(query, args = [], result = 0) {|Hash| ... } ⇒ Object
Exec a single parameterized command.
-
#initialize(conn, log) ⇒ Txn
constructor
A new instance of Txn.
Constructor Details
#initialize(conn, log) ⇒ Txn
Returns a new instance of Txn.
152 153 154 155 |
# File 'lib/pgtk/pool.rb', line 152 def initialize(conn, log) @conn = conn @log = log end |
Instance Method Details
#exec(query, args = [], result = 0) {|Hash| ... } ⇒ Object
Exec a single parameterized command.
162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 |
# File 'lib/pgtk/pool.rb', line 162 def exec(query, args = [], result = 0) start = Time.now sql = query.is_a?(Array) ? query.join(' ') : query begin out = if args.empty? @conn.exec(sql) do |res| if block_given? yield res else res.each.to_a end end else @conn.exec_params(sql, args, result) do |res| if block_given? yield res else res.each.to_a end end end rescue StandardError => e @log.error("#{sql}: #{e.}") raise e end lag = Time.now - start if lag < 1 @log.debug("#{sql}: #{(lag * 1000).round}ms / #{@conn.object_id}") else @log.info("#{sql}: #{format('%.02f', lag)}s") end out end |