- set default position to 0 so we don't miss the first row of a log

table
- remove debug print
This commit is contained in:
Jordan Sissel 2013-05-28 23:28:00 -07:00
parent f638e379f8
commit d8d863b222

View file

@ -86,7 +86,6 @@ class LogStash::Inputs::Sqlite < LogStash::Inputs::Base
def get_placeholder(db, table)
since = db[SINCE_TABLE]
x = since.where(:table => "#{table}")
p x
if x[:place].nil?
init_placeholder(db, table)
return 0
@ -100,7 +99,7 @@ class LogStash::Inputs::Sqlite < LogStash::Inputs::Base
def init_placeholder(db, table)
@logger.debug("init placeholder for #{table}")
since = db[SINCE_TABLE]
since.insert(:table => table, :place => 1)
since.insert(:table => table, :place => 0)
end
public