D-Net

package eu.dnetlib.iis.core.workflows.stats;

import eu.dnetlib.data.mapreduce.hbase.statsExport.drivers.DBDriver;

import eu.dnetlib.iis.core.java.HadoopContext;

import eu.dnetlib.iis.core.java.PortBindings;

import eu.dnetlib.iis.core.java.Process;

import eu.dnetlib.iis.core.java.porttype.PortType;

import org.apache.log4j.Logger;

import java.util.HashMap;

import java.util.Map;

/**

 * @author eri

 * 

 *         Simple Wrapper for preparing the Database for the Import

 */

public class DBInitWrapper implements Process {

	private Logger log = Logger.getLogger(this.getClass());

	private DBDriver dbDriver;

	@Override

	public void run(PortBindings portBindings, HadoopContext context, Map<String, String> parameters) throws Exception {

		dbDriver = new DBDriver(parameters.get("Stats_db_Url"), 

				parameters.get("Stats_db_User"), 

				parameters.get("Stats_db_Pass"), 

				parameters.get("Stats_db_Driver"));

		try {

			dbDriver.prepareDB(parameters.get("Stats_db_User"));

		} catch (Exception ex) {

			log.error("Failed to prepare database schema on :" + parameters.get("Stats_db_Url") + "for " + parameters.get("Stats_db_User") + ex);

			throw new Exception("Failed to prepare schema on :" + parameters.get("Stats_db_Url")+"for "+ parameters.get("Stats_db_User"), ex);

		}

	}

	@Override

	public Map<String, PortType> getInputPorts() {

		return createInputPorts();

	}

	@Override

	public Map<String, PortType> getOutputPorts() {

		return createOutputPorts();

	}

	private static HashMap<String, PortType> createInputPorts() {

		HashMap<String, PortType> inputPorts = new HashMap<String, PortType>();

		return inputPorts;

	}

	private static HashMap<String, PortType> createOutputPorts() {

		HashMap<String, PortType> outputPorts = new HashMap<String, PortType>();

		return outputPorts;

	}

}