Sha256: c3ebec8c58230af1ae7824db181f7770e6b0c7e4a98c8c43d0f2549422519378

Contents?: true

Size: 661 Bytes

Versions: 6

Compression:

Stored size: 661 Bytes

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