Method: Fluent::RedshiftOutput::RedshiftConnection#exec

Defined in:
lib/fluent/plugin/out_redshift-out.rb

#exec(sql, &block) ⇒ Object 



308
309
310
311
312
313
314
315
316
317
318
319
320
 
# File 'lib/fluent/plugin/out_redshift-out.rb', line 308

def exec(sql, &block)
  conn = @connection
  conn = create_redshift_connection if conn.nil?
  if block
    conn.exec(sql) {|result| block.call(result)}
  else
    conn.exec(sql)
  end
rescue PG::Error => e
  raise RedshiftError.new(e)
ensure
  conn.close if conn && @connection.nil?
end