Project

General

Profile

1 26600 sandro.lab
package eu.dnetlib.msro.workflows.nodes.index;
2
3
import org.apache.commons.logging.Log;
4
import org.apache.commons.logging.LogFactory;
5
6
import com.googlecode.sarasvati.NodeToken;
7
8
import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;
9
import eu.dnetlib.msro.workflows.nodes.BlackboardJobNode;
10
11
public class DeleteIndexJobNode extends BlackboardJobNode {
12
13
	private static final Log log = LogFactory.getLog(DeleteIndexJobNode.class);
14
15
	private String indexId;
16 29694 sandro.lab
	private String defaultIndexId;
17 26600 sandro.lab
18
	@Override
19
	protected String getXqueryForServiceId(final NodeToken token) {
20
		return "collection('/db/DRIVER/ServiceResources/IndexServiceResourceType')//RESOURCE_IDENTIFIER/@value/string()";
21
	}
22
23
	@Override
24
	protected void prepareJob(final BlackboardJob job, final NodeToken token) throws Exception {
25
		log.info("deleting index id = " + getIndexId());
26
27
		job.setAction("DELETE");
28
		job.getParameters().put("id", getIndexId());
29 29694 sandro.lab
		job.getParameters().put("backend_Id", defaultIndexId);
30 26600 sandro.lab
31
	}
32
33
	public String getIndexId() {
34
		return indexId;
35
	}
36
37
	public void setIndexId(final String indexId) {
38
		this.indexId = indexId;
39
	}
40 30101 sandro.lab
41
	public String getDefaultIndexId() {
42
		return defaultIndexId;
43
	}
44
45
	public void setDefaultIndexId(final String defaultIndexId) {
46
		this.defaultIndexId = defaultIndexId;
47
	}
48 26600 sandro.lab
}