Project

General

Profile

« Previous | Next » 

Revision 54703

Added by Claudio Atzori about 5 years ago

added operation to set the last validation jobId

View differences:

modules/dnet-openaire-datasource-manager/trunk/src/main/java/eu/dnetlib/enabling/datasources/LocalOpenaireDatasourceManagerImpl.java
39 39 
	private static final Resource setLastCollectionInfo = new ClassPathResource(QUERY_BASEDIR + "setLastCollectionInfo.sql");
40 40 
	private static final Resource setLastAggregationInfo = new ClassPathResource(QUERY_BASEDIR + "setLastAggregationInfo.sql");
41 41 
	private static final Resource setLastDownloadInfo = new ClassPathResource(QUERY_BASEDIR + "setLastDownloadInfo.sql");
42 
	private static final Resource setLastValidationJob = new ClassPathResource(QUERY_BASEDIR + "setLastValidationJob.sql");
42 43 
	private static final Resource resetLastOperationsInfo = new ClassPathResource(QUERY_BASEDIR + "resetLastOperationsInfo.sql");
43 44 
	private static final Resource insertApiParam = new ClassPathResource(QUERY_BASEDIR + "insertApiParam.sql");
44 45 
	private static final Resource insertApi = new ClassPathResource(QUERY_BASEDIR + "insertApi.sql");
......
225 226 
		setLastOperationInfo(setLastDownloadInfo, fixDsId(dsId), apiId, objId, size, date);
226 227 
	}
227 228 

  		




  
  229
  
    
	@Override


  		




  
  230
  
    
	public void setLastValidationJob(String dsId, String apiId, String jobId) throws DsmException {


  		




  
  231
  
    
		final Map<String, Object> params = new HashMap<>();


  		




  
  232
  
    
		params.put("dsId", dsId);


  		




  
  233
  
    
		params.put("apiId", apiId);


  		




  
  234
  
    
		params.put("jobId", jobId);


  		




  
  235
  
    

  		




  
  236
  
    
		datasourceManagerClients.updateSQL(dsId, setLastValidationJob, AfterSqlUpdate.NONE, params);


  		




  
  237
  
    
		setManaged(dsId, true); // It also update the IS profile


  		




  
  238
  
    
	}


  		




  
  239
  
    

  		




  228
  240
  
    
	@Transactional


  		




  229
  241
  
    
	protected void setLastOperationInfo(final Resource sqlResource, final String dsId, final String apiId, final String mdId, final Integer size, final Date date)


  		




  230
  242
  
    
			throws DsmException {


  		












  

    
      modules/dnet-openaire-datasource-manager/trunk/src/main/resources/eu/dnetlib/enabling/datasources/queries/setLastValidationJob.sql
    
  





  
  1
  
    
UPDATE dsm_api


  		




  
  2
  
    
SET (last_validation_job) = (:jobId)


  		




  
  3
  
    
WHERE id = :apiId AND datasource = :dsId


  		












  

    
      modules/dnet-datasource-manager-common/trunk/src/main/java/eu/dnetlib/enabling/datasources/common/LocalDatasourceManager.java
    
  





  27
  27
  
    

  		




  28
  28
  
    
	void setLastDownloadInfo(String dsId, String apiId, String objId, Integer size, Date date) throws DsmException;


  		




  29
  29
  
    

  		




  
  30
  
    
	void setLastValidationJob(String dsId, String apiId, String jobId) throws DsmException;


  		




  
  31
  
    

  		




  30
  32
  
    
	void updateApiDetails(String dsId, String apiId, String metadataIdentifierPath, String baseUrl, Map<String, String> params) throws DsmException;


  		




  31
  33
  
    

  		




  32
  34
  
    
	boolean isRemovable(String dsId, String apiId) throws DsmException;


  		












Also available in:  Unified diff