+
−package nl.cwi.monetdb.mcl.connection;
+
−
+
−import nl.cwi.monetdb.embedded.env.MonetDBEmbeddedDatabase;
+
−import nl.cwi.monetdb.embedded.env.MonetDBEmbeddedException;
+
−import nl.cwi.monetdb.mcl.MCLException;
+
−import nl.cwi.monetdb.mcl.io.*;
+
−import nl.cwi.monetdb.mcl.parser.MCLParseException;
+
−
+
−import java.io.*;
+
−import java.net.SocketException;
+
−import java.util.List;
+
−
+
−/**
+
− * Created by ferreira on 11/23/16.
+
− */
+
−public final class EmbeddedMonetDB extends AbstractMonetDBConnection {
+
−
+
−    private final String directory;
+
−
+
−    private InternalConnection connection;
+
−
+
−    public EmbeddedMonetDB(String database, String hash, boolean debug, MonetDBLanguage lang, String directory) throws IOException {
+
−        super(database, hash, debug, lang);
+
−        this.directory = directory;
+
−    }
+
−
+
−    public String getDirectory() {
+
−        return directory;
+
−    }
+
−
+
−    @Override
+
−    public List<String> connect(String user, String pass) throws IOException, MCLParseException, MCLException {
+
−        try {
+
−            if(MonetDBEmbeddedDatabase.IsDatabaseRunning() && !MonetDBEmbeddedDatabase.GetDatabaseDirectory().equals(this.directory)) {
+
−                throw new MCLException("The embedded database is already running on a different directory!");
+
−            } else {
+
−                MonetDBEmbeddedDatabase.StartDatabase(this.directory, true, false);
+
−            }
+
−            this.connection = MonetDBEmbeddedDatabase.AddJDBCEmbeddedConnection();
+
−        } catch (MonetDBEmbeddedException ex) {
+
−            throw new MCLException(ex);
+
−        }
+
−        return null;
+
−    }
+
−
+
−    @Override
+
−    public synchronized void close() {
+
−        super.close();
+
−        try {
+
−            MonetDBEmbeddedDatabase.StopDatabase();
+
−        } catch (MonetDBEmbeddedException e) {
+
−            // ignore it
+
−        }
+
−    }
+
−
+
−    @Override
+
−    public String getJDBCURL() {
+
−        return "jdbc:monetdb://localhost@" + this.getDirectory() + "/" + this.getDatabase();
+
−    }
+
−
+
−    @Override
+
−    public int getBlockSize() {
+
−        return Integer.MAX_VALUE;
+
−    }
+
−
+
−    @Override
+
−    public int getSoTimeout() throws SocketException {
+
−        throw new IllegalArgumentException("Cannot get a timeout on a embedded connection!");
+
−    }
+
−
+
−    @Override
+
−    public void setSoTimeout(int s) throws SocketException {
+
−        throw new IllegalArgumentException("Cannot set a timeout on a embedded connection!");
+
−    }
+
−}