lib/fluent/plugin/in_mysql_appender.rb in fluent-plugin-mysql-appender-0.1.2 vs lib/fluent/plugin/in_mysql_appender.rb in fluent-plugin-mysql-appender-0.1.3

@@ -57,12 +57,12 @@
       max_id = -1
       loop do
         rows_count = 0
         start_time = Time.now
         if max_id == -1
-          select_query = @query + " order by #{primary_key} asc"
+          select_query = @query.gsub(/"/,'') + " order by #{primary_key} asc"
         else
-          select_query = @query + " where #{primary_key} > #{max_id} order by #{primary_key} asc"
+          select_query = @query.gsub(/"/,'') + " where #{primary_key} > #{max_id} order by #{primary_key} asc"
         end
         rows, con = query(select_query, con)
         rows.each_with_index do |row, index|
           tag = format_tag(@tag, {:event => :insert})
           row.each {|k, v| row[k] = v.to_s if v.is_a?(Time) || v.is_a?(Date) || v.is_a?(BigDecimal)}