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