rails中Elasticsearch的客户端Tire配置

小木木

$ gem install tire   ||  https://github.com/karmi/retire
#加载

#model中加载tire模块 
class Article < ActiveRecord::Base
include Tire::Model::Search
include Tire::Model::Callbacks
end
#索引的名字
 index_name "#{Tire::Model::Search.index_prefix}<模型名字>"
 
#建立索引

  class Article < ActiveRecord::Base
include Tire::Model::Search
include Tire::Model::Callbacks
mapping do
indexes :id,           :index    => :not_analyzed
indexes :title,        :analyzer => 'snowball', :boost => 100
indexes :content,      :analyzer => 'snowball'
indexes :content_size, :as       => 'content.size'
indexes :author,       :analyzer => 'keyword'
indexes :published_on, :type => 'date', :include_in_all => false
end
end
# analyzer：分词【keyword，snowball…】  type：类型【string, integer, date ...】 boost：权重
 
# 创建json

class Article < ActiveRecord::Base
# 可以添加一些方法
def to_indexed_json
names      = author.split(/\W/)
last_name  = names.pop
first_name = names.join
{
:title   => title,
:content => content,
:author  => {
:first_name => first_name,
:last_name  => last_name
}
}.to_json
end
end
#... 添加方法
def is_admin? do
...
end
def to_indexed_json
to_json(
include: {:user{methods: [:is_admin?]}})
end
 
# 更新索引
 

    class Article < ActiveRecord::Base
include Tire::Model::Search
after_save do
update_index if state == 'published'
end
end
 
# 构建搜索的json数据

……
# 搜索方法，静态方法
DEFAULT_QUERY_FIELDS = ['title','des']
def self.search(params)  
# page：分页页数，per_page：每页的数量， highlight：高亮
# load：不加这个以为着要直接用elasticsearch搜索的json，通过 _source 或fields 取JSON属性，如果加上true 或 {include: user}，返回的结果有对象
tire.search(:page => (params[:page] || 1), per_page: 10, highlight: :name, load: true) do
# 表示查询项
query do
# 表示对比值
boolean do
term单一属性
must { term 'is_admin?', true }        
must { string (params[:q] || '*'), default_operator: "AND", fields: DEFAULT_QUERY_FIELDS }
end
end
# terms表述属性是[...], 与后面的交集
filter :terms, 'tags' => ['ruby', 'java']
## range 表示范围
filter :range, 'price' => {gte: 1}
filter :range, 'price' => {lte: 2}
# 表示被包含
facet 'global-tags', :global => true do
terms :tags
end
# 排序(添加时间索引 type:date)
sort { by 'created_at', "desc" }
end
end
……
 

简单类型：
String:字符型最常用的
Integer:整型
Long:长整型
Float:浮点型
Double:双字节型
Boolean：布尔型
复杂类型：
Array：数组型
Object:对象类型
Nested: 嵌入类型用的还是比较多的
multi_field允许为一个字段设置多个数据类型。应用multi_field的一个最典型的场景是："properties": { "created": { "type":"multi_field", "fields": { "created": { "type": "string" }, "date": { "type": "date"}}}}

     filter :nested, {path: 'cars'}.merge({query: (
Tire::Search::Query.new do
filtered do
query { all }
filter :range, 'cars.price' => {gte: params[:price_from].to_i} if params[:price_from].present?
filter :range, 'cars.price' => {lte: params[:price_to].to_i} if params[:price_to].present?
end
end).to_hash}) if params[:price_from].blank? && params[:price_to]
　　tire 删除索引（这个索引的数据已经被删除了）

def self.date_authen!(klass, result)
begin
result.results
rescue ActiveRecord::RecordNotFound => ex
index_ids = ex.message.split('(')[1].to_s.split(')')[0].to_s.split(',').map(&:to_i)
kass_ids = klass.where(id: index_ids).select(:id).map(&:id)
delete_ids = index_ids - kass_ids
delete_ids.each do |id|
klass.tire.index.remove(klass.name.tableize.singularize, id)
end
klass.tire.index.refresh
end
result
end
 
 
 [size=1em]Nested http://www.elasticsearch.org/blog/managing-relations-inside-elasticsearch/
 
 查看index：sudo ./bin/plugin -install mobz/elasticsearch-head