Project

General

Profile

« Previous | Next » 

Revision 42184

oai import

View differences:

DropStoreAction.java
2 2

  
3 3
import javax.annotation.Resource;
4 4

  
5
import eu.dnetlib.data.oai.store.mongo.MongoPublisherStoreDAO;
6
import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;
7
import eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler;
8
import org.apache.commons.lang.StringUtils;
5
import org.apache.commons.lang3.StringUtils;
9 6
import org.apache.commons.logging.Log;
10 7
import org.apache.commons.logging.LogFactory;
11 8

  
9
import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;
10
import eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler;
11
import eu.dnetlib.oai.mongo.MongoPublisherStoreDAO;
12

  
12 13
public class DropStoreAction extends AbstractOAIStoreAction {
13 14

  
14 15
	private static final Log log = LogFactory.getLog(DropStoreAction.class); // NOPMD by marko on 11/24/08 5:02 PM
......
18 19

  
19 20
	@Override
20 21
	public void execute(final BlackboardServerHandler handler, final BlackboardJob job) throws Exception {
21
		String mdformat = job.getParameters().get("format");
22
		String layout = job.getParameters().get("layout");
23
		String interp = job.getParameters().get("interpretation");
24
		String dbName = job.getParameters().get("oai_dbName");
25
		String set = job.getParameters().get("set");
22
		final String mdformat = job.getParameters().get("format");
23
		final String layout = job.getParameters().get("layout");
24
		final String interp = job.getParameters().get("interpretation");
25
		final String dbName = job.getParameters().get("oai_dbName");
26
		final String set = job.getParameters().get("set");
26 27
		boolean deleted = false;
27 28
		if (StringUtils.isNotBlank(set)) {
28
			deleted = mongoPublisherStoreDAO.deleteFromStore(mdformat, interp, layout, dbName, set);
29
			deleted = this.mongoPublisherStoreDAO.deleteFromStore(mdformat, interp, layout, dbName, set);
29 30
		} else {
30 31
			deleted = this.mongoPublisherStoreDAO.deleteStore(mdformat, interp, layout, dbName);
31 32
		}

Also available in: Unified diff