module ActiveRecordShards::SqlComments::Methods

Public Instance Methods

execute(query, name = nil) click to toggle source
Calls superclass method
# File lib/active_record_shards/sql_comments.rb, line 5
def execute(query, name = nil)
  shard = ActiveRecord::Base.current_shard_selection.shard
  shard_text = shard ? "shard #{shard}" : 'unsharded'
  replica = ActiveRecord::Base.current_shard_selection.on_replica?
  replica_text = replica ? 'replica' : 'primary'
  query = "/* #{shard_text} #{replica_text} */ " + query
  super(query, name)
end