EDIT

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import org.apache.commons.compress.compressors.gzip.GzipCompressorInputStream;

import org.apache.commons.compress.compressors.gzip.GzipUtils;

import org.apache.commons.compress.utils.IOUtils;

import org.apache.commons.io.FileUtils;

import org.apache.commons.io.FilenameUtils;

import org.apache.http.client.ClientProtocolException;

import org.apache.http.client.methods.CloseableHttpResponse;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.impl.client.CloseableHttpClient;

import org.apache.http.impl.client.HttpClients;

import org.apache.jena.tdb.TDBFactory;

import org.apache.jena.tdb.base.file.Location;

    private Opmode opmode = null;

    private final String baseUri;

    private File rdfFile = null;

    private Dataset dataset = null;

    public enum Opmode{

        SPARCLE_ENDPOINT, RDF_ARCHIVE;

    }

    public SparqlClient(String baseUri, Opmode opmode) {

        this.opmode = opmode;

        if(opmode.equals(Opmode.RDF_ARCHIVE)) {

            if(baseUri != null) {

                this.rdfFile = downloadAndExtract();

            }

            try {

                createStore();

            } catch (IOException e) {

                // TODO Auto-generated catch block

                e.printStackTrace();

            }

        }

     *

    private File downloadAndExtract() {

        File expandedFile = null;

        CloseableHttpClient httpClient = HttpClients.createDefault();

        CloseableHttpResponse response;

        try {

            // 1. download and store in local filesystem in TMP

            logger.debug("downloading rdf file from " + baseUri);

            HttpGet httpGet = new HttpGet(baseUri);

            response = httpClient.execute(httpGet);

            String archiveFileName = FilenameUtils.getName(httpGet.getURI().getRawPath());

            File archiveFile = new File(tmpDir, archiveFileName);

            FileOutputStream fout = new FileOutputStream(archiveFile);

            IOUtils.copy(response.getEntity().getContent(), new FileOutputStream(archiveFile));

            fout.close();

            logger.debug(archiveFile.length() + " bytes downloaded to " + archiveFile.getCanonicalPath());

            // 2. extract the archive

            FileInputStream fin = new FileInputStream(archiveFile);

            InputStream ain = null;

            if(GzipUtils.isCompressedFilename(archiveFileName)) {

                logger.debug("Extracting GZIP file " + archiveFile.getCanonicalPath());

                ain = new GzipCompressorInputStream(fin);

            } else {

                // TO UNZIP

                //ArchiveInputStream ain = new ArchiveStreamFactory().createArchiveInputStream(ArchiveStreamFactory.ZIP, fin);

            }

            expandedFile = new File(tmpDir, GzipUtils.getUncompressedFilename(archiveFileName));

            fout = new FileOutputStream(expandedFile);

            IOUtils.copy(ain, fout);

            fout.close();

            fin.close();

            logger.debug("Extracted to " + expandedFile.getCanonicalPath());

        } catch (ClientProtocolException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (IOException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

        return expandedFile;

    /**

     * WARNING!!! This needs at least 1.5GB of heap space!!!

     * set -Xmx1500M

     *

     * NOTE: The bulkloader is a faster way to load data into an empty dataset than just using the Jena update operations.

     * the bulkloader also requires less memory

     * It is accessed through the command line utility tdbloader.

     *

     * rm /tmp/drf_tnb_store/*; bin/tdbloader2 -l /tmp/drf_tnb_store /tmp/species.rdf

     * @throws IOException

     */

    private void createStore() throws IOException {

        boolean doClearStoreLocation = rdfFile != null;

        boolean doLoadRdfFile = rdfFile != null;

        File tdbStoreFolder = new File(utisHome, "tdb" + File.separator);

        if(tdbStoreFolder.exists()) {

            if( doClearStoreLocation ) {

                FileUtils.cleanDirectory(tdbStoreFolder);

            }

        } else {

            tdbStoreFolder.mkdirs();

        }

        Location location = Location.create(tdbStoreFolder.toString());

        Dataset dataset = TDBFactory.createDataset(location);

        logger.info("Using TDB store at " + location);

        dataset.begin(ReadWrite.READ) ;

        // Get model inside the transaction

        Model model = dataset.getDefaultModel() ;

        logger.info("Dataset in TDB has " + dataset.asDatasetGraph().size() + " named graphs");

        logger.info("Model-size: " + model.size());

        dataset.end();

        if(doLoadRdfFile) {

            dataset.begin(ReadWrite.WRITE);

            model = dataset.getDefaultModel();

            // parse InputStream as RDF in Turtle format

            InputStream fin = new FileInputStream(rdfFile);

            logger.info("loading RDF/XML into TDB store");

            model.read(fin, null, "RDF/XML");

            logger.info("loading RDF/XML done");

            logger.info("Dataset in TDB has " + dataset.asDatasetGraph().size() + " named graphs");

            logger.info("Model-size: " + model.size());

            dataset.commit();

            dataset.end();

            logger.info("rdf loaded into TDB store at " + tdbStoreFolder);

        }

        this.dataset = dataset;

    }

            if(dataset != null) {

                dataset.begin(ReadWrite.READ) ;

        if(dataset != null) {

            dataset.end();

        QueryExecution qe;

        if(opmode.equals(Opmode.SPARCLE_ENDPOINT)) {

            qe = QueryExecutionFactory.sparqlService(baseUri, query);

        } else {

            qe = QueryExecutionFactory.create(queryString, dataset);

        return qe;

        if(dataset != null) {

    /**

     * @return the rdfFile

     */

    public File getRdfFile() {

        return rdfFile;

    }