Contents

module Octopus::Migration
  def self.extended(base)
    class << base
      def connection
        ActiveRecord::Base.connection_proxy()
      end
    end
  end

  def using(*args)
    if args.size == 1
      self.connection().block = true
      self.connection().current_shard = args.first
    else
      self.connection().current_shard = args        
    end

    return self
  end

  def using_group(*args)
    if args.size == 1
      self.connection().block = true
      self.connection().current_group = args.first
    else
      self.connection().current_group = args
    end

    return self
  end
end


ActiveRecord::Migration.extend(Octopus::Migration)

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
ar-octopus-0.0.8	lib/octopus/migration.rb
ar-octopus-0.0.7	lib/octopus/migration.rb
ar-octopus-0.0.6	lib/octopus/migration.rb
ar-octopus-0.0.5	lib/octopus/migration.rb
ar-octopus-0.0.4	lib/octopus/migration.rb
ar-octopus-0.0.3	lib/octopus/migration.rb