gistfile1.rb

module Octopus
    module Querying

        def find_by_sql(sql, binds = [])
            p sql
            p binds
            if binds.present?
                key = 'user_id'
                v = binds.collect { |x| [x.first.name, x.second] }.to_h[key]
                shard = if v.to_i >= 100
                    :new_contact_1
                else
                    :new_contact_0
                end
            elsif sql.is_a?(Arel::SelectManager)
                puts 'select'
            end
            if shard
                Octopus.using(shard) { super }
            else
                super
            end
        end

    end
end

ActiveRecord::Base.extend(Octopus::Querying)