Changeset 401

Show
Ignore:
Timestamp:
04/20/09 20:31:59 (9 years ago)
Author:
samuraraujo
Message:
 
Files:
1 modified

Legend:

Unmodified
Added
Removed
  • Explorator/trunk/vendor/plugins/active_rdf/lib/active_rdf/federation/connection_pool.rb

    r387 r401  
    4141    self.write_adapter = nil 
    4242  end 
    43    def ConnectionPool.void 
    44    @@void 
     43  def ConnectionPool.void 
     44    @@void 
    4545  end 
    4646  def ConnectionPool.adapters 
     
    7070   
    7171  # returns adapter-instance for given parameters (either existing or new) 
    72   def ConnectionPool.add_data_source(connection_params) 
     72  def ConnectionPool.add_data_source(connection_params ) 
    7373    $activerdflog.info "ConnectionPool: add_data_source with params: #{connection_params.inspect}" 
    7474     
     
    8282      $activerdflog.debug("Create a new adapter for parameters #{connection_params.inspect}") 
    8383      adapter = create_adapter(connection_params) 
    84       @@adapter_parameters << connection_params 
    85       @@adapter_pool << adapter 
     84      # this is necessary because activerdf search in the order repositories were added 
     85      if adapter.title == 'INTERNAL'  
     86         
     87        @@adapter_parameters << connection_params 
     88        @@adapter_pool << adapter 
     89      else 
     90        @@adapter_parameters.insert(0,connection_params) 
     91        @@adapter_pool.insert(0,adapter) 
     92      end 
    8693    else 
    8794      # if adapter parametrs registered already, 
     
    102109  def ConnectionPool.remove_data_source(adapter) 
    103110    RDFS::Resource.reset_cache()  
    104       
     111     
    105112    $activerdflog.info "ConnectionPool: remove_data_source with params: #{adapter.to_s}" 
    106113     
     
    111118      @@adapter_parameters.delete_at(index) 
    112119      @@adapter_pool.delete_at(index) 
    113 #      if self.write_adapters.empty? 
    114 #        self.write_adapter = nil 
    115 #      else 
    116 #        self.write_adapter = self.write_adapters.first 
    117 #      end 
     120      #      if self.write_adapters.empty? 
     121      #        self.write_adapter = nil 
     122      #      else 
     123      #        self.write_adapter = self.write_adapters.first 
     124      #      end 
    118125       
    119126    end 
     
    141148  #find an sparql adapter by its uri 
    142149  def ConnectionPool.find_by_uri(uri) 
    143   
     150     
    144151    @@adapter_pool.each {|x| 
    145      if x.instance_of? SparqlAdapter 
    146   
    147        if x.url == uri 
    148          return x 
    149        end 
    150      end 
     152      if x.instance_of? SparqlAdapter 
     153         
     154        if x.url == uri 
     155          return x 
     156        end 
     157      end 
    151158    } 
    152159    return nil 
    153     
     160     
    154161  end 
    155162  # adapter-types can register themselves with connection pool by