Sha256: a4fed539e5f33c59a2d1486f748757ddf41e2c59dba5924fed11cef117633c87
Contents?: true
Size: 1.54 KB
Versions: 6
Compression:
Stored size: 1.54 KB
Contents
# encoding: utf-8
# This writer collects index change requests but does not submit them immediately to the database.
# The index changes are applied when the commit method is called.
# This writer is intended for internal use only. Do not use it in a xapian configuration!
# @author Gernot Kogler
module XapianDb
module IndexWriters
class TransactionalWriter
attr_reader :index_requests, :unindex_requests
# Constructor
def initialize
@index_requests = []
@unindex_requests = []
end
# Update an object in the index
# @param [Object] obj An instance of a class with a blueprint configuration
def index(obj)
@index_requests << obj
end
# Remove an object from the index
# @param [Object] obj An instance of a class with a blueprint configuration
def unindex(obj)
@unindex_requests << obj
end
# Reindex all objects of a given class
# @param [Class] klass The class to reindex
# @param [Hash] options Options for reindexing
# @option options [Boolean] :verbose (false) Should the reindexing give status informations?
def reindex_class(klass, options={})
raise "rebuild_xapian_index is not supported in transactions"
end
# Commit all pending changes to the database
# @param [DirectWriter, BeanstalkWriter] writer The writer to use
def commit_using(writer)
@index_requests.each { |obj| writer.index obj }
@unindex_requests.each { |obj| writer.unindex obj }
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems