Class: ActiveFedora::SolrService
- Inherits:
-
Object
- Object
- ActiveFedora::SolrService
- Includes:
- Loggable, Solrizer::FieldNameMapper
- Defined in:
- lib/active_fedora/solr_service.rb
Instance Attribute Summary collapse
-
#conn ⇒ Object
readonly
Returns the value of attribute conn.
Class Method Summary collapse
- .add(doc) ⇒ Object
- .class_from_solr_document(hit) ⇒ Object
- .commit ⇒ Object
-
.construct_query_for_pids(pid_array) ⇒ Object
Construct a solr query for a list of pids This is used to get a solr response based on the list of pids in an object’s RELS-EXT relationhsips If the pid_array is empty, defaults to a query of “id:NEVER_USE_THIS_ID”, which will return an empty solr response.
- .construct_query_for_rel(predicate, target_uri) ⇒ Object
- .escape_uri_for_query(uri) ⇒ Object
- .instance ⇒ Object
- .query(query, args = {}) ⇒ Object
- .register(host = nil, args = {}) ⇒ Object
- .reify_solr_results(solr_result, opts = {}) ⇒ Object
- .reset! ⇒ Object
Instance Method Summary collapse
-
#initialize(host, args) ⇒ SolrService
constructor
A new instance of SolrService.
Constructor Details
#initialize(host, args) ⇒ SolrService
Returns a new instance of SolrService.
22 23 24 25 26 27 |
# File 'lib/active_fedora/solr_service.rb', line 22 def initialize(host, args) host = 'http://localhost:8080/solr' unless host args = {:read_timeout => 120, :open_timeout => 120}.merge(args.dup) args.merge!(:url=>host) @conn = RSolr.connect args end |
Instance Attribute Details
#conn ⇒ Object (readonly)
Returns the value of attribute conn.
12 13 14 |
# File 'lib/active_fedora/solr_service.rb', line 12 def conn @conn end |
Class Method Details
.add(doc) ⇒ Object
90 91 92 |
# File 'lib/active_fedora/solr_service.rb', line 90 def self.add(doc) SolrService.instance.conn.add(doc) end |
.class_from_solr_document(hit) ⇒ Object
53 54 55 56 57 58 |
# File 'lib/active_fedora/solr_service.rb', line 53 def self.class_from_solr_document(hit) model_value = nil hit[solr_name("has_model", :symbol)].each {|value| model_value ||= Model.from_class_uri(value)} logger.warn "Could not find a model for #{hit["id"]}, defaulting to ActiveFedora::Base" unless model_value model_value || ActiveFedora::Base end |
.commit ⇒ Object
94 95 96 |
# File 'lib/active_fedora/solr_service.rb', line 94 def self.commit SolrService.instance.conn.commit end |
.construct_query_for_pids(pid_array) ⇒ Object
Construct a solr query for a list of pids This is used to get a solr response based on the list of pids in an object’s RELS-EXT relationhsips If the pid_array is empty, defaults to a query of “id:NEVER_USE_THIS_ID”, which will return an empty solr response
64 65 66 67 68 69 70 71 72 |
# File 'lib/active_fedora/solr_service.rb', line 64 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 |
.construct_query_for_rel(predicate, target_uri) ⇒ Object
78 79 80 |
# File 'lib/active_fedora/solr_service.rb', line 78 def self.construct_query_for_rel(predicate, target_uri) "#{solr_name(predicate, :symbol)}:#{escape_uri_for_query(target_uri)}" end |
.escape_uri_for_query(uri) ⇒ Object
74 75 76 |
# File 'lib/active_fedora/solr_service.rb', line 74 def self.escape_uri_for_query(uri) return uri.gsub(/(:)/, '\\:').gsub(/(\/)/, '\\/') end |
.instance ⇒ Object
29 30 31 32 33 34 35 36 37 38 |
# File 'lib/active_fedora/solr_service.rb', line 29 def self.instance # Register Solr unless Thread.current[:solr_service] register(ActiveFedora.solr_config[:url]) end raise SolrNotInitialized unless Thread.current[:solr_service] Thread.current[:solr_service] end |
.query(query, args = {}) ⇒ Object
82 83 84 85 86 87 88 |
# File 'lib/active_fedora/solr_service.rb', line 82 def self.query(query, args={}) raw = args.delete(:raw) args = args.merge(:q=>query, :qt=>'standard') result = SolrService.instance.conn.get('select', :params=>args) return result if raw result['response']['docs'] end |
.register(host = nil, args = {}) ⇒ Object
14 15 16 |
# File 'lib/active_fedora/solr_service.rb', line 14 def self.register(host=nil, args={}) Thread.current[:solr_service]=self.new(host, args) end |
.reify_solr_results(solr_result, opts = {}) ⇒ Object
40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/active_fedora/solr_service.rb', line 40 def self.reify_solr_results(solr_result,opts={}) results = [] solr_result.each do |hit| classname = class_from_solr_document(hit) if opts[:load_from_solr] results << classname.load_instance_from_solr(hit[SOLR_DOCUMENT_ID]) else results << classname.find(hit[SOLR_DOCUMENT_ID]) end end return results end |
.reset! ⇒ Object
18 19 20 |
# File 'lib/active_fedora/solr_service.rb', line 18 def self.reset! Thread.current[:solr_service] = nil end |