+
−package nl.cwi.monetdb.mcl.embedded;
+
−
+
−import nl.cwi.monetdb.embedded.env.IEmbeddedConnection;
+
−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.connection.AbstractBufferedReader;
+
−import nl.cwi.monetdb.mcl.connection.AbstractBufferedWriter;
+
−import nl.cwi.monetdb.mcl.connection.AbstractMonetDBConnection;
+
−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 class EmbeddedConnection extends AbstractMonetDBConnection implements IEmbeddedConnection {
+
−
+
−    private long connectionPointer;
+
−
+
−    protected static final int BUFFER_SIZE = 102400; //100 kb to start
+
−
+
−    private final String directory;
+
−
+
−    private EmbeddedReader reader;
+
−
+
−    private EmbeddedWriter writer;
+
−
+
−    public EmbeddedConnection(String hostname, int port, String database, String username, boolean debug, String language, String hash, String directory) {
+
−        super(hostname, port, database, username, debug, language, hash, new String[]{"s", "\n;", "\n;\n"}, new String[]{"X", null, "\nX"});
+
−        this.directory = directory;
+
−    }
+
−
+
−    public String getDirectory() {
+
−        return directory;
+
−    }
+
−
+
−    @Override
+
−    public void setHostname(String hostname) {
+
−        throw new IllegalArgumentException("Cannot set a hostname on a embedded connection!");
+
−    }
+
−
+
−    @Override
+
−    public void setPort(int port) {
+
−        throw new IllegalArgumentException("Cannot set a port on a embedded connection!");
+
−    }
+
−
+
−    @Override
+
−    public void setDatabase(String db) {
+
−        throw new IllegalArgumentException("Not yet planned!");
+
−    }
+
−
+
−    @Override
+
−    public void setLanguage(String language) {
+
−        if(this.lang != LANG_SQL) {
+
−            throw new IllegalArgumentException("The embedded connection only supports the SQL language!");
+
−        }
+
−        super.setLanguage(language);
+
−    }
+
−
+
−    @Override
+
−    public void setHash(String hash) {
+
−        throw new IllegalArgumentException("The embedded connection does not support user authentication yet!");
+
−    }
+
−
+
−    @Override
+
−    public int getSoTimeout() throws SocketException {
+
−        throw new IllegalArgumentException("Cannot get socket timeout on an embedded connection!");
+
−    }
+
−
+
−    @Override
+
−    public void setSoTimeout(int s) throws SocketException {
+
−        throw new IllegalArgumentException("Cannot set socket timeout on an embedded connection!");
+
−    }
+
−
+
−    @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.reader = new EmbeddedReader();
+
−            this.writer = new EmbeddedWriter();
+
−            MonetDBEmbeddedDatabase.AddJDBCEmbeddedConnection(this);
+
−        } catch (MonetDBEmbeddedException ex) {
+
−            throw new MCLException(ex);
+
−        }
+
−        return null;
+
−    }
+
−
+
−    @Override
+
−    public InputStream getInputStream() {
+
−        throw new IllegalArgumentException("Not available!");
+
−    }
+
−
+
−    @Override
+
−    public OutputStream getOutputStream() {
+
−        throw new IllegalArgumentException("Not available!");
+
−    }
+
−
+
−    @Override
+
−    public AbstractBufferedReader getReader() {
+
−        return this.reader;
+
−    }
+
−
+
−    @Override
+
−    public AbstractBufferedWriter getWriter() {
+
−        return this.writer;
+
−    }
+
−
+
−    @Override
+
−    public synchronized void close() {
+
−        super.close();
+
−        try {
+
−            MonetDBEmbeddedDatabase.StopDatabase();
+
−        } catch (MonetDBEmbeddedException e) {
+
−            // ignore it
+
−        }
+
−    }
+
−
+
−    @Override
+
−    public String getJDBCURL() {
+
−        return "jdbc:monetdb://" + this.getHostname() + "@" + this.getDirectory() + "/" + this.getDatabase();
+
−    }
+
−
+
−    @Override
+
−    public int getBlockSize() {
+
−        return BUFFER_SIZE;
+
−    }
+
−
+
−    @Override
+
−    public long getConnectionPointer() {
+
−        return connectionPointer;
+
−    }
+
−
+
−    @Override
+
−    public void closeConnectionImplementation() {
+
−        this.closeConnectionInternal(this.connectionPointer);
+
−    }
+
−
+
−    private native void closeConnectionInternal(long connectionPointer);
+
−}