Module: Switchman::ActiveRecord::Base
- Defined in:
- lib/switchman/active_record/base.rb
Defined Under Namespace
Modules: ClassMethods
Class Method Summary collapse
Instance Method Summary collapse
- #clone ⇒ Object
- #destroy ⇒ Object
- #hash ⇒ Object
- #initialize_dup(*args) ⇒ Object
- #save(*args) ⇒ Object
- #save!(*args) ⇒ Object
- #scope_class ⇒ Object
- #shard ⇒ Object
- #shard=(new_shard) ⇒ Object
- #to_param ⇒ Object
- #transaction(options = {}, &block) ⇒ Object
Class Method Details
.included(klass) ⇒ Object
70 71 72 73 74 75 76 77 78 79 80 81 |
# File 'lib/switchman/active_record/base.rb', line 70 def self.included(klass) klass.extend(ClassMethods) klass.set_callback(:initialize, :before) do unless @shard if self.class.sharded_primary_key? @shard = Shard.shard_for(self[self.class.primary_key], Shard.current(self.class.shard_category)) else @shard = Shard.current(self.class.shard_category) end end end end |
Instance Method Details
#clone ⇒ Object
115 116 117 118 119 120 121 122 |
# File 'lib/switchman/active_record/base.rb', line 115 def clone result = super # TODO: adjust foreign keys # don't use the setter, cause the foreign keys are already # relative to this shard result.instance_variable_set(:@shard, self.shard) result end |
#destroy ⇒ Object
111 112 113 |
# File 'lib/switchman/active_record/base.rb', line 111 def destroy scope_class.shard(shard, :implicit).scoping { super } end |
#hash ⇒ Object
130 131 132 |
# File 'lib/switchman/active_record/base.rb', line 130 def hash self.class.sharded_primary_key? ? global_id.hash : super end |
#initialize_dup(*args) ⇒ Object
139 140 141 142 143 |
# File 'lib/switchman/active_record/base.rb', line 139 def initialize_dup(*args) copy = super @shard_set_in_stone = false copy end |
#save(*args) ⇒ Object
101 102 103 104 |
# File 'lib/switchman/active_record/base.rb', line 101 def save(*args) @shard_set_in_stone = true scope_class.shard(shard, :implicit).scoping { super } end |
#save!(*args) ⇒ Object
106 107 108 109 |
# File 'lib/switchman/active_record/base.rb', line 106 def save!(*args) @shard_set_in_stone = true scope_class.shard(shard, :implicit).scoping { super } end |
#scope_class ⇒ Object
97 98 99 |
# File 'lib/switchman/active_record/base.rb', line 97 def scope_class self.class.base_class end |
#shard ⇒ Object
83 84 85 |
# File 'lib/switchman/active_record/base.rb', line 83 def shard @shard || Shard.current(self.class.shard_category) || Shard.default end |
#shard=(new_shard) ⇒ Object
87 88 89 90 91 92 93 94 95 |
# File 'lib/switchman/active_record/base.rb', line 87 def shard=(new_shard) raise ::ActiveRecord::ReadOnlyRecord if !self.new_record? || @shard_set_in_stone if shard != new_shard attributes.each do |attr, value| self[attr] = Shard.relative_id_for(value, shard, new_shard) if self.class.sharded_column?(attr) end @shard = new_shard end end |
#to_param ⇒ Object
134 135 136 137 |
# File 'lib/switchman/active_record/base.rb', line 134 def to_param short_id = Shard.short_id_for(id) short_id && short_id.to_s end |
#transaction(options = {}, &block) ⇒ Object
124 125 126 127 128 |
# File 'lib/switchman/active_record/base.rb', line 124 def transaction(={}, &block) shard.activate(self.class.shard_category) do self.class.transaction(, &block) end end |