Class: LogStash::Outputs::Jdbc

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/outputs/jdbc.rb

Overview

Write events to a SQL engine, using JDBC.

It is upto the user of the plugin to correctly configure the plugin. This includes correctly crafting the SQL statement, and matching the number of parameters correctly.

Constant Summary collapse

STRFTIME_FMT = 
'%Y-%m-%d %T.%L'.freeze
RETRYABLE_SQLSTATE_CLASSES = 
[
  # Classes of retryable SQLSTATE codes
  # Not all in the class will be retryable. However, this is the best that 
  # we've got right now.
  # If a custom state code is required, set it in retry_sql_states.
  '08', # Connection Exception
  '24', # Invalid Cursor State (Maybe retry-able in some circumstances)
  '25', # Invalid Transaction State 
  '40', # Transaction Rollback 
  '53', # Insufficient Resources
  '54', # Program Limit Exceeded (MAYBE)
  '55', # Object Not In Prerequisite State
  '57', # Operator Intervention
  '58', # System Error
].freeze

Instance Method Summary collapse

Instance Method Details

#close ⇒ Object 



128
129
130
131
132
 
# File 'lib/logstash/outputs/jdbc.rb', line 128

def close
  @stopping.make_true
  @pool.close
  super
end

#multi_receive(events) ⇒ Object 



122
123
124
125
126
 
# File 'lib/logstash/outputs/jdbc.rb', line 122

def multi_receive(events)
  events.each_slice(@flush_size) do |slice|
    retrying_submit(slice)
  end
end

#register ⇒ Object 



102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
 
# File 'lib/logstash/outputs/jdbc.rb', line 102

def register
  @logger.info('JDBC - Starting up')

  load_jar_files!

  @stopping = Concurrent::AtomicBoolean.new(false)

  @logger.warn('JDBC - Flush size is set to > 1000') if @flush_size > 1000

  if @statement.empty?
    @logger.error('JDBC - No statement provided. Configuration error.')
  end

  if !@unsafe_statement && @statement.length < 2
    @logger.error("JDBC - Statement has no parameters. No events will be inserted into SQL as you're not passing any event data. Likely configuration error.")
  end

  setup_and_test_pool!
end