Sha256: 8beb8a7dd77474e30b3cd485716932fc4c16b752670c21cabd7a3050a8ff43de
Contents?: true
Size: 1.91 KB
Versions: 16
Compression:
Stored size: 1.91 KB
Contents
require 'solr'
require "solrizer"
module ActiveFedora
class SolrService
include Solrizer::FieldNameMapper
include Loggable
load_mappings
attr_reader :conn
def self.register(host=nil, args={})
Thread.current[:solr_service]=self.new(host, args)
end
def initialize(host, args)
host = 'http://localhost:8080/solr' unless host
opts = {:autocommit=>:on}.merge(args)
@conn = Solr::Connection.new(host, opts)
end
def self.instance
raise SolrNotInitialized unless Thread.current[:solr_service]
Thread.current[:solr_service]
end
def self.reify_solr_results(solr_result,opts={})
unless solr_result.is_a?(Solr::Response::Standard)
raise ArgumentError.new("Only solr responses (Solr::Response::Standard) are allowed. You provided a #{solr_result.class}")
end
results = []
solr_result.hits.each do |hit|
model_value = hit[solr_name("active_fedora_model", :symbol)].first
if model_value.include?("::")
classname = eval(model_value)
else
classname = Kernel.const_get(model_value)
end
if opts[:load_from_solr]
results << classname.load_instance_from_solr(hit[SOLR_DOCUMENT_ID])
else
results << Fedora::Repository.instance.find_model(hit[SOLR_DOCUMENT_ID], classname)
end
end
return results
end
def self.construct_query_for_pids(pid_array)
query = ""
pid_array.each_index do |i|
query << "#{SOLR_DOCUMENT_ID}:#{escape_uri_for_query(pid_array[i])}"
query << " OR " if i != pid_array.length-1
end
query = "id:NEVER_USE_THIS_ID" if query.empty? || query == "id:"
return query
end
def self.escape_uri_for_query(uri)
return uri.gsub(/(:)/, '\\:')
end
end #SolrService
class SolrNotInitialized < StandardError;end
end #ActiveFedora
Version data entries
16 entries across 16 versions & 1 rubygems