Sha256: 1e36646cc0a44e564dc37d1de8069eab66533677fedb6b87e4a2853bc563b8d6
Contents?: true
Size: 922 Bytes
Versions: 30
Compression:
Stored size: 922 Bytes
Contents
# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/plugin_mixins/jdbc_streaming/parameter_handler"
describe LogStash::PluginMixins::JdbcStreaming::ParameterHandler do
context "resolve field reference" do
let(:event) { ::LogStash::Event.new("field" => "field_value") }
it "should resolve root field" do
handler = LogStash::PluginMixins::JdbcStreaming::ParameterHandler.build_bind_value_handler "[field]"
handler.extract_from(event)
expect(handler.extract_from(event)).to eq "field_value"
end
it "should resolve nested field" do
event = ::LogStash::Event.from_json("{\"field\": {\"nested\": \"nested_field\"}}").first
handler = LogStash::PluginMixins::JdbcStreaming::ParameterHandler.build_bind_value_handler "[field][nested]"
handler.extract_from(event)
expect(handler.extract_from(event)).to eq "nested_field"
end
end
end
Version data entries
30 entries across 30 versions & 1 rubygems