+
−package nl.cwi.monetdb.mcl.connection.embedded;
+
−
+
−import nl.cwi.monetdb.embedded.env.MonetDBEmbeddedConnection;
+
−import nl.cwi.monetdb.embedded.env.MonetDBEmbeddedDatabase;
+
−import nl.cwi.monetdb.embedded.env.MonetDBEmbeddedException;
+
−import nl.cwi.monetdb.jdbc.MonetConnection;
+
−import nl.cwi.monetdb.mcl.connection.ControlCommands;
+
−import nl.cwi.monetdb.mcl.connection.MCLException;
+
−import nl.cwi.monetdb.mcl.protocol.ProtocolException;
+
−import nl.cwi.monetdb.mcl.protocol.ServerResponses;
+
−import nl.cwi.monetdb.mcl.protocol.embedded.EmbeddedProtocol;
+
−
+
−import java.io.*;
+
−import java.sql.SQLException;
+
−import java.util.List;
+
−import java.util.Properties;
+
−
+
−/**
+
− * Created by ferreira on 11/23/16.
+
− */
+
−public final class EmbeddedConnection extends MonetConnection {
+
−
+
−    private final String directory;
+
−
+
−    public EmbeddedConnection(Properties props, String database, String hash, String language, boolean blobIsBinary,
+
−                              boolean isDebugging, String directory) throws IOException {
+
−        super(props, database, hash, EmbeddedLanguage.GetLanguageFromString(language), blobIsBinary, isDebugging);
+
−        this.directory = directory;
+
−    }
+
−
+
−    public String getDirectory() {
+
−        return directory;
+
−    }
+
−
+
−    public MonetDBEmbeddedConnection getAsMonetDBEmbeddedConnection() {
+
−        return ((EmbeddedProtocol)protocol).getEmbeddedConnection();
+
−    }
+
−
+
−    @Override
+
−    public List<String> connect(String username, String password) throws IOException, ProtocolException, 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.protocol = new EmbeddedProtocol(MonetDBEmbeddedDatabase.CreateJDBCEmbeddedConnection());
+
−        } catch (MonetDBEmbeddedException ex) {
+
−            throw new MCLException(ex);
+
−        }
+
−        return null;
+
−    }
+
−
+
−    @Override
+
−    public String getJDBCURL() {
+
−        return "jdbc:monetdb://localhost@" + this.directory + "/" + this.database;
+
−    }
+
−
+
−    @Override
+
−    public int getBlockSize() {
+
−        return Integer.MAX_VALUE;
+
−    }
+
−
+
−    @Override
+
−    public int getDefFetchsize() {
+
−        return Integer.MAX_VALUE;
+
−    }
+
−
+
−    @Override
+
−    public int getSoTimeout() {
+
−        this.addWarning("Cannot get a timeout on a embedded connection!", "M1M05");
+
−        return -1;
+
−    }
+
−
+
−    @Override
+
−    public void setSoTimeout(int s) {
+
−        this.addWarning("Cannot set a timeout on a embedded connection!", "M1M05");
+
−    }
+
−
+
−    @Override
+
−    public void closeUnderlyingConnection() throws IOException {
+
−        ((EmbeddedProtocol)protocol).getEmbeddedConnection().closeConnection();
+
−    }
+
−
+
−    @Override
+
−    public void sendControlCommand(ControlCommands con, int data) throws SQLException {
+
−        try {
+
−            switch (con) {
+
−                case AUTO_COMMIT:
+
−                    ((EmbeddedProtocol)protocol).getEmbeddedConnection().sendAutocommitCommand(data);
+
−                    break;
+
−                case RELEASE:
+
−                    ((EmbeddedProtocol)protocol).getEmbeddedConnection().sendReleaseCommand(data);
+
−                    break;
+
−                case CLOSE:
+
−                    ((EmbeddedProtocol)protocol).getEmbeddedConnection().sendCloseCommand(data);
+
−                case REPLY_SIZE:
+
−                    throw new SQLException("Cannot set reply size on a Embedded connection!", "M1M05");
+
−            }
+
−            protocol.waitUntilPrompt();
+
−            if (protocol.getCurrentServerResponseHeader() == ServerResponses.ERROR) {
+
−                throw new SQLException(protocol.getRemainingStringLine(0));
+
−            }
+
−        } catch (IOException ex) {
+
−            throw new SQLException(ex);
+
−        }
+
−    }
+
−
+
−    @Override
+
−    public ResponseList createResponseList(int fetchSize, int maxRows, int resultSetType, int resultSetConcurrency) throws SQLException {
+
−        return new MonetConnection.ResponseList(this.getDefFetchsize(), maxRows, resultSetType, resultSetConcurrency);
+
−    }
+
−
+
−    @Override
+
−    public void setServerMaxRows(int maxRows) throws SQLException {
+
−        ((EmbeddedProtocol)protocol).getEmbeddedConnection().setMaxRows(maxRows);
+
−    }
+
−}