Sha256: f3f85befbdb7f7573d98f29a5fd4a17dd663c56a7d1039793dcaf7e2b62512b3
Contents?: true
Size: 1.43 KB
Versions: 13
Compression:
Stored size: 1.43 KB
Contents
Sequel.extension :pg_json, :pg_json_ops
module Mobility
module Backend
class Sequel::Jsonb::QueryMethods < Sequel::QueryMethods
def initialize(attributes, **)
super
attributes_extractor = @attributes_extractor
define_method :_filter_or_exclude do |invert, clause, *conds, &block|
if (clause == :where) && i18n_keys = attributes_extractor.call(conds.first)
locale = Mobility.locale.to_s
table_name = model.table_name
cond = conds.first
i18n_query = i18n_keys.inject(::Sequel.expr(!invert)) do |expr, attr|
value = cond.delete(attr)
attr_jsonb = ::Sequel.pg_jsonb_op(attr)
contains_value = attr_jsonb.contains({ locale => value })
has_key = attr_jsonb.has_key?(locale)
if invert
expr.|(has_key & ~contains_value)
else
expr.&(value.nil? ? ~has_key : contains_value)
end
end
super(invert, clause, *conds, &block).where(i18n_query)
else
super(invert, clause, *conds, &block)
end
end
attributes.each do |attribute|
define_method :"first_by_#{attribute}" do |value|
where(::Sequel.pg_jsonb_op(attribute).contains({ Mobility.locale => value })).
select_all(model.table_name).first
end
end
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems