Project

General

Profile

« Previous | Next » 

Revision 53526

Added by Michele Artini over 5 years ago

ovveride an sql query

View differences:

modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/consistency/FindInvalidRepoProfilesJobNode.java
1 1 
package eu.dnetlib.msro.openaireplus.workflows.nodes.consistency;
2 2 

  		




  
  3
  
    
import java.util.HashMap;


  		




  3
  4
  
    
import java.util.List;


  		




  4
  5
  
    
import java.util.Map;


  		




  5
  6
  
    
import java.util.concurrent.atomic.AtomicInteger;


  		




  ......




  14
  15
  
    
import com.googlecode.sarasvati.NodeToken;


  		




  15
  16
  
    

  		




  16
  17
  
    
import eu.dnetlib.enabling.datasources.LocalOpenaireDatasourceManager;


  		




  
  18
  
    
import eu.dnetlib.enabling.datasources.LocalOpenaireDatasourceManagerImpl;


  		




  17
  19
  
    
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;


  		




  18
  20
  
    
import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService;


  		




  19
  21
  
    
import eu.dnetlib.enabling.locators.UniqueServiceLocator;


  		




  ......




  41
  43
  
    
	@Override


  		




  42
  44
  
    
	protected String execute(final NodeToken token) throws Exception {


  		




  43
  45
  
    

  		




  44
  
  
    
		final Map<String, AtomicInteger> validIds = dsManager.listManagedDatasourceIds().stream().collect(Collectors.toMap(s -> s, s -> new AtomicInteger(0)));


  		




  
  46
  
    
		final Map<String, AtomicInteger> validIds = ((LocalOpenaireDatasourceManagerImpl) dsManager).getDatasourceManagerClients()


  		




  
  47
  
    
				.searchSQL("SELECT id FROM dsm_datasources", new HashMap<>())


  		




  
  48
  
    
				.stream()


  		




  
  49
  
    
				.map(m -> (String) m.get("id"))


  		




  
  50
  
    
				.collect(Collectors.toMap(s -> s, s -> new AtomicInteger(0)));


  		




  45
  51
  
    

  		




  46
  52
  
    
		final List<String> list = serviceLocator.getService(ISLookUpService.class).quickSearchProfile(


  		




  47
  53
  
    
				"for $x in collection('/db/DRIVER/RepositoryServiceResources/RepositoryServiceResourceType') return concat($x//DATASOURCE_ORIGINAL_ID, ' @@@ ', $x//RESOURCE_IDENTIFIER/@value)");


  		












Also available in:  Unified diff