D-Net

public abstract class ConnectDB {

    private static String dbURL;

    private static String dbUsername;

        sql = "DROP VIEW IF EXISTS  result_views_monthly_tmp";

        stmt.executeUpdate(sql);

        sql = "DROP TABLE IF EXISTS piwiklogtmp;";

        stmt.executeUpdate(sql);

        int batch_size = 0;

        JSONParser parser = new JSONParser();

        for (String jsonFile : jsonFiles) {

            JSONArray jsonArray = (JSONArray) parser.parse(readHDFSFile(jsonFile));

            for (Object aJsonArray : jsonArray) {

        String sql = "INSERT INTO piwiklogtmp SELECT DISTINCT source, id_visit, country, action, url, roid.orid, \'oaItem\', timestamp, referrer_name, agent FROM process_portal_log_tmp, public.result_oids roid WHERE entity_id IS NOT null AND entity_id=roid.orid AND roid.orid IS NOT null;";

        stmt.executeUpdate(sql);

//        con.commit();

        stmt = con.createStatement();

        sql = "INSERT INTO piwiklogtmp SELECT DISTINCT source, id_visit, country, action, url, roid.orid, \'datasource\', timestamp, referrer_name, agent FROM process_portal_log_tmp, public.datasource_oids roid WHERE entity_id IS NOT null AND entity_id=roid.orid AND roid.orid IS NOT null;";

        stmt.executeUpdate(sql);

//        con.commit();

        stmt = con.createStatement();

        sql = "INSERT INTO piwiklogtmp SELECT DISTINCT source, id_visit, country, action, url, roid.orid, \'organization\', timestamp, referrer_name, agent FROM process_portal_log_tmp, public.organization_oids roid WHERE entity_id IS NOT null AND entity_id=roid.orid AND roid.orid IS NOT null;";

        stmt.executeUpdate(sql);

//        con.commit();

        stmt = con.createStatement();

        sql = "INSERT INTO piwiklogtmp SELECT DISTINCT source, id_visit, country, action, url, roid.orid, \'project\', timestamp, referrer_name, agent FROM process_portal_log_tmp, public.project_oids roid WHERE entity_id IS NOT null AND entity_id=roid.orid AND roid.orid IS NOT null;";

        stmt.executeUpdate(sql);

        stmt.close();

    }

    private void cleanOAI() throws Exception {

        sql = "insert into pageviews_stats select * from pageviews_stats_tmp;";

        stmt.executeUpdate(sql);

        stmt.close();

        ConnectDB.getConnection().commit();

        ConnectDB.getConnection().close();