Changeset 152

Timestamp:

11/17/08 16:14:39 (5 years ago)

Author:

samuraraujo

Message:

 

Files:

• activerdf-1.6.10/lib/active_rdf/federation/federation_manager.rb (modified) (4 diffs)

activerdf-1.6.10/lib/active_rdf/federation/federation_manager.rb

@@ -11 +11 @@
     ConnectionPool.write_adapter.add(s,p,o)
   end
-
+  
   # delete triple s,p,o from the currently selected write adapter (s and p are 
   # mandatory, o is optional, symbols are interpreted as wildcards)
@@ -23 +23 @@
     adapter.reset_cache()
     RDFS::Resource.reset_cache()
-
+    
   end
-
+  
   # executes read-only queries
   # by distributing query over complete read-pool
   # and aggregating the results
-  def FederationManager.query(q, options={:flatten => true})
-   
-                if ConnectionPool.read_adapters.empty?
-                        raise ActiveRdfError, "cannot execute query without data sources" 
-                end
-    
+  def FederationManager.query(q, options={:flatten => true})   
+    if ConnectionPool.read_adapters.empty?
+      raise ActiveRdfError, "cannot execute query without data sources" 
+    end   
     # ask each adapter for query results
     # and yield them consequtively
@@ -49 +47 @@
       # were filtered out when doing results.union)
       results = []
-      ConnectionPool.read_adapters.each do |source|         
-                                source_results = source.query(q)
-                                source_results.each do |clauses|
-                                        results << clauses
-                        end
-                        end
- 
+      ConnectionPool.read_adapters.each do |source|    
+        #verifies if the repository was enabled by the Explorator's user.
+        begin
+          if (Thread.current[:disablerepositories].include? source.title) 
+            next
+          end
+        rescue    
+          #outside the Explorator.
+        end
+        source_results = source.query(q)
+        source_results.each do |clauses|
+          results << clauses
+        end
+        
+      end
+      
       # filter the empty results
       results.reject {|ary| ary.empty? }
-
+      
       # remove duplicate results from multiple
       # adapters if asked for distinct query
@@ -64 +71 @@
       # but they cannot check duplicates against each other)
       results.uniq! if q.distinct?
-
+      
       # flatten results array if only one select clause
       # to prevent unnecessarily nested array [[eyal],[renaud],...]
       results.flatten! if q.select_clauses.size == 1 or q.ask?
-    
+      
       # remove array (return single value or nil) if asked to
       if options[:flatten] or q.count?
         case results.size
-        when 0
+          when 0
           results = nil
-        when 1
+          when 1
           results = results.first
-                                end
-                        end
+        end
+      end
     end    
     results