Module: MultiTenant::DatabaseStatements
- Defined in:
- lib/activerecord-multi-tenant/query_rewriter.rb
Instance Method Summary collapse
- #delete(arel, name = nil, binds = []) ⇒ Object
- #join_to_delete(delete, *args) ⇒ Object
- #join_to_update(update, *args) ⇒ Object
- #update(arel, name = nil, binds = []) ⇒ Object
Instance Method Details
#delete(arel, name = nil, binds = []) ⇒ Object
250 251 252 253 254 255 256 |
# File 'lib/activerecord-multi-tenant/query_rewriter.rb', line 250 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? && MultiTenant.current_tenant_id.present? arel.where(MultiTenant::TenantEnforcementClause.new(model.arel_table[model.partition_key])) end super(arel, name, binds) end |
#join_to_delete(delete, *args) ⇒ Object
232 233 234 235 236 237 238 239 |
# File 'lib/activerecord-multi-tenant/query_rewriter.rb', line 232 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? && MultiTenant.current_tenant_id.present? delete.where(MultiTenant::TenantEnforcementClause.new(model.arel_table[model.partition_key])) end delete end |
#join_to_update(update, *args) ⇒ Object
223 224 225 226 227 228 229 230 |
# File 'lib/activerecord-multi-tenant/query_rewriter.rb', line 223 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? && MultiTenant.current_tenant_id.present? update.where(MultiTenant::TenantEnforcementClause.new(model.arel_table[model.partition_key])) end update end |
#update(arel, name = nil, binds = []) ⇒ Object
242 243 244 245 246 247 248 |
# File 'lib/activerecord-multi-tenant/query_rewriter.rb', line 242 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? && MultiTenant.current_tenant_id.present? arel.where(MultiTenant::TenantEnforcementClause.new(model.arel_table[model.partition_key])) end super(arel, name, binds) end |