+
−/*
+
− * SPDX-License-Identifier: MPL-2.0
+
− *
+
− * This Source Code Form is subject to the terms of the Mozilla Public
+
− * License, v. 2.0.  If a copy of the MPL was not distributed with this
+
− * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
− *
+
− * Copyright 2024, 2025 MonetDB Foundation;
+
− * Copyright August 2008 - 2023 MonetDB B.V.;
+
− * Copyright 1997 - July 2008 CWI.
+
− */
+
−
+
−package org.monetdb.jdbc;
+
−
+
−import java.io.*;
+
−import java.net.SocketException;
+
−import java.net.SocketTimeoutException;
+
−import java.nio.charset.StandardCharsets;
+
−import java.sql.CallableStatement;
+
−import java.sql.Connection;
+
−import java.sql.DatabaseMetaData;
+
−import java.sql.PreparedStatement;
+
−import java.sql.ResultSet;
+
−import java.sql.ResultSetMetaData;
+
−import java.sql.SQLClientInfoException;
+
−import java.sql.SQLException;
+
−import java.sql.SQLFeatureNotSupportedException;
+
−import java.sql.SQLNonTransientConnectionException;
+
−import java.sql.SQLWarning;
+
−import java.sql.Savepoint;
+
−import java.sql.Statement;
+
−import java.util.*;
+
−import java.util.Map.Entry;
+
−import java.util.concurrent.Executor;
+
−
+
−import org.monetdb.mcl.io.BufferedMCLReader;
+
−import org.monetdb.mcl.io.BufferedMCLWriter;
+
−import org.monetdb.mcl.io.LineType;
+
−import org.monetdb.mcl.net.ClientInfo;
+
−import org.monetdb.mcl.net.MapiSocket;
+
−import org.monetdb.mcl.net.Target;
+
−import org.monetdb.mcl.net.ValidationError;
+
−import org.monetdb.mcl.parser.HeaderLineParser;
+
−import org.monetdb.mcl.parser.MCLParseException;
+
−import org.monetdb.mcl.parser.StartOfHeaderParser;
+
−
+
−/**
+
− *<pre>
+
− * A {@link Connection} suitable for the MonetDB database.
+
− *
+
− * This connection represents a connection (session) to a MonetDB
+
− * database. SQL statements are executed and results are returned within
+
− * the context of a connection. This Connection object holds a physical
+
− * connection to the MonetDB database.
+
− *
+
− * A Connection object's database should able to provide information
+
− * describing its tables, its supported SQL grammar, its stored
+
− * procedures, the capabilities of this connection, and so on. This
+
− * information is obtained with the getMetaData method.
+
− *
+
− * Note: By default a Connection object is in auto-commit mode, which
+
− * means that it automatically commits changes after executing each
+
− * statement. If auto-commit mode has been disabled, the method commit
+
− * must be called explicitly in order to commit changes; otherwise,
+
− * database changes will not be saved.
+
− *
+
− * The current state of this class is that it nearly implements the
+
− * whole Connection interface.
+
− *</pre>
+
− *
+
− * @author Fabian Groffen
+
− * @author Martin van Dinther
+
− * @version 1.7
+
− */
+
−public class MonetConnection
+
−	extends MonetWrapper
+
−	implements Connection, AutoCloseable
+
−{
+
−	/* All connection parameters */
+
−	private final Target target;
+
−	/** A connection to mserver5 using a TCP socket */
+
−	private final MapiSocket server;
+
−	/** The Reader from the server */
+
−	private final BufferedMCLReader in;
+
−	/** The Writer to the server */
+
−	private final BufferedMCLWriter out;
+
−
+
−	/** A StartOfHeaderParser declared for reuse. */
+
−	private final StartOfHeaderParser sohp = new StartOfHeaderParser();
+
−
+
−	/** Whether this Connection is closed (and cannot be used anymore) */
+
−	private boolean closed;
+
−
+
−	/** Whether this Connection is in autocommit mode */
+
−	private boolean autoCommit = true;
+
−
+
−	/** The stack of warnings for this Connection object */
+
−	private SQLWarning warnings;
+
−
+
−	/** The Connection specific mapping of user defined types to Java types */
+
−	private Map<String,Class<?>> typeMap = new HashMap<String,Class<?>>() {
+
−		private static final long serialVersionUID = 1L;
+
−		{
+
−			put("inet", org.monetdb.jdbc.types.INET.class);
+
−			put("url",  org.monetdb.jdbc.types.URL.class);
+
−		}
+
−	};
+
−
+
−	// See javadoc for documentation about WeakHashMap if you don't know what
+
−	// it does !!!NOW!!! (only when you deal with it of course)
+
−	/** A Map containing all (active) Statements created from this Connection */
+
−	private final WeakHashMap<Statement,?> statements = new WeakHashMap<Statement, Object>();
+
−
+
−	/** The number of results we receive from the server at once */
+
−	private int curReplySize = 100;	// server default
+
−
+
−	/** A template to apply to each query (like pre and post fixes), filled in constructor */
+
−	// note: it is made public to the package as queryTempl[2] is used from MonetStatement
+
−	final String[] queryTempl = new String[3]; // pre, post, sep
+
−
+
−	/** A template to apply to each command (like pre and post fixes), filled in constructor */
+
−	private final String[] commandTempl = new String[2]; // pre, post
+
−
+
−	/** A mapping of ClientInfo property names such as 'ClientHostname' to columns of the
+
−	 * sessions table, such as 'hostname'.
+
−	 */
+
−	private HashMap<String,String> clientInfoAttributeNames = null;
+
−
+
−	/** the SQL language */
+
−	private static final int LANG_SQL = 0;
+
−	/** the MAL language (officially *NOT* supported) */
+
−	private static final int LANG_MAL = 3;
+
−	/** an unknown language */
+
−	private static final int LANG_UNKNOWN = -1;
+
−	/** The language which is used */
+
−	private final int lang;
+
−
+
−	/** The last set query timeout on the server as used by Statement, PreparedStatement and CallableStatement */
+
−	protected int lastSetQueryTimeout = 0;	// 0 means no timeout, which is the default on the server
+
−
+
−	/** A cache to reduce the number of DatabaseMetaData objects created by getMetaData() to maximum 1 per connection */
+
−	private DatabaseMetaData dbmd;
+
−
+
−	/**
+
−	 * Constructor of a Connection for MonetDB.
+
−	 * This constructor is only accessible to classes from the jdbc package.
+
−	 *
+
−	 * @param target a {@link Target} object containing all connection parameters
+
−	 * @throws SQLException if a database error occurs
+
−	 * @throws IllegalArgumentException is one of the arguments is null or empty
+
−	 */
+
−	MonetConnection(Target target)
+
−		throws SQLException, IllegalArgumentException
+
−	{
+
−		this.target = target;
+
−		Target.Validated validated;
+
−		try {
+
−			validated = target.validate();
+
−		} catch (ValidationError e) {
+
−			throw new SQLNonTransientConnectionException(e.getMessage());
+
−		}
+
−		server = new MapiSocket();
+
−
+
−		// we're debugging here... uhm, should be off in real life
+
−		if (validated.isDebug()) {
+
−			try {
+
−				String fname = validated.getLogfile();
+
−				if (fname == null)
+
−					fname = "monet_" + System.currentTimeMillis() + ".log";
+
−
+
−				File f = new File(fname);
+
−
+
−				int ext = fname.lastIndexOf('.');
+
−				if (ext < 0)
+
−					ext = fname.length();
+
−				final String pre = fname.substring(0, ext);
+
−				final String suf = fname.substring(ext);
+
−
+
−				for (int i = 1; f.exists(); i++) {
+
−					f = new File(pre + "-" + i + suf);
+
−				}
+
−
+
−				server.debug(f.getAbsolutePath());	// enable logging on the MapiSocket level
+
−			} catch (IOException ex) {
+
−				throw new SQLNonTransientConnectionException("Opening logfile failed: " + ex.getMessage(), "08M01");
+
−			}
+
−		}
+
−
+
−		SqlOptionsCallback callback = null;
+
−		switch (validated.getLanguage()) {
+
−			case "sql":
+
−				lang = LANG_SQL;
+
−				queryTempl[0] = "s";        // pre
+
−				queryTempl[1] = "\n;";      // post
+
−				queryTempl[2] = "\n;\n";    // separator
+
−				commandTempl[0] = "X";      // pre
+
−				commandTempl[1] = "";       // post
+
−				callback = new SqlOptionsCallback(validated);
+
−				break;
+
−			case "mal":
+
−				lang = LANG_MAL;
+
−				queryTempl[0] = "";         // pre
+
−				queryTempl[1] = ";\n";      // post
+
−				queryTempl[2] = ";\n";      // separator
+
−				commandTempl[0] = "";       // pre
+
−				commandTempl[1] = "";       // post
+
−				break;
+
−			default:
+
−				lang = LANG_UNKNOWN;
+
−				break;
+
−		}
+
−
+
−		try {
+
−
+
−			final java.util.List<String> warnings = server.connect(target, callback);
+
−			for (String warning : warnings) {
+
−				addWarning(warning, "01M02");
+
−			}
+
−
+
−			in = server.getReader();
+
−			out = server.getWriter();
+
−
+
−			final String error = in.discardRemainder();
+
−			if (error != null)
+
−				throw new SQLNonTransientConnectionException((error.length() > 6) ? error.substring(6) : error, "08001");
+
−		} catch (javax.net.ssl.SSLException e) {
+
−			throw new SQLNonTransientConnectionException("Cannot establish secure connection: " + e.getMessage(), e);
+
−		} catch (IOException e) {
+
−			throw new SQLNonTransientConnectionException("Cannot connect: " + e.getMessage(), "08006", e);
+
−		} catch (MCLParseException e) {
+
−			throw new SQLNonTransientConnectionException(e.getMessage(), "08001");
+
−		} catch (org.monetdb.mcl.MCLException e) {
+
−			final String[] connex = e.getMessage().split("\n");
+
−			final SQLException sqle = new SQLNonTransientConnectionException(connex[0], "08001", e);
+
−			for (int i = 1; i < connex.length; i++) {
+
−				sqle.setNextException(new SQLNonTransientConnectionException(connex[1], "08001"));
+
−			}
+
−			throw sqle;
+
−		}
+
−
+
−		if (server.canClientInfo() && validated.sendClientInfo()) {
+
−			ClientInfo info = new ClientInfo();
+
−			info.setDefaults();
+
−			String clientApplication = validated.getClientApplication();
+
−			String clientRemark = validated.getClientRemark();
+
−			if (!clientApplication.isEmpty())
+
−				info.set("ApplicationName", clientApplication);
+
−			if (!clientRemark.isEmpty())
+
−				info.set("ClientRemark", clientRemark);
+
−			sendClientInfo(info);
+
−		}
+
−
+
−		// Now take care of any options not handled during the handshake
+
−		curReplySize = defaultFetchSize;
+
−		if (lang == LANG_SQL) {
+
−			if (autoCommit != validated.isAutocommit()) {
+
−				setAutoCommit(validated.isAutocommit());
+
−			}
+
−			if (!callback.sizeHeaderEnabled) {
+
−				sendControlCommand("sizeheader 1");
+
−			}
+
−			if (!callback.timeZoneSet) {
+
−				setTimezone(60 * validated.getTimezone());
+
−			}
+
−		}
+
−
+
−		// we're absolutely not closed, since we're brand new
+
−		closed = false;
+
−
+
−		if (!validated.getSchema().isEmpty()) {
+
−			try (Statement stmt = this.createStatement()) {
+
−				String escaped = validated.getSchema().replaceAll("\"", "\"\"");
+
−				stmt.execute("SET SCHEMA \"" + escaped + "\"");
+
−			}
+
−		}
+
−	}
+
−
+
−	//== methods of interface Connection
+
−
+
−	/**
+
−	 * Clears all warnings reported for this Connection object. After a
+
−	 * call to this method, the method getWarnings returns null until a
+
−	 * new warning is reported for this Connection object.
+
−	 */
+
−	@Override
+
−	public void clearWarnings() {
+
−		warnings = null;
+
−	}
+
−
+
−	/**
+
−	 * Releases this Connection object's database and JDBC resources
+
−	 * immediately instead of waiting for them to be automatically
+
−	 * released. All Statements created from this Connection will be
+
−	 * closed when this method is called.
+
−	 *
+
−	 * Calling the method close on a Connection object that is already
+
−	 * closed is a no-op.
+
−	 */
+
−	@Override
+
−	public void close() {
+
−		if (closed)
+
−			return;
+
−
+
−		clearWarnings();
+
−		clientInfoAttributeNames = null;
+
−		dbmd = null;
+
−		synchronized (server) {
+
−			// Note: An entry in a WeakHashMap will automatically be
+
−			// removed when its key is no longer in ordinary use.
+
−			for (Statement st : statements.keySet()) {
+
−				try {
+
−					st.close();
+
−				} catch (SQLException e) {
+
−					// better luck next time!
+
−				}
+
−			}
+
−			// close the socket
+
−			server.close();
+
−			// report ourselves as closed
+
−			closed = true;
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Makes all changes made since the previous commit/rollback
+
−	 * permanent and releases any database locks currently held by this
+
−	 * Connection object.  This method should be used only when
+
−	 * auto-commit mode has been disabled.
+
−	 *
+
−	 * @throws SQLException if a database access error occurs or this
+
−	 *         Connection object is in auto-commit mode
+
−	 * @see #setAutoCommit(boolean)
+
−	 */
+
−	@Override
+
−	public void commit() throws SQLException {
+
−		// note: can't use sendIndependentCommand here because we need
+
−		// to process the auto_commit state the server gives
+
−		sendTransactionCommand("COMMIT");
+
−	}
+
−
+
−	/**
+
−	 * Creates a Statement object for sending SQL statements to the
+
−	 * database.  SQL statements without parameters are normally
+
−	 * executed using Statement objects. If the same SQL statement is
+
−	 * executed many times, it may be more efficient to use a
+
−	 * PreparedStatement object.
+
−	 *
+
−	 * Result sets created using the returned Statement object will by
+
−	 * default be type TYPE_FORWARD_ONLY and have a concurrency level of
+
−	 * CONCUR_READ_ONLY and a holdability of HOLD_CURSORS_OVER_COMMIT.
+
−	 *
+
−	 * @return a new default Statement object
+
−	 * @throws SQLException if a database access error occurs
+
−	 */
+
−	@Override
+
−	public Statement createStatement() throws SQLException {
+
−		return createStatement(MonetResultSet.DEF_RESULTSETTYPE, MonetResultSet.DEF_CONCURRENCY, MonetResultSet.DEF_HOLDABILITY);
+
−	}
+
−
+
−	/**
+
−	 * Creates a Statement object that will generate ResultSet objects
+
−	 * with the given type and concurrency. This method is the same as
+
−	 * the createStatement method above, but it allows the default
+
−	 * result set type and concurrency to be overridden.
+
−	 *
+
−	 * @param resultSetType a result set type; one of
+
−	 *        ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE,
+
−	 *        or ResultSet.TYPE_SCROLL_SENSITIVE
+
−	 * @param resultSetConcurrency a concurrency type; one of
+
−	 *        ResultSet.CONCUR_READ_ONLY or ResultSet.CONCUR_UPDATABLE
+
−	 * @return a new Statement object that will generate ResultSet objects with
+
−	 *         the given type and concurrency
+
−	 * @throws SQLException if a database access error occurs
+
−	 */
+
−	@Override
+
−	public Statement createStatement(final int resultSetType, final int resultSetConcurrency) throws SQLException {
+
−		return createStatement(resultSetType, resultSetConcurrency, MonetResultSet.DEF_HOLDABILITY);
+
−	}
+
−
+
−	/**
+
−	 * Creates a Statement object that will generate ResultSet objects
+
−	 * with the given type, concurrency, and holdability.  This method
+
−	 * is the same as the createStatement method above, but it allows
+
−	 * the default result set type, concurrency, and holdability to be
+
−	 * overridden.
+
−	 *
+
−	 * @param resultSetType one of the following ResultSet constants:
+
−	 * ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE,
+
−	 * or ResultSet.TYPE_SCROLL_SENSITIVE
+
−	 * @param resultSetConcurrency one of the following ResultSet
+
−	 * constants: ResultSet.CONCUR_READ_ONLY or
+
−	 * ResultSet.CONCUR_UPDATABLE
+
−	 * @param resultSetHoldability one of the following ResultSet
+
−	 * constants: ResultSet.HOLD_CURSORS_OVER_COMMIT or
+
−	 * ResultSet.CLOSE_CURSORS_AT_COMMIT
+
−	 *
+
−	 * @return a new Statement object that will generate ResultSet
+
−	 * objects with the given type, concurrency, and holdability
+
−	 * @throws SQLException if a database access error occurs or the
+
−	 * given parameters are not ResultSet constants indicating type,
+
−	 * concurrency, and holdability
+
−	 */
+
−	@Override
+
−	public Statement createStatement(final int resultSetType, final int resultSetConcurrency, final int resultSetHoldability) throws SQLException {
+
−		try {
+
−			final Statement ret = new MonetStatement(this, resultSetType, resultSetConcurrency, resultSetHoldability);
+
−			// store it in the map for when we close...
+
−			statements.put(ret, null);
+
−			return ret;
+
−		} catch (IllegalArgumentException e) {
+
−			throw new SQLException(e.toString(), "M0M03");
+
−		}
+
−		// we don't have to catch SQLException because that is declared to be thrown
+
−	}
+
−
+
−	/**
+
−	 * Retrieves the current auto-commit mode for this Connection object.
+
−	 *
+
−	 * @return the current state of this Connection object's auto-commit mode
+
−	 * @see #setAutoCommit(boolean)
+
−	 */
+
−	@Override
+
−	public boolean getAutoCommit() {
+
−		return autoCommit;
+
−	}
+
−
+
−	/**
+
−	 * Retrieves this Connection object's current catalog name.
+
−	 *
+
−	 * @return the current catalog name or null if there is none
+
−	 */
+
−	@Override
+
−	public String getCatalog() {
+
−		// MonetDB does NOT support catalog names or qualifiers
+
−		return null;
+
−	}
+
−
+
−	/**
+
−	 * Retrieves the current holdability of ResultSet objects created
+
−	 * using this Connection object.
+
−	 *
+
−	 * @return the holdability, one of
+
−	 *         ResultSet.HOLD_CURSORS_OVER_COMMIT or
+
−	 *         ResultSet.CLOSE_CURSORS_AT_COMMIT
+
−	 * @see #setHoldability(int)
+
−	 */
+
−	@Override
+
−	public int getHoldability() {
+
−		// TODO: perhaps it is better to have the server implement
+
−		//       CLOSE_CURSORS_AT_COMMIT
+
−		return ResultSet.HOLD_CURSORS_OVER_COMMIT;
+
−	}
+
−
+
−	/**
+
−	 * Retrieves a DatabaseMetaData object that contains metadata about
+
−	 * the database to which this Connection object represents a
+
−	 * connection. The metadata includes information about the
+
−	 * database's tables, its supported SQL grammar, its stored
+
−	 * procedures, the capabilities of this connection, and so on.
+
−	 *
+
−	 * @throws SQLException if the current language is not SQL
+
−	 * @return a DatabaseMetaData object for this Connection object
+
−	 */
+
−	@Override
+
−	public DatabaseMetaData getMetaData() throws SQLException {
+
−		// for debug: System.out.println("calling getMetaData()");
+
−		if (lang != LANG_SQL)
+
−			throw new SQLException("This method is only supported in SQL mode", "M0M04");
+
−		if (dbmd == null) {
+
−			// first use, construct it once and reuse it for all next calls
+
−			dbmd = new MonetDatabaseMetaData(this);
+
−		}
+
−		return dbmd;
+
−	}
+
−
+
−	/**
+
−	 * Retrieves this Connection object's current transaction isolation
+
−	 * level.
+
−	 *
+
−	 * @return the current transaction isolation level, which will be
+
−	 *         Connection.TRANSACTION_SERIALIZABLE
+
−	 */
+
−	@Override
+
−	public int getTransactionIsolation() {
+
−		return TRANSACTION_SERIALIZABLE;
+
−	}
+
−
+
−	/**
+
−	 * Retrieves the Map object associated with this Connection object.
+
−	 * Unless the application has added an entry, the type map returned
+
−	 * will be empty.
+
−	 *
+
−	 * @return the java.util.Map object associated with this Connection
+
−	 *         object
+
−	 */
+
−	@Override
+
−	public Map<String,Class<?>> getTypeMap() {
+
−		return typeMap;
+
−	}
+
−
+
−	/**
+
−	 * Retrieves the first warning reported by calls on this Connection
+
−	 * object.  If there is more than one warning, subsequent warnings
+
−	 * will be chained to the first one and can be retrieved by calling
+
−	 * the method SQLWarning.getNextWarning on the warning that was
+
−	 * retrieved previously.
+
−	 *
+
−	 * This method may not be called on a closed connection; doing so
+
−	 * will cause an SQLException to be thrown.
+
−	 *
+
−	 * Note: Subsequent warnings will be chained to this SQLWarning.
+
−	 *
+
−	 * @return the first SQLWarning object or null if there are none
+
−	 * @throws SQLException if a database access error occurs or this method is
+
−	 *         called on a closed connection
+
−	 */
+
−	@Override
+
−	public SQLWarning getWarnings() throws SQLException {
+
−		checkNotClosed();
+
−		// if there are no warnings, this will be null, which fits with the
+
−		// specification.
+
−		return warnings;
+
−	}
+
−
+
−	/**
+
−	 * Retrieves whether this Connection object has been closed.  A
+
−	 * connection is closed if the method close has been called on it or
+
−	 * if certain fatal errors have occurred.  This method is guaranteed
+
−	 * to return true only when it is called after the method
+
−	 * Connection.close has been called.
+
−	 *
+
−	 * This method generally cannot be called to determine whether a
+
−	 * connection to a database is valid or invalid.  A typical client
+
−	 * can determine that a connection is invalid by catching any
+
−	 * exceptions that might be thrown when an operation is attempted.
+
−	 *
+
−	 * @return true if this Connection object is closed; false if it is
+
−	 *         still open
+
−	 */
+
−	@Override
+
−	public boolean isClosed() {
+
−		return closed;
+
−	}
+
−
+
−	/**
+
−	 * Retrieves whether this Connection object is in read-only mode.
+
−	 * MonetDB currently doesn't support updateable result sets, but
+
−	 * updates are possible.  Hence the Connection object is never in
+
−	 * read-only mode.
+
−	 *
+
−	 * @return true if this Connection object is read-only; false otherwise
+
−	 */
+
−	@Override
+
−	public boolean isReadOnly() {
+
−		return false;
+
−	}
+
−
+
−	/**
+
−	 * Converts the given SQL statement into the system's native SQL grammar.
+
−	 * A driver may convert the JDBC SQL grammar into its system's native SQL grammar prior to sending it.
+
−	 * This method returns the native form of the statement that the driver would have sent.
+
−	 *
+
−	 * @param sql - an SQL statement that may contain one or more '?' parameter placeholders.
+
−	 * @return the native form of this statement
+
−	 */
+
−	@Override
+
−	public String nativeSQL(final String sql) {
+
−		/* there is currently no way to get the native MonetDB rewritten SQL string back, so just return the original string */
+
−		return sql;
+
−	}
+
−
+
−	/**
+
−	 * Creates a CallableStatement object for calling database stored procedures.
+
−	 * The CallableStatement object provides methods for setting up its IN and OUT parameters,
+
−	 * and methods for executing the call to a stored procedure.
+
−	 *
+
−	 * Note: This method is optimized for handling stored procedure call statements.
+
−	 *       Some drivers may send the call statement to the database when the method prepareCall is done;
+
−	 *       others may wait until the CallableStatement object is executed. This has no direct effect
+
−	 *       on users; however, it does affect which method throws certain SQLExceptions.
+
−	 *
+
−	 * Result sets created using the returned CallableStatement object will by default be type TYPE_FORWARD_ONLY
+
−	 * and have a concurrency level of CONCUR_READ_ONLY.
+
−	 * The holdability of the created result sets can be determined by calling getHoldability().
+
−	 *
+
−	 * @param sql - an SQL statement that may contain one or more '?' parameter placeholders.
+
−	 *	Typically this statement is specified using JDBC call escape syntax.
+
−	 * @return a new default CallableStatement object containing the pre-compiled SQL statement
+
−	 * @throws SQLException - if a database access error occurs or this method is called on a closed connection
+
−	 */
+
−	@Override
+
−	public CallableStatement prepareCall(final String sql) throws SQLException {
+
−		return prepareCall(sql, MonetResultSet.DEF_RESULTSETTYPE, MonetResultSet.DEF_CONCURRENCY, MonetResultSet.DEF_HOLDABILITY);
+
−	}
+
−
+
−	/**
+
−	 * Creates a CallableStatement object that will generate ResultSet objects with the given type and concurrency.
+
−	 * This method is the same as the prepareCall method above, but it allows the default result set type and concurrency to be overridden.
+
−	 * The holdability of the created result sets can be determined by calling getHoldability().
+
−	 *
+
−	 * @param sql - a String object that is the SQL statement to be sent to the database; may contain on or more '?' parameters
+
−	 *	Typically this statement is specified using JDBC call escape syntax.
+
−	 * @param resultSetType - a result set type; one of ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE, or ResultSet.TYPE_SCROLL_SENSITIVE
+
−	 * @param resultSetConcurrency - a concurrency type; one of ResultSet.CONCUR_READ_ONLY or ResultSet.CONCUR_UPDATABLE
+
−	 * @return a new CallableStatement object containing the pre-compiled SQL statement that
+
−	 *	will produce ResultSet objects with the given type and concurrency
+
−	 * @throws SQLException - if a database access error occurs, this method is called on a closed connection or
+
−	 *	the given parameters are not ResultSet constants indicating type and concurrency
+
−	 */
+
−	@Override
+
−	public CallableStatement prepareCall(final String sql, final int resultSetType, final int resultSetConcurrency) throws SQLException {
+
−		return prepareCall(sql, resultSetType, resultSetConcurrency, MonetResultSet.DEF_HOLDABILITY);
+
−	}
+
−
+
−	/**
+
−	 * Creates a CallableStatement object that will generate ResultSet objects with the given type and concurrency.
+
−	 * This method is the same as the prepareCall method above, but it allows the default result set type, result set concurrency type and holdability to be overridden.
+
−	 *
+
−	 * @param sql - a String object that is the SQL statement to be sent to the database; may contain on or more '?' parameters
+
−	 *	Typically this statement is specified using JDBC call escape syntax.
+
−	 * @param resultSetType - a result set type; one of ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE, or ResultSet.TYPE_SCROLL_SENSITIVE
+
−	 * @param resultSetConcurrency - a concurrency type; one of ResultSet.CONCUR_READ_ONLY or ResultSet.CONCUR_UPDATABLE
+
−	 * @param resultSetHoldability - one of the following ResultSet constants: ResultSet.HOLD_CURSORS_OVER_COMMIT or ResultSet.CLOSE_CURSORS_AT_COMMIT
+
−	 * @return a new CallableStatement object, containing the pre-compiled SQL statement, that will generate ResultSet objects with the given type, concurrency, and holdability
+
−	 * @throws SQLException - if a database access error occurs, this method is called on a closed connection or
+
−	 *	the given parameters are not ResultSet constants indicating type, concurrency, and holdability
+
−	 */
+
−	@Override
+
−	public CallableStatement prepareCall(final String sql, final int resultSetType, final int resultSetConcurrency, final int resultSetHoldability)
+
−		throws SQLException
+
−	{
+
−		checkNotClosed();
+
−
+
−		if (sql == null || sql.isEmpty())
+
−			throw new SQLException("Missing SQL statement", "M1M05");
+
−
+
−		try {
+
−			final CallableStatement ret = new MonetCallableStatement(
+
−				this,
+
−				resultSetType,
+
−				resultSetConcurrency,
+
−				resultSetHoldability,
+
−				sql
+
−			);
+
−			// store it in the map for when we close...
+
−			statements.put(ret, null);
+
−			return ret;
+
−		} catch (IllegalArgumentException e) {
+
−			throw new SQLException(e.toString(), "M0M03");
+
−		}
+
−		// we don't have to catch SQLException because that is declared to be thrown
+
−	}
+
−
+
−	/**
+
−	 * Creates a PreparedStatement object for sending parameterized SQL
+
−	 * statements to the database.
+
−	 *
+
−	 * A SQL statement with or without IN parameters can be pre-compiled
+
−	 * and stored in a PreparedStatement object. This object can then be
+
−	 * used to efficiently execute this statement multiple times.
+
−	 *
+
−	 * Note: This method is optimized for handling parametric SQL
+
−	 * statements that benefit from precompilation. If the driver
+
−	 * supports precompilation, the method prepareStatement will send
+
−	 * the statement to the database for precompilation. Some drivers
+
−	 * may not support precompilation. In this case, the statement may
+
−	 * not be sent to the database until the PreparedStatement object is
+
−	 * executed. This has no direct effect on users; however, it does
+
−	 * affect which methods throw certain SQLException objects.
+
−	 *
+
−	 * Result sets created using the returned PreparedStatement object
+
−	 * will by default be type TYPE_FORWARD_ONLY and have a concurrency
+
−	 * level of CONCUR_READ_ONLY.
+
−	 *
+
−	 * @param sql an SQL statement that may contain one or more '?' IN
+
−	 *        parameter placeholders
+
−	 * @return a new default PreparedStatement object containing the
+
−	 *         pre-compiled SQL statement
+
−	 * @throws SQLException if a database access error occurs
+
−	 */
+
−	@Override
+
−	public PreparedStatement prepareStatement(final String sql) throws SQLException {
+
−		return prepareStatement(sql, MonetResultSet.DEF_RESULTSETTYPE, MonetResultSet.DEF_CONCURRENCY, MonetResultSet.DEF_HOLDABILITY);
+
−	}
+
−
+
−	/**
+
−	 * Creates a PreparedStatement object that will generate ResultSet
+
−	 * objects with the given type and concurrency.  This method is the
+
−	 * same as the prepareStatement method above, but it allows the
+
−	 * default result set type and concurrency to be overridden.
+
−	 *
+
−	 * @param sql a String object that is the SQL statement to be sent to the
+
−	 *        database; may contain one or more ? IN parameters
+
−	 * @param resultSetType a result set type; one of
+
−	 *        ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE,
+
−	 *        or ResultSet.TYPE_SCROLL_SENSITIVE
+
−	 * @param resultSetConcurrency a concurrency type; one of
+
−	 *        ResultSet.CONCUR_READ_ONLY or ResultSet.CONCUR_UPDATABLE
+
−	 * @return a new PreparedStatement object containing the pre-compiled SQL
+
−	 *         statement that will produce ResultSet objects with the given
+
−	 *         type and concurrency
+
−	 * @throws SQLException if a database access error occurs or the given
+
−	 *         parameters are not ResultSet constants indicating
+
−	 *         type and concurrency
+
−	 */
+
−	@Override
+
−	public PreparedStatement prepareStatement(final String sql, final int resultSetType, final int resultSetConcurrency) throws SQLException {
+
−		return prepareStatement(sql, resultSetType, resultSetConcurrency, MonetResultSet.DEF_HOLDABILITY);
+
−	}
+
−
+
−	/**
+
−	 * Creates a PreparedStatement object that will generate ResultSet
+
−	 * objects with the given type, concurrency, and holdability.
+
−	 *
+
−	 * This method is the same as the prepareStatement method above, but
+
−	 * it allows the default result set type, concurrency, and
+
−	 * holdability to be overridden.
+
−	 *
+
−	 * @param sql a String object that is the SQL statement to be sent
+
−	 * to the database; may contain one or more ? IN parameters
+
−	 * @param resultSetType one of the following ResultSet constants:
+
−	 * ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE,
+
−	 * or ResultSet.TYPE_SCROLL_SENSITIVE
+
−	 * @param resultSetConcurrency one of the following ResultSet
+
−	 * constants: ResultSet.CONCUR_READ_ONLY or
+
−	 * ResultSet.CONCUR_UPDATABLE
+
−	 * @param resultSetHoldability one of the following ResultSet
+
−	 * constants: ResultSet.HOLD_CURSORS_OVER_COMMIT or
+
−	 * ResultSet.CLOSE_CURSORS_AT_COMMIT
+
−	 * @return a new PreparedStatement object, containing the
+
−	 * pre-compiled SQL statement, that will generate ResultSet objects
+
−	 * with the given type, concurrency, and holdability
+
−	 * @throws SQLException if a database access error occurs or the
+
−	 * given parameters are not ResultSet constants indicating type,
+
−	 * concurrency, and holdability
+
−	 */
+
−	@Override
+
−	public PreparedStatement prepareStatement(final String sql, final int resultSetType, final int resultSetConcurrency, final int resultSetHoldability)
+
−		throws SQLException
+
−	{
+
−		checkNotClosed();
+
−
+
−		if (sql == null || sql.isEmpty())
+
−			throw new SQLException("Missing SQL statement", "M1M05");
+
−
+
−		try {
+
−			final PreparedStatement ret = new MonetPreparedStatement(
+
−				this,
+
−				resultSetType,
+
−				resultSetConcurrency,
+
−				resultSetHoldability,
+
−				sql
+
−			);
+
−			// store it in the map for when we close...
+
−			statements.put(ret, null);
+
−			return ret;
+
−		} catch (IllegalArgumentException e) {
+
−			throw new SQLException(e.toString(), "M0M03");
+
−		}
+
−		// we don't have to catch SQLException because that is declared to be thrown
+
−	}
+
−
+
−	/**
+
−	 * Creates a default PreparedStatement object that has the
+
−	 * capability to retrieve auto-generated keys.  The given constant
+
−	 * tells the driver whether it should make auto-generated keys
+
−	 * available for retrieval.  This parameter is ignored if the SQL
+
−	 * statement is not an INSERT statement.
+
−	 *
+
−	 * Note: This method is optimized for handling parametric SQL
+
−	 * statements that benefit from precompilation.  If the driver
+
−	 * supports precompilation, the method prepareStatement will send
+
−	 * the statement to the database for precompilation. Some drivers
+
−	 * may not support precompilation.  In this case, the statement may
+
−	 * not be sent to the database until the PreparedStatement object is
+
−	 * executed.  This has no direct effect on users; however, it does
+
−	 * affect which methods throw certain SQLExceptions.
+
−	 *
+
−	 * Result sets created using the returned PreparedStatement object
+
−	 * will by default be type TYPE_FORWARD_ONLY and have a concurrency
+
−	 * level of CONCUR_READ_ONLY.
+
−	 *
+
−	 * @param sql an SQL statement that may contain one or more '?' IN
+
−	 *        parameter placeholders
+
−	 * @param autoGeneratedKeys a flag indicating whether auto-generated
+
−	 *        keys should be returned; one of
+
−	 *        Statement.RETURN_GENERATED_KEYS or
+
−	 *        Statement.NO_GENERATED_KEYS
+
−	 * @return a new PreparedStatement object, containing the
+
−	 *         pre-compiled SQL statement, that will have the capability
+
−	 *         of returning auto-generated keys
+
−	 * @throws SQLException - if a database access error occurs or the
+
−	 *         given parameter is not a Statement  constant indicating
+
−	 *         whether auto-generated keys should be returned
+
−	 */
+
−	@Override
+
−	public PreparedStatement prepareStatement(final String sql, final int autoGeneratedKeys) throws SQLException {
+
−		if (autoGeneratedKeys != Statement.RETURN_GENERATED_KEYS &&
+
−		    autoGeneratedKeys != Statement.NO_GENERATED_KEYS)
+
−			throw new SQLException("Invalid argument, expected RETURN_GENERATED_KEYS or NO_GENERATED_KEYS", "M1M05");
+
−
+
−		/* MonetDB has no way to disable this, so just do the normal thing ;) */
+
−		return prepareStatement(sql, MonetResultSet.DEF_RESULTSETTYPE, MonetResultSet.DEF_CONCURRENCY, MonetResultSet.DEF_HOLDABILITY);
+
−	}
+
−
+
−	/**
+
−	 * Creates a default PreparedStatement object capable of returning the auto-generated keys designated by the given array.
+
−	 * This array contains the indexes of the columns in the target table that contain the auto-generated keys that should be made available.
+
−	 * The driver will ignore the array if the SQL statement is not an INSERT statement, or an SQL statement able to
+
−	 * return auto-generated keys (the list of such statements is vendor-specific).
+
−	 *
+
−	 * An SQL statement with or without IN parameters can be pre-compiled and stored in a PreparedStatement object.
+
−	 * This object can then be used to efficiently execute this statement multiple times.
+
−	 *
+
−	 * Note: This method is optimized for handling parametric SQL statements that benefit from precompilation.
+
−	 * If the driver supports precompilation, the method prepareStatement will send the statement to the database for precompilation.
+
−	 * Some drivers may not support precompilation. In this case, the statement may not be sent to the database until the PreparedStatement
+
−	 * object is executed. This has no direct effect on users; however, it does affect which methods throw certain SQLExceptions.
+
−	 *
+
−	 * Result sets created using the returned PreparedStatement object will by default be type TYPE_FORWARD_ONLY and have
+
−	 * a concurrency level of CONCUR_READ_ONLY. The holdability of the created result sets can be determined by calling getHoldability().
+
−	 *
+
−	 * @param sql - an SQL statement that may contain one or more '?' IN parameter placeholders
+
−	 * @param columnIndexes - an array of column indexes indicating the columns that should be returned from the inserted row or rows
+
−	 * @return a new PreparedStatement object, containing the pre-compiled statement, that is capable of
+
−	 *	returning the auto-generated keys designated by the given array of column indexes
+
−	 * @throws SQLException - if a database access error occurs or this method is called on a closed connection
+
−	 * @throws SQLFeatureNotSupportedException - if the JDBC driver does not support this method
+
−	 */
+
−	@Override
+
−	public PreparedStatement prepareStatement(final String sql, final int[] columnIndexes) throws SQLException {
+
−		throw newSQLFeatureNotSupportedException("prepareStatement(String sql, int[] columnIndexes)");
+
−	}
+
−
+
−	/**
+
−	 * Creates a default PreparedStatement object capable of returning the auto-generated keys designated by the given array.
+
−	 * This array contains the names of the columns in the target table that contain the auto-generated keys that should be returned.
+
−	 * The driver will ignore the array if the SQL statement is not an INSERT statement, or an SQL statement able to
+
−	 * return auto-generated keys (the list of such statements is vendor-specific).
+
−	 *
+
−	 * An SQL statement with or without IN parameters can be pre-compiled and stored in a PreparedStatement object.
+
−	 * This object can then be used to efficiently execute this statement multiple times.
+
−	 *
+
−	 * Note: This method is optimized for handling parametric SQL statements that benefit from precompilation.
+
−	 * If the driver supports precompilation, the method prepareStatement will send the statement to the database for precompilation.
+
−	 * Some drivers may not support precompilation. In this case, the statement may not be sent to the database until the PreparedStatement
+
−	 * object is executed. This has no direct effect on users; however, it does affect which methods throw certain SQLExceptions.
+
−	 *
+
−	 * Result sets created using the returned PreparedStatement object will by default be type TYPE_FORWARD_ONLY and have
+
−	 * a concurrency level of CONCUR_READ_ONLY. The holdability of the created result sets can be determined by calling getHoldability().
+
−	 *
+
−	 * @param sql - an SQL statement that may contain one or more '?' IN parameter placeholders
+
−	 * @param columnNames - an array of column names indicating the columns that should be returned from the inserted row or rows
+
−	 * @return a new PreparedStatement object, containing the pre-compiled statement, that is capable of
+
−	 *	returning the auto-generated keys designated by the given array of column names
+
−	 * @throws SQLException - if a database access error occurs or this method is called on a closed connection
+
−	 * @throws SQLFeatureNotSupportedException - if the JDBC driver does not support this method
+
−	 */
+
−	@Override
+
−	public PreparedStatement prepareStatement(final String sql, final String[] columnNames) throws SQLException {
+
−		throw newSQLFeatureNotSupportedException("prepareStatement(String sql, String[] columnNames)");
+
−	}
+
−
+
−	/**
+
−	 * Removes the given Savepoint object from the current transaction.
+
−	 * Any reference to the savepoint after it have been removed will
+
−	 * cause an SQLException to be thrown.
+
−	 *
+
−	 * @param savepoint the Savepoint object to be removed
+
−	 * @throws SQLException if a database access error occurs or the given
+
−	 *         Savepoint object is not a valid savepoint in the current
+
−	 *         transaction
+
−	 */
+
−	@Override
+
−	public void releaseSavepoint(final Savepoint savepoint) throws SQLException {
+
−		checkNotClosed();
+
−		if (!(savepoint instanceof MonetSavepoint))
+
−			throw new SQLException("This driver can only handle savepoints it created itself", "M0M06");
+
−
+
−		final MonetSavepoint sp = (MonetSavepoint)savepoint;
+
−
+
−		// note: can't use sendIndependentCommand here because we need
+
−		// to process the auto_commit state the server gives
+
−		sendTransactionCommand("RELEASE SAVEPOINT " + sp.getName());
+
−	}
+
−
+
−	/**
+
−	 * Undoes all changes made in the current transaction and releases
+
−	 * any database locks currently held by this Connection object.
+
−	 * This method should be used only when auto-commit mode has been disabled.
+
−	 *
+
−	 * @throws SQLException if a database access error occurs or this
+
−	 *         Connection object is in auto-commit mode
+
−	 * @see #setAutoCommit(boolean)
+
−	 */
+
−	@Override
+
−	public void rollback() throws SQLException {
+
−		checkNotClosed();
+
−		// note: can't use sendIndependentCommand here because we need
+
−		// to process the auto_commit state the server gives
+
−		sendTransactionCommand("ROLLBACK");
+
−	}
+
−
+
−	/**
+
−	 * Undoes all changes made after the given Savepoint object was set.
+
−	 *
+
−	 * This method should be used only when auto-commit has been disabled.
+
−	 *
+
−	 * @param savepoint the Savepoint object to roll back to
+
−	 * @throws SQLException if a database access error occurs, the
+
−	 *         Savepoint object is no longer valid, or this Connection
+
−	 *         object is currently in auto-commit mode
+
−	 */
+
−	@Override
+
−	public void rollback(final Savepoint savepoint) throws SQLException {
+
−		checkNotClosed();
+
−		if (!(savepoint instanceof MonetSavepoint))
+
−			throw new SQLException("This driver can only handle savepoints it created itself", "M0M06");
+
−
+
−		final MonetSavepoint sp = (MonetSavepoint)savepoint;
+
−
+
−		// note: can't use sendIndependentCommand here because we need
+
−		// to process the auto_commit state the server gives
+
−		sendTransactionCommand("ROLLBACK TO SAVEPOINT " + sp.getName());
+
−	}
+
−
+
−	/**
+
−	 * Sets this connection's auto-commit mode to the given state. If a
+
−	 * connection is in auto-commit mode, then all its SQL statements
+
−	 * will be executed and committed as individual transactions.
+
−	 * Otherwise, its SQL statements are grouped into transactions that
+
−	 * are terminated by a call to either the method commit or the
+
−	 * method rollback. By default, new connections are in auto-commit mode.
+
−	 *
+
−	 * The commit occurs when the statement completes or the next
+
−	 * execute occurs, whichever comes first. In the case of statements
+
−	 * returning a ResultSet object, the statement completes when the
+
−	 * last row of the ResultSet object has been retrieved or the
+
−	 * ResultSet object has been closed. In advanced cases, a single
+
−	 * statement may return multiple results as well as output parameter
+
−	 * values. In these cases, the commit occurs when all results and
+
−	 * output parameter values have been retrieved.
+
−	 *
+
−	 * NOTE: If this method is called during a transaction, the
+
−	 * transaction is committed.
+
−	 *
+
−	 * @param autoCommit true to enable auto-commit mode; false to disable it
+
−	 * @throws SQLException if a database access error occurs
+
−	 * @see #getAutoCommit()
+
−	 */
+
−	@Override
+
−	public void setAutoCommit(final boolean autoCommit) throws SQLException {
+
−		checkNotClosed();
+
−		if (this.autoCommit != autoCommit) {
+
−			sendControlCommand(autoCommit ? "auto_commit 1" : "auto_commit 0");
+
−			this.autoCommit = autoCommit;
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Sets the given catalog name in order to select a subspace of this
+
−	 * Connection object's database in which to work.  If the driver
+
−	 * does not support catalogs, it will silently ignore this request.
+
−	 */
+
−	@Override
+
−	public void setCatalog(final String catalog) {
+
−		// silently ignore this request as MonetDB does not support catalog names
+
−	}
+
−
+
−	/**
+
−	 * Changes the default holdability of ResultSet objects created using this
+
−	 * Connection object to the given holdability. The default holdability of
+
−	 * ResultSet objects can be be determined by invoking DatabaseMetaData.getResultSetHoldability().
+
−	 *
+
−	 * @param holdability - a ResultSet holdability constant; one of
+
−	 *	ResultSet.HOLD_CURSORS_OVER_COMMIT or
+
−	 *	ResultSet.CLOSE_CURSORS_AT_COMMIT
+
−	 * @throws SQLException - if a database access error occurs or this method is called on a closed connection
+
−	 * @throws SQLFeatureNotSupportedException - if the JDBC driver does not support this method or argument
+
−	 * @see #getHoldability()
+
−	 */
+
−	@Override
+
−	public void setHoldability(final int holdability) throws SQLException {
+
−		// we only support ResultSet.HOLD_CURSORS_OVER_COMMIT
+
−		if (holdability != ResultSet.HOLD_CURSORS_OVER_COMMIT)
+
−			throw newSQLFeatureNotSupportedException("setHoldability(CLOSE_CURSORS_AT_COMMIT)");
+
−	}
+
−
+
−	/**
+
−	 * Puts this connection in read-only mode as a hint to the driver to
+
−	 * enable database optimizations.  MonetDB doesn't support any mode
+
−	 * here, hence an SQLWarning is generated if attempted to set
+
−	 * to true here.
+
−	 *
+
−	 * @param readOnly true enables read-only mode; false disables it
+
−	 * @throws SQLException if a database access error occurs or this
+
−	 *         method is called during a transaction.
+
−	 */
+
−	@Override
+
−	public void setReadOnly(final boolean readOnly) throws SQLException {
+
−		if (readOnly == true)
+
−			addWarning("cannot setReadOnly(true): read-only Connection mode not supported", "01M08");
+
−	}
+
−
+
−	/**
+
−	 * Creates an unnamed savepoint in the current transaction and
+
−	 * returns the new Savepoint object that represents it.
+
−	 *
+
−	 * @return the new Savepoint object
+
−	 * @throws SQLException if a database access error occurs or this Connection
+
−	 *         object is currently in auto-commit mode
+
−	 */
+
−	@Override
+
−	public Savepoint setSavepoint() throws SQLException {
+
−		return setSavepoint(null);
+
−	}
+
−
+
−	/**
+
−	 * Creates a savepoint with the given name in the current transaction
+
−	 * and returns the new Savepoint object that represents it.
+
−	 *
+
−	 * @param name a String containing the name of the savepoint
+
−	 * @return the new Savepoint object
+
−	 * @throws SQLException if a database access error occurs or this Connection
+
−	 *         object is currently in auto-commit mode
+
−	 */
+
−	@Override
+
−	public Savepoint setSavepoint(final String name) throws SQLException {
+
−		checkNotClosed();
+
−		// create a new Savepoint object
+
−		final MonetSavepoint sp;
+
−		try {
+
−			sp = (name != null) ? new MonetSavepoint(name) : new MonetSavepoint();
+
−		} catch (IllegalArgumentException e) {
+
−			throw new SQLException(e.getMessage(), "M0M03");
+
−		}
+
−
+
−		// note: can't use sendIndependentCommand here because we need
+
−		// to process the auto_commit state the server gives
+
−		sendTransactionCommand("SAVEPOINT " + sp.getName());
+
−		return sp;
+
−	}
+
−
+
−	/**
+
−	 * Attempts to change the transaction isolation level for this
+
−	 * Connection object to the one given.  The constants defined in the
+
−	 * interface Connection are the possible transaction isolation levels.
+
−	 *
+
−	 * @param level one of the following Connection constants:
+
−	 *        Connection.TRANSACTION_READ_UNCOMMITTED,
+
−	 *        Connection.TRANSACTION_READ_COMMITTED,
+
−	 *        Connection.TRANSACTION_REPEATABLE_READ, or
+
−	 *        Connection.TRANSACTION_SERIALIZABLE.
+
−	 */
+
−	@Override
+
−	public void setTransactionIsolation(final int level) {
+
−		if (level != TRANSACTION_SERIALIZABLE) {
+
−			addWarning("MonetDB only supports fully serializable " +
+
−				"transactions, continuing with transaction level " +
+
−				"raised to TRANSACTION_SERIALIZABLE", "01M09");
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Installs the given TypeMap object as the type map for this
+
−	 * Connection object. The type map will be used for the custom
+
−	 * mapping of SQL structured types and distinct types.
+
−	 *
+
−	 * @param map the java.util.Map object to install as the replacement for
+
−	 *        this Connection object's default type map
+
−	 */
+
−	@Override
+
−	public void setTypeMap(final Map<String, Class<?>> map) {
+
−		typeMap = map;
+
−	}
+
−
+
−	/**
+
−	 * Returns a string identifying this Connection to the MonetDB server.
+
−	 *
+
−	 * @return a String representing this Object
+
−	 */
+
−	@Override
+
−	public String toString() {
+
−		return "MonetDB Connection (" + getJDBCURL()
+
−			+ (closed ? ") disconnected" : ") connected");
+
−	}
+
−
+
−	//== Java 1.6 methods (JDBC 4.0)
+
−
+
−	/**
+
−	 * Factory method for creating Array objects.
+
−	 *
+
−	 * Note: When createArrayOf is used to create an array object that
+
−	 * maps to a primitive data type, then it is implementation-defined
+
−	 * whether the Array object is an array of that primitive data type
+
−	 * or an array of Object.
+
−	 *
+
−	 * Note: The JDBC driver is responsible for mapping the elements
+
−	 * Object array to the default JDBC SQL type defined in
+
−	 * java.sql.Types for the given class of Object. The default mapping
+
−	 * is specified in Appendix B of the JDBC specification. If the
+
−	 * resulting JDBC type is not the appropriate type for the given
+
−	 * typeName then it is implementation defined whether an
+
−	 * SQLException is thrown or the driver supports the resulting conversion.
+
−	 *
+
−	 * @param typeName the SQL name of the type the elements of the
+
−	 *        array map to. The typeName is a database-specific name
+
−	 *        which may be the name of a built-in type, a user-defined
+
−	 *        type or a standard SQL type supported by this database.
+
−	 *        This is the value returned by Array.getBaseTypeName
+
−	 * @return an Array object whose elements map to the specified SQL type
+
−	 * @throws SQLException - if a database error occurs, the JDBC type is not appropriate for the typeName and
+
−	 *         the conversion is not supported, the typeName is null or this method is called on a closed connection
+
−	 * @throws SQLFeatureNotSupportedException - if the JDBC driver does not support this data type
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public java.sql.Array createArrayOf(final String typeName, final Object[] elements) throws SQLException {
+
−		throw newSQLFeatureNotSupportedException("createArrayOf");
+
−	}
+
−
+
−	/**
+
−	 * Constructs an object that implements the Clob interface. The
+
−	 * object returned initially contains no data. The setAsciiStream,
+
−	 * setCharacterStream and setString methods of the Clob interface
+
−	 * may be used to add data to the Clob.
+
−	 *
+
−	 * @return a MonetClob instance
+
−	 * @throws SQLException - if an object that implements the Clob interface can not be constructed,
+
−	 *         this method is called on a closed connection or a database access error occurs.
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public java.sql.Clob createClob() throws SQLException {
+
−		return new MonetClob("");
+
−	}
+
−
+
−	/**
+
−	 * Constructs an object that implements the Blob interface. The
+
−	 * object returned initially contains no data. The setBinaryStream
+
−	 * and setBytes methods of the Blob interface may be used to add
+
−	 * data to the Blob.
+
−	 *
+
−	 * @return a MonetBlob instance
+
−	 * @throws SQLException - if an object that implements the Blob interface can not be constructed,
+
−	 *         this method is called on a closed connection or a database access error occurs.
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public java.sql.Blob createBlob() throws SQLException {
+
−		return new MonetBlob(new byte[1]);
+
−	}
+
−
+
−	/**
+
−	 * Constructs an object that implements the NClob interface. The
+
−	 * object returned initially contains no data. The setAsciiStream,
+
−	 * setCharacterStream and setString methods of the NClob interface
+
−	 * may be used to add data to the NClob.
+
−	 *
+
−	 * @return an NClob instance
+
−	 * @throws SQLException - if an object that implements the NClob interface can not be constructed,
+
−	 *         this method is called on a closed connection or a database access error occurs.
+
−	 * @throws SQLFeatureNotSupportedException - if the JDBC driver does not support this data type
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public java.sql.NClob createNClob() throws SQLException {
+
−		throw newSQLFeatureNotSupportedException("createNClob");
+
−	}
+
−
+
−	/**
+
−	 * Factory method for creating Struct objects.
+
−	 *
+
−	 * @param typeName the SQL type name of the SQL structured type that
+
−	 *        this Struct object maps to. The typeName is the name of a
+
−	 *        user-defined type that has been defined for this database.
+
−	 *        It is the value returned by Struct.getSQLTypeName.
+
−	 * @param attributes the attributes that populate the returned object
+
−	 * @return a Struct object that maps to the given SQL type and is
+
−	 *         populated with the given attributes
+
−	 * @throws SQLException - if an object that implements the Struct interface can not be constructed,
+
−	 *         this method is called on a closed connection or a database access error occurs.
+
−	 * @throws SQLFeatureNotSupportedException - if the JDBC driver does not support this data type
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public java.sql.Struct createStruct(String typeName, Object[] attributes) throws SQLException {
+
−		throw newSQLFeatureNotSupportedException("createStruct");
+
−	}
+
−
+
−	/**
+
−	 * Constructs an object that implements the SQLXML interface. The
+
−	 * object returned initially contains no data. The
+
−	 * createXmlStreamWriter object and setString method of the SQLXML
+
−	 * interface may be used to add data to the SQLXML object.
+
−	 *
+
−	 * @return An object that implements the SQLXML interface
+
−	 * @throws SQLException - if an object that implements the SQLXML interface can not be constructed,
+
−	 *         this method is called on a closed connection or a database access error occurs.
+
−	 * @throws SQLFeatureNotSupportedException - if the JDBC driver does not support this data type
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public java.sql.SQLXML createSQLXML() throws SQLException {
+
−		throw newSQLFeatureNotSupportedException("createSQLXML");
+
−	}
+
−
+
−	/**
+
−	 * Returns true if the connection has not been closed and is still
+
−	 * valid. The driver shall submit a query on the connection or use
+
−	 * some other mechanism that positively verifies the connection is
+
−	 * still valid when this method is called.
+
−	 *
+
−	 * The query submitted by the driver to validate the connection
+
−	 * shall be executed in the context of the current transaction.
+
−	 *
+
−	 * @param timeout The time in seconds to wait for the database
+
−	 *        operation used to validate the connection to complete. If
+
−	 *        the timeout period expires before the operation completes,
+
−	 *        this method returns false. A value of 0 indicates a
+
−	 *        timeout is not applied to the database operation.
+
−	 * @return true if the connection is valid, false otherwise
+
−	 * @throws SQLException if the value supplied for timeout is less than 0
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public boolean isValid(final int timeout) throws SQLException {
+
−		if (timeout < 0)
+
−			throw new SQLException("timeout is less than 0", "M1M05");
+
−		if (closed)
+
−			return false;
+
−
+
−		// ping monetdb server using query: select 1;
+
−		Statement stmt = null;
+
−		ResultSet rs = null;
+
−		boolean isValid = false;
+
−		final int original_timeout = this.lastSetQueryTimeout;
+
−		try {
+
−			stmt = createStatement();
+
−			if (stmt != null) {
+
−				if (timeout > 0 && original_timeout != timeout) {
+
−					// we need to change the requested timeout for this test query
+
−					stmt.setQueryTimeout(timeout);
+
−				}
+
−				rs = stmt.executeQuery("SELECT 1");
+
−				if (rs != null && rs.next()) {
+
−					isValid = true;
+
−				}
+
−			}
+
−		} catch (SQLException se) {
+
−			final String msg = se.getMessage();
+
−			// System.out.println(se.getSQLState() + " Con.isValid(): " + msg);
+
−			if (msg != null && msg.equalsIgnoreCase("Current transaction is aborted (please ROLLBACK)")) {
+
−				// Must use equalsIgnoreCase() here because up to Jul2017 release 'Current' was 'current' so with lowercase c.
+
−				// It changed to 'Current' after Jul2017 release. We need to support all server versions.
+
−				// SQLState = 25005
+
−				isValid = true;
+
−			}
+
−			/* ignore stmt errors/exceptions, we are only testing if the connection is still alive and usable */
+
−		} finally {
+
−			closeResultsetStatement(rs, stmt);
+
−			/* when changed, reset the original server timeout value on the server */
+
−			if (timeout > 0 && original_timeout != this.lastSetQueryTimeout) {
+
−				this.lastSetQueryTimeout = original_timeout;
+
−				try {
+
−					/* we have to set in the server explicitly, because the test 'queryTimeout != connection.lastSetQueryTimeout'
+
−					   on MonetStatement.internalExecute(sql) won't pass and the server won't be set back */
+
−					setQueryTimeout(original_timeout);
+
−				} catch (SQLException se) {
+
−					/* ignore stmt errors/exceptions, we are only testing if the connection is still alive and usable */
+
−				}
+
−			}
+
−		}
+
−		return isValid;
+
−	}
+
−
+
−	/**
+
−	 * Returns the value of the client info property specified by name.
+
−	 * This method may return null if the specified client info property
+
−	 * has not been set and does not have a default value.
+
−	 * This method will also return null if the specified client info
+
−	 * property name is not supported by the driver.
+
−	 * Applications may use the DatabaseMetaData.getClientInfoProperties method
+
−	 * to determine the client info properties supported by the driver.
+
−	 *
+
−	 * @param name - The name of the client info property to retrieve
+
−	 * @return The value of the client info property specified or null
+
−	 * @throws SQLException - if the database server returns an error
+
−	 *	when fetching the client info value from the database
+
−	 *	or this method is called on a closed connection
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public String getClientInfo(final String name) throws SQLException {
+
−		// only MonetDB Server 11.51 (Aug2024) or higher supports Client Info Properties
+
−		String attrName = getClientInfoAttributeNames().get(name);
+
−		if (attrName == null)
+
−			return null;
+
−		String query = "SELECT " + attrName + " FROM sys.sessions WHERE sessionid = current_sessionid()";
+
−		try (Statement st = createStatement(); ResultSet rs = st.executeQuery(query)) {
+
−			if (rs != null && rs.next())
+
−				return rs.getString(1);
+
−			else
+
−				return null;
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Returns a list containing the name and current value of each client info
+
−	 * property supported by the driver. The value of a client info property may
+
−	 * be null if the property has not been set and does not have a default value.
+
−	 *
+
−	 * @return A Properties object that contains the name and current value
+
−	 *         of each of the client info properties supported by the driver.
+
−	 * @throws SQLException - if the database server returns an error
+
−	 *	when fetching the client info value from the database
+
−	 *	or this method is called on a closed connection
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public Properties getClientInfo() throws SQLException {
+
−		Properties props = new Properties();
+
−
+
−		// only MonetDB Server 11.51 (Aug2024) or higher supports Client Info Properties
+
−		if (server.canClientInfo()) {
+
−			StringBuilder builder = new StringBuilder("SELECT ");
+
−			String sep = "";
+
−			for (Entry<String, String> entry: getClientInfoAttributeNames().entrySet()) {
+
−				String jdbcName = entry.getKey();
+
−				String attrName = entry.getValue();
+
−				builder.append(sep);
+
−				sep = ", ";
+
−				builder.append(attrName);
+
−				builder.append(" AS \"");
+
−				builder.append(jdbcName);
+
−				builder.append("\"");
+
−			}
+
−			builder.append(" FROM sys.sessions WHERE sessionid = current_sessionid()");
+
−
+
−			try (Statement st = createStatement(); ResultSet rs = st.executeQuery(builder.toString())) {
+
−				if (rs != null && rs.next()) {
+
−					ResultSetMetaData md = rs.getMetaData();
+
−					for (int i = 1; i <= md.getColumnCount(); i++) {
+
−						String key = md.getColumnName(i);
+
−						String value = rs.getString(i);
+
−						props.setProperty(key, value != null ? value : "");
+
−					}
+
−				}
+
−			}
+
−		}
+
−		return props;
+
−	}
+
−
+
−	private HashMap<String,String> getClientInfoAttributeNames() throws SQLException {
+
−		if (clientInfoAttributeNames == null) {
+
−			HashMap<String, String> map = new HashMap<>();
+
−			// only MonetDB Server 11.51 (Aug2024) or higher has table sys.clientinfo_properties with 5 rows
+
−			if (server.canClientInfo()) {
+
−				try (Statement st = createStatement(); ResultSet rs = st.executeQuery("SELECT prop, session_attr FROM sys.clientinfo_properties")) {
+
−					while (rs != null && rs.next()) {
+
−						String jdbcName = rs.getString(1);
+
−						String attrName = rs.getString(2);
+
−						map.put(jdbcName, attrName);
+
−					}
+
−				}
+
−			}
+
−			clientInfoAttributeNames = map;
+
−		}
+
−		return clientInfoAttributeNames;
+
−	}
+
−
+
−	/**
+
−	 * Sets the value of the client info property specified by name to the value specified by value.
+
−	 * Applications may use the DatabaseMetaData.getClientInfoProperties method to determine
+
−	 * the client info properties supported by the driver and the maximum length that may be specified
+
−	 * for each property.
+
−	 *
+
−	 * The driver stores the value specified in a suitable location in the database. For example
+
−	 * in a special register, session parameter, or system table column. For efficiency the driver
+
−	 * may defer setting the value in the database until the next time a statement is executed
+
−	 * or prepared. Other than storing the client information in the appropriate place in the
+
−	 * database, these methods shall not alter the behavior of the connection in anyway.
+
−	 * The values supplied to these methods are used for accounting, diagnostics and debugging purposes only.
+
−	 *
+
−	 * The driver shall generate a warning if the client info name specified is not recognized by the driver.
+
−	 *
+
−	 * If the value specified to this method is greater than the maximum length for the property
+
−	 * the driver may either truncate the value and generate a warning or generate a SQLClientInfoException.
+
−	 * If the driver generates a SQLClientInfoException, the value specified was not set on the connection.
+
−	 *
+
−	 * The following are standard client info properties. Drivers are not required to support these
+
−	 * properties however if the driver supports a client info property that can be described by one
+
−	 * of the standard properties, the standard property name should be used.
+
−	 *
+
−	 *	ApplicationName - The name of the application currently utilizing the connection
+
−	 *	ClientUser - The name of the user that the application using the connection is performing work for.
+
−	 *		This may not be the same as the user name that was used in establishing the connection.
+
−	 *	ClientHostname - The hostname of the computer the application using the connection is running on.
+
−	 *
+
−	 * @param name - The name of the client info property to set
+
−	 * @param value - The value to set the client info property to. If the
+
−	 *        value is null, the current value of the specified property is cleared.
+
−	 * @throws SQLClientInfoException - if the database server returns an error
+
−	 *         while setting the clientInfo values on the database server
+
−	 *         or this method is called on a closed connection
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public void setClientInfo(final String name, final String value) throws SQLClientInfoException {
+
−		ClientInfo info = new ClientInfo();
+
−		try {
+
−			info.set(name, value, getClientInfoAttributeNames().keySet());
+
−			sendClientInfo(info);
+
−			SQLWarning warn = info.warnings();
+
−			if (warn != null)
+
−				addWarning(warn);
+
−		} catch (SQLException e) {
+
−			throw info.wrapException(e);
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Sets the value of the connection's client info properties.
+
−	 * The Properties object contains the names and values of the client info
+
−	 * properties to be set. The set of client info properties contained in the
+
−	 * properties list replaces the current set of client info properties on the connection.
+
−	 * If a property that is currently set on the connection is not present in the
+
−	 * properties list, that property is cleared. Specifying an empty properties list
+
−	 * will clear all of the properties on the connection.
+
−	 * See setClientInfo (String, String) for more information.
+
−	 *
+
−	 * If an error occurs in setting any of the client info properties, a
+
−	 * SQLClientInfoException is thrown. The SQLClientInfoException contains information
+
−	 * indicating which client info properties were not set. The state of the client
+
−	 * information is unknown because some databases do not allow multiple client info
+
−	 * properties to be set atomically. For those databases, one or more properties may
+
−	 * have been set before the error occurred.
+
−	 *
+
−	 * @param props - The list of client info properties to set
+
−	 * @throws SQLClientInfoException - if the database server returns an error
+
−	 *	while setting the clientInfo values on the database server
+
−	 *	or this method is called on a closed connection
+
−	 * @since 1.6
+
−	 */
+
−	@Override
+
−	public void setClientInfo(final Properties props) throws SQLClientInfoException {
+
−		ClientInfo info = new ClientInfo();
+
−		try {
+
−			for (String name: props.stringPropertyNames()) {
+
−				String value = props.getProperty(name);
+
−				info.set(name, value, getClientInfoAttributeNames().keySet());
+
−			}
+
−			sendClientInfo(info);
+
−			SQLWarning warn = info.warnings();
+
−			if (warn != null)
+
−				addWarning(warn);
+
−		} catch (SQLClientInfoException e) {
+
−			throw e;
+
−		} catch (SQLException e) {
+
−			throw info.wrapException(e);
+
−		}
+
−	}
+
−
+
−	private void sendClientInfo(ClientInfo info) throws SQLException {
+
−		String formatted = info.format();
+
−		if (!formatted.isEmpty())
+
−			sendControlCommand("clientinfo " + formatted);
+
−	}
+
−
+
−	//== Java 1.7 methods (JDBC 4.1)
+
−
+
−	/**
+
−	 * Sets the given schema name to access.
+
−	 *
+
−	 * @param schema the name of a schema in which to work
+
−	 * @throws SQLException if a database access error occurs or this
+
−	 *         method is called on a closed connection
+
−	 * @since 1.7
+
−	 */
+
−	@Override
+
−	public void setSchema(final String schema) throws SQLException {
+
−		checkNotClosed();
+
−		if (schema == null || schema.isEmpty())
+
−			throw new SQLException("Missing schema name", "M1M05");
+
−
+
−		Statement st = null;
+
−		try {
+
−			st = createStatement();
+
−			if (st != null)
+
−				st.execute("SET SCHEMA \"" + schema + "\"");
+
−		// do not catch any Exception, just let it propagate
+
−		} finally {
+
−			closeResultsetStatement(null, st);
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Retrieves this Connection object's current schema name.
+
−	 *
+
−	 * @return the current schema name or null if there is none
+
−	 * @throws SQLException if a database access error occurs or this
+
−	 *         method is called on a closed connection
+
−	 * @since 1.7
+
−	 */
+
−	@Override
+
−	public String getSchema() throws SQLException {
+
−		checkNotClosed();
+
−
+
−		String cur_schema = null;
+
−		Statement st = null;
+
−		ResultSet rs = null;
+
−		try {
+
−			st = createStatement();
+
−			if (st != null) {
+
−				rs = st.executeQuery("SELECT CURRENT_SCHEMA");
+
−				if (rs != null && rs.next()) {
+
−					cur_schema = rs.getString(1);
+
−				}
+
−			}
+
−		// do not catch any Exception, just let it propagate
+
−		} finally {
+
−			closeResultsetStatement(rs, st);
+
−		}
+
−		if (cur_schema == null)
+
−			throw new SQLException("Failed to fetch schema name", "02000");
+
−		return cur_schema;
+
−	}
+
−
+
−	/**
+
−	 * Terminates an open connection. Calling abort results in:
+
−	 *  * The connection marked as closed
+
−	 *  * Closes any physical connection to the database
+
−	 *  * Releases resources used by the connection
+
−	 *  * Insures that any thread that is currently accessing the
+
−	 *    connection will either progress to completion or throw an
+
−	 *    SQLException.
+
−	 * Calling abort marks the connection closed and releases any
+
−	 * resources. Calling abort on a closed connection is a no-op.
+
−	 *
+
−	 * @param executor The Executor implementation which will be used by
+
−	 *        abort
+
−	 * @throws SQLException if a database access error occurs or the
+
−	 *         executor is null
+
−	 * @throws SecurityException if a security manager exists and
+
−	 *         its checkPermission method denies calling abort
+
−	 * @since 1.7
+
−	 */
+
−	@Override
+
−	public void abort(final Executor executor) throws SQLException {
+
−		if (closed)
+
−			return;
+
−		if (executor == null)
+
−			throw new SQLException("executor is null", "M1M05");
+
−
+
−		executor.execute(new Runnable() {
+
−			@Override
+
−			public void run() {
+
−				// this is really the simplest thing to do, it destroys
+
−				// everything (in particular the server connection)
+
−				close();
+
−			}
+
−		});
+
−	}
+
−
+
−	/**
+
−	 * Sets the maximum period a Connection or objects created from the
+
−	 * Connection will wait for the database to reply to any one
+
−	 * request. If any request remains unanswered, the waiting method
+
−	 * will return with a SQLException, and the Connection or objects
+
−	 * created from the Connection will be marked as closed. Any
+
−	 * subsequent use of the objects, with the exception of the close,
+
−	 * isClosed or Connection.isValid methods, will result in a
+
−	 * SQLException.
+
−	 *
+
−	 * @param executor The Executor implementation which will be used by
+
−	 *        setNetworkTimeout
+
−	 * @param millis The time in milliseconds to wait for the
+
−	 *        database operation to complete
+
−	 * @throws SQLException if a database access error occurs, this
+
−	 *         method is called on a closed connection, the executor is
+
−	 *         null, or the value specified for seconds is less than 0.
+
−	 * @since 1.7
+
−	 */
+
−	@Override
+
−	public void setNetworkTimeout(final Executor executor, final int millis) throws SQLException {
+
−		checkNotClosed();
+
−//		executor object is not used yet, so no need to test it.
+
−//		if (executor == null)
+
−//			throw new SQLException("executor is null", "M1M05");
+
−		if (millis < 0)
+
−			throw new SQLException("milliseconds is less than zero", "M1M05");
+
−
+
−		try {
+
−			server.setSoTimeout(millis);
+
−		} catch (SocketException e) {
+
−			throw new SQLNonTransientConnectionException(e.getMessage(), "08000");
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Retrieves the number of milliseconds the driver will wait for a
+
−	 * database request to complete. If the limit is exceeded, a
+
−	 * SQLException is thrown.
+
−	 *
+
−	 * @return the current timeout limit in milliseconds; zero means
+
−	 *         there is no limit
+
−	 * @throws SQLException if a database access error occurs or
+
−	 *         this method is called on a closed Connection
+
−	 * @since 1.7
+
−	 */
+
−	@Override
+
−	public int getNetworkTimeout() throws SQLException {
+
−		checkNotClosed();
+
−		try {
+
−			return server.getSoTimeout();
+
−		} catch (SocketException e) {
+
−			throw new SQLNonTransientConnectionException(e.getMessage(), "08000");
+
−		}
+
−	}
+
−
+
−	//== end methods of interface java.sql.Connection
+
−
+
−
+
−	//== internal helper methods which do NOT belong to the JDBC interface
+
−
+
−	/**
+
−	 * Construct a Properties object holding all connection parameters such
+
−	 * as host, port, TLS configuration, autocommit, etc.
+
−	 * Passing this to {@link java.sql.DriverManager#getConnection(String,java.util.Properties)}
+
−	 * together with the URL "jdbc:monetdb:" will create a new connection identical to
+
−	 * the current one.
+
−	 *
+
−	 * @return a Properties object
+
−	 */
+
−	public Properties getConnectionProperties() {
+
−		return target.getProperties();
+
−	}
+
−
+
−
+
−	/** Handler for COPY ... INTO ... FROM 'data-file-name' ON CLIENT requests */
+
−	private UploadHandler uploadHandler;
+
−	/** Handler for COPY ... INTO 'data-file-name' ON CLIENT requests */
+
−	private DownloadHandler downloadHandler;
+
−
+
−	/**
+
−	 * Registers a {@link UploadHandler} to support for example COPY INTO mytable FROM 'data.csv' ON CLIENT
+
−	 *
+
−	 * @param uploadHandler the handler to register, or null to deregister
+
−	 */
+
−	public void setUploadHandler(final UploadHandler uploadHandler) {
+
−		this.uploadHandler = uploadHandler;
+
−	}
+
−
+
−	/**
+
−	 * Get the currently registered {@link UploadHandler}, or null
+
−	 *
+
−	 * @return the currently registered UploadHandler, or null
+
−	 */
+
−	public UploadHandler getUploadHandler() {
+
−		return uploadHandler;
+
−	}
+
−
+
−	/**
+
−	 * Registers a {@link DownloadHandler} to support for example COPY select_result INTO 'data.csv' ON CLIENT
+
−	 *
+
−	 * @param downloadHandler the handler to register, or null to deregister
+
−	 */
+
−	public void setDownloadHandler(final DownloadHandler downloadHandler) {
+
−		this.downloadHandler = downloadHandler;
+
−	}
+
−
+
−	/**
+
−	 * Get the currently registered {@link DownloadHandler} handler, or null
+
−	 *
+
−	 * @return the currently registered DownloadHandler handler, or null
+
−	 */
+
−	public DownloadHandler getDownloadHandler() {
+
−		return downloadHandler;
+
−	}
+
−
+
−	/**
+
−	 * Local helper method to set the time zone for this connection
+
−	 *
+
−	 * @param offsetSeconds Time Zone offset in seconds, can be negative or zero
+
−	 * @throws SQLException if an IO exception or a database error occurs
+
−	 */
+
−	private void setTimezone(int offsetSeconds) throws SQLException {
+
−		final StringBuilder tz = new StringBuilder(64);
+
−		tz.append("SET TIME ZONE INTERVAL '");
+
−		int offsetMinutes = offsetSeconds / 60;
+
−		if (offsetMinutes < 0) {
+
−			tz.append('-');
+
−			offsetMinutes = -offsetMinutes; // make it positive
+
−		} else {
+
−			tz.append('+');
+
−		}
+
−		int offsetHours = offsetMinutes / 60;
+
−		if (offsetHours < 10)
+
−			tz.append('0');
+
−		tz.append(offsetHours).append(':');
+
−		offsetMinutes -= offsetHours * 60;
+
−		if (offsetMinutes < 10)
+
−			tz.append('0');
+
−		tz.append(offsetMinutes).append("' HOUR TO MINUTE");
+
−		sendIndependentCommand(tz.toString());
+
−	}
+
−
+
−	/**
+
−	 * Local helper method to check whether the Connection object is closed
+
−	 * and throw an SQLExecption if it is closed.
+
−	 *
+
−	 * @throws SQLException if this connection is closed
+
−	 */
+
−	private void checkNotClosed() throws SQLException {
+
−		if (closed)
+
−			throw new SQLException("Connection is closed", "M1M20");
+
−	}
+
−
+
−	/**
+
−	 * Utility method to call sys.setquerytimeout(int); procedure on the connected server
+
−	 * or sys.settimeout(int); procedure on older servers which do not support the new procedure.
+
−	 * It is called from: MonetConnection.isValid() and MonetStatement.internalExecute()
+
−	 *
+
−	 * @param seconds the time out time in seconds
+
−	 * @throws SQLException if an IO exception or a database error occurs
+
−	 */
+
−	void setQueryTimeout(final int seconds) throws SQLException {
+
−		if (seconds < 0)
+
−			throw new SQLException("query timeout seconds is less than zero", "M1M05");
+
−
+
−		checkNotClosed();
+
−		Statement st = null;
+
−		try {
+
−			final String callstmt;
+
−
+
−			// as of release Jun2020 (11.37.7) the function sys.settimeout(secs bigint)
+
−			// is deprecated and replaced by new sys.setquerytimeout(secs int)
+
−			if (checkMinimumDBVersion(11, 37))
+
−				callstmt = "CALL sys.\"setquerytimeout\"(" + seconds + ")";
+
−			else
+
−				callstmt = "CALL sys.\"settimeout\"(" + seconds + ")";
+
−
+
−			// for debug: System.out.println("Before: " + callstmt);
+
−			st = createStatement();
+
−			st.execute(callstmt);
+
−			// for debug: System.out.println("After : " + callstmt);
+
−
+
−			this.lastSetQueryTimeout = seconds;
+
−		}
+
−		/* do not catch SQLException here, as we want to know it when it fails */
+
−		finally {
+
−			closeResultsetStatement(null, st);
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * This allows generic JDBC programs to fetch Blob data via getBytes()
+
−	 * instead of getBlob() and Blob.getBinaryStream() to reduce overhead.
+
−	 * It is called from: MonetResultSet and MonetPreparedStatement
+
−	 *
+
−	 * @return whether the JDBC BLOB type should be mapped to VARBINARY type.
+
−	 */
+
−	boolean mapBlobAsVarBinary() {
+
−		return target.isTreatBlobAsBinary();
+
−	}
+
−
+
−	/**
+
−	 * This allows generic JDBC programs to fetch Clob data via getString()
+
−	 * instead of getClob() and Clob.getCharacterStream() to reduce overhead.
+
−	 * It is called from: MonetResultSet and MonetPreparedStatement
+
−	 *
+
−	 * @return whether the JDBC CLOB type should be mapped to VARCHAR type.
+
−	 */
+
−	boolean mapClobAsVarChar() {
+
−		return target.isTreatClobAsVarchar();
+
−	}
+
−
+
−	/**
+
−	 * It is called from: getURL()in MonetDatabaseMetaData
+
−	 *
+
−	 * @return the MonetDB JDBC Connection URL (without user name and password).
+
−	 */
+
−	String getJDBCURL() {
+
−		return target.buildUrl();
+
−	}
+
−
+
−	// Internal caches for 4 static mserver5 environment values
+
−	private String env_current_user;
+
−	private String env_monet_version;
+
−	private String env_raw_strings;	// Note: this is only supported from Jun2020 (11.37) servers
+
−	private int maxConnections;
+
−
+
−	/**
+
−	 * Utility method to fetch 4 mserver5 environment values combined in one query for efficiency.
+
−	 * We fetch the env values of: current_user, monet_version, max_clients and raw_strings.
+
−	 * We cache them such that we do not need to query the server again and again.
+
−	 * Note: raw_strings is available in sys.env() result set since release Jun2020 (11.37)
+
−	 *
+
−	 * @throws SQLException if execution of query failed
+
−	 */
+
−	private synchronized void getEnvValues() throws SQLException {
+
−		Statement st = null;
+
−		ResultSet rs = null;
+
−		try {
+
−			st = createStatement();
+
−			if (st != null) {
+
−				rs = st.executeQuery(
+
−					"SELECT \"name\", \"value\" FROM \"sys\".\"env\"()" +
+
−					" WHERE \"name\" IN ('monet_version', 'max_clients', 'raw_strings')" +
+
−					" UNION SELECT 'current_user' as \"name\", current_user as \"value\"");
+
−				if (rs != null) {
+
−					while (rs.next()) {
+
−						final String prop = rs.getString(1);
+
−						final String value = rs.getString(2);
+
−						if ("current_user".equals(prop)) {
+
−							env_current_user = value;
+
−						} else
+
−						if ("monet_version".equals(prop)) {
+
−							env_monet_version = value;
+
−						} else
+
−						if ("raw_strings".equals(prop)) {
+
−							env_raw_strings = value;
+
−						} else
+
−						if ("max_clients".equals(prop) && value != null) {
+
−							try {
+
−								maxConnections = Integer.parseInt(value);
+
−							} catch (NumberFormatException nfe) {
+
−								/* ignore */
+
−							}
+
−							if (maxConnections <= 0)
+
−								maxConnections = 1;
+
−						}
+
−					}
+
−				}
+
−			}
+
−		/* do not catch SQLException here, as we need to know it when it fails */
+
−		} finally {
+
−			closeResultsetStatement(rs, st);
+
−		}
+
−		// for debug: System.out.println("Read: env_current_user: " + env_current_user + "  env_monet_version: " + env_monet_version + "  env_max_clients: " + maxConnections + "  env_raw_strings: " + env_raw_strings);
+
−	}
+
−
+
−	/**
+
−	 * Get user login name from the server.
+
−	 * It is called from: MonetDatabaseMetaData
+
−	 *
+
−	 * @return the current User Name for this comnection
+
−	 * @throws SQLException if fetching user name failed
+
−	 */
+
−	String getUserName() throws SQLException {
+
−		if (env_current_user == null)
+
−			getEnvValues();
+
−		return env_current_user;
+
−	}
+
−
+
−	/**
+
−	 * Get the maximum number of allowed connections from the server.
+
−	 * It is called from: MonetDatabaseMetaData
+
−	 * A result of zero means that there is no limit or the limit is not known
+
−	 *
+
−	 * @return the maximum number of active connections possible at one time
+
−	 * @throws SQLException if fetching maximum connections failed
+
−	 */
+
−	int getMaxConnections() throws SQLException {
+
−		if (maxConnections == 0)
+
−			getEnvValues();
+
−		return maxConnections;
+
−	}
+
−
+
−	/**
+
−	 * Get whether the server is started with raw_strings turned on.
+
−	 * By default this is false (so C-style strings processing is used).
+
−	 * When a server is started with option: --set raw_strings=true
+
−	 * then this will return true, else false.
+
−	 * This startup option is supported only by servers since Jun2020 (11.37) onwards.
+
−	 *
+
−	 * @return whether the server is started with raw_strings processing enabled.
+
−	 * @throws SQLException if fetching raw_strings setting failed
+
−	 */
+
−	boolean inRawStringsMode() throws SQLException {
+
−		if (env_raw_strings == null) {
+
−			getEnvValues();
+
−			if (env_raw_strings == null) {
+
−				/* older servers (pre Jun2020 (11.37)) do not
+
−				 * return this in the sys.env() view and did
+
−				 * not yet support raw_strings.
+
−				 * So set it to: false. */
+
−				env_raw_strings = "false";
+
−			}
+
−		}
+
−		return "true".equals(env_raw_strings);
+
−	}
+
−
+
−	/**
+
−	 * Get the product version of the connected MonetDB Database Server.
+
−	 * It is called from: MonetDatabaseMetaData
+
−	 *
+
−	 * @return the MonetDB Database Server version string.
+
−	 * @throws SQLException if fetching MonetDB server version string failed
+
−	 */
+
−	String getDatabaseProductVersion() throws SQLException {
+
−		if (env_monet_version == null)
+
−			getEnvValues();
+
−		// always return a valid String to prevent NPE in getTables() and getTableTypes()
+
−		if (env_monet_version != null)
+
−			return env_monet_version;
+
−		return "";
+
−	}
+
−
+
−	private int databaseMajorVersion;
+
−	/**
+
−	 * Get the major product version of the connected MonetDB Database Server.
+
−	 * The number is extracted from the env_monet_version the first time and cached for next calls.
+
−	 * It is called from: MonetDatabaseMetaData and MonetConnection
+
−	 *
+
−	 * @return the MonetDB Database Server major version number.
+
−	 * @throws SQLException if fetching MonetDB server version string failed
+
−	 */
+
−	int getDatabaseMajorVersion() throws SQLException {
+
−		if (databaseMajorVersion == 0) {
+
−			if (env_monet_version == null)
+
−				getEnvValues();
+
−			if (env_monet_version != null) {
+
−				try {
+
−					// from version string such as 11.33.9 extract number: 11
+
−					final int end = env_monet_version.indexOf('.');
+
−					databaseMajorVersion = Integer.parseInt((end >= 0) ? env_monet_version.substring(0, end) : env_monet_version);
+
−				} catch (NumberFormatException nfe) {
+
−					// ignore
+
−				}
+
−			}
+
−		}
+
−		return databaseMajorVersion;
+
−	}
+
−
+
−	private int databaseMinorVersion;
+
−	/**
+
−	 * Get the minor product version of the connected MonetDB Database Server.
+
−	 * The number is extracted from the env_monet_version the first time and cached for next calls.
+
−	 * It is called from: MonetDatabaseMetaData and MonetConnection
+
−	 *
+
−	 * @return the MonetDB Database Server minor version number.
+
−	 * @throws SQLException if fetching MonetDB server version string failed
+
−	 */
+
−	int getDatabaseMinorVersion() throws SQLException {
+
−		if (databaseMinorVersion == 0) {
+
−			if (env_monet_version == null)
+
−				getEnvValues();
+
−			if (env_monet_version != null) {
+
−				try {
+
−					// from version string such as 11.33.9 extract number: 33
+
−					int start = env_monet_version.indexOf('.');
+
−					if (start >= 0) {
+
−						start++;
+
−						final int end = env_monet_version.indexOf('.', start);
+
−						databaseMinorVersion = Integer.parseInt((end > 0) ? env_monet_version.substring(start, end) : env_monet_version.substring(start));
+
−					}
+
−				} catch (NumberFormatException nfe) {
+
−					// ignore
+
−				}
+
−			}
+
−		}
+
−		return databaseMinorVersion;
+
−	}
+
−
+
−	/**
+
−	 * Utility method to check if connected server matches or is higher than a requested version.
+
−	 *
+
−	 * @param major dbserver major version number.
+
−	 * @param minor dbserver minor version number.
+
−	 * @return true when the server version is higher or equal to the major.minor else false.
+
−	 */
+
−	boolean checkMinimumDBVersion(int major, int minor) {
+
−		try {
+
−			if ((getDatabaseMinorVersion() >= minor) && (getDatabaseMajorVersion() == major))
+
−				return true;
+
−		} catch (SQLException e) { /* ignore */	}
+
−		return false;
+
−	}
+
−
+
−	/**
+
−	 * Get whether the MonetDB SQL parser supports ODBC/JDBC escape sequence syntax.
+
−	 * See also: https://docs.oracle.com/javadb/10.6.2.1/ref/rrefjdbc1020262.html
+
−	 * It does when the server version is 11.47 (Jun2023) or higher.
+
−	 * This method is called from: MonetDatabaseMetaData and MonetCallableStatement.
+
−	 *
+
−	 * @return true when the server supports ODBC/JDBC escape sequence syntax else false.
+
−	 */
+
−	boolean supportsEscapeSequenceSyntax() {
+
−		return checkMinimumDBVersion(11, 47);
+
−	}
+
−
+
−
+
−	// Internal cache for determining if system table sys.privilege_codes (new as of Jul2017 release) exists on connected server
+
−	private boolean queriedPrivilege_codesTable = false;
+
−	private boolean hasPrivilege_codesTable = false;
+
−	/**
+
−	 * Utility method to query the server to find out if it has
+
−	 * the system table sys.privilege_codes (which is new as of Jul2017 release).
+
−	 * The result is cached and reused, so that we only test the query once per connection.
+
−	 * This method is used by methods from MonetDatabaseMetaData.
+
−	 *
+
−	 * @return whether the system table sys.privilege_codes exist in the connected server.
+
−	 */
+
−	boolean privilege_codesTableExists() {
+
−		if (!queriedPrivilege_codesTable) {
+
−			querySysTable();
+
−			queriedPrivilege_codesTable = true;	// set flag, so the querying is done only at first invocation.
+
−		}
+
−		return hasPrivilege_codesTable;
+
−	}
+
−
+
−	// Internal cache for determining if system table sys.comments (new as of Mar2018 release) exists on connected server
+
−	private boolean queriedCommentsTable = false;
+
−	private boolean hasCommentsTable = false;
+
−	/**
+
−	 * Utility method to query the server to find out if it has
+
−	 * the system table sys.comments (which is new as of Mar2018 release).
+
−	 * The result is cached and reused, so that we only test the query once per connection.
+
−	 * This method is used by methods from MonetDatabaseMetaData.
+
−	 *
+
−	 * @return whether the system table sys.comments exist in the connected server.
+
−	 */
+
−	boolean commentsTableExists() {
+
−		if (!queriedCommentsTable) {
+
−			querySysTable();
+
−			queriedCommentsTable = true;	// set flag, so the querying is done only at first invocation.
+
−		}
+
−		return hasCommentsTable;
+
−	}
+
−
+
−
+
−	/**
+
−	 * Internal utility method to query the server to find out if it has a specific system tables.
+
−	 */
+
−	private void querySysTable() {
+
−		Statement stmt = null;
+
−		ResultSet rs = null;
+
−		try {
+
−			stmt = createStatement();
+
−			if (stmt != null) {
+
−				rs = stmt.executeQuery("SELECT name FROM sys._tables WHERE name in ('privilege_codes', 'comments')"
+
−							+ " AND schema_id IN (SELECT id FROM sys.schemas WHERE name = 'sys')");
+
−				if (rs != null) {
+
−					while (rs.next()) {
+
−						String name = rs.getString(1);
+
−						// for debug: System.out.println("querySysTable() retrieved name: " + name);
+
−						if ("comments".equals(name)) {
+
−							hasCommentsTable = true;
+
−							queriedCommentsTable = true;
+
−						} else
+
−						if ("privilege_codes".equals(name)) {
+
−							hasPrivilege_codesTable = true;
+
−							queriedPrivilege_codesTable = true;
+
−						}
+
−					}
+
−				}
+
−			}
+
−		} catch (SQLException se) {
+
−			/* ignore */
+
−		} finally {
+
−			closeResultsetStatement(rs, stmt);
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Closes a ResultSet and/or Statement object without throwing any SQLExceptions
+
−	 * It can be used in the finally clause after creating a Statement and
+
−	 * (optionally) executed a query which produced a ResultSet.
+
−	 *
+
−	 * @param rs ResultSet object to be closed. It may be null
+
−	 * @param st Statement object to be closed. It may be null
+
−	 */
+
−	static final void closeResultsetStatement(final ResultSet rs, final Statement st) {
+
−		if (rs != null) {
+
−			try {
+
−				rs.close();
+
−			} catch (SQLException e) { /* ignore */ }
+
−		}
+
−		if (st != null) {
+
−			try {
+
−				st.close();
+
−			} catch (SQLException e) { /* ignore */ }
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Sends the given string to MonetDB as special transaction command.
+
−	 * All possible returned information is discarded.
+
−	 * Encountered errors are reported.
+
−	 *
+
−	 * @param command the exact string to send to MonetDB
+
−	 * @throws SQLException if an IO exception or a database error occurs
+
−	 */
+
−	private void sendTransactionCommand(final String command) throws SQLException {
+
−		// create a container for the result
+
−		final ResponseList l = new ResponseList(0, 0, ResultSet.FETCH_FORWARD, ResultSet.CONCUR_READ_ONLY);
+
−		// send the appropriate query string to the database
+
−		try {
+
−			l.processQuery(command);
+
−		} finally {
+
−			l.close();
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Sends the given string to MonetDB as regular SQL statement/query using queryTempl
+
−	 * Making sure there is a prompt after the command is sent.  All possible
+
−	 * returned information is discarded.  Encountered errors are reported.
+
−	 *
+
−	 * @param command the exact string to send to MonetDB
+
−	 * @throws SQLException if an IO exception or a database error occurs
+
−	 */
+
−	private void sendIndependentCommand(String command) throws SQLException {
+
−		sendCommand(command, true);
+
−	}
+
−
+
−	/**
+
−	 * Sends the given string to MonetDB as control statement using commandTempl
+
−	 * Making sure there is a prompt after the command is sent.  All possible
+
−	 * returned information is discarded.  Encountered errors are reported.
+
−	 *
+
−	 * @param command the exact string to send to MonetDB
+
−	 * @throws SQLException if an IO exception or a database error occurs
+
−	 */
+
−	void sendControlCommand(String command) throws SQLException {
+
−		// send X command
+
−		sendCommand(command, false);
+
−	}
+
−
+
−	/**
+
−	 * Sends the given string to MonetDB as command/query using commandTempl or queryTempl
+
−	 * Making sure there is a prompt after the command is sent.  All possible
+
−	 * returned information is discarded. Encountered errors are reported.
+
−	 *
+
−	 * @param command the exact string to send to MonetDB
+
−	 * @param usequeryTempl send the command using queryTempl or else using commandTempl
+
−	 * @throws SQLException if an IO exception or a database error occurs
+
−	 */
+
−	private void sendCommand(final String command, final boolean usequeryTempl) throws SQLException {
+
−		synchronized (server) {
+
−			try {
+
−				if (usequeryTempl)
+
−					out.writeLine(queryTempl[0] + command + queryTempl[1]);
+
−				else
+
−					out.writeLine(commandTempl[0] + command + commandTempl[1]);
+
−				final String error = in.discardRemainder();
+
−				if (error != null)
+
−					throw new SQLException(error.substring(6), error.substring(0, 5));
+
−			} catch (SocketTimeoutException e) {
+
−				close(); // JDBC 4.1 semantics, abort()
+
−				throw new SQLNonTransientConnectionException("connection timed out", "08M33");
+
−			} catch (IOException e) {
+
−				throw new SQLNonTransientConnectionException(e.getMessage(), "08000");
+
−			}
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Adds a warning to the pile of warnings this Connection object has.
+
−	 * If there were no warnings (or clearWarnings was called) this
+
−	 * warning will be the first, otherwise this warning will get
+
−	 * appended to the current warning.
+
−	 *
+
−	 * @param warning The warning to add
+
−	 */
+
−	private final void addWarning(SQLWarning warning) {
+
−		if (warnings == null) {
+
−			warnings = warning;
+
−		} else {
+
−			warnings.setNextWarning(warning);
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Adds a warning to the pile of warnings this Connection object has.
+
−	 * If there were no warnings (or clearWarnings was called) this
+
−	 * warning will be the first, otherwise this warning will get
+
−	 * appended to the current warning.
+
−	 *
+
−	 * @param reason the warning message
+
−	 * @param sqlstate the SQLState code (5 characters)
+
−	 */
+
−	private final void addWarning(final String reason, final String sqlstate) {
+
−		final SQLWarning warning = new SQLWarning(reason, sqlstate);
+
−		addWarning(warning);
+
−	}
+
−
+
−	/** the default number of rows that are (attempted to) read at once */
+
−	private static final int DEF_FETCHSIZE = 250;
+
−
+
−	/** the default number of rows to read at once from this connection */
+
−	private int defaultFetchSize = DEF_FETCHSIZE;
+
−	/** The sequence counter */
+
−	private static int seqCounter = 0;
+
−
+
−	/**
+
−	 * returns default fetchSize as set at connection moment
+
−	 *
+
−	 * @return defaultFetchSize
+
−	 */
+
−	protected int getDefaultFetchSize() {
+
−		return defaultFetchSize;
+
−	}
+
−
+
−	/**
+
−	 * A Response is a message sent by the server to indicate some
+
−	 * action has taken place, and possible results of that action.
+
−	 */
+
−	// {{{ interface Response
+
−	interface Response {
+
−		/**
+
−		 * Adds a line to the underlying Response implementation.
+
−		 *
+
−		 * @param line the header line as String
+
−		 * @param linetype the line type according to the MAPI protocol
+
−		 * @return a non-null String if the line is invalid,
+
−		 *         or additional lines are not allowed.
+
−		 */
+
−		String addLine(String line, LineType linetype);
+
−
+
−		/**
+
−		 * Returns whether this Response expects more lines to be added
+
−		 * to it.
+
−		 *
+
−		 * @return true if a next line should be added, false otherwise
+
−		 */
+
−		boolean wantsMore();
+
−
+
−		/**
+
−		 * Indicates that no more header lines will be added to this
+
−		 * Response implementation.
+
−		 *
+
−		 * @throws SQLException if the contents of the Response is not
+
−		 *         consistent or sufficient.
+
−		 */
+
−		/* MvD: disabled not used/needed code
+
−		void complete() throws SQLException;
+
−		*/
+
−
+
−		/**
+
−		 * Instructs the Response implementation to close and do the
+
−		 * necessary clean up procedures.
+
−		 */
+
−		void close();
+
−	}
+
−	// }}}
+
−
+
−	/**
+
−	 * The ResultSetResponse represents a tabular result sent by the
+
−	 * server.  This is typically an SQL table.  The MAPI headers of the
+
−	 * Response look like:
+
−	 * <pre>
+
−	 * &amp;1 1 28 2 10
+
−	 * % sys.props,	sys.props # table_name
+
−	 * % name,	value # name
+
−	 * % varchar,	int # type
+
−	 * % 15,	3 # length
+
−	 * % 60 0,	32 0 # typesizes
+
−	 * </pre>
+
−	 * there the first line consists out of<br />
+
−	 * <samp>&amp;"qt" "id" "tc" "cc" "rc"</samp>.
+
−	 */
+
−	// {{{ ResultSetResponse class implementation
+
−	final class ResultSetResponse implements Response {
+
−		/** The number of columns in this result */
+
−		public final int columncount;
+
−		/** The total number of rows this result set has */
+
−		public final long tuplecount;
+
−		/** The numbers of rows to retrieve per DataBlockResponse */
+
−		private int cacheSize;
+
−		/** The table ID of this result */
+
−		public final int id;
+
−
+
−		/** arrays for the resultset columns metadata */
+
−		/** The names of the columns in this result */
+
−		private String[] name;
+
−		/** The types of the columns in this result */
+
−		private String[] type;
+
−		/** The max string length for each column in this result */
+
−		private int[] columnLengths;
+
−		/** The precision for each column in this result */
+
−		private int[] colPrecisions;
+
−		/** The scale for each column in this result */
+
−		private int[] colScales;
+
−		/** The table for each column in this result */
+
−		private String[] tableNames;
+
−		/** The schema for each column in this result */
+
−		private String[] schemaNames;
+
−
+
−		/** The query sequence number */
+
−		private final int seqnr;
+
−		/** A List of result blocks (chunks of size fetchSize/cacheSize) */
+
−		private DataBlockResponse[] resultBlocks;
+
−
+
−		/** Whether this Response is closed */
+
−		private boolean closed;
+
−
+
−		/** The Connection that we should use when requesting a new block */
+
−		private final MonetConnection.ResponseList parent;
+
−		/** Whether the fetchSize was explicitly set by the user */
+
−		private final boolean cacheSizeSetExplicitly;
+
−		/** Whether we should send an Xclose command to the server
+
−		 *  if we close this Response */
+
−		private boolean destroyOnClose;
+
−		/** the offset to be used on Xexport queries */
+
−		private int blockOffset;
+
−
+
−		/** A parser for header lines */
+
−		private final HeaderLineParser hlp;
+
−
+
−		/** A boolean array telling whether the headers are set or not */
+
−		private final boolean[] isSet;
+
−		private static final int NAMES  = 0;
+
−		private static final int TYPES  = 1;
+
−		private static final int TABLES = 2;
+
−		private static final int LENS   = 3;
+
−		private static final int TYPESIZES = 4;
+
−
+
−		/**
+
−		 * Sole constructor, which requires a MonetConnection parent to
+
−		 * be given.
+
−		 *
+
−		 * @param id the ID of the result set
+
−		 * @param tuplecount the total number of tuples in the result set
+
−		 * @param columncount the number of columns in the result set
+
−		 * @param rowcount the number of rows in the current block
+
−		 * @param parent the parent that created this Response and will
+
−		 *        supply new result blocks when necessary
+
−		 * @param seq the query sequence number
+
−		 */
+
−		ResultSetResponse(
+
−				final int id,
+
−				final long tuplecount,
+
−				final int columncount,
+
−				final int rowcount,
+
−				final MonetConnection.ResponseList parent,
+
−				final int seq)
+
−		{
+
−			isSet = new boolean[5];
+
−			this.parent = parent;
+
−			if (parent.cachesize == 0) {
+
−				/* Below we have to calculate how many "chunks" we need
+
−				 * to allocate to store the entire result.  However, if
+
−				 * the user didn't set a cache size, as in this case, we
+
−				 * need to stick to our defaults. */
+
−				cacheSize = defaultFetchSize;
+
−				cacheSizeSetExplicitly = false;
+
−			} else {
+
−				cacheSize = parent.cachesize;
+
−				cacheSizeSetExplicitly = true;
+
−			}
+
−			/* So far, so good.  Now the problem with EXPLAIN, DOT, etc
+
−			 * queries is, that they don't support any block fetching,
+
−			 * so we need to always fetch everything at once.  For that
+
−			 * reason, the cache size is here set to the rowcount if
+
−			 * it's larger, such that we do a full fetch at once.
+
−			 * (Because we always set a reply_size, we can only get a
+
−			 * larger rowcount from the server if it doesn't paginate,
+
−			 * because it's a pseudo SQL result.) */
+
−			if (rowcount > cacheSize)
+
−				cacheSize = rowcount;
+
−			seqnr = seq;
+
−			closed = false;
+
−			destroyOnClose = id > 0 && tuplecount > rowcount;
+
−
+
−			this.id = id;
+
−			this.tuplecount = tuplecount;
+
−			this.columncount = columncount;
+
−			this.resultBlocks = new DataBlockResponse[(int)(tuplecount / cacheSize) + 1];
+
−
+
−			hlp = new HeaderLineParser(columncount);
+
−
+
−			resultBlocks[0] = new DataBlockResponse(rowcount, parent.rstype == ResultSet.TYPE_FORWARD_ONLY);
+
−		}
+
−
+
−		/**
+
−		 * Parses the given string and changes the value of the matching
+
−		 * header appropriately, or passes it on to the underlying
+
−		 * DataBlockResponse.
+
−		 *
+
−		 * @param tmpLine the string that contains the header
+
−		 * @return a non-null String if the header cannot be parsed or
+
−		 *         is unknown
+
−		 */
+
−		@Override
+
−		public String addLine(final String tmpLine, final LineType linetype) {
+
−			// System.out.println("In ResultSetResponse.addLine(line, type: " + linetype + ") line: " + tmpLine);
+
−			if (linetype == LineType.RESULT ||
+
−			    (isSet[LENS] && isSet[TYPES] && isSet[TABLES] && isSet[NAMES] && isSet[TYPESIZES])) {
+
−				if (!isSet[TYPESIZES])
+
−					// this is needed to get proper output when processing a: DEBUG SQL-statement
+
−					isSet[TYPESIZES] = true;
+
−				return resultBlocks[0].addLine(tmpLine, linetype);
+
−			}
+
−
+
−			if (linetype != LineType.HEADER) {
+
−				if (!isSet[TYPESIZES])
+
−					isSet[TYPESIZES] = true;
+
−				return "Header expected, got " + linetype + " line: " + tmpLine;
+
−			}
+
−
+
−			// depending on the name of the header, we continue
+
−			try {
+
−				switch (hlp.parse(tmpLine)) {
+
−					case HeaderLineParser.NAME:
+
−						name = hlp.values.clone();
+
−						isSet[NAMES] = true;
+
−						break;
+
−					case HeaderLineParser.LENGTH:
+
−						columnLengths = hlp.intValues.clone();
+
−						isSet[LENS] = true;
+
−						break;
+
−					case HeaderLineParser.TYPE:
+
−						type = hlp.values.clone();
+
−						isSet[TYPES] = true;
+
−						break;
+
−					case HeaderLineParser.TABLE:
+
−					{
+
−						tableNames = hlp.values.clone();
+
−						final int array_size = tableNames.length;
+
−						schemaNames = new String[array_size];
+
−						// split the schema and table names from the cloned values array
+
−						for (int i = 0; i < array_size; i++) {
+
−							String qtable = tableNames[i];
+
−							if (qtable != null) {
+
−								int dot = qtable.indexOf('.');
+
−								if (dot >= 0) {
+
−									schemaNames[i] = qtable.substring(0, dot);
+
−									tableNames[i] = qtable.substring(dot +1);
+
−								} else {
+
−									schemaNames[i] = "";
+
−								}
+
−							} else {
+
−								schemaNames[i] = "";
+
−								tableNames[i] = "";
+
−							}
+
−						}
+
−						isSet[TABLES] = true;
+
−						break;
+
−					}
+
−					case HeaderLineParser.TYPESIZES:
+
−					{
+
−						// System.out.println("In ResultSetResponse.addLine() case HeaderLineParser.TYPESIZES: values: " + hlp.values[0]);
+
−						final int array_size = hlp.values.length;
+
−						colPrecisions = new int[array_size];
+
−						colScales = new int[array_size];
+
−						// extract the precision and scale integer numbers from the string
+
−						for (int i = 0; i < array_size; i++) {
+
−							String ps = hlp.values[i];
+
−							if (ps != null) {
+
−								try {
+
−									int separator = ps.indexOf(' ');
+
−									if (separator > 0) {
+
−										colPrecisions[i] = Integer.parseInt(ps.substring(0, separator));
+
−										colScales[i] = Integer.parseInt(ps.substring(separator +1));
+
−									} else {
+
−										colPrecisions[i] = Integer.parseInt(ps);
+
−										colScales[i] = 0;
+
−									}
+
−								} catch (NumberFormatException nfe) {
+
−									return nfe.getMessage();
+
−								}
+
−							} else {
+
−								colPrecisions[i] = 1;
+
−								colScales[i] = 0;
+
−							}
+
−						}
+
−						isSet[TYPESIZES] = true;
+
−						break;
+
−					}
+
−				}
+
−			} catch (MCLParseException e) {
+
−				return e.getMessage();
+
−			}
+
−
+
−			// all is well
+
−			return null;
+
−		}
+
−
+
−		/**
+
−		 * Returns whether this ResultSetResponse needs more lines.
+
−		 * This method returns true if not all headers are set, or the
+
−		 * first DataBlockResponse reports to want more.
+
−		 */
+
−		@Override
+
−		public boolean wantsMore() {
+
−			return resultBlocks[0].wantsMore();
+
−		}
+
−
+
−		/**
+
−		 * Returns an array of Strings containing the values between
+
−		 * ',\t' separators.
+
−		 *
+
−		 * @param chrLine a character array holding the input data
+
−		 * @param start where the relevant data starts
+
−		 * @param stop where the relevant data stops
+
−		 * @return an array of Strings
+
−		 */
+
−		private final String[] getValues(final char[] chrLine, int start, final int stop) {
+
−			int elem = 0;
+
−			final String[] values = new String[columncount];
+
−
+
−			for (int i = start; i < stop; i++) {
+
−				if (chrLine[i] == '\t' && chrLine[i - 1] == ',') {
+
−					values[elem++] =
+
−						new String(chrLine, start, i - 1 - start);
+
−					start = i + 1;
+
−				}
+
−			}
+
−			// at the left over part
+
−			values[elem++] = new String(chrLine, start, stop - start);
+
−
+
−			return values;
+
−		}
+
−
+
−		/**
+
−		 * Adds the given DataBlockResponse to this ResultSetResponse at
+
−		 * the given block position.
+
−		 *
+
−		 * @param offset the offset number of rows for this block
+
−		 * @param rr the DataBlockResponse to add
+
−		 */
+
−		void addDataBlockResponse(final int offset, final DataBlockResponse rr) {
+
−			final int block = (offset - blockOffset) / cacheSize;
+
−			resultBlocks[block] = rr;
+
−		}
+
−
+
−		/**
+
−		 * Marks this Response as being completed.  A complete Response
+
−		 * needs to be consistent with regard to its internal data.
+
−		 *
+
−		 * @throws SQLException if the data currently in this Response is not
+
−		 *         sufficient to be consistent
+
−		 */
+
−		/* MvD: disabled not used/needed code
+
−		@Override
+
−		public void complete() throws SQLException {
+
−			final StringBuilder err = new StringBuilder(99);
+
−			if (!isSet[NAMES])  err.append("name header missing\n");
+
−			if (!isSet[TYPES])  err.append("type header missing\n");
+
−			if (!isSet[TABLES]) err.append("table name header missing\n");
+
−			if (!isSet[LENS])   err.append("column width header missing\n");
+
−			if (!isSet[TYPESIZES]) err.append("column precision and scale header missing\n");
+
−			if (err.length() > 0)
+
−				throw new SQLException(err.toString(), "M0M10");
+
−		}
+
−		*/
+
−
+
−		/**
+
−		 * Returns the names of the columns
+
−		 *
+
−		 * @return the names of the columns
+
−		 */
+
−		String[] getNames() {
+
−			return name;
+
−		}
+
−
+
−		/**
+
−		 * Returns the types of the columns
+
−		 *
+
−		 * @return the types of the columns
+
−		 */
+
−		String[] getTypes() {
+
−			return type;
+
−		}
+
−
+
−		/**
+
−		 * Returns the table names of the columns
+
−		 *
+
−		 * @return the table names of the columns
+
−		 */
+
−		String[] getTableNames() {
+
−			return tableNames;
+
−		}
+
−
+
−		/**
+
−		 * Returns the schema names of the columns
+
−		 *
+
−		 * @return the schema names of the columns
+
−		 */
+
−		String[] getSchemaNames() {
+
−			return schemaNames;
+
−		}
+
−
+
−		/**
+
−		 * Returns the display lengths of the columns
+
−		 *
+
−		 * @return the display lengths of the columns
+
−		 */
+
−		int[] getColumnLengths() {
+
−			return columnLengths;
+
−		}
+
−
+
−		/**
+
−		 * Returns the precisions of the columns
+
−		 *
+
−		 * @return the precisions of the columns, it can return null
+
−		 */
+
−		int[] getColumnPrecisions() {
+
−			return colPrecisions;
+
−		}
+
−
+
−		/**
+
−		 * Returns the scales of the columns (0 when scale is not applicable)
+
−		 *
+
−		 * @return the scales of the columns, it can return null
+
−		 */
+
−		int[] getColumnScales() {
+
−			return colScales;
+
−		}
+
−
+
−		/**
+
−		 * Returns the cache size used within this Response
+
−		 *
+
−		 * @return the cache size
+
−		 */
+
−		int getCacheSize() {
+
−			return cacheSize;
+
−		}
+
−
+
−		/**
+
−		 * Returns the current block offset
+
−		 *
+
−		 * @return the current block offset
+
−		 */
+
−		int getBlockOffset() {
+
−			return blockOffset;
+
−		}
+
−
+
−		/**
+
−		 * Returns the ResultSet type, FORWARD_ONLY or not.
+
−		 *
+
−		 * @return the ResultSet type
+
−		 */
+
−		int getRSType() {
+
−			return parent.rstype;
+
−		}
+
−
+
−		/**
+
−		 * Returns the concurrency of the ResultSet.
+
−		 *
+
−		 * @return the ResultSet concurrency
+
−		 */
+
−		int getRSConcur() {
+
−			return parent.rsconcur;
+
−		}
+
−
+
−		/**
+
−		 * Returns a line from the cache. If the line is already present in the
+
−		 * cache, it is returned, if not appropriate actions are taken to make
+
−		 * sure the right block is being fetched and as soon as the requested
+
−		 * line is fetched it is returned.
+
−		 *
+
−		 * @param row the row in the result set to return
+
−		 * @return the exact row read as requested or null if the requested row
+
−		 *         is out of the scope of the result set
+
−		 * @throws SQLException if an database error occurs
+
−		 */
+
−		String getLine(final int row) throws SQLException {
+
−			if (row >= tuplecount || row < 0)
+
−				return null;
+
−
+
−			int block = (row - blockOffset) / cacheSize;
+
−			int blockLine = (row - blockOffset) % cacheSize;
+
−
+
−			// do we have the right block loaded? (optimistic try)
+
−			DataBlockResponse rawr = resultBlocks[block];
+
−			if (rawr == null) {
+
−				// load block
+
−				/// TODO: ponder about a maximum number of blocks to keep
+
−				///       in memory when dealing with random access to
+
−				///       reduce memory blow-up
+
−
+
−				// if we're running forward only, we can discard the old
+
−				// block loaded
+
−				if (parent.rstype == ResultSet.TYPE_FORWARD_ONLY) {
+
−					for (int i = 0; i < block; i++)
+
−						resultBlocks[i] = null;
+
−
+
−					if (MonetConnection.seqCounter - 1 == seqnr &&
+
−							!cacheSizeSetExplicitly &&
+
−							tuplecount - row > cacheSize &&
+
−							cacheSize < MonetConnection.DEF_FETCHSIZE * 10)
+
−					{
+
−						// there has no query been issued after this
+
−						// one, so we can consider this an uninterrupted
+
−						// continuation request.  Let's once increase
+
−						// the cacheSize as it was not explicitly set,
+
−						// since the chances are high that we won't
+
−						// bother anyone else by doing so, and just
+
−						// gaining some performance.
+
−
+
−						// store the previous position in the
+
−						// blockOffset variable
+
−						blockOffset += cacheSize;
+
−
+
−						// increase the cache size (a lot)
+
−						cacheSize *= 10;
+
−
+
−						// by changing the cacheSize, we also
+
−						// change the block measures.  Luckily
+
−						// we don't care about previous blocks
+
−						// because we have a forward running
+
−						// pointer only.  However, we do have
+
−						// to recalculate the block number, to
+
−						// ensure the next call to find this
+
−						// new block.
+
−						block = (row - blockOffset) / cacheSize;
+
−						blockLine = (row - blockOffset) % cacheSize;
+
−					}
+
−				}
+
−
+
−				// ok, need to fetch cache block first
+
−				parent.executeQuery(commandTempl,
+
−						"export " + id + " " + ((block * cacheSize) + blockOffset) + " " + cacheSize);
+
−				rawr = resultBlocks[block];
+
−				if (rawr == null)
+
−					throw new SQLException("resultBlocks[" + block + "] should have been fetched by now", "M0M10");
+
−			}
+
−
+
−			return rawr.getRow(blockLine);
+
−		}
+
−
+
−		/**
+
−		 * Closes this Response by sending an Xclose to the server indicating
+
−		 * that the result can be closed at the server side as well.
+
−		 */
+
−		@Override
+
−		public void close() {
+
−			if (closed)
+
−				return;
+
−
+
−			// send command to server indicating we're done with this
+
−			// result only if we had an ID in the header and this result
+
−			// was larger than the reply size
+
−			try {
+
−				if (destroyOnClose)
+
−					sendControlCommand("close " + id);
+
−			} catch (SQLException e) {
+
−				// probably a connection error...
+
−			}
+
−
+
−			// close the data block associated with us
+
−			for (int i = 1; i < resultBlocks.length; i++) {
+
−				DataBlockResponse r = resultBlocks[i];
+
−				if (r != null)
+
−					r.close();
+
−			}
+
−			name = null;
+
−			type = null;
+
−			columnLengths = null;
+
−			colPrecisions = null;
+
−			colScales = null;
+
−			tableNames = null;
+
−			schemaNames = null;
+
−			resultBlocks = null;
+
−			closed = true;
+
−		}
+
−
+
−		/**
+
−		 * Returns whether this Response is closed
+
−		 *
+
−		 * @return whether this Response is closed
+
−		 */
+
−		boolean isClosed() {
+
−			return closed;
+
−		}
+
−	}
+
−	// }}}
+
−
+
−	/**
+
−	 * The DataBlockResponse is tabular data belonging to a
+
−	 * ResultSetResponse.  Tabular data from the server typically looks
+
−	 * like:
+
−	 * <pre>
+
−	 * [ "value",	56	]
+
−	 * </pre>
+
−	 * where each column is separated by ",\t" and each tuple surrounded
+
−	 * by brackets ("[" and "]").  A DataBlockResponse object holds the
+
−	 * raw data as read from the server, in a parsed manner, ready for
+
−	 * easy retrieval.
+
−	 *
+
−	 * This object is not intended to be queried by multiple threads
+
−	 * synchronously. It is designed to work for one thread retrieving
+
−	 * rows from it.  When multiple threads will retrieve rows from this
+
−	 * object, it is possible for threads to get the same data.
+
−	 */
+
−	// {{{ DataBlockResponse class implementation
+
−	private final static class DataBlockResponse implements Response {
+
−		/** The String array to keep the data in */
+
−		private final String[] data;
+
−
+
−		/** The counter which keeps the current position in the data array */
+
−		private int pos;
+
−		/** Whether we can discard lines as soon as we have read them */
+
−		private final boolean forwardOnly;
+
−
+
−		/**
+
−		 * Constructs a DataBlockResponse object
+
−		 * @param size the size of the data array to create
+
−		 * @param forward whether this is a forward only result
+
−		 */
+
−		DataBlockResponse(final int size, final boolean forward) {
+
−			pos = -1;
+
−			data = new String[size];
+
−			forwardOnly = forward;
+
−		}
+
−
+
−		/**
+
−		 * addLine adds a String of data to this object's data array.
+
−		 * Note that an ArrayIndexOutOfBoundsException can be thrown when an
+
−		 * attempt is made to add more than the original construction size
+
−		 * specified.
+
−		 *
+
−		 * @param line the header line as String
+
−		 * @param linetype the line type according to the MAPI protocol
+
−		 * @return a non-null String if the line is invalid,
+
−		 *         or additional lines are not allowed.
+
−		 */
+
−		@Override
+
−		public String addLine(final String line, final LineType linetype) {
+
−			if (linetype != LineType.RESULT)
+
−				return "protocol violation: unexpected " + linetype + " line in data block: " + line;
+
−			// add to the backing array
+
−			data[++pos] = line;
+
−
+
−			// all is well
+
−			return null;
+
−		}
+
−
+
−		/**
+
−		 * Returns whether this Response expects more lines to be added
+
−		 * to it.
+
−		 *
+
−		 * @return true if a next line should be added, false otherwise
+
−		 */
+
−		@Override
+
−		public boolean wantsMore() {
+
−			// remember: pos is the value already stored
+
−			return pos + 1 < data.length;
+
−		}
+
−
+
−		/**
+
−		 * Indicates that no more header lines will be added to this
+
−		 * Response implementation.  In most cases this is a redundant
+
−		 * operation because the data array is full.  However... it can
+
−		 * happen that this is NOT the case!
+
−		 *
+
−		 * @throws SQLException if not all rows are filled
+
−		 */
+
−		/* MvD: disabled not used/needed code
+
−		@Override
+
−		public void complete() throws SQLException {
+
−			if ((pos + 1) != data.length)
+
−				throw new SQLException("Inconsistent state detected! Current block capacity: "
+
−					+ data.length + ", block usage: " + (pos + 1)
+
−					+ ". Did MonetDB send what it promised to?", "M0M10");
+
−		}
+
−		*/
+
−
+
−		/**
+
−		 * Instructs the Response implementation to close and do the
+
−		 * necessary clean up procedures.
+
−		 */
+
−		@Override
+
−		public void close() {
+
−			// feed all rows to the garbage collector
+
−			Arrays.fill(data, null);
+
−		}
+
−
+
−		/**
+
−		 * Retrieves the required row.  Warning: if the requested rows
+
−		 * is out of bounds, an IndexOutOfBoundsException will be
+
−		 * thrown.
+
−		 *
+
−		 * @param line the row to retrieve
+
−		 * @return the requested row as String
+
−		 */
+
−		String getRow(final int line) {
+
−			if (forwardOnly) {
+
−				final String ret = data[line];
+
−				data[line] = null;
+
−				return ret;
+
−			} else {
+
−				return data[line];
+
−			}
+
−		}
+
−	}
+
−	// }}}
+
−
+
−	/**
+
−	 * The UpdateResponse represents an update statement response.  It
+
−	 * is issued on an UPDATE, INSERT or DELETE SQL statement.  This
+
−	 * response keeps a count field that represents the affected rows
+
−	 * and a field that contains the last inserted auto-generated ID, or
+
−	 * -1 if not applicable.<br />
+
−	 * <samp>&amp;2 0 -1</samp>
+
−	 */
+
−	// {{{ UpdateResponse class implementation
+
−	final static class UpdateResponse implements Response {
+
−		public final long count;
+
−		public final String lastid;
+
−
+
−		public UpdateResponse(final long cnt, final String id) {
+
−			// fill the blank finals
+
−			this.count = cnt;
+
−			this.lastid = id;
+
−		}
+
−
+
−		@Override
+
−		public String addLine(final String line, final LineType linetype) {
+
−			return "Header lines are not supported for an UpdateResponse";
+
−		}
+
−
+
−		@Override
+
−		public boolean wantsMore() {
+
−			return false;
+
−		}
+
−
+
−		/* MvD: disabled not used/needed code
+
−		@Override
+
−		public void complete() {
+
−			// empty, because there is nothing to check
+
−		}
+
−		*/
+
−
+
−		@Override
+
−		public void close() {
+
−			// nothing to do here...
+
−		}
+
−	}
+
−	// }}}
+
−
+
−	/**
+
−	 * The SchemaResponse represents an schema modification response.
+
−	 * It is issued on statements like CREATE, DROP or ALTER TABLE.
+
−	 * <samp>&amp;3</samp>
+
−	 */
+
−	// {{{ SchemaResponse class implementation
+
−	class SchemaResponse implements Response {
+
−		@Override
+
−		public String addLine(final String line, final LineType linetype) {
+
−			return "Header lines are not supported for a SchemaResponse";
+
−		}
+
−
+
−		@Override
+
−		public boolean wantsMore() {
+
−			return false;
+
−		}
+
−
+
−		/* MvD: disabled not used/needed code
+
−		@Override
+
−		public void complete() {
+
−			// empty, because there is nothing to check
+
−		}
+
−		*/
+
−
+
−		@Override
+
−		public void close() {
+
−			// nothing to do here...
+
−		}
+
−	}
+
−	// }}}
+
−
+
−	/**
+
−	 * The AutoCommitResponse represents a transaction message.  It
+
−	 * stores (a change in) the server side auto commit mode.<br />
+
−	 * <samp>&amp;4 (t|f)</samp>
+
−	 */
+
−	// {{{ AutoCommitResponse class implementation
+
−	private final class AutoCommitResponse extends SchemaResponse {
+
−		public final boolean autocommit;
+
−
+
−		public AutoCommitResponse(final boolean ac) {
+
−			// fill the blank final
+
−			this.autocommit = ac;
+
−		}
+
−	}
+
−	// }}}
+
−
+
−	/**
+
−	 * A list of Response objects.  Responses are added to this list.
+
−	 * Methods of this class are not synchronized.  This is left as
+
−	 * responsibility to the caller to prevent concurrent access.
+
−	 */
+
−	// {{{ ResponseList class implementation
+
−	final class ResponseList {
+
−		/** The cache size (number of rows in a DataBlockResponse object) */
+
−		private final int cachesize;
+
−		/** The maximum number of results for this query */
+
−		private final long maxrows;
+
−		/** The ResultSet type to produce */
+
−		private final int rstype;
+
−		/** The ResultSet concurrency to produce */
+
−		private final int rsconcur;
+
−		/** The sequence number of this ResponseList */
+
−		private final int seqnr;
+
−		/** A list of the Responses associated with the query,
+
−		 *  in the right order */
+
−		private final ArrayList<Response> responses;
+
−		/** A map of ResultSetResponses, used for additional
+
−		 *  DataBlockResponse mapping */
+
−		private HashMap<Integer, ResultSetResponse> rsresponses;
+
−
+
−		/** The current header returned by getNextResponse() */
+
−		private int curResponse;
+
−
+
−		/**
+
−		 * Main constructor.
+
−		 *
+
−		 * @param cachesize overall cachesize to use
+
−		 * @param maxrows maximum number of rows to allow in the set
+
−		 * @param rstype the type of result sets to produce
+
−		 * @param rsconcur the concurrency of result sets to produce
+
−		 */
+
−		ResponseList(
+
−			final int cachesize,
+
−			final long maxrows,
+
−			final int rstype,
+
−			final int rsconcur)
+
−		{
+
−			this.cachesize = cachesize;
+
−			this.maxrows = maxrows;
+
−			this.rstype = rstype;
+
−			this.rsconcur = rsconcur;
+
−			responses = new ArrayList<Response>();
+
−			curResponse = -1;
+
−			seqnr = MonetConnection.seqCounter++;
+
−		}
+
−
+
−		/**
+
−		 * Retrieves the next available response, or null if there are
+
−		 * no more responses.
+
−		 *
+
−		 * @return the next Response available or null
+
−		 */
+
−		Response getNextResponse() {
+
−			if (rstype == ResultSet.TYPE_FORWARD_ONLY) {
+
−				// free resources if we're running forward only
+
−				if (curResponse >= 0 && curResponse < responses.size()) {
+
−					final Response tmp = responses.get(curResponse);
+
−					if (tmp != null)
+
−						tmp.close();
+
−					responses.set(curResponse, null);
+
−				}
+
−			}
+
−			curResponse++;
+
−			if (curResponse >= responses.size()) {
+
−				// ResponseList is obviously completed so, there are no
+
−				// more responses
+
−				return null;
+
−			} else {
+
−				// return this response
+
−				return responses.get(curResponse);
+
−			}
+
−		}
+
−
+
−		/**
+
−		 * Closes the Response at index i, if not null.
+
−		 *
+
−		 * @param i the index position of the header to close
+
−		 */
+
−		void closeResponse(final int i) {
+
−			if (i < 0 || i >= responses.size())
+
−				return;
+
−			final Response tmp = responses.set(i, null);
+
−			if (tmp != null)
+
−				tmp.close();
+
−		}
+
−
+
−		/**
+
−		 * Closes the current response.
+
−		 */
+
−		void closeCurrentResponse() {
+
−			closeResponse(curResponse);
+
−		}
+
−
+
−		/**
+
−		 * Closes the current and previous responses.
+
−		 */
+
−		void closeCurOldResponses() {
+
−			for (int i = curResponse; i >= 0; i--) {
+
−				closeResponse(i);
+
−			}
+
−		}
+
−
+
−		/**
+
−		 * Closes this ResponseList by closing all the Responses in this
+
−		 * ResponseList.
+
−		 */
+
−		void close() {
+
−			for (int i = 0; i < responses.size(); i++) {
+
−				closeResponse(i);
+
−			}
+
−		}
+
−
+
−		/**
+
−		 * Returns whether this ResponseList has still unclosed
+
−		 * Responses.
+
−		 * @return whether there are unclosed Responses
+
−		 */
+
−		boolean hasUnclosedResponses() {
+
−			for (Response r : responses) {
+
−				if (r != null)
+
−					return true;
+
−			}
+
−			return false;
+
−		}
+
−
+
−		/**
+
−		 * Executes the query contained in this ResponseList, and
+
−		 * stores the Responses resulting from this query in this
+
−		 * ResponseList.
+
−		 *
+
−		 * @param query the SQL query to execute
+
−		 * @throws SQLException if a database error occurs
+
−		 */
+
−		void processQuery(final String query) throws SQLException {
+
−			executeQuery(queryTempl, query);
+
−		}
+
−
+
−		/**
+
−		 * Internal executor of queries.
+
−		 *
+
−		 * @param templ the template to fill in
+
−		 * @param query the query to execute
+
−		 * @throws SQLException if a database error occurs
+
−		 */
+
−		@SuppressWarnings("fallthrough")
+
−		void executeQuery(final String[] templ, final String query)
+
−			throws SQLException
+
−		{
+
−			String error = null;
+
−
+
−			try {
+
−				synchronized (server) {
+
−					// make sure we're ready to send query; read data till we
+
−					// have the prompt it is possible (and most likely) that we
+
−					// already have the prompt and do not have to skip any
+
−					// lines.  Ignore errors from previous result sets.
+
−					in.discardRemainder();
+
−
+
−					// {{{ set reply size
+
−					/**
+
−					 * Change the reply size of the server.  If the given
+
−					 * value is the same as the current value known to use,
+
−					 * then ignore this call.  If it is set to 0 we get a
+
−					 * prompt after the server sent it's header.
+
−					 */
+
−					int size = cachesize;
+
−					if (size == 0)
+
−						size = defaultFetchSize;
+
−					if (maxrows > 0 && maxrows < size)
+
−						size = (int)maxrows;
+
−					// don't do work if it's not needed
+
−					if (lang == LANG_SQL && size != curReplySize && templ != commandTempl) {
+
−						sendControlCommand("reply_size " + size);
+
−
+
−						// store the reply size after a successful change
+
−						curReplySize = size;
+
−					}
+
−					// }}} set reply size
+
−
+
−					// send query to the server
+
−					out.writeLine(templ[0] + query + templ[1]);
+
−
+
−					// go for new results
+
−					in.advance();
+
−					Response res = null;
+
−					while (in.getLineType() != LineType.PROMPT) {
+
−						// each response should start with a start of header (or error)
+
−						switch (in.getLineType()) {
+
−						case SOHEADER:
+
−							// make the response object, and fill it
+
−							try {
+
−								switch (sohp.parse(in.getLine())) {
+
−								case StartOfHeaderParser.Q_PARSE:
+
−									throw new MCLParseException("Q_PARSE header not allowed here", 1);
+
−								case StartOfHeaderParser.Q_TABLE:
+
−								case StartOfHeaderParser.Q_PREPARE: {
+
−									final int id = sohp.getNextAsInt();
+
−									long tuplecount = sohp.getNextAsLong();
+
−									final int columncount = sohp.getNextAsInt();
+
−									final int rowcount = sohp.getNextAsInt();
+
−									// enforce the maxrows setting
+
−									if (maxrows != 0 && tuplecount > maxrows)
+
−										tuplecount = maxrows;
+
−									res = new ResultSetResponse(id, tuplecount, columncount, rowcount, this, seqnr);
+
−									// only add this resultset to the hashmap if it can possibly have an additional datablock
+
−									if (rowcount < tuplecount) {
+
−										if (rsresponses == null)
+
−											rsresponses = new HashMap<Integer, ResultSetResponse>();
+
−										rsresponses.put(id, (ResultSetResponse) res);
+
−									}
+
−								} break;
+
−								case StartOfHeaderParser.Q_UPDATE:
+
−									res = new UpdateResponse(sohp.getNextAsLong(),   // count
+
−												 sohp.getNextAsString() // key-id
+
−												);
+
−									break;
+
−								case StartOfHeaderParser.Q_SCHEMA:
+
−									res = new SchemaResponse();
+
−									break;
+
−								case StartOfHeaderParser.Q_TRANS:
+
−									final boolean ac = sohp.getNextAsString().equals("t");
+
−									if (autoCommit && ac) {
+
−										addWarning("Server enabled auto commit mode " +
+
−											"while local state already was auto commit.", "01M11");
+
−									}
+
−									autoCommit = ac;
+
−									res = new AutoCommitResponse(ac);
+
−									break;
+
−								case StartOfHeaderParser.Q_BLOCK: {
+
−									// a new block of results for a response...
+
−									final int id = sohp.getNextAsInt();
+
−									sohp.getNextAsInt();	// columncount
+
−									final int rowcount = sohp.getNextAsInt();
+
−									final int offset = sohp.getNextAsInt();
+
−									final ResultSetResponse t;
+
−									if (rsresponses != null)
+
−										t = rsresponses.get(id);
+
−									else
+
−										t = null;
+
−									if (t == null) {
+
−										error = "M0M12!no ResultSetResponse with id " + id + " found";
+
−										break;
+
−									}
+
−									final DataBlockResponse r = new DataBlockResponse(rowcount, t.getRSType() == ResultSet.TYPE_FORWARD_ONLY);
+
−									t.addDataBlockResponse(offset, r);
+
−									res = r;
+
−								} break;
+
−								} // end of switch (sohp.parse(tmpLine))
+
−							} catch (MCLParseException e) {
+
−								final int offset = e.getErrorOffset();
+
−								error = "M0M10!error while parsing start of header:\n" +
+
−									e.getMessage() +
+
−									" found: '" + in.getLine().charAt(offset) +
+
−									"' in: \"" + in.getLine() +
+
−									"\" at pos: " + offset;
+
−								// flush all the rest
+
−								in.discardRemainder();
+
−								break;
+
−							}
+
−
+
−							// immediately handle errors after parsing the header (res may be null)
+
−							if (error != null) {
+
−								in.discardRemainder();
+
−								break;
+
−							}
+
−
+
−							// advance to the line after the header
+
−							in.advance();
+
−
+
−							// stuff all header lines into the res
+
−							while (error == null && in.getLineType() == LineType.HEADER) {
+
−								error = res.addLine(in.getLine(), in.getLineType());
+
−								in.advance();
+
−							}
+
−
+
−							// then feed it more lines until it is satisfied
+
−							while (error == null && res.wantsMore()) {
+
−								error = res.addLine(in.getLine(), in.getLineType());
+
−								in.advance();
+
−							}
+
−
+
−							if (error != null) {
+
−								// right, some protocol violation,
+
−								// skip the rest of the result
+
−								error = "M0M10!" + error;
+
−								in.discardRemainder(error);
+
−								break;
+
−							}
+
−
+
−							// it is of no use to store DataBlockResponses, you never want to
+
−							// retrieve them directly anyway
+
−							if (!(res instanceof DataBlockResponse))
+
−								responses.add(res);
+
−
+
−							// We have already advanced 'in' to the next line in the response
+
−							// so we're ready to start the next iteration of the loop.
+
−							break;
+
−						case INFO:
+
−							addWarning(in.getLine().substring(1), "01000");
+
−							// read the next line (can be prompt, new result, error, etc.)
+
−							// before we start the loop over
+
−							in.advance();
+
−							break;
+
−						case FILETRANSFER:
+
−							// Consume the command
+
−							in.advance();
+
−							final String transferCommand = in.getLine();
+
−							// Consume the fake prompt inserted by MapiSocket.
+
−							in.advance();
+
−							// Handle the request
+
−							if (transferCommand != null)
+
−								error = handleTransfer(transferCommand);
+
−							else
+
−								error = "Protocol violation, expected transfer command, got nothing";
+
−							// Then prepare for the next iteration
+
−							if (error != null) {
+
−								out.writeLine(error + "\n");
+
−								error = in.discardRemainder();
+
−							} else {
+
−								in.resetLineType();
+
−								in.advance();
+
−							}
+
−							break;
+
−						default:
+
−							// we have something we don't expect/understand, let's make it an error message
+
−							String msg = "M0M10!protocol violation, unexpected " + in.getLineType() + " line: " + in.getLine();
+
−							error = in.discardRemainder(msg);
+
−							break;
+
−						case ERROR:
+
−							// read everything till the prompt (should be
+
−							// error) we don't know if we ignore some
+
−							// garbage here... but the log should reveal that
+
−							error = in.discardRemainder(in.getLine().substring(1));
+
−							break;
+
−						} // end of switch (linetype)
+
−					} // end of while (linetype != LineType.PROMPT)
+
−				} // end of synchronized (server)
+
−
+
−				if (error != null) {
+
−					SQLException ret = null;
+
−					final String[] errors = error.split("\n");
+
−					for (int i = 0; i < errors.length; i++) {
+
−						final SQLException newErr;
+
−						if (errors[i].length() >= 6) {
+
−							newErr = new SQLException(errors[i].substring(6), errors[i].substring(0, 5));
+
−						} else {
+
−							newErr = new SQLNonTransientConnectionException(errors[i], "08000");
+
−						}
+
−						if (ret == null) {
+
−							ret = newErr;
+
−						} else {
+
−							ret.setNextException(newErr);
+
−						}
+
−					}
+
−					throw ret;
+
−				}
+
−			} catch (SocketTimeoutException e) {
+
−				close(); // JDBC 4.1 semantics, abort()
+
−				throw new SQLNonTransientConnectionException("connection timed out", "08M33");
+
−			} catch (IOException e) {
+
−				closed = true;
+
−				throw new SQLNonTransientConnectionException(e.getMessage() + " (mserver5 still alive?)", "08006");
+
−			}
+
−		}
+
−	}
+
−	// }}}
+
−
+
−	private String handleTransfer(final String transferCommand) throws IOException {
+
−		if (transferCommand.startsWith("r ")) {
+
−			final String[] parts = transferCommand.split(" ", 3);
+
−			if (parts.length == 3) {
+
−				final long offset;
+
−				try {
+
−					offset = Long.parseLong(parts[1]);
+
−				} catch (NumberFormatException e) {
+
−					return e.toString();
+
−				}
+
−				return handleUpload(parts[2], true, offset);
+
−			}
+
−		} else if (transferCommand.startsWith("rb ")) {
+
−			return handleUpload(transferCommand.substring(3), false, 0);
+
−		} else if (transferCommand.startsWith("w ")) {
+
−			return handleDownload(transferCommand.substring(2), true);
+
−		} else if (transferCommand.startsWith("wb ")) {
+
−			return handleDownload(transferCommand.substring(3), false);
+
−		}
+
−		return "JDBC does not support this file transfer yet: " + transferCommand;
+
−	}
+
−
+
−	private String handleUpload(final String path, final boolean textMode, final long offset) throws IOException {
+
−		if (uploadHandler == null) {
+
−			return "No file upload handler has been registered with the JDBC driver";
+
−		}
+
−
+
−		final long linesToSkip = offset >= 1 ? offset - 1 : 0;
+
−		final Upload handle = new Upload(server, uploadHandler::uploadCancelled, textMode);
+
−		final boolean wasFaking = server.setInsertFakePrompts(false);
+
−		try {
+
−			uploadHandler.handleUpload(handle, path, textMode, linesToSkip);
+
−			if (!handle.hasBeenUsed()) {
+
−				throw new IOException("Call to " + uploadHandler.getClass().getCanonicalName() + ".handleUpload for path '" + path + "' sent neither data nor an error message");
+
−			}
+
−		} finally {
+
−			handle.close();
+
−			server.setInsertFakePrompts(wasFaking);
+
−		}
+
−		return handle.getError();
+
−	}
+
−
+
−	private String handleDownload(final String path, final boolean textMode) throws IOException {
+
−		if (downloadHandler == null) {
+
−			return "No file download handler has been registered with the JDBC driver";
+
−		}
+
−
+
−		final Download handle = new Download(server, textMode);
+
−		try {
+
−			downloadHandler.handleDownload(handle, path, true);
+
−			if (!handle.hasBeenUsed()) {
+
−				handle.sendError("Call to " + downloadHandler.getClass().getSimpleName() + ".handleDownload sent neither data nor error");
+
−			}
+
−		} finally {
+
−			handle.close();
+
−		}
+
−		return handle.getError();
+
−	}
+
−
+
−	/**
+
−	 * Callback for sending files for COPY INTO "table" FROM 'file-name' ON CLIENT commands
+
−	 *
+
−	 * To be registered with {@link MonetConnection#setUploadHandler(UploadHandler)}
+
−	 *
+
−	 * An example implementation can be found at ../util/FileTransferHandler.java
+
−	 */
+
−	public interface UploadHandler {
+
−		/**
+
−		 * Called if the server sends a request to read file data.
+
−		 *
+
−		 * Use the given handle to receive data or send errors to the server.
+
−		 *
+
−		 * @param handle Handle to communicate with the server
+
−		 * @param name Name of the file the server would like to read. Make sure
+
−		 *             to validate this before reading from the file system
+
−		 * @param textMode Whether to open the file as text or binary data.
+
−		 * @param linesToSkip In text mode, number of initial lines to skip.
+
−		 *                    0 means upload everything, 1 means skip the first line, etc.
+
−		 *                    Note: this is different from the OFFSET option of the COPY INTO,
+
−		 *                    where both 0 and 1 mean 'upload everything'
+
−		 * @throws IOException when I/O problem occurs
+
−		 */
+
−		void handleUpload(Upload handle, String name, boolean textMode, long linesToSkip) throws IOException;
+
−
+
−		/**
+
−		 * Called when the upload is cancelled halfway by the server.
+
−		 *
+
−		 * The default implementation does nothing.
+
−		 */
+
−		default void uploadCancelled() {}
+
−	}
+
−
+
−	/**
+
−	 * Callback for receiving files from COPY .. INTO 'file-name' ON CLIENT commands
+
−	 *
+
−	 * To be registered with {@link MonetConnection#setDownloadHandler(DownloadHandler)}
+
−	 *
+
−	 * An example implementation can be found at ../util/FileTransferHandler.java
+
−	 */
+
−	public interface DownloadHandler {
+
−		/**
+
−		 * Called if the server sends a request to write a file.
+
−		 *
+
−		 * Use the given handle to send data or errors to the server.
+
−		 *
+
−		 * @param handle Handle to communicate with the server
+
−		 * @param name Name of the file the server would like to write. Make sure
+
−		 *             to validate this before writing to the file system
+
−		 * @param textMode Whether this is text or binary data.
+
−		 * @throws IOException when I/O problem occurs
+
−		 */
+
−		void handleDownload(Download handle, String name, boolean textMode) throws IOException;
+
−	}
+
−
+
−	/**
+
−	 * Handle passed to {@link UploadHandler} to allow communication with the server
+
−	 */
+
−	public static class Upload {
+
−		private final MapiSocket server;
+
−		private final Runnable cancellationCallback;
+
−		private final boolean textMode;
+
−		private PrintStream print = null;
+
−		private String error = null;
+
−		private int customChunkSize = -1;
+
−
+
−		Upload(MapiSocket server, Runnable cancellationCallback, boolean textMode) {
+
−			this.server = server;
+
−			this.cancellationCallback = cancellationCallback;
+
−			this.textMode = textMode;
+
−		}
+
−
+
−		/**
+
−		 * Send an error message to the server
+
−		 *
+
−		 * The server will generally let the currently executing statement fail
+
−		 * with this error message. The connection will remain usable.
+
−		 *
+
−		 * This method can only be sent if no data has been sent to the server
+
−		 * yet. After data has been sent, you can still throw an
+
−		 * {@link IOException} but this will terminate the connection.
+
−		 *
+
−		 * @param errorMessage the error message to send
+
−		 * @throws IOException when error message is null
+
−		 */
+
−		public void sendError(final String errorMessage) throws IOException {
+
−			if (error != null) {
+
−				throw new IOException("another error has already been sent: " + error);
+
−			}
+
−			error = errorMessage;
+
−		}
+
−
+
−		/**
+
−		 * After every {@code chunkSize} bytes, the server gets the opportunity to
+
−		 * terminate the upload.
+
−		 *
+
−		 * @param chunkSize size of chunk
+
−		 */
+
−		public void setChunkSize(final int chunkSize) {
+
−			this.customChunkSize = chunkSize;
+
−		}
+
−
+
−		/**
+
−		 * Get a {@link PrintStream} to write data to.
+
−		 *
+
−		 * For text mode uploads, the data MUST be validly UTF-8 encoded.
+
−		 *
+
−		 * @return PrintStream a PrintStream
+
−		 * @throws IOException when error message is null or I/O problem occurs
+
−		 */
+
−		public PrintStream getStream() throws IOException {
+
−			if (error != null) {
+
−				throw new IOException("Cannot send data after an error has been sent");
+
−			}
+
−			if (print == null) {
+
−				try {
+
−					final MapiSocket.UploadStream up = customChunkSize >= 0 ? server.uploadStream(customChunkSize) : server.uploadStream();
+
−					up.setCancellationCallback(cancellationCallback);
+
−					print = new PrintStream(textMode ? new StripCrLfStream(up) : up, false, "UTF-8");
+
−					up.write('\n');
+
−				} catch (UnsupportedEncodingException e) {
+
−					throw new RuntimeException("The system is guaranteed to support the UTF-8 encoding but apparently it doesn't", e);
+
−				}
+
−			}
+
−			return print;
+
−		}
+
−
+
−		/**
+
−		 * Tell whether data or an error has been sent.
+
−		 * @return true if data or an error has been sent.
+
−		 */
+
−		public boolean hasBeenUsed() {
+
−			return print != null || error != null;
+
−		}
+
−
+
−		/**
+
−		 * Get the error string.
+
−		 * @return the error that was sent, if any
+
−		 */
+
−		public String getError() {
+
−			return error;
+
−		}
+
−
+
−		/**
+
−		 * Read from the given input stream and write it to the server.
+
−		 *
+
−		 * For text mode uploads, the data MUST be validly UTF-8 encoded.
+
−		 *
+
−		 * @param inputStream stream to read from
+
−		 * @throws IOException when I/O problem occurs
+
−		 */
+
−		public void uploadFrom(final InputStream inputStream) throws IOException {
+
−			final OutputStream s = getStream();
+
−			final byte[] buffer = new byte[64 * 1024];
+
−			while (true) {
+
−				int nread = inputStream.read(buffer);
+
−				if (nread < 0) {
+
−					break;
+
−				}
+
−				s.write(buffer, 0, nread);
+
−			}
+
−		}
+
−
+
−		/**
+
−		 * Read data from the given buffered reader and send it to the server
+
−		 *
+
−		 * @param reader buffered reader to read from
+
−		 * @param linesToSkip start uploading at line {@code offset}. Value 0 and 1
+
−		 *        both mean upload the whole file, value 2 means skip the first line, etc.
+
−		 * @throws IOException when I/O problem occurs
+
−		 */
+
−		public void uploadFrom(final BufferedReader reader, final long linesToSkip) throws IOException {
+
−			for (int i = 0; i < linesToSkip; i++) {
+
−				String line = reader.readLine();
+
−				if (line == null) {
+
−					return;
+
−				}
+
−			}
+
−
+
−			uploadFrom(reader);
+
−		}
+
−
+
−		/**
+
−		 * Read data from the given buffered reader and send it to the server
+
−		 *
+
−		 * @param reader reader to read from
+
−		 * @throws IOException when ...
+
−		 */
+
−		public void uploadFrom(final Reader reader) throws IOException {
+
−			final OutputStream s = getStream();
+
−			final OutputStreamWriter writer = new OutputStreamWriter(s, StandardCharsets.UTF_8);
+
−			final char[] buffer = new char[64 * 1024];
+
−			while (true) {
+
−				int nread = reader.read(buffer, 0, buffer.length);
+
−				if (nread < 0) {
+
−					break;
+
−				}
+
−				writer.write(buffer, 0, nread);
+
−			}
+
−			writer.close();
+
−		}
+
−
+
−		/**
+
−		 * Close opened {@link PrintStream}.
+
−		 */
+
−		public void close() {
+
−			if (print != null) {
+
−				print.close();
+
−				print = null;
+
−			}
+
−		}
+
−	}
+
−
+
−	/**
+
−	 * Handle passed to {@link DownloadHandler} to allow communication with the server
+
−	 */
+
−	public static class Download {
+
−		private final MapiSocket server;
+
−		private boolean prependCr;
+
−		private MapiSocket.DownloadStream stream = null;
+
−		private String error = null;
+
−
+
−		Download(MapiSocket server, boolean textMode) {
+
−			this.server = server;
+
−			prependCr = false;
+
−			if (textMode) {
+
−				setLineSeparator(System.lineSeparator());
+
−			}
+
−		}
+
−
+
−		/**
+
−		 * Send an error message to the server
+
−		 *
+
−		 * The server will generally let the currently executing statement fail
+
−		 * with this error message. The connection will remain usable.
+
−		 *
+
−		 * This method can only be sent if no data has been received from the server
+
−		 * yet. After data has been received, you can still throw an
+
−		 * {@link IOException} but this will terminate the connection.
+
−		 *
+
−		 * Note: as of MonetDB version Jul2021 the server always terminates the connection
+
−		 * when this error is used.  This will probably change in the future.
+
−		 *
+
−		 * @param errorMessage the error message to send
+
−		 * @throws IOException when error message is null
+
−		 */
+
−		public void sendError(final String errorMessage) throws IOException {
+
−			if (error != null) {
+
−				throw new IOException("another error has already been sent: " + error);
+
−			}
+
−			error = errorMessage;
+
−		}
+
−
+
−		/**
+
−		 * Get an {@link InputStream} to read data from.
+
−		 *
+
−		 * Textual data is UTF-8 encoded. If the download is in text mode, line endings
+
−		 * are converted according to {@link java.lang.System#lineSeparator()}.
+
−		 * This can be overridden with {@link Download#setLineSeparator(String)}.
+
−		 *
+
−		 * @return InputStream the stream to read from
+
−		 * @throws IOException when error message exist or I/O problem occurs
+
−		 */
+
−		public InputStream getStream() throws IOException {
+
−			if (error != null) {
+
−				throw new IOException("cannot receive data after error has been sent");
+
−			}
+
−			if (stream == null) {
+
−				stream = server.downloadStream(prependCr);
+
−				server.getOutputStream().flush();
+
−			}
+
−			return stream;
+
−		}
+
−
+
−		/**
+
−		 * Write the data from the server to the given {@link OutputStream}.
+
−		 *
+
−		 * @param stream the OutputStream to write to
+
−		 * @throws IOException when cannot read from InputStream or write to OutputStream
+
−		 */
+
−		public void downloadTo(final OutputStream stream) throws IOException {
+
−			final InputStream s = getStream();
+
−			final byte[] buffer = new byte[65536];
+
−			while (true) {
+
−				int nread = s.read(buffer);
+
−				if (nread < 0) {
+
−					break;
+
−				}
+
−				stream.write(buffer, 0, nread);
+
−			}
+
−		}
+
−
+
−		/**
+
−		 * Write the textual data from the server to the given {@link Writer}
+
−		 *
+
−		 * @param writer to write to
+
−		 * @throws IOException when cannot read from InputStreamReader or write to Writer
+
−		 */
+
−		public void downloadTo(final Writer writer) throws IOException {
+
−			final InputStream s = getStream();
+
−			final InputStreamReader r = new InputStreamReader(s, StandardCharsets.UTF_8);
+
−			final char[] buffer = new char[65536];
+
−			while (true) {
+
−				final int nread = r.read(buffer);
+
−				if (nread < 0) {
+
−					break;
+
−				}
+
−				writer.write(buffer, 0, nread);
+
−			}
+
−		}
+
−
+
−		/**
+
−		 * Tell whether data has been received or an error has been sent.
+
−		 * @return true if data has been received or an error has been sent.
+
−		 */
+
−		public boolean hasBeenUsed() {
+
−			return stream != null || error != null;
+
−		}
+
−
+
−		/**
+
−		 * Get the error string.
+
−		 * @return the error that was sent, if any
+
−		 */
+
−		public String getError() {
+
−			return error;
+
−		}
+
−
+
−		/**
+
−		 * Close opened stream.
+
−		 */
+
−		public void close() {
+
−			if (stream != null) {
+
−				try {
+
−					stream.close();
+
−					stream = null;
+
−				} catch (IOException e) {
+
−					/* ignore close error */
+
−				}
+
−			}
+
−		}
+
−
+
−		/**
+
−		 * Set the line endings used in the stream returned by {@link Download#getStream()}
+
−		 *
+
−		 * @param sep separator to use
+
−		 * @throws IllegalArgumentException if sep is neither "\n" nor "\r\n"
+
−		 */
+
−		public void setLineSeparator(final String sep) {
+
−			if ("\n".equals(sep)) {
+
−				prependCr = false;
+
−			} else if ("\r\n".equals(sep)) {
+
−				prependCr = true;
+
−			} else {
+
−				throw new IllegalArgumentException("sep must be \\n or \\r\\n");
+
−			}
+
−		}
+
−	}
+
−
+
−	public static class StripCrLfStream extends FilterOutputStream {
+
−		private boolean crPending = false;
+
−
+
−		public StripCrLfStream(OutputStream out) {
+
−			super(out);
+
−		}
+
−
+
−		public boolean pending() {
+
−			return this.crPending;
+
−		}
+
−
+
−		@Override
+
−		public void write(final int b) throws IOException {
+
−			if (crPending && b != '\n') {
+
−				out.write('\r');
+
−			}
+
−			if (b != '\r') {
+
−				out.write(b);
+
−				crPending = false;
+
−			} else {
+
−				crPending = true;
+
−			}
+
−		}
+
−
+
−		@Override
+
−		public void write(final byte[] b) throws IOException {
+
−			this.write(b, 0, b.length);
+
−		}
+
−
+
−		@Override
+
−		public void write(final byte[] b, int off, int len) throws IOException {
+
−			if (len == 0) {
+
−				return;
+
−			}
+
−			if (crPending && b[0] != '\n') {
+
−				out.write('\r');
+
−			}
+
−
+
−			// deal with final \r up front
+
−			if (b[len - 1] == '\r') {
+
−				crPending = true;
+
−				len -= 1;
+
−			} else {
+
−				crPending = false;
+
−			}
+
−
+
−			for (int i = off; i < off + len - 1; i++) {
+
−				if (b[i] == '\r' && b[i + 1] == '\n') {
+
−					int chunk = i - off;
+
−					out.write(b, off, chunk);
+
−					// chunk + 1 because we want to skip the \r
+
−					len -= chunk + 1;
+
−					off += chunk + 1;
+
−					// we don't have to look at the \n because we know it's no \r.
+
−					i++;
+
−				}
+
−			}
+
−
+
−			// write the remainder
+
−			out.write(b, off, len);
+
−		}
+
−
+
−		@Override
+
−		public void flush() throws IOException {
+
−			// we cannot flush our pending CR but we can ask our downstream to flush what we have sent them so far
+
−			out.flush();
+
−		}
+
−
+
−		@Override
+
−		public void close() throws IOException {
+
−			if (crPending) {
+
−				out.write('\r');
+
−			}
+
−			crPending = false;
+
−			super.close();
+
−		}
+
−	}
+
−
+
−	/* encode knowledge of currently available handshake options as an enum. */
+
−	enum SqlOption {
+
−		Autocommit(1, "auto_commit"),
+
−		ReplySize(2, "reply_size"),
+
−		SizeHeader(3, "size_header"),
+
−		// NOTE: 4 has been omitted on purpose
+
−		TimeZone(5, "time_zone"),
+
−		;
+
−		final int level;
+
−		final String field;
+
−
+
−		SqlOption(int level, String field) {
+
−			this.level = level;
+
−			this.field = field;
+
−		}
+
−	}
+
−
+
−
+
−	private class SqlOptionsCallback extends MapiSocket.OptionsCallback {
+
−		private final Target.Validated validated;
+
−		private int level;
+
−		boolean sizeHeaderEnabled = false; // used during handshake
+
−		boolean timeZoneSet = false; // used during handshake
+
−
+
−		public SqlOptionsCallback(Target.Validated validated) {
+
−			super();
+
−			this.validated = validated;
+
−		}
+
−
+
−
+
−		@Override
+
−		public void addOptions(String lang, int level) {
+
−			if (!lang.equals("sql"))
+
−				return;
+
−			this.level = level;
+
−
+
−			// Try to add options and record that this happened if it succeeds.
+
−			if (contribute(SqlOption.Autocommit, validated.isAutocommit() ? 1 : 0))
+
−				autoCommit = target.isAutocommit();
+
−			if (contribute(SqlOption.ReplySize, validated.getReplySize()))
+
−				defaultFetchSize = validated.getReplySize();
+
−			if (contribute(SqlOption.SizeHeader, 1))
+
−				sizeHeaderEnabled = true;
+
−			if (contribute(SqlOption.TimeZone, 60 * target.getTimezone()))
+
−				timeZoneSet = true;
+
−		}
+
−
+
−		private boolean contribute(SqlOption opt, int value) {
+
−			if (opt.level >= this.level)
+
−				return false;
+
−			contribute(opt.field, value);
+
−			return true;
+
−		}
+
−	}
+
−}