Contents

require 'upsert/buffer/pg_connection/column_definition'
require 'upsert/buffer/pg_connection/merge_function'

class Upsert
  class Buffer
    # @private
    class PG_Connection < Buffer
      def ready
        return if rows.empty?
        row = rows.shift
        MergeFunction.execute self, row
      end

      def clear_database_functions
        MergeFunction.clear self
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
upsert-0.5.0	lib/upsert/buffer/pg_connection.rb