Contents

require 'deadly_serious/engine/json_io'

module DeadlySerious
  module Processes
    module DbSource
      def run(writer)
        run(JsonIo.new(writer))
      end

      def for_each_record(sql)
        connection.select_all(sql).each do |row|
          yield row
        end
      end
    end
  end
end

Version data entries

23 entries across 23 versions & 1 rubygems

Version	Path
deadly_serious-0.12.0	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.11.0	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.10.0	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.9.5	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.9.4	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.9.3	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.9.2	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.9.1	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.9.0	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.8.1	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.8.0	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.7.0	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.6.1	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.6.0	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.5.3	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.5.2	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.5.1	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.5.0	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.4.1	lib/deadly_serious/processes/db_source.rb
deadly_serious-0.4.0	lib/deadly_serious/processes/db_source.rb