D-Net

package eu.dnetlib.data.mapreduce.hbase.statsExport.utils;

import java.io.InputStream;

import java.util.Properties;

import org.apache.hadoop.conf.Configuration;

import org.apache.log4j.Logger;

import org.junit.Before;

import org.junit.Test;

import eu.dnetlib.data.mapreduce.hbase.statsExport.daos.SqlDAO;

import eu.dnetlib.data.mapreduce.hbase.statsExport.daos.SqlStore;

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

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

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

public class DaoTest {

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

    private SqlDAO statsDao;

    private SqlStore statsStore;

    private Properties props;

    @Before

    public void init() throws Exception {

        InputStream file = ClassLoader.getSystemResourceAsStream("eu/dnetlib/data/mapreduce/hbase/statsExport/StatsProperties");

        props = new Properties();

        props.load(file);

        file.close();

        statsStore = new SqlStore();

        statsStore.setDbDriver(props.getProperty("Stats_db_Driver"));

        statsStore.setDB_URL(props.getProperty("Stats_db_Url"));

        statsStore.setDbUser(props.getProperty("Stats_db_User"));

        statsStore.setDbPassword(props.getProperty("Stats_db_Pass"));

        statsDao = new SqlDAO();

        statsDao.setStore(statsStore);

    }

    @Test

    public void getReports() throws Exception {

        statsDao.generateReports();

    }

    @Test

    public void installProcedures() throws Exception {

        statsStore.getConnection();

        InputStream in = ClassLoader.getSystemResourceAsStream("eu/dnetlib/data/mapreduce/hbase/statsExport/reportProcedures.sql");

        byte[] b = new byte[in.available()];

        in.read(b);

        String q = new String(b);

        in.close();

        log.info(" Creating Report Procedures in Temporary  Database   ....");

        // CREATE USER 'jeffrey'@'localhost' IDENTIFIED BY 'mypass';

        try {

            statsStore.executeCommand(q);

        } catch (Exception e) {

            log.error("Could not create Report Procedures in  Temporary database  :" + e.getMessage());

            throw new Exception("Could not create Report Procedures   in Temporary database  :", e);

        } finally {

            statsStore.closeConnection();

        }

        log.info(" Done.");

    }

    // @Test

    public void executeExtraInserts() throws Exception {

        statsDao.executeExtraInserts();

    }

    // @Test

    public void buildIndexesDb() throws Exception {

        statsDao.executeExtraInserts();

    }

}