Module: MultiTenant::DatabaseStatements

Defined in:
lib/activerecord-multi-tenant/query_rewriter.rb

Instance Method Summary collapse

Instance Method Details

#delete(arel, name = nil, binds = []) ⇒ Object



216
217
218
219
220
221
222
# File 'lib/activerecord-multi-tenant/query_rewriter.rb', line 216

def delete(arel, name = nil, binds = [])
  model = MultiTenant.multi_tenant_model_for_table(arel.ast.left.table_name)
  if model.present? && !MultiTenant.with_write_only_mode_enabled?
    arel.where(MultiTenant::TenantEnforcementClause.new(model.arel_table[model.partition_key]))
  end
  super(arel, name, binds)
end

#join_to_delete(delete, *args) ⇒ Object



198
199
200
201
202
203
204
205
# File 'lib/activerecord-multi-tenant/query_rewriter.rb', line 198

def join_to_delete(delete, *args)
  delete = super(delete, *args)
  model = MultiTenant.multi_tenant_model_for_table(delete.ast.left.table_name)
  if model.present? && !MultiTenant.with_write_only_mode_enabled?
    delete.where(MultiTenant::TenantEnforcementClause.new(model.arel_table[model.partition_key]))
  end
  delete
end

#join_to_update(update, *args) ⇒ Object



189
190
191
192
193
194
195
196
# File 'lib/activerecord-multi-tenant/query_rewriter.rb', line 189

def join_to_update(update, *args)
  update = super(update, *args)
  model = MultiTenant.multi_tenant_model_for_table(update.ast.relation.table_name)
  if model.present? && !MultiTenant.with_write_only_mode_enabled?
    update.where(MultiTenant::TenantEnforcementClause.new(model.arel_table[model.partition_key]))
  end
  update
end

#update(arel, name = nil, binds = []) ⇒ Object



208
209
210
211
212
213
214
# File 'lib/activerecord-multi-tenant/query_rewriter.rb', line 208

def update(arel, name = nil, binds = [])
  model = MultiTenant.multi_tenant_model_for_table(arel.ast.relation.table_name)
  if model.present? && !MultiTenant.with_write_only_mode_enabled?
    arel.where(MultiTenant::TenantEnforcementClause.new(model.arel_table[model.partition_key]))
  end
  super(arel, name, binds)
end