Contents

# Copyright (c) 2011, SoundCloud Ltd., Rany Keddo, Tobias Bielohlawek, Tobias
# Schmidt

require File.expand_path(File.dirname(__FILE__)) + '/integration_helper'

require 'lhm'
require 'lhm/table'
require 'lhm/migration'

describe Lhm::Chunker do
  include IntegrationHelper

  before(:each) { connect_master! }

  describe "copying" do
    before(:each) do
      @origin = table_create(:origin)
      @destination = table_create(:destination)
      @migration = Lhm::Migration.new(@origin, @destination)
    end

    it "should copy 23 rows from origin to destination" do
      23.times { |n| execute("insert into origin set id = '#{ n * n + 23 }'") }

      Lhm::Chunker.new(@migration, connection, { :stride => 100 }).run

      slave do
        count_all(@destination.name).must_equal(23)
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 2 rubygems

Version	Path
sbader-lhm-1.1.0	spec/integration/chunker_spec.rb
lhm-1.1.0	spec/integration/chunker_spec.rb
lhm-1.0.3	spec/integration/chunker_spec.rb
lhm-1.0.2	spec/integration/chunker_spec.rb
lhm-1.0.0.rc7	spec/integration/chunker_spec.rb
lhm-1.0.0.rc6	spec/integration/chunker_spec.rb
lhm-1.0.0.rc5	spec/integration/chunker_spec.rb
lhm-1.0.0.rc4	spec/integration/chunker_spec.rb
lhm-1.0.0.rc3	spec/integration/chunker_spec.rb