Class: Sunspot::Indexer

Inherits:

Object

• Object
• Sunspot::Indexer

show all

Includes:

RSolr::Char

Defined in:

sunspot/lib/sunspot/indexer.rb

Overview

Instance Method Summary (collapse)

• - (Object) add(model)

  Construct a representation of the model for indexing and send it to the connection for indexing.

• - (Object) flush_batch

  Write batch out to Solr and clear it.

• - (Indexer) initialize(connection) constructor

  A new instance of Indexer.

• - (Object) remove(*models)

  Remove the given model from the Solr index.

• - (Object) remove_all(clazz = nil)

  Delete all documents of the class indexed by this indexer from Solr.

• - (Object) remove_by_id(class_name, *ids)

  Remove the model from the Solr index by specifying the class and ID.

• - (Object) remove_by_scope(scope)

  Remove all documents that match the scope given in the Query.

• - (Object) start_batch

  Start batch processing.

11
12
13

# File 'sunspot/lib/sunspot/indexer.rb', line 11

def initialize(connection)
  @connection = connection
end

23
24
25
26
27
28
29
30

# File 'sunspot/lib/sunspot/indexer.rb', line 23

def add(model)
  documents = Util.Array(model).map { |m| prepare(m) }
  if @batch.nil?
    add_documents(documents)
  else
    @batch.concat(documents)
  end
end

78
79
80
81

# File 'sunspot/lib/sunspot/indexer.rb', line 78

def flush_batch
  add_documents(@batch)
  @batch = nil
end

35
36
37
38
39

# File 'sunspot/lib/sunspot/indexer.rb', line 35

def remove(*models)
  @connection.delete_by_id(
    models.map { |model| Adapters::InstanceAdapter.adapt(model).index_id }
  )
end

53
54
55
56
57
58
59

# File 'sunspot/lib/sunspot/indexer.rb', line 53

def remove_all(clazz = nil)
  if clazz
    @connection.delete_by_query("type:#{escape(clazz.name)}")
  else
    @connection.delete_by_query("*:*")
  end
end

44
45
46
47
48

# File 'sunspot/lib/sunspot/indexer.rb', line 44

def remove_by_id(class_name, *ids)
  @connection.delete_by_id(
    ids.map { |id| Adapters::InstanceAdapter.index_id_for(class_name, id) }
  )
end

64
65
66

# File 'sunspot/lib/sunspot/indexer.rb', line 64

def remove_by_scope(scope)
  @connection.delete_by_query(scope.to_boolean_phrase)
end

71
72
73

# File 'sunspot/lib/sunspot/indexer.rb', line 71

def start_batch
  @batch = []
end