lib/logstash/outputs/charrington/create_redshift_table.rb in logstash-output-charrington-0.3.1 vs lib/logstash/outputs/charrington/create_redshift_table.rb in logstash-output-charrington-0.3.2
- old
+ new
@@ -73,12 +73,10 @@
def create_table
execute("CREATE TABLE IF NOT EXISTS #{schema}#{table_name} (#{column_types.join(', ')}) diststyle key sortkey(received_at)")
end
def execute(sql)
- puts "CREATE SQL #{sql}"
statement = connection.prepareStatement( sql.gsub(/\s+/, " ").strip )
- puts "CREATE SQL #{sql}"
statement.execute()
rescue Java::JavaSql::SQLException => e
puts "Redshift SQLException: #{e.message}"
ensure
statement.close unless statement.nil?