monetdb-java: src/main/java/org/monetdb/jdbc/MonetResultSet.java comparison

comparison src/main/java/org/monetdb/jdbc/MonetResultSet.java @ 391:f523727db392

Moved Java classes from packages starting with nl.cwi.monetdb.* to package org.monetdb.* This naming complies to the Java Package Naming convention as MonetDB's main website is www.monetdb.org.

author	Martin van Dinther <martin.van.dinther@monetdbsolutions.com>
date	Thu, 12 Nov 2020 22:02:01 +0100 (2020-11-12)
parents	src/main/java/nl/cwi/monetdb/jdbc/MonetResultSet.java@cc472ea19b3f
children	bf9f6b6ecf40

comparison

equal deleted inserted replaced

-:6199e0be3c6e
+:f523727db392
+/*
+* 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 1997 - July 2008 CWI, August 2008 - 2020 MonetDB B.V.
+*/
+package org.monetdb.jdbc;
+import org.monetdb.mcl.parser.MCLParseException;
+import org.monetdb.mcl.parser.TupleLineParser;
+import java.io.InputStream;
+import java.io.Reader;
+import java.math.BigDecimal;
+import java.net.URL;
+import java.sql.Array;
+import java.sql.Blob;
+import java.sql.Clob;
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.NClob;
+import java.sql.Ref;
+import java.sql.ResultSet;
+import java.sql.ResultSetMetaData;
+import java.sql.RowId;
+import java.sql.SQLData;
+import java.sql.SQLDataException;
+import java.sql.SQLException;
+import java.sql.SQLFeatureNotSupportedException;
+import java.sql.SQLInput;
+import java.sql.SQLType;	// new as of Java 1.8
+import java.sql.SQLWarning;
+import java.sql.SQLXML;
+import java.sql.Statement;
+import java.sql.Time;
+import java.sql.Timestamp;
+import java.sql.Types;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Map;
+import java.util.TimeZone;
+/**
+* A ResultSet suitable for the MonetDB database.
+*
+* A table of data representing a database result set, which is usually
+* generated by executing a statement that queries the database.
+*
+* A ResultSet object maintains a cursor pointing to its current row of data.
+* Initially the cursor is positioned before the first row. The next method
+* moves the cursor to the next row, and because it returns false when there
+* are no more rows in the ResultSet object, it can be used in a while loop to
+* iterate through the result set.
+*
+* The current state of this ResultSet is that it supports positioning in the
+* result set, absolute and relative. A slight performance difference between
+* FORWARD_ONLY or result sets scrollable in both directions can be noticed as
+* for FORWARD_ONLY result sets the memory usage will be likely lower for large
+* result sets.
+*
+* @author Fabian Groffen
+* @author Martin van Dinther
+* @version 0.9
+*/
+public class MonetResultSet
+	extends MonetWrapper
+	implements ResultSet, AutoCloseable
+{
+	static final int DEF_RESULTSETTYPE = ResultSet.TYPE_FORWARD_ONLY;
+	static final int DEF_FETCHDIRECTION = ResultSet.FETCH_FORWARD;
+	static final int DEF_CONCURRENCY = ResultSet.CONCUR_READ_ONLY;
+	static final int DEF_HOLDABILITY = ResultSet.HOLD_CURSORS_OVER_COMMIT;
+	/** The parental Statement object */
+	private final Statement statement;
+	/** A Header to retrieve lines from. Note: it will be null in case of a MonetVirtualResultSet ! */
+	private final MonetConnection.ResultSetResponse header;
+	/** The names of the columns in this ResultSet */
+	private final String[] columns;
+	/** The MonetDB types of the columns in this ResultSet */
+	private final String[] types;
+	/** The JDBC SQL types of the columns in this ResultSet. The content will be derived from the MonetDB types[] */
+	private final int[] JdbcSQLTypes;
+	// the following have protected access modifier for the MonetVirtualResultSet subclass
+	// they are accessed from MonetVirtualResultSet.absolute()
+	/** The current line of the buffer split in columns */
+	protected final TupleLineParser tlp;
+	/** The number of rows in this ResultSet */
+	protected final long tupleCount;
+	/** The current position of the cursor for this ResultSet object */
+	protected int curRow = 0;
+	/** The type of this ResultSet (forward or scrollable) */
+	private int type = DEF_RESULTSETTYPE;
+	/** The concurrency of this ResultSet (currently only read-only) */
+	private int concurrency = DEF_CONCURRENCY;
+	/** The warnings for this ResultSet object */
+	private SQLWarning warnings;
+	/** whether the last read field (via some getXyz() method) was NULL */
+	private boolean lastReadWasNull = true;
+	/** to store the fetchsize set. */
+	private int fetchSize;
+	/**
+	 * Main constructor backed by the given Header.
+	 *
+	 * @param statement the statement which created this ResultSet
+	 * @param header a header containing the query, resultset type, etc.
+	 * @throws IllegalArgumentException if called with null or invalid value for one of the arguments
+	 */
+	MonetResultSet(
+		final Statement statement,
+		final MonetConnection.ResultSetResponse header)
+		throws IllegalArgumentException
+	{
+		if (statement == null) {
+			throw new IllegalArgumentException("Statement may not be null!");
+		}
+		if (header == null) {
+			throw new IllegalArgumentException("Header may not be null!");
+		}
+		this.statement = statement;
+		this.header = header;
+		type = header.getRSType();
+		concurrency = header.getRSConcur();
+		/* the fetchSize used for this result set is the header's cacheSize */
+		fetchSize = header.getCacheSize();
+		columns = header.getNames();
+		types = header.getTypes();
+		if (columns == null || types == null) {
+			throw new IllegalArgumentException("Missing Header metadata");
+		}
+		if (columns.length != types.length) {
+			throw new IllegalArgumentException("Inconsistent Header metadata");
+		}
+		tupleCount = header.tuplecount;
+		// create result array
+		tlp = new TupleLineParser(columns.length);
+		// for efficiency derive the JDBC SQL type codes from the types[] names once
+		JdbcSQLTypes = new int[types.length];
+		populateJdbcSQLtypesArray();
+	}
+	/**
+	 * Constructor used by MonetVirtualResultSet.
+	 * DO NOT USE THIS CONSTRUCTOR IF YOU ARE NOT EXTENDING THIS OBJECT!
+	 *
+	 * @param statement the statement which created this ResultSet
+	 * @param columns the column names
+	 * @param types the column types
+	 * @param results the number of rows in the ResultSet
+	 * @throws IllegalArgumentException if called with null or invalid value for one of the arguments
+	 */
+	MonetResultSet(
+		final Statement statement,
+		final String[] columns,
+		final String[] types,
+		final int results)
+		throws IllegalArgumentException
+	{
+		if (statement == null || columns == null || types == null) {
+			throw new IllegalArgumentException("One of the given arguments is null");
+		}
+		if (columns.length != types.length) {
+			throw new IllegalArgumentException("Given arrays are not the same size");
+		}
+		if (results < 0) {
+			throw new IllegalArgumentException("Negative rowcount not allowed");
+		}
+		this.statement = statement;
+		header = null;
+		fetchSize = 0;
+		this.columns = columns;
+		this.types = types;
+		tupleCount = results;
+		tlp = new TupleLineParser(columns.length);
+		// for efficiency derive the JDBC SQL type codes from the types[] names once
+		JdbcSQLTypes = new int[types.length];
+		populateJdbcSQLtypesArray();
+	}
+	/**
+	 * Internal utility method to fill the JdbcSQLTypes array with derivable values.
+	 * By doing it once (in the constructor) we can avoid doing this in many getXyz()
+	 * methods again and again thereby improving getXyz() method performance.
+	 */
+	private final void populateJdbcSQLtypesArray() {
+		MonetConnection connection = null;
+		try {
+			connection = (MonetConnection) statement.getConnection();
+		} catch (SQLException se) { /* ignore it */ }
+		for (int i = 0; i < types.length; i++) {
+			int javaSQLtype = MonetDriver.getJdbcSQLType(types[i]);
+			if (javaSQLtype == Types.CLOB) {
+				if (connection != null && connection.mapClobAsVarChar())
+					javaSQLtype = Types.VARCHAR;
+			} else
+			if (javaSQLtype == Types.BLOB) {
+				if (connection != null && connection.mapBlobAsVarBinary())
+					javaSQLtype = Types.VARBINARY;
+			}
+			JdbcSQLTypes[i] = javaSQLtype;
+		}
+	}
+	//== methods of interface ResultSet
+	// Chapter 14.2.2 Sun JDBC 3.0 Specification
+	/**
+	 * Moves the cursor to the given row number in this ResultSet object.
+	 *
+	 * If the row number is positive, the cursor moves to the given row number
+	 * with respect to the beginning of the result set. The first row is row 1,
+	 * the second is row 2, and so on.
+	 *
+	 * If the given row number is negative, the cursor moves to an absolute row
+	 * position with respect to the end of the result set. For example, calling
+	 * the method absolute(-1) positions the cursor on the last row; calling the
+	 * method absolute(-2) moves the cursor to the next-to-last row, and so on.
+	 *
+	 * An attempt to position the cursor beyond the first/last row in the result
+	 * set leaves the cursor before the first row or after the last row.
+	 * Note: calling absolute(1) is the same as calling first(). Calling
+	 *       absolute(-1) is the same as calling last().
+	 *
+	 * @param row the number of the row to which the cursor should move. A
+	 *        positive number indicates the row number counting from the
+	 *        beginning of the result set; a negative number indicates the row
+	 *        number counting from the end of the result set
+	 * @return true if the cursor is on the result set; false otherwise
+	 * @throws SQLException if a database access error occurs, or the result set
+	 *         type is TYPE_FORWARD_ONLY
+	 */
+	@Override
+	public boolean absolute(int row) throws SQLException {
+		checkNotClosed();
+		if (row != curRow + 1 && type == TYPE_FORWARD_ONLY)
+			throw new SQLException("(Absolute) positioning not allowed on forward " +
+				" only result sets!", "M1M05");
+		// first calculate what the JDBC row is
+		if (row < 0) {
+			// calculate the negatives...
+			row = (int) tupleCount + row + 1;
+		}
+		// now place the row not farther than just before or after the result
+		if (row < 0)
+			row = 0;	// before first
+		else if (row > tupleCount + 1)
+			row = (int) tupleCount + 1;	// after last
+		// store it
+		curRow = row;
+		final String tmpLine = (header != null) ? header.getLine(row - 1) : null;
+		if (tmpLine == null)
+			return false;
+		try {
+			tlp.parse(tmpLine);
+		} catch (MCLParseException e) {
+			throw new SQLException(e.getMessage(), "M0M10");
+		}
+		return true;
+	}
+	/**
+	 * Moves the cursor to the end of this ResultSet object, just after the last
+	 * row. This method has no effect if the result set contains no rows.
+	 *
+	 * @throws SQLException if a database access error occurs or the result set
+	 *         type is TYPE_FORWARD_ONLY
+	 */
+	@Override
+	public void afterLast() throws SQLException {
+		absolute((int)tupleCount + 1);
+	}
+	/**
+	 * Moves the cursor to the front of this ResultSet object, just before the
+	 * first row. This method has no effect if the result set contains no rows.
+	 *
+	 * @throws SQLException if a database access error occurs or the result set
+	 *         type is TYPE_FORWARD_ONLY
+	 */
+	@Override
+	public void beforeFirst() throws SQLException {
+		absolute(0);
+	}
+	/**
+	 * Clears all warnings reported for this ResultSet object. After a call to
+	 * this method, the method getWarnings returns null until a new warning is
+	 * reported for this ResultSet object.
+	 */
+	@Override
+	public void clearWarnings() {
+		warnings = null;
+	}
+	/**
+	 * Releases this ResultSet object's database (and JDBC) resources
+	 * immediately instead of waiting for this to happen when it is
+	 * automatically closed.
+	 */
+	@Override
+	public void close() {
+		if (header != null && !header.isClosed()) {
+			header.close();
+		}
+		if (statement instanceof MonetStatement)
+			((MonetStatement)statement).closeIfCompletion();
+	}
+	// Chapter 14.2.3 from Sun JDBC 3.0 specification
+	/**
+	 * Maps the given ResultSet column name to its ResultSet column index.
+	 * Column names supplied to getter methods are case insensitive. If a select
+	 * list contains the same column more than once, the first instance of the
+	 * column will be returned.
+	 *
+	 * @param columnLabel the name of the column
+	 * @return the column index of the given column name
+	 * @throws SQLException if the ResultSet object does not contain a column labeled columnLabel,
+	 *	a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public int findColumn(final String columnLabel) throws SQLException {
+		checkNotClosed();
+		if (columnLabel != null) {
+			final int array_size = columns.length;
+			for (int i = 0; i < array_size; i++) {
+				if (columnLabel.equals(columns[i]))
+					return i + 1;
+			}
+			/* if an exact match did not succeed try a case insensitive match */
+			for (int i = 0; i < array_size; i++) {
+				if (columnLabel.equalsIgnoreCase(columns[i]))
+					return i + 1;
+			}
+		}
+		throw new SQLException("No such column name: " + columnLabel, "M1M05");
+	}
+	/**
+	 * Moves the cursor to the first row in this ResultSet object.
+	 *
+	 * @return true if the cursor is on a valid row; false if there are no rows
+	 *         in the result set
+	 * @throws SQLException - if a database access error occurs or the result
+	 *         set type is TYPE_FORWARD_ONLY
+	 */
+	@Override
+	public boolean first() throws SQLException {
+		return absolute(1);
+	}
+	@Override
+	public Array getArray(final int columnIndex) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getArray");
+	}
+	@Override
+	public Array getArray(final String columnLabel) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getArray");
+	}
+	/* Mapi doesn't allow something for streams at the moment, thus all not implemented for now */
+	@Override
+	public InputStream getAsciiStream(final int columnIndex) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getAsciiStream");
+	}
+	@Override
+	public InputStream getAsciiStream(final String columnLabel) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getAsciiStream");
+	}
+	@Override
+	@Deprecated
+	public InputStream getUnicodeStream(int columnIndex) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getUnicodeStream");
+	}
+	@Override
+	@Deprecated
+	public InputStream getUnicodeStream(String columnLabel) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getUnicodeStream");
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a stream of uninterpreted bytes. The
+	 * value can then be read in chunks from the stream. This method is
+	 * particularly suitable for retrieving large LONGVARBINARY values.
+	 *
+	 * Note: All the data in the returned stream must be read prior to
+	 * getting the value of any other column. The next call to a getter
+	 * method implicitly closes the stream. Also, a stream may return 0
+	 * when the method InputStream.available  is called whether there is
+	 * data available or not.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return a Java input stream that delivers the database column
+	 * value as a stream of uninterpreted bytes; if the value is SQL
+	 * NULL, the value returned is null
+	 * @throws SQLException if the columnIndex is not valid; if a
+	 * database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public InputStream getBinaryStream(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			switch (JdbcSQLTypes[columnIndex - 1]) {
+				case Types.BLOB:
+					final Blob blob = getBlob(columnIndex);
+					if (blob == null)
+						return null;
+					return blob.getBinaryStream();
+				case Types.BINARY:
+				case Types.VARBINARY:
+				case Types.LONGVARBINARY:
+					final byte[] bte = getBytes(columnIndex);
+					if (bte == null)
+						return null;
+					return new java.io.ByteArrayInputStream(bte);
+			}
+			throw new SQLException("Cannot operate on " + types[columnIndex - 1] + " type", "M1M05");
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a stream of uninterpreted bytes. The
+	 * value can then be read in chunks from the stream. This method is
+	 * particularly suitable for retrieving large LONGVARBINARY  values.
+	 *
+	 * Note: All the data in the returned stream must be read prior to
+	 * getting the value of any other column. The next call to a getter
+	 * method implicitly closes the stream. Also, a stream may return 0
+	 * when the method available  is called whether there is data
+	 * available or not.
+	 *
+	 * @param columnLabel the label for the column specified with
+	 * the SQL AS clause. If the SQL AS clause was not specified, then
+	 * the label is the name of the column
+	 * @return a Java input stream that delivers the database column
+	 * value as a stream of uninterpreted bytes; if the value is SQL
+	 * NULL, the result is null
+	 * @throws SQLException if the columnLabel is not valid; if a
+	 * database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public InputStream getBinaryStream(final String columnLabel) throws SQLException {
+		return getBinaryStream(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a java.io.Reader object.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return a java.io.Reader object that contains the column value;
+	 *         if the value is SQL NULL, the value returned is null in
+	 *         the Java programming language.
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public Reader getCharacterStream(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			return new java.io.StringReader(val);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a java.io.Reader object.
+	 *
+	 * @param columnLabel the name of the column
+	 * @return a java.io.Reader object that contains the column value;
+	 *         if the value is SQL NULL, the value returned is null in
+	 *         the Java programming language.
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Reader getCharacterStream(final String columnLabel) throws SQLException {
+		return getCharacterStream(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a java.io.Reader object. It is
+	 * intended for use when accessing NCHAR,NVARCHAR and LONGNVARCHAR
+	 * columns.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return a java.io.Reader object that contains the column value;
+	 *         if the value is SQL NULL, the value returned is null in
+	 *         the Java programming language.
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Reader getNCharacterStream(final int columnIndex) throws SQLException {
+		return getCharacterStream(columnIndex);
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a java.io.Reader object. It is
+	 * intended for use when accessing NCHAR,NVARCHAR and LONGNVARCHAR
+	 * columns.
+	 *
+	 * @param columnLabel the name of the column
+	 * @return a java.io.Reader object that contains the column value;
+	 *         if the value is SQL NULL, the value returned is null in
+	 *         the Java programming language.
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Reader getNCharacterStream(final String columnLabel) throws SQLException {
+		return getCharacterStream(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a Blob object in the Java programming
+	 * language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return a Blob object representing the SQL BLOB value in the
+	 *         specified column
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public Blob getBlob(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			return new MonetBlob(val);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a Blob object in the Java programming
+	 * language.
+	 *
+	 * @param columnLabel the name of the column from which to retrieve
+	 *        the value
+	 * @return a Blob object representing the SQL BLOB value in the
+	 *         specified column
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Blob getBlob(final String columnLabel) throws SQLException {
+		return getBlob(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a Clob object in the
+	 * Java programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return a Clob object representing the SQL CLOB value in the
+	 *         specified column
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public Clob getClob(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			return new MonetClob(val);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a Clob object in the
+	 * Java programming language.
+	 *
+	 * @param columnLabel the name of the column from which to retrieve
+	 *        the value
+	 * @return a Clob object representing the SQL CLOB value in the
+	 *         specified column
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Clob getClob(final String columnLabel) throws SQLException {
+		return getClob(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a NClob object in the
+	 * Java programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return a NClob object representing the SQL NCLOB value in the
+	 *         specified column
+	 * @throws SQLException if a database access error occurs
+	 * @throws SQLFeatureNotSupportedException the JDBC driver does
+	 *         not support this method
+	 */
+	@Override
+	public NClob getNClob(final int columnIndex) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getNClob");
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a NClob object in the
+	 * Java programming language.
+	 *
+	 * @param columnLabel the name of the column from which to retrieve
+	 *        the value
+	 * @return a NClob object representing the SQL NCLOB value in the
+	 *         specified column
+	 * @throws SQLException if a database access error occurs
+	 * @throws SQLFeatureNotSupportedException the JDBC driver does
+	 *         not support this method
+	 */
+	@Override
+	public NClob getNClob(final String columnLabel) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getNClob");
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.math.BigDecimal with full precision.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value (full precision); if the value is SQL NULL,
+	 *         the value returned is null in the Java programming language.
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public BigDecimal getBigDecimal(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			return new BigDecimal(val);
+		} catch (NumberFormatException e) {
+			throw newSQLNumberFormatException(e);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.math.BigDecimal with full precision.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @param scale the number of digits to the right of the decimal point
+	 * @return the column value (full precision); if the value is SQL NULL,
+	 *         the value returned is null in the Java programming language.
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	@Deprecated
+	public BigDecimal getBigDecimal(final int columnIndex, final int scale)
+		throws SQLException
+	{
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			return (new BigDecimal(val)).setScale(scale);
+		} catch (NumberFormatException e) {
+			throw newSQLNumberFormatException(e);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.math.BigDecimal with full precision.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value (full precision); if the value is SQL NULL,
+	 *         the value returned is null in the Java programming language.
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public BigDecimal getBigDecimal(final String columnLabel) throws SQLException {
+		return getBigDecimal(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.math.BigDecimal with full precision.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @param scale the number of digits to the right of the decimal point
+	 * @return the column value (full precision); if the value is SQL NULL,
+	 *         the value returned is null in the Java programming language.
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	@Deprecated
+	public BigDecimal getBigDecimal(final String columnLabel, final int scale)
+		throws SQLException
+	{
+		return getBigDecimal(findColumn(columnLabel), scale);
+	}
+	// See Sun JDBC Specification 3.0 Table B-6
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a boolean in the Java programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned
+	 *         is false
+	 * @throws SQLException if the columnIndex is not valid; if a database access error occurs
+	 *	or this method is called on a closed result set
+	 */
+	@Override
+	public boolean getBoolean(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return false;	// if the value is SQL NULL, the value returned is false
+			}
+			lastReadWasNull = false;
+			// match common cases first
+			if ("false".equalsIgnoreCase(val) || "0".equals(val))
+				return false;
+			if ("true".equalsIgnoreCase(val) || "1".equals(val))
+				return true;
+			// match type specific values
+			switch (JdbcSQLTypes[columnIndex - 1]) {
+				case Types.BOOLEAN:
+				case Types.CHAR:
+				case Types.VARCHAR:
+				case Types.LONGVARCHAR: // MonetDB doesn't use type LONGVARCHAR, it's here for completeness
+				case Types.CLOB:
+					// check if string value equals "true" (case insensitive) or not
+					return Boolean.parseBoolean(val);
+				case Types.TINYINT:
+				case Types.SMALLINT:
+				case Types.INTEGER:
+					if (getInt(columnIndex) == 0) {
+						return false;
+					}
+					return true;
+				case Types.BIGINT:
+					if (getLong(columnIndex) == 0L) {
+						return false;
+					}
+					return true;
+				case Types.DOUBLE:
+				case Types.FLOAT:
+				case Types.REAL:
+					if (getDouble(columnIndex) == 0.0) {
+						return false;
+					}
+					return true;
+				case Types.DECIMAL:
+				case Types.NUMERIC:
+					if (getBigDecimal(columnIndex).compareTo(BigDecimal.ZERO) == 0) {
+						return false;
+					}
+					return true;
+				default:
+					throw new SQLException("Conversion from " + types[columnIndex - 1] + " to boolean type not supported", "M1M05");
+			}
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a boolean in the Java programming language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned
+	 *         is false
+	 * @throws SQLException if the ResultSet object does not contain columnLabel
+	 */
+	@Override
+	public boolean getBoolean(final String columnLabel) throws SQLException {
+		return getBoolean(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a byte in the Java programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned
+	 *         is 0
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public byte getByte(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return (byte) 0;
+			}
+			lastReadWasNull = false;
+			return Byte.parseByte(val);
+		} catch (NumberFormatException e) {
+			throw newSQLNumberFormatException(e);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a byte in the Java programming language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned
+	 *         is 0
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public byte getByte(final String columnLabel) throws SQLException {
+		return getByte(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a byte array in the Java programming language. The
+	 * bytes represent the raw values returned by the driver.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned
+	 *         is null
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public byte[] getBytes(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			// According to Table B-6, getBytes() only operates on BINARY types
+			switch (JdbcSQLTypes[columnIndex - 1]) {
+				case Types.BLOB:
+				case Types.BINARY:
+				case Types.VARBINARY:
+				case Types.LONGVARBINARY:
+					return MonetBlob.hexStrToByteArray(val);
+				default:
+					throw new SQLException("Cannot operate on " + types[columnIndex - 1] + " type", "M1M05");
+			}
+		} catch (NumberFormatException e) {
+			throw newSQLNumberFormatException(e);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a byte array in the Java programming language. The
+	 * bytes represent the raw values returned by the driver.
+	 *
+	 * NOTE: Since the mapi protocol is ASCII-based, this method only returns
+	 *       Java byte representations of Strings, which is nothing more than
+	 *       an encoding into a sequence of bytes using the platform's default
+	 *       charset.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned
+	 *         is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public byte[] getBytes(final String columnLabel) throws SQLException {
+		return getBytes(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the concurrency mode of this ResultSet object. The concurrency
+	 * used is determined by the Statement object that created the result set.
+	 *
+	 * NOTE: MonetDB only supports read-only result sets, and will always return
+	 *       ResultSet.CONCUR_READ_ONLY
+	 *
+	 * @return the concurrency type, either ResultSet.CONCUR_READ_ONLY or
+	 *         ResultSet.CONCUR_UPDATABLE
+	 */
+	@Override
+	public int getConcurrency() {
+		return concurrency;
+	}
+	/**
+	 * Retrieves the name of the SQL cursor used by this ResultSet object.
+	 * In SQL, a result table is retrieved through a cursor that is named.
+	 * For MonetDB this is the header.id returned in a resultset header. The
+	 * current row of a result set can be updated or deleted using a positioned
+	 * update/delete statement that references the cursor name. To insure that
+	 * the cursor has the proper isolation level to support update, the
+	 * cursor's SELECT statement should be of the form SELECT FOR UPDATE. If
+	 * FOR UPDATE is omitted, the positioned updates may fail.
+	 *
+	 * The JDBC API supports this SQL feature by providing the name of the SQL
+	 * cursor used by a ResultSet object. The current row of a ResultSet object
+	 * is also the current row of this SQL cursor.
+	 *
+	 * Note: If positioned update is not supported, a SQLException is thrown.
+	 *       MonetDB currently doesn't support updates, so the SQLException is
+	 *       thrown for now.
+	 *
+	 * @return the SQL name for this ResultSet object's cursor
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public String getCursorName() throws SQLException {
+		throw new SQLException("Positioned updates not supported for this " +
+				   "cursor (" + (header != null ? header.id : "") + ")", "0AM21");
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a double in the Java programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned is 0
+	 * @throws SQLException if there is no such column or this method is called on a closed result set
+	 */
+	@Override
+	public double getDouble(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return 0;
+			}
+			lastReadWasNull = false;
+			return Double.parseDouble(val);
+		} catch (NumberFormatException e) {
+			throw newSQLNumberFormatException(e);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a double in the Java programming language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned is 0
+	 * @throws SQLException if the ResultSet object does not contain columnLabel
+	 */
+	@Override
+	public double getDouble(final String columnLabel) throws SQLException {
+		return getDouble(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the holdability of this ResultSet object.
+	 *
+	 * @return either ResultSet.HOLD_CURSORS_OVER_COMMIT or
+	 *         ResultSet.CLOSE_CURSORS_AT_COMMIT
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public int getHoldability() throws SQLException {
+		return getStatement().getConnection().getHoldability();
+	}
+	/**
+	 * Retrieves the fetch direction for this ResultSet object.
+	 *
+	 * @return the current fetch direction for this ResultSet object
+	 */
+	@Override
+	public int getFetchDirection() {
+		return ResultSet.FETCH_FORWARD;
+	}
+	/**
+	 * Gives a hint as to the direction in which the rows in this ResultSet
+	 * object will be processed. The initial value is determined by the
+	 * Statement object that produced this ResultSet object.
+	 * The fetch direction may be changed at any time.
+	 *
+	 * @param direction - an int specifying the suggested fetch direction;
+	 * one of ResultSet.FETCH_FORWARD, ResultSet.FETCH_REVERSE, or ResultSet.FETCH_UNKNOWN
+	 */
+	@Override
+	public void setFetchDirection(final int direction) throws SQLException {
+		switch (direction) {
+		case ResultSet.FETCH_FORWARD:
+			break;
+		case ResultSet.FETCH_REVERSE:
+		case ResultSet.FETCH_UNKNOWN:
+			throw new SQLException("Not supported direction " + direction, "0A000");
+		default:
+			throw new SQLException("Illegal direction: " + direction, "M1M05");
+		}
+	}
+	/**
+	 * Retrieves the fetch size for this ResultSet object.
+	 *
+	 * @return the current fetch size for this ResultSet object
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public int getFetchSize() throws SQLException {
+		return fetchSize;
+	}
+	/**
+	 * Gives the JDBC driver a hint as to the number of rows that should be
+	 * fetched from the database when more rows are needed.  In MonetDB, this is
+	 * actually a no-op, because even before a MonetResultSet object is
+	 * created, the fetch size is already determined in the
+	 * MonetConnection.ResultSetResponse passed to its constructor.  Since all
+	 * data blocks for this whole result set are already allocated in
+	 * MonetConnection.ResultSetResponse, it is too complicated and error-prone
+	 * to still change the fetchSize here.  If one really needs to overwrite
+	 * the default fetchSize, please use MonetStatement.setFetchSize() instead.
+	 *
+	 * @param rows the number of rows to fetch
+	 * @throws SQLException if the condition 0 &lt;= rows is not satisfied
+	 */
+	@Override
+	public void setFetchSize(final int rows) throws SQLException {
+		if (rows >= 0) {
+			fetchSize = rows;
+		} else {
+			throw new SQLException("Illegal fetch size value: " + rows, "M1M05");
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a float in the Java programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned is 0
+	 * @throws SQLException if there is no such column or this method is called on a closed result set
+	 */
+	@Override
+	public float getFloat(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return 0;
+			}
+			lastReadWasNull = false;
+			return Float.parseFloat(val);
+		} catch (NumberFormatException e) {
+			throw newSQLNumberFormatException(e);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a float in the Java programming language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned is 0
+	 * @throws SQLException if the ResultSet object does not contain columnLabel
+	 */
+	@Override
+	public float getFloat(final String columnLabel) throws SQLException {
+		return getFloat(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as an int in the Java programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned is 0
+	 * @throws SQLException if there is no such column or this method is called on a closed result set
+	 */
+	@Override
+	public int getInt(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		String val = "";
+		try {
+			val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return 0;
+			}
+			lastReadWasNull = false;
+			return Integer.parseInt(val);
+		} catch (NumberFormatException e) {
+			// The oid datatype values (as string) have a  @0  suffix in the string value.
+			// To allow succesful parsing and conversion to int, we need to remove the suffix first
+			if ("oid".equals(types[columnIndex - 1])) {
+				if (val.endsWith("@0")) {
+					try {
+						return Integer.parseInt(val.substring(0, val.length()-2));
+					} catch (NumberFormatException nfe) {
+						throw newSQLNumberFormatException(nfe);
+					}
+				}
+			}
+			throw newSQLNumberFormatException(e);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as an int in the Java programming language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned is 0
+	 * @throws SQLException if the ResultSet object does not contain columnLabel
+	 */
+	@Override
+	public int getInt(final String columnLabel) throws SQLException {
+		return getInt(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a long in the Java programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned is 0
+	 * @throws SQLException if there is no such column or this method is called on a closed result set
+	 */
+	@Override
+	public long getLong(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		String val = "";
+		try {
+			val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return 0;
+			}
+			lastReadWasNull = false;
+			return Long.parseLong(val);
+		} catch (NumberFormatException e) {
+			// The oid datatype values (as string) have a  @0  suffix in the string value.
+			// To allow succesful parsing and conversion to long, we need to remove the suffix first
+			if ("oid".equals(types[columnIndex - 1])) {
+				if (val.endsWith("@0")) {
+					try {
+						return Long.parseLong(val.substring(0, val.length()-2));
+					} catch (NumberFormatException nfe) {
+						throw newSQLNumberFormatException(nfe);
+					}
+				}
+			}
+			throw newSQLNumberFormatException(e);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a long in the Java programming language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned is 0
+	 * @throws SQLException if the ResultSet object does not contain columnLabel
+	 */
+	@Override
+	public long getLong(final String columnLabel) throws SQLException {
+		return getLong(findColumn(columnLabel));
+	}
+	/* helper for the anonymous class inside getMetaData */
+	private abstract class rsmdw extends MonetWrapper implements ResultSetMetaData {}
+	/**
+	 * Retrieves the number, types and properties of this ResultSet object's
+	 * columns.
+	 *
+	 * @return the description of this ResultSet object's columns
+	 */
+	@Override
+	public ResultSetMetaData getMetaData() throws SQLException {
+		// return inner class which implements the ResultSetMetaData interface
+		return new rsmdw() {
+			// for the more expensive methods (getPrecision(), getScale(), isNullable(), isAutoIncrement()), we
+			// use caches to store precision, scale and isNullable values from getColumns() combined per fully qualified column.
+			private final int array_size = columns.length + 1;  // add 1 as in JDBC columns start from 1 (array from 0).
+			private final boolean[] _is_fetched = new boolean[array_size];
+			private final int[] _precision	= new int[array_size];
+			private final int[] _scale	= new int[array_size];
+			private final int[] _isNullable	= new int[array_size];
+			private final boolean[] _isAutoincrement = new boolean[array_size];
+			private final Connection conn = getStatement().getConnection();
+			private DatabaseMetaData dbmd = null;	// it will be assigned at first need and reused for other columns
+			/**
+			 * A private utility method to check validity of column index number
+			 * @throws an SQLDataException when invalid column index number
+			 */
+			private final void checkColumnIndexValidity(final int column) throws SQLDataException {
+				if (column < 1 || column > columns.length)
+					throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+			}
+			/**
+			 * A private method to fetch the precision, scale, isNullable and isAutoincrement value for a fully qualified column.
+			 * As md.getColumns() is an expensive method we call it only once per column and store
+			 * the precision, scale, isNullable and isAutoincrement values in the above array caches.
+			 * Also we only call md.getColumns() when we have a non empty schema name and table name and column name.
+			 */
+			private final void fetchColumnInfo(final int column) throws SQLException
+			{
+				checkColumnIndexValidity(column);
+				_is_fetched[column] = true;
+				_precision[column] = 0;
+				_scale[column] = 0;
+				_isNullable[column] = columnNullableUnknown;
+				_isAutoincrement[column] = false;
+				if (dbmd == null) {
+					// first time usage
+					dbmd = conn.getMetaData();
+					if (dbmd == null)
+						return;
+				}
+				// we will only call dbmd.getColumns() when we have a specific schema name and table name and column name
+				final String schName = getSchemaName(column);
+				if (schName != null && !schName.isEmpty()) {
+					final String tblName = getTableName(column);
+					if (tblName != null && !tblName.isEmpty()) {
+						final String colName = getColumnName(column);
+						if (colName != null && !colName.isEmpty()) {
+							// for precision, scale, isNullable and isAutoincrement we query the information from data dictionary
+							final ResultSet colInfo = dbmd.getColumns(null, schName, tblName, colName);
+							if (colInfo != null) {
+								// we expect exactly one row in the resultset
+								if (colInfo.next()) {
+									_precision[column] = colInfo.getInt(7);  // col 7 is "COLUMN_SIZE"
+									_scale[column] = colInfo.getInt(9);  // col 9 is "DECIMAL_DIGITS"
+									_isNullable[column] = colInfo.getInt(11);  // col 11 is "NULLABLE"
+									final String strVal = colInfo.getString(23);  // col 23 is "IS_AUTOINCREMENT"
+									if (strVal != null && "YES".equals(strVal))
+										_isAutoincrement[column] = true;
+								}
+								colInfo.close();  // close the resultset to release resources
+							}
+						}
+					}
+				}
+			}
+			/**
+			 * Returns the number of columns in this ResultSet object.
+			 *
+			 * @return the number of columns
+			 */
+			@Override
+			public int getColumnCount() {
+				return columns.length;
+			}
+			/**
+			 * Indicates whether the designated column is automatically numbered.
+			 *
+			 * This method is currently very expensive for BIGINT,
+			 * INTEGER, SMALLINT and TINYINT result column types
+			 * as it needs to retrieve the information from the
+			 * database using an SQL meta data query.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return true if so; false otherwise
+			 * @throws SQLException if a database access error occurs
+			 */
+			@Override
+			public boolean isAutoIncrement(final int column) throws SQLException {
+				// only few integer types can be auto incrementable in MonetDB
+				// see: https://www.monetdb.org/Documentation/SQLReference/DataTypes/SerialDatatypes
+				switch (getColumnType(column)) {
+					case Types.BIGINT:
+					case Types.INTEGER:
+					case Types.SMALLINT:
+					case Types.TINYINT:
+						try {
+							if (_is_fetched[column] != true) {
+								fetchColumnInfo(column);
+							}
+							return _isAutoincrement[column];
+						} catch (IndexOutOfBoundsException e) {
+							throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+						}
+				}
+				return false;
+			}
+			/**
+			 * Indicates whether a column's case matters.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return true for all character string columns else false
+			 */
+			@Override
+			public boolean isCaseSensitive(final int column) throws SQLException {
+				switch (getColumnType(column)) {
+					case Types.CHAR:
+					case Types.LONGVARCHAR: // MonetDB doesn't use type LONGVARCHAR, it's here for completeness
+					case Types.CLOB:
+						return true;
+					case Types.VARCHAR:
+						final String monettype = getColumnTypeName(column);
+						if (monettype != null && monettype.length() == 4) {
+							// data of type inet or uuid is not case sensitive
+							if ("inet".equals(monettype)
+							 || "uuid".equals(monettype))
+								return false;
+						}
+						return true;
+				}
+				return false;
+			}
+			/**
+			 * Indicates whether the designated column can be used in a
+			 * where clause.
+			 * It is unknown to me what kind ot columns they regard to,
+			 * as I think all columns are useable in a where clause.
+			 * Returning true for all here, for the time being.
+			 * Possible thought; maybe they want to know here if it's a
+			 * real column existing in a table or not...
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return true
+			 */
+			@Override
+			public boolean isSearchable(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				return true;
+			}
+			/**
+			 * Indicates whether the designated column is a cash value.
+			 * From the MonetDB database perspective it is by definition
+			 * unknown whether the value is a currency, because there are
+			 * no currency datatypes such as MONEY.  With this knowledge
+			 * we can always return false here.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return false
+			 */
+			@Override
+			public boolean isCurrency(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				return false;
+			}
+			/**
+			 * Indicates whether values in the designated column are signed
+			 * numbers.
+			 * Within MonetDB all numeric types (except oid and ptr) are signed.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return true if so; false otherwise
+			 */
+			@Override
+			public boolean isSigned(final int column) throws SQLException {
+				// we can hardcode this, based on the colum type
+				switch (getColumnType(column)) {
+					case Types.TINYINT:
+					case Types.SMALLINT:
+					case Types.INTEGER:
+					case Types.REAL:
+					case Types.FLOAT:
+					case Types.DOUBLE:
+					case Types.DECIMAL:
+					case Types.NUMERIC:
+						return true;
+					case Types.BIGINT:
+						final String monettype = getColumnTypeName(column);
+						if (monettype != null && monettype.length() == 3) {
+							// data of type oid or ptr is not signed
+							if ("oid".equals(monettype)
+							 || "ptr".equals(monettype))
+								return false;
+						}
+						return true;
+				//	All other types should return false
+				//	case Types.BOOLEAN:
+				//	case Types.DATE:	// can year be negative?
+				//	case Types.TIME:	// can time be negative?
+				//	case Types.TIME_WITH_TIMEZONE:
+				//	case Types.TIMESTAMP:	// can year be negative?
+				//	case Types.TIMESTAMP_WITH_TIMEZONE:
+					default:
+						return false;
+				}
+			}
+			/**
+			 * Indicates the designated column's normal maximum width in
+			 * characters.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return the normal maximum number of characters allowed as the
+			 *         width of the designated column
+			 * @throws SQLException if there is no such column
+			 */
+			@Override
+			public int getColumnDisplaySize(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				if (header != null) {
+					try {
+						return header.getColumnLengths()[column - 1];
+					} catch (IndexOutOfBoundsException e) {
+						throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+					}
+				}
+				return 1;
+			}
+			/**
+			 * Get the designated column's schema name.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return schema name or "" if not applicable
+			 * @throws SQLException if a database access error occurs
+			 */
+			@Override
+			public String getSchemaName(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				if (header != null) {
+					// figure the name out
+					try {
+						final String schema = header.getTableNames()[column - 1];
+						if (schema != null) {
+							final int dot = schema.indexOf('.');
+							return (dot >= 0) ? schema.substring(0, dot) : "";
+						}
+					} catch (IndexOutOfBoundsException e) {
+						throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+					}
+				}
+				return "";
+			}
+			/**
+			 * Gets the designated column's table name.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return table name or "" if not applicable
+			 */
+			@Override
+			public String getTableName(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				if (header != null) {
+					// figure the name out
+					try {
+						final String table = header.getTableNames()[column - 1];
+						if (table != null) {
+							final int dot = table.indexOf('.');
+							return (dot >= 0) ? table.substring(dot + 1) : table;
+						}
+					} catch (IndexOutOfBoundsException e) {
+						throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+					}
+				}
+				return "";
+			}
+			/**
+			 * Get the designated column's specified column size.
+			 * For numeric data, this is the maximum precision.
+			 * For character data, this is the length in characters.
+			 * For datetime datatypes, this is the length in characters
+			 * of the String representation (assuming the maximum
+			 * allowed precision of the fractional seconds component).
+			 * For binary data, this is the length in bytes.
+			 * For the ROWID datatype, this is the length in bytes.
+			 * 0 is returned for data types where the column size is not applicable.
+			 *
+			 * This method is currently very expensive for DECIMAL, NUMERIC
+			 * CHAR, VARCHAR, CLOB, BLOB, VARBINARY and BINARY result
+			 * column types as it needs to retrieve the information
+			 * from the database using an SQL meta data query.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return precision
+			 * @throws SQLException if a database access error occurs
+			 */
+			@Override
+			public int getPrecision(final int column) throws SQLException {
+				final int tpe = getColumnType(column);
+				switch (tpe) {
+					case Types.BIGINT:
+						return 19;
+					case Types.INTEGER:
+						return 10;
+					case Types.SMALLINT:
+						return 5;
+					case Types.TINYINT:
+						return 3;
+					case Types.REAL:
+						return 7;
+					case Types.FLOAT:
+					case Types.DOUBLE:
+						return 15;
+					case Types.DECIMAL:
+					case Types.NUMERIC:
+						// these data types do not have a fixed precision, max precision however is 38
+						// we need to fetch the defined precision with an SQL query !
+					case Types.CHAR:
+					case Types.VARCHAR:
+					case Types.LONGVARCHAR: // MonetDB doesn't use type LONGVARCHAR, it's here for completeness
+					case Types.CLOB:
+					case Types.BINARY:
+					case Types.VARBINARY:
+					case Types.BLOB:
+						// these data types also do not have a fixed length
+						try {
+							if (_is_fetched[column] != true) {
+								fetchColumnInfo(column);
+							}
+							if (_precision[column] == 0) {
+								// apparently no precision or max length could be fetched
+								// use columnDisplaySize() value as alternative
+								_precision[column] = getColumnDisplaySize(column);
+								if (tpe == Types.BLOB || tpe == Types.VARBINARY || tpe == Types.BINARY)
+									// These expect number of bytes, not number of hex chars
+									_precision[column] = (_precision[column] / 2) +1;
+							}
+							return _precision[column];
+						} catch (IndexOutOfBoundsException e) {
+							throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+						}
+					case Types.DATE:
+						return 10;	// 2020-10-08
+					case Types.TIME:
+						return 15;	// 21:51:34.399753
+					case Types.TIME_WITH_TIMEZONE:
+						return 21;	// 21:51:34.399753+02:00
+					case Types.TIMESTAMP:
+						return 26;	// 2020-10-08 21:51:34.399753
+					case Types.TIMESTAMP_WITH_TIMEZONE:
+						return 32;	// 2020-10-08 21:51:34.399753+02:00
+					case Types.BOOLEAN:
+						return 1;
+					default:
+						// All other types should return 0
+						return 0;
+				}
+			}
+			/**
+			 * Gets the designated column's number of digits to right of
+			 * the decimal point.
+			 * 0 is returned for data types where the scale is not applicable.
+			 *
+			 * This method is currently very expensive for DECIMAL and NUMERIC
+			 * result column types as it needs to retrieve the information
+			 * from the database using an SQL meta data query.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return scale
+			 * @throws SQLException if a database access error occurs
+			 */
+			@Override
+			public int getScale(final int column) throws SQLException {
+				switch (getColumnType(column)) {
+					case Types.DECIMAL:
+					case Types.NUMERIC:
+						// these data types may have a scale, max scale is 38
+						try {
+							if (_is_fetched[column] != true) {
+								fetchColumnInfo(column);
+							}
+							return _scale[column];
+						} catch (IndexOutOfBoundsException e) {
+							throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+						}
+					case Types.TIME:
+					case Types.TIME_WITH_TIMEZONE:
+					case Types.TIMESTAMP:
+					case Types.TIMESTAMP_WITH_TIMEZONE:
+						// support microseconds, so scale 6
+						return 6;	// 21:51:34.399753
+					// All other types should return 0
+				//	case Types.BIGINT:
+				//	case Types.INTEGER:
+				//	case Types.SMALLINT:
+				//	case Types.TINYINT:
+				//	case Types.REAL:
+				//	case Types.FLOAT:
+				//	case Types.DOUBLE:
+				//	case Types.CHAR:
+				//	case Types.VARCHAR:
+				//	case Types.LONGVARCHAR: // MonetDB doesn't use type LONGVARCHAR, it's here for completeness
+				//	case Types.CLOB:
+				//	case Types.BINARY:
+				//	case Types.VARBINARY:
+				//	case Types.BLOB:
+				//	case Types.DATE:
+				//	case Types.BOOLEAN:
+					default:
+						return 0;
+				}
+			}
+			/**
+			 * Indicates the nullability of values in the designated column.
+			 *
+			 * This method is currently very expensive as it needs to
+			 * retrieve the information from the database using an SQL
+			 * meta data query (for each column).
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return the nullability status of the given column; one of
+			 *	columnNoNulls, columnNullable or columnNullableUnknown
+			 * @throws SQLException if a database access error occurs
+			 */
+			@Override
+			public int isNullable(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				try {
+					if (_is_fetched[column] != true) {
+						fetchColumnInfo(column);
+					}
+					return _isNullable[column];
+				} catch (IndexOutOfBoundsException e) {
+					throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+				}
+			}
+			/**
+			 * Gets the designated column's table's catalog name.
+			 * MonetDB does not support the catalog naming concept as in: catalog.schema.table naming scheme
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return the name of the catalog for the table in which the given
+			 *         column appears or "" if not applicable
+			 */
+			@Override
+			public String getCatalogName(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				return null;	// MonetDB does NOT support catalogs
+			}
+			/**
+			 * Indicates whether the designated column is definitely not
+			 * writable.  MonetDB does not support cursor updates, so
+			 * nothing is writable.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return true if so; false otherwise
+			 */
+			@Override
+			public boolean isReadOnly(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				return true;
+			}
+			/**
+			 * Indicates whether it is possible for a write on the
+			 * designated column to succeed.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return true if so; false otherwise
+			 */
+			@Override
+			public boolean isWritable(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				return false;
+			}
+			/**
+			 * Indicates whether a write on the designated column will
+			 * definitely succeed.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return true if so; false otherwise
+			 */
+			@Override
+			public boolean isDefinitelyWritable(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				return false;
+			}
+			/**
+			 * Returns the fully-qualified name of the Java class whose
+			 * instances are manufactured if the method
+			 * ResultSet.getObject is called to retrieve a value from
+			 * the column.  ResultSet.getObject may return a subclass of
+			 * the class returned by this method.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return the fully-qualified name of the class in the Java
+			 *         programming language that would be used by the method
+			 *         ResultSet.getObject to retrieve the value in the
+			 *         specified column. This is the class name used for custom
+			 *         mapping.
+			 * @throws SQLException if there is no such column
+			 */
+			@Override
+			public String getColumnClassName(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				try {
+					final String MonetDBType = types[column - 1];
+					Class<?> type = null;
+					if (conn != null) {
+						final Map<String,Class<?>> map = conn.getTypeMap();
+						if (map != null && map.containsKey(MonetDBType)) {
+							type = (Class)map.get(MonetDBType);
+						}
+					}
+					if (type == null) {
+						// fallback to the standard SQL type Class mappings
+						type = getClassForType(JdbcSQLTypes[column - 1]);
+					}
+					if (type != null) {
+						return type.getName();
+					}
+					throw new SQLException("column type mapping null: " + MonetDBType, "M0M03");
+				} catch (IndexOutOfBoundsException e) {
+					throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+				}
+			}
+			/**
+			 * Gets the designated column's suggested title for use in
+			 * printouts and displays. This is currently equal to
+			 * getColumnName().
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return the suggested column title
+			 * @throws SQLException if there is no such column
+			 */
+			@Override
+			public String getColumnLabel(final int column) throws SQLException {
+				return getColumnName(column);
+			}
+			/**
+			 * Gets the designated column's name
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return the column name
+			 * @throws SQLException if there is no such column
+			 */
+			@Override
+			public String getColumnName(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				try {
+					return columns[column - 1];
+				} catch (IndexOutOfBoundsException e) {
+					throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+				}
+			}
+			/**
+			 * Retrieves the designated column's SQL type.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return SQL type from java.sql.Types
+			 * @throws SQLException if there is no such column
+			 */
+			@Override
+			public int getColumnType(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				try {
+					return JdbcSQLTypes[column - 1];
+				} catch (IndexOutOfBoundsException e) {
+					throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+				}
+			}
+			/**
+			 * Retrieves the designated column's database-specific type name.
+			 *
+			 * @param column the first column is 1, the second is 2, ...
+			 * @return type name used by the database. If the column type is a
+			 *         user-defined type, then a fully-qualified type name is
+			 *         returned.
+			 * @throws SQLException if there is no such column
+			 */
+			@Override
+			public String getColumnTypeName(final int column) throws SQLException {
+				checkColumnIndexValidity(column);
+				try {
+					return types[column - 1];
+				} catch (IndexOutOfBoundsException e) {
+					throw MonetResultSet.newSQLInvalidColumnIndexException(column);
+				}
+			}
+		};	// end of new rsmdw()
+	}	// end of getMetaData()
+	/**
+	 * Gets the value of the designated column in the current row of this
+	 * ResultSet object as an Object in the Java programming language.
+	 *
+	 * This method will return the value of the given column as a Java object.
+	 * The type of the Java object will be the default Java object type
+	 * corresponding to the column's SQL type, following the mapping for
+	 * built-in types specified in the JDBC specification. If the value is
+	 * an SQL NULL, the driver returns a Java null.
+	 *
+	 * This method may also be used to read database-specific abstract data
+	 * types. In the JDBC 2.0 API, the behavior of method getObject is extended
+	 * to materialize data of SQL user-defined types. When a column contains a
+	 * structured or distinct value, the behavior of this method is as if it
+	 * were a call to: getObject(columnIndex, this.getStatement().getConnection().getTypeMap()).
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return a java.lang.Object holding the column value or null
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public Object getObject(final int columnIndex) throws SQLException {
+		// Many generic JDBC programs use getObject(colnr) to retrieve value objects from a resultset
+		// For speed the implementation should be as fast as possible, so avoid method calls (by inlining code) where possible
+		checkNotClosed();
+		final int JdbcType;
+		final String val;
+		try {
+			val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			JdbcType = JdbcSQLTypes[columnIndex - 1];
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+		switch(JdbcType) {
+			case Types.TINYINT:
+			case Types.SMALLINT:
+				try {
+					return Short.valueOf(val);
+				} catch (NumberFormatException e) {
+					return val;
+				}
+			case Types.INTEGER:
+				try {
+					return Integer.valueOf(val);
+				} catch (NumberFormatException e) {
+					return val;
+				}
+			case Types.BIGINT:
+				try {
+					return Long.valueOf(val);
+				} catch (NumberFormatException e) {
+					return val;
+				}
+			case Types.DOUBLE:
+			case Types.FLOAT:
+				try {
+					return Double.valueOf(val);
+				} catch (NumberFormatException e) {
+					return val;
+				}
+			case Types.REAL:
+				try {
+					return Float.valueOf(val);
+				} catch (NumberFormatException e) {
+					return val;
+				}
+			case Types.DECIMAL:
+			case Types.NUMERIC:
+				try {
+					return new BigDecimal(val);
+				} catch (NumberFormatException e) {
+					return val;
+				}
+			case Types.BOOLEAN:
+				return Boolean.valueOf(val);
+			case Types.VARCHAR:
+			{
+				// The MonetDB types: inet, json, url and uuid are all mapped to Types.VARCHAR in MonetDriver.typeMap
+				// For these MonetDB types (except json, see comments below) we try to create objects of the corresponding class.
+				final String MonetDBType = types[columnIndex - 1];
+				switch (MonetDBType.length()) {
+				case 3:
+					if ("url".equals(MonetDBType)) {
+						try {
+							final org.monetdb.jdbc.types.URL url_obj = new org.monetdb.jdbc.types.URL();
+							url_obj.fromString(val);
+							return url_obj;
+						} catch (Exception exc) {
+							// ignore exception and just return the val String object
+							return val;
+						}
+					}
+					break;
+				case 4:
+					if ("inet".equals(MonetDBType)) {
+						try {
+							final org.monetdb.jdbc.types.INET inet_obj = new org.monetdb.jdbc.types.INET();
+							inet_obj.fromString(val);
+							return inet_obj;
+						} catch (Exception exc) {
+							// ignore exception and just return the val String object
+							return val;
+						}
+					} else
+					if ("uuid".equals(MonetDBType)) {
+						try {
+							return java.util.UUID.fromString(val);
+						} catch (IllegalArgumentException exc) {
+							// ignore exception and just return the val String object
+							return val;
+						}
+//					} else
+//					if ("json".equals(MonetDBType)) {
+						// There is no support for JSON in standard java class libraries.
+						// Possibly we could use org.json.simple.JSONObject or other/faster libs
+						// javax.json.Json is not released yet (see https://json-processing-spec.java.net/)
+						// see also https://github.com/fabienrenaud/java-json-benchmark
+						// Note that it would make our JDBC driver dependent of an external jar
+						// and we don't want that so simply return it as String object
+//						return val;
+					}
+					break;
+				}
+				return val;
+			}
+			case Types.CHAR:
+			case Types.LONGVARCHAR: // MonetDB doesn't use type LONGVARCHAR, it's here for completeness
+				return val;
+			case Types.CLOB:
+				return new MonetClob(val);
+			case Types.BLOB:
+				return new MonetBlob(val);
+			case Types.DATE:
+				return getDate(columnIndex, null);
+			case Types.TIME:
+			case Types.TIME_WITH_TIMEZONE:
+				return getTime(columnIndex, null);
+			case Types.TIMESTAMP:
+			case Types.TIMESTAMP_WITH_TIMEZONE:
+				return getTimestamp(columnIndex, null);
+			case Types.BINARY:
+			case Types.VARBINARY:
+			case Types.LONGVARBINARY: // MonetDB doesn't use type LONGVARBINARY, it's here for completeness
+				return getBytes(columnIndex);
+			case Types.OTHER:
+			default:
+				// When we get here the column type is a non-standard JDBC SQL type, possibly a User Defined Type.
+				// Just call getObject(int, Map) for those rare cases.
+				return getObject(columnIndex, this.getStatement().getConnection().getTypeMap());
+		}
+	}
+	private final boolean classImplementsSQLData(final Class<?> cl) {
+		final Class<?>[] cls = cl.getInterfaces();
+		for (int i = 0; i < cls.length; i++) {
+			if (cls[i] == SQLData.class)
+				return true;
+		}
+		return false;
+	}
+	/**
+	 * Gets the value of the designated column in the current row of this
+	 * ResultSet object as an Object in the Java programming language.
+	 *
+	 * This method will return the value of the given column as a Java object.
+	 * The type of the Java object will be the default Java object type corresponding
+	 * to the column's SQL type, following the mapping for built-in types specified
+	 * in the JDBC specification.
+	 * If the value is an SQL NULL, the driver returns a Java null.
+	 *
+	 * This method may also be used to read database-specific abstract data types.
+	 * In the JDBC 2.0 API, the behavior of method getObject is extended to
+	 * materialize data of SQL user-defined types.
+	 *
+	 * If Connection.getTypeMap does not throw a SQLFeatureNotSupportedException, then
+	 * when a column contains a structured or distinct value, the behavior of this
+	 * method is as if it were a call to: getObject(columnIndex,
+	 * this.getStatement().getConnection().getTypeMap()).
+	 * If Connection.getTypeMap does throw a SQLFeatureNotSupportedException, then
+	 * structured values are not supported, and distinct values are mapped to the
+	 * default Java class as determined by the underlying SQL type of the DISTINCT type.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @param map a java.util.Map object that contains the mapping from SQL
+	 *        type names to classes in the Java programming language
+	 * @return an Object in the Java programming language representing the SQL value
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	@SuppressWarnings("unchecked")
+	public Object getObject(final int columnIndex, final Map<String,Class<?>> map)
+		throws SQLException
+	{
+		checkNotClosed();
+		final String val;
+		final String MonetDBtype;
+		try {
+			val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			MonetDBtype = types[columnIndex - 1];
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+		Class<?> type = null;
+		if (map != null && map.containsKey(MonetDBtype)) {
+			type = map.get(MonetDBtype);
+		}
+		if (type == null) {
+			// fallback to the standard SQL type Class mappings
+			type = getClassForType(JdbcSQLTypes[columnIndex - 1]);
+		}
+		if (type == null || type == String.class) {
+			return val;
+		} else if (type == BigDecimal.class) {
+			return getBigDecimal(columnIndex);
+		} else if (type == Boolean.class) {
+			return Boolean.valueOf(getBoolean(columnIndex));
+		} else if (type == Short.class) {
+			return Short.valueOf(getShort(columnIndex));
+		} else if (type == Integer.class) {
+			return Integer.valueOf(getInt(columnIndex));
+		} else if (type == Long.class) {
+			return Long.valueOf(getLong(columnIndex));
+		} else if (type == Float.class) {
+			return Float.valueOf(getFloat(columnIndex));
+		} else if (type == Double.class) {
+			return Double.valueOf(getDouble(columnIndex));
+		} else if (type == byte[].class) {
+			return getBytes(columnIndex);
+		} else if (type == java.sql.Date.class) {
+			return getDate(columnIndex, null);
+		} else if (type == Time.class) {
+			return getTime(columnIndex, null);
+		} else if (type == Timestamp.class) {
+			return getTimestamp(columnIndex, null);
+		} else if (type == Clob.class) {
+			return getClob(columnIndex);
+		} else if (type == Blob.class) {
+			return getBlob(columnIndex);
+		} else if (classImplementsSQLData(type)) {
+			final SQLData x;
+			try {
+				final java.lang.reflect.Constructor<? extends SQLData> ctor =
+					((Class)type).getConstructor();
+				x = ctor.newInstance();
+			} catch (NoSuchMethodException nsme) {
+				throw new SQLException(nsme.getMessage(), "M0M27");
+			} catch (InstantiationException ie) {
+				throw new SQLException(ie.getMessage(), "M0M27");
+			} catch (IllegalAccessException iae) {
+				throw new SQLException(iae.getMessage(), "M0M27");
+			} catch (java.lang.reflect.InvocationTargetException ite) {
+				throw new SQLException(ite.getMessage(), "M0M27");
+			} catch (SecurityException se) {
+				throw new SQLException(se.getMessage(), "M0M27");
+			}
+			final int colnum = columnIndex;
+			final boolean valwasnull = wasNull();
+			final SQLInput input = new SQLInput() {
+				@Override
+				public String readString() throws SQLException {
+					return getString(colnum);
+				}
+				@Override
+				public boolean readBoolean() throws SQLException {
+					return getBoolean(colnum);
+				}
+				@Override
+				public byte readByte() throws SQLException {
+					return getByte(colnum);
+				}
+				@Override
+				public short readShort() throws SQLException {
+					return getShort(colnum);
+				}
+				@Override
+				public int readInt() throws SQLException {
+					return getInt(colnum);
+				}
+				@Override
+				public long readLong() throws SQLException {
+					return getLong(colnum);
+				}
+				@Override
+				public float readFloat() throws SQLException {
+					return getFloat(colnum);
+				}
+				@Override
+				public double readDouble() throws SQLException {
+					return getDouble(colnum);
+				}
+				@Override
+				public BigDecimal readBigDecimal() throws SQLException {
+					return getBigDecimal(colnum);
+				}
+				@Override
+				public byte[] readBytes() throws SQLException {
+					return getBytes(colnum);
+				}
+				@Override
+				public java.sql.Date readDate() throws SQLException {
+					return getDate(colnum, null);
+				}
+				@Override
+				public java.sql.Time readTime() throws SQLException {
+					return getTime(colnum, null);
+				}
+				@Override
+				public Timestamp readTimestamp() throws SQLException {
+					return getTimestamp(colnum, null);
+				}
+				@Override
+				public Reader readCharacterStream() throws SQLException {
+					return getCharacterStream(colnum);
+				}
+				@Override
+				public InputStream readAsciiStream() throws SQLException {
+					return getAsciiStream(colnum);
+				}
+				@Override
+				public InputStream readBinaryStream() throws SQLException {
+					return getBinaryStream(colnum);
+				}
+				@Override
+				public Object readObject() throws SQLException {
+					return getObject(colnum);
+				}
+				@Override
+				public Ref readRef() throws SQLException {
+					return getRef(colnum);
+				}
+				@Override
+				public Blob readBlob() throws SQLException {
+					return getBlob(colnum);
+				}
+				@Override
+				public Clob readClob() throws SQLException {
+					return getClob(colnum);
+				}
+				@Override
+				public Array readArray() throws SQLException {
+					return getArray(colnum);
+				}
+				@Override
+				public boolean wasNull() throws SQLException {
+					return valwasnull;
+				}
+				@Override
+				public URL readURL() throws SQLException {
+					return getURL(colnum);
+				}
+				@Override
+				public NClob readNClob() throws SQLException {
+					return getNClob(colnum);
+				}
+				@Override
+				public String readNString() throws SQLException {
+					return getNString(colnum);
+				}
+				@Override
+				public SQLXML readSQLXML() throws SQLException {
+					return getSQLXML(colnum);
+				}
+				@Override
+				public RowId readRowId() throws SQLException {
+					return getRowId(colnum);
+				}
+			};
+			x.readSQL(input, MonetDBtype);
+			return x;
+		} else {
+			return val;
+		}
+	}
+	/**
+	 * Helper method to support the getObject and
+	 * ResultsetMetaData.getColumnClassName JDBC methods.
+	 *
+	 * @param type a value from java.sql.Types
+	 * @return a Class object from which an instance would be returned
+	 */
+	final static Class<?> getClassForType(final int type) {
+		/**
+		 * This switch returns the types as objects according to table B-3 from
+		 * Oracle's JDBC specification 4.1
+		 */
+		// keep this switch regarding the returned classes aligned with getObject(int, Map) !
+		switch(type) {
+			case Types.CHAR:
+			case Types.VARCHAR:
+			case Types.LONGVARCHAR:
+				return String.class;
+			case Types.NUMERIC:
+			case Types.DECIMAL:
+				return BigDecimal.class;
+			case Types.BOOLEAN:
+				return Boolean.class;
+			case Types.TINYINT:
+			case Types.SMALLINT:
+				return Short.class;
+			case Types.INTEGER:
+				return Integer.class;
+			case Types.BIGINT:
+				return Long.class;
+			case Types.REAL:
+				return Float.class;
+			case Types.FLOAT:
+			case Types.DOUBLE:
+				return Double.class;
+			case Types.BINARY:      // MonetDB currently does not support these
+			case Types.VARBINARY:   // see treat_blob_as_binary property
+			case Types.LONGVARBINARY:
+				return byte[].class;
+			case Types.DATE:
+				return java.sql.Date.class;
+			case Types.TIME:
+			case Types.TIME_WITH_TIMEZONE:
+				return Time.class;
+			case Types.TIMESTAMP:
+			case Types.TIMESTAMP_WITH_TIMEZONE:
+				return Timestamp.class;
+			case Types.CLOB:
+				return Clob.class;
+			case Types.BLOB:
+				return Blob.class;
+			// all the rest are currently not implemented and used
+			default:
+				return String.class;
+		}
+	}
+	/**
+	 * Gets the value of the designated column in the current row of this
+	 * ResultSet object as an Object in the Java programming language.
+	 *
+	 * This method will return the value of the given column as a Java object.
+	 * The type of the Java object will be the default Java object type
+	 * corresponding to the column's SQL type, following the mapping for
+	 * built-in types specified in the JDBC specification. If the value is an
+	 * SQL NULL, the driver returns a Java null.
+	 *
+	 * This method may also be used to read database-specific abstract data
+	 * types.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return a java.lang.Object holding the column value
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public Object getObject(final String columnLabel) throws SQLException {
+		return getObject(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as an Object  in the Java programming language. If the
+	 * value is an SQL NULL, the driver returns a Java null. This method uses
+	 * the specified Map object for custom mapping if appropriate.
+	 *
+	 * @param columnLabel the name of the column from which to retrieve the value
+	 * @param map a java.util.Map object that contains the mapping from SQL
+	 *        type names to classes in the Java programming language
+	 * @return an Object representing the SQL value in the specified column
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public Object getObject(final String columnLabel, final Map<String,Class<?>> map) throws SQLException {
+		return getObject(findColumn(columnLabel), map);
+	}
+	@Override
+	public Ref getRef(int columnIndex) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getRef");
+	}
+	@Override
+	public Ref getRef(final String columnLabel) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getRef");
+	}
+	/**
+	 * Retrieves the current row number. The first row is number 1, the second
+	 * number 2, and so on.
+	 *
+	 * @return the current row number; 0 if there is no current row
+	 */
+	@Override
+	public int getRow() {
+		return curRow;
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a java.sql.RowId object in the Java
+	 * programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned
+	 *         is null
+	 * @throws SQLException if there is no such column
+	 * @throws SQLFeatureNotSupportedException the JDBC driver does
+	 *         not support this method
+	 */
+	@Override
+	public RowId getRowId(final int columnIndex) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getRowId");
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a java.sql.RowId object in the Java
+	 * programming language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned
+	 *         is null
+	 * @throws SQLException if the ResultSet object does not contain columnLabel
+	 * @throws SQLFeatureNotSupportedException the JDBC driver does
+	 *         not support this method
+	 */
+	@Override
+	public RowId getRowId(final String columnLabel) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getRowId");
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a short in the Java programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned is 0
+	 * @throws SQLException if there is no such column or this method is called on a closed result set
+	 */
+	@Override
+	public short getShort(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return 0;
+			}
+			lastReadWasNull = false;
+			return Short.parseShort(val);
+		} catch (NumberFormatException e) {
+			throw newSQLNumberFormatException(e);
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a short in the Java programming language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned is 0
+	 * @throws SQLException if the ResultSet object does not contain columnLabel
+	 */
+	@Override
+	public short getShort(final String columnLabel) throws SQLException {
+		return getShort(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the Statement object that produced this ResultSet object.
+	 * If the result set was generated some other way, such as by a
+	 * DatabaseMetaData method, this method may return null.
+	 *
+	 * In our implementation we always return a non-null object, see constructors.
+	 * Also from subclass MonetVirtualResultSet, see its constructor.
+	 *
+	 * @return the Statement object that produced this ResultSet object or
+	 *         null if the result set was produced some other way
+	 */
+	@Override
+	public Statement getStatement() {
+		return statement;
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a String in the Java programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if there is no such column or this method is called on a closed result set
+	 */
+	@Override
+	public String getString(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			return val;
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a String in the Java programming language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if the ResultSet object does not contain columnLabel
+	 */
+	@Override
+	public String getString(final String columnLabel) throws SQLException {
+		return getString(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a String in the Java programming
+	 * language. It is intended for use when accessing NCHAR,NVARCHAR
+	 * and LONGNVARCHAR columns.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if there is no such column
+	 */
+	@Override
+	public String getNString(final int columnIndex) throws SQLException {
+		return getString(columnIndex);
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a String in the Java programming
+	 * language. It is intended for use when accessing NCHAR,NVARCHAR
+	 * and LONGNVARCHAR columns.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if the ResultSet object does not contain columnLabel
+	 */
+	@Override
+	public String getNString(final String columnLabel) throws SQLException {
+		return getString(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet as a java.sql.SQLXML object in the Java
+	 * programming language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return a SQLXML object that maps an SQL XML value
+	 * @throws SQLException if a database access error occurs
+	 * @throws SQLFeatureNotSupportedException the JDBC driver does
+	 *         not support this method
+	 */
+	@Override
+	public SQLXML getSQLXML(final int columnIndex) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getSQLXML");
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet as a java.sql.SQLXML object in the Java
+	 * programming language.
+	 *
+	 * @param columnLabel the label for the column specified with the SQL AS
+	 *        clause. If the SQL AS clause was not specified, then the
+	 *        label is the name of the column
+	 * @return a SQLXML object that maps an SQL XML value
+	 * @throws SQLException if a database access error occurs
+	 * @throws SQLFeatureNotSupportedException the JDBC driver does
+	 *         not support this method
+	 */
+	@Override
+	public SQLXML getSQLXML(final String columnLabel) throws SQLException {
+		throw newSQLFeatureNotSupportedException("getSQLXML");
+	}
+	// This behaviour is according table B-6 of Sun JDBC Specification 3.0
+	private SimpleDateFormat dateFormat;
+	private SimpleDateFormat timeFormat;
+	private SimpleDateFormat timestampFormat;
+	/**
+	 * Helper method which parses the date/time value for columns of type
+	 * TIME, DATE and TIMESTAMP.  For the types CHAR, VARCHAR and
+	 * LONGVARCHAR an attempt is made to parse the date according to the
+	 * given type.  The given Calender object is filled with the parsed
+	 * data.  Optional fractional seconds (nanos) are returned by this
+	 * method.  If the underlying type of the column is none of the
+	 * mentioned six, January 1st 1970 0:00:00 GMT is returned.<br />
+	 * The dates are parsed with the given Calendar.
+	 *
+	 * @param cal the Calendar to use/fill when parsing the date/time
+	 * @param col the column to parse
+	 * @param type the corresponding java.sql.Types type of the calling function
+	 * @return the fractional seconds (nanos) or -1 if the value is NULL
+	 * @throws SQLException if a database error occurs
+	 */
+	private final int getJavaDate(final Calendar cal, final int columnIndex, int type)
+		throws SQLException
+	{
+		checkNotClosed();
+		if (cal == null)
+			throw new IllegalArgumentException("No Calendar object given!");
+		final String monetDateStr;
+		final String monetDate;
+		final String MonetDBType;
+		int JdbcType;
+		boolean negativeYear = false;
+		try {
+			monetDateStr = tlp.values[columnIndex - 1];
+			if (monetDateStr == null) {
+				lastReadWasNull = true;
+				return -1;
+			}
+			lastReadWasNull = false;
+			MonetDBType = types[columnIndex - 1];
+			JdbcType = JdbcSQLTypes[columnIndex - 1];
+			// If we got a string type, set the JdbcType to the given type
+			// so we attempt to parse it as the caller thinks it is.
+			if (JdbcType == Types.CHAR ||
+			    JdbcType == Types.VARCHAR ||
+			    JdbcType == Types.LONGVARCHAR ||
+			    JdbcType == Types.CLOB)
+			{
+				JdbcType = type;
+			}
+			if ((JdbcType == Types.DATE || JdbcType == Types.TIMESTAMP || JdbcType == Types.TIMESTAMP_WITH_TIMEZONE)
+			 && monetDateStr.startsWith("-")) {
+				// the SimpleDateFormat parsers do not support to parse negative year numbers, deal with it separately
+				negativeYear = true;
+				monetDate = monetDateStr.substring(1);
+			} else {
+				monetDate = monetDateStr;
+			}
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+		TimeZone ptz = cal.getTimeZone();
+		// it is important to parse the time in the given timezone in
+		// order to get a correct (UTC) time value, hence we need to
+		// parse it first
+		if (MonetDBType != null && ("timetz".equals(MonetDBType) || "timestamptz".equals(MonetDBType))) {
+			int vallen = monetDate.length();
+			if (vallen >= 6) {
+				// MonetDB/SQL99:  Sign TwoDigitHours : Minutes
+				ptz = TimeZone.getTimeZone("GMT" + monetDate.substring(vallen - 6, vallen));
+			}
+		}
+		java.util.Date pdate = null;
+		final java.text.ParsePosition ppos = new java.text.ParsePosition(0);
+		switch(JdbcType) {
+			case Types.DATE:
+				if (dateFormat == null) {
+					// first time usage, create and keep the dateFormat object for next usage
+					dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+				}
+				dateFormat.setTimeZone(ptz);
+				pdate = dateFormat.parse(monetDate, ppos);
+				break;
+			case Types.TIME:
+			case Types.TIME_WITH_TIMEZONE:
+				if (timeFormat == null) {
+					// first time usage, create and keep the timeFormat object for next usage
+					timeFormat = new SimpleDateFormat("HH:mm:ss");
+				}
+				timeFormat.setTimeZone(ptz);
+				pdate = timeFormat.parse(monetDate, ppos);
+				break;
+			case Types.TIMESTAMP:
+			case Types.TIMESTAMP_WITH_TIMEZONE:
+				if (timestampFormat == null) {
+					// first time usage, create and keep the timestampFormat object for next usage
+					timestampFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+				}
+				timestampFormat.setTimeZone(ptz);
+				pdate = timestampFormat.parse(monetDate, ppos);
+				// if parsing with timestampFormat failed try to parse it in dateFormat
+				if (pdate == null && monetDate.length() <= 10 && monetDate.contains("-")) {
+					if (dateFormat == null) {
+						// first time usage, create and keep the dateFormat object for next usage
+						dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+					}
+					dateFormat.setTimeZone(ptz);
+					pdate = dateFormat.parse(monetDate, ppos);
+				}
+				break;
+			default:
+				throw new SQLException("Internal error, unsupported data type: " + type, "01M03");
+		}
+		if (pdate == null) {
+			// parsing failed
+			final String errMsg;
+			final int epos = ppos.getErrorIndex();
+			if (epos == -1) {
+				errMsg = "parsing '" + monetDateStr + "' failed";
+			} else if (epos < monetDate.length()) {
+				errMsg = "parsing failed," +
+					 " found: '" + monetDate.charAt(epos) + "'" +
+					 " in: \"" + monetDateStr + "\"" +
+					 " at pos: " + (epos + (negativeYear ? 2 : 1));
+			} else {
+				errMsg = "parsing failed, expected more data after '" +	monetDateStr + "'";
+			}
+			throw new SQLException(errMsg, "01M10");
+		}
+		cal.setTime(pdate);
+		if (negativeYear) {
+			// System.out.println("Current cal: " + cal.toString());
+			// using cal.set(Calendar.YEAR, -(cal.get(Calendar.YEAR))); does not work. We must set the ERA instead
+			cal.set(Calendar.ERA, java.util.GregorianCalendar.BC);
+			// System.out.println("Corrected cal: " + cal.toString());
+		}
+		if (JdbcType == Types.TIME
+		 || JdbcType == Types.TIME_WITH_TIMEZONE
+		 || JdbcType == Types.TIMESTAMP
+		 || JdbcType == Types.TIMESTAMP_WITH_TIMEZONE) {
+			// parse additional nanos (if any)
+			int nanos = 0;
+			int pos = ppos.getIndex();
+			final char[] monDate = monetDate.toCharArray();
+			if (pos < monDate.length && monDate[pos] == '.') {
+				pos++;
+				try {
+					int ctr;
+					nanos = getIntrinsicValue(monDate[pos], pos++);
+					for (ctr = 1;
+							pos < monDate.length &&
+							monDate[pos] >= '0' &&
+							monDate[pos] <= '9';
+							ctr++)
+					{
+						if (ctr < 9) {
+							nanos *= 10;
+							nanos += (getIntrinsicValue(monDate[pos], pos));
+						}
+						if (ctr == 2)	// we have three at this point
+							cal.set(Calendar.MILLISECOND, nanos);
+						pos++;
+					}
+					while (ctr++ < 9)
+						nanos *= 10;
+				} catch (MCLParseException e) {
+					addWarning(e.getMessage() +
+							" found: '" + monDate[e.getErrorOffset()] + "'" +
+							" in: \"" + monetDate + "\"" +
+							" at pos: " + e.getErrorOffset(), "01M10");
+					// default value
+					nanos = 0;
+				}
+			}
+			return nanos;
+		}
+		return 0;
+	}
+	/**
+	 * Small helper method that returns the intrinsic value of a char if
+	 * it represents a digit.  If a non-digit character is encountered
+	 * an MCLParseException is thrown.
+	 *
+	 * @param c the char
+	 * @param pos the position
+	 * @return the intrinsic value of the char
+	 * @throws MCLParseException if c is not a digit
+	 */
+	private static final int getIntrinsicValue(final char c, final int pos)
+		throws MCLParseException
+	{
+		// note: don't use Character.isDigit() here, because
+		// we only want ISO-LATIN-1 digits
+		if (c >= '0' && c <= '9') {
+			return (int)c - (int)'0';
+		} else {
+			throw new MCLParseException("Expected a digit", pos);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.sql.Date object in the Java programming
+	 * language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value as a java.sql.Date object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 * @see #getDate(int col, Calendar cal)
+	 */
+	@Override
+	public java.sql.Date getDate(final int columnIndex) throws SQLException {
+		return getDate(columnIndex, null);
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.sql.Date object in the Java programming
+	 * language. This method uses the given calendar to construct an appropriate
+	 * millisecond value for the date if the underlying database does not store
+	 * timezone information.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @param cal the java.util.Calendar object to use in constructing the date
+	 * @return the column value as a java.sql.Date object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public java.sql.Date getDate(final int columnIndex, Calendar cal)
+		throws SQLException
+	{
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			if (cal == null) {
+				// try to convert string directly to a Date object
+				// Note: the string must be in JDBC date escape format: yyyy-[m]m-[d]d
+				try {
+					return java.sql.Date.valueOf(val);
+				} catch (IllegalArgumentException iae) {
+					// this happens if string doesn't match the format, such as for years < 1000 (including negative years)
+					// in those cases just continue and use slower getJavaDate(cal, columnIndex, Types.DATE) method
+				}
+				cal = Calendar.getInstance();
+			}
+			final int ret = getJavaDate(cal, columnIndex, Types.DATE);
+			return ret == -1 ? null : new java.sql.Date(cal.getTimeInMillis());
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.sql.Date object in the Java programming
+	 * language.
+	 *
+	 * @param columnLabel the SQL name of the column from which to retrieve the value
+	 * @return the column value as a java.sql.Date object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public java.sql.Date getDate(final String columnLabel) throws SQLException {
+		return getDate(findColumn(columnLabel), null);
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.sql.Date object in the Java programming
+	 * language. This method uses the given calendar to construct an appropriate
+	 * millisecond value for the date if the underlying database does not store
+	 * timezone information.
+	 *
+	 * @param columnLabel the SQL name of the column from which to retrieve the value
+	 * @param cal the java.util.Calendar object to use in constructing the date
+	 * @return the column value as a java.sql.Date object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public java.sql.Date getDate(final String columnLabel, final Calendar cal)
+		throws SQLException
+	{
+		return getDate(findColumn(columnLabel), cal);
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.sql.Time object in the Java programming
+	 * language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value as a java.sql.Time object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Time getTime(final int columnIndex) throws SQLException {
+		return getTime(columnIndex, null);
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of
+	 * this ResultSet object as a java.sql.Time object in the Java programming
+	 * language. This method uses the given calendar to construct an appropriate
+	 * millisecond value for the time if the underlying database does not store
+	 * timezone information.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @param cal the java.util.Calendar object to use in constructing the timestamp
+	 * @return the column value as a java.sql.Time object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Time getTime(final int columnIndex, Calendar cal)
+		throws SQLException
+	{
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			if (cal == null) {
+				// try to convert string directly to a Time object
+				// Note: the string must be in JDBC time escape format: hh:mm:ss
+				try {
+					return Time.valueOf(val);
+				} catch (IllegalArgumentException iae) {
+					// this happens if string doesn't match the format or hh >= 24 or mm >= 60 or ss >= 60
+					// in those cases just continue and use slower getJavaDate(cal, columnIndex, Types.TIME) method
+				}
+				cal = Calendar.getInstance();
+			}
+			final int ret = getJavaDate(cal, columnIndex, Types.TIME);
+			return ret == -1 ? null : new Time(cal.getTimeInMillis());
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.sql.Time object in the Java programming
+	 * language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value as a java.sql.Time object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Time getTime(final String columnLabel) throws SQLException {
+		return getTime(findColumn(columnLabel), null);
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of
+	 * this ResultSet object as a java.sql.Time object in the Java programming
+	 * language. This method uses the given calendar to construct an appropriate
+	 * millisecond value for the time if the underlying database does not store
+	 * timezone information.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @param cal the java.util.Calendar object to use in constructing the timestamp
+	 * @return the column value as a java.sql.Time object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Time getTime(final String columnLabel, final Calendar cal)
+		throws SQLException
+	{
+		return getTime(findColumn(columnLabel), cal);
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.sql.Timestamp object in the Java programming
+	 * language.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @return the column value as a java.sql.Timestamp object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Timestamp getTimestamp(final int columnIndex) throws SQLException {
+		return getTimestamp(columnIndex, null);
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.sql.Timestamp object in the Java programming
+	 * language. This method uses the given calendar to construct an appropriate
+	 * millisecond value for the timestamp if the underlying database does not
+	 * store timezone information.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @param cal the java.util.Calendar object to use in constructing the timestamp
+	 * @return the column value as a java.sql.Timestamp object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Timestamp getTimestamp(final int columnIndex, Calendar cal)
+		throws SQLException
+	{
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			if (cal == null) {
+				// try to convert the string directly to a Timestamp object
+				// Note: the string must be in JDBC timestamp escape format: yyyy-[m]m-[d]d hh:mm:ss[.f...]
+				try {
+					return Timestamp.valueOf(val);
+				} catch (IllegalArgumentException iae) {
+					// this happens if string doesn't match the format, such as for years < 1000 (including negative years)
+					// in those cases just continue and use slower getJavaDate(cal, columnIndex, Types.TIMESTAMP) method
+				}
+				cal = Calendar.getInstance();
+			}
+			final int nanos = getJavaDate(cal, columnIndex, Types.TIMESTAMP);
+			if (nanos == -1)
+				return null;
+			final Timestamp ts = new Timestamp(cal.getTimeInMillis());
+			ts.setNanos(nanos);
+			return ts;
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.sql.Timestamp object in the Java programming
+	 * language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value as a java.sql.Timestamp object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Timestamp getTimestamp(final String columnLabel) throws SQLException {
+		return getTimestamp(findColumn(columnLabel), null);
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row of this
+	 * ResultSet object as a java.sql.Timestamp object in the Java programming
+	 * language. This method uses the given calendar to construct an appropriate
+	 * millisecond value for the timestamp if the underlying database does not
+	 * store timezone information.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @param cal the java.util.Calendar object to use in constructing the timestamp
+	 * @return the column value as a java.sql.Timestamp object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs
+	 */
+	@Override
+	public Timestamp getTimestamp(final String columnLabel, final Calendar cal)
+		throws SQLException
+	{
+		return getTimestamp(findColumn(columnLabel), cal);
+	}
+	/**
+	 * Retrieves the type of this ResultSet object. The type is determined by
+	 * the Statement object that created the result set.
+	 *
+	 * @return ResultSet.TYPE_FORWARD_ONLY, ResultSet.TYPE_SCROLL_INSENSITIVE,
+	 *         or ResultSet.TYPE_SCROLL_SENSITIVE
+	 */
+	@Override
+	public int getType() {
+		return type;
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a java.net.URL object in the Java
+	 * programming language.
+	 *
+	 * @param columnIndex the index of the column 1 is the first, 2 is the second,...
+	 * @return the column value as a java.net.URL object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs, or if a URL is malformed
+	 */
+	@Override
+	public URL getURL(final int columnIndex) throws SQLException {
+		checkNotClosed();
+		try {
+			final String val = tlp.values[columnIndex - 1];
+			if (val == null) {
+				lastReadWasNull = true;
+				return null;
+			}
+			lastReadWasNull = false;
+			try {
+				return new URL(val);
+			} catch (java.net.MalformedURLException e) {
+				throw new SQLException(e.getMessage(), "M1M05");
+			}
+		} catch (IndexOutOfBoundsException e) {
+			throw newSQLInvalidColumnIndexException(columnIndex);
+		}
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object as a java.net.URL object in the Java
+	 * programming language.
+	 *
+	 * @param columnLabel the SQL name of the column
+	 * @return the column value as a java.net.URL object; if the value is SQL NULL, the value returned is null
+	 * @throws SQLException if a database access error occurs, or if a URL is malformed
+	 */
+	@Override
+	public URL getURL(final String columnLabel) throws SQLException {
+		return getURL(findColumn(columnLabel));
+	}
+	/**
+	 * Retrieves the first warning reported by calls on this ResultSet 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 result set; 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 result set
+	 */
+	@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 the cursor is after the last row in this ResultSet
+	 * object.
+	 *
+	 * @return true if the cursor is after the last row; false if the cursor is
+	 *         at any other position or the result set contains no rows
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public boolean isAfterLast() throws SQLException {
+		checkNotClosed();
+		return curRow == tupleCount + 1;
+	}
+	/**
+	 * Retrieves whether the cursor is before the first row in this ResultSet
+	 * object.
+	 *
+	 * @return true if the cursor is before the first row; false if the cursor
+	 *         is at any other position or the result set contains no rows
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public boolean isBeforeFirst() throws SQLException {
+		checkNotClosed();
+		return curRow == 0;
+	}
+	/**
+	 * Retrieves whether this ResultSet object has been closed. A
+	 * ResultSet is closed if the method close has been called on it, or
+	 * if it is automatically closed.
+	 *
+	 * @return true if this ResultSet object is closed; false if it is still open
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public boolean isClosed() throws SQLException {
+		return header != null && header.isClosed();
+	}
+	/**
+	 * Retrieves whether the cursor is on the first row of this ResultSet
+	 * object.
+	 *
+	 * @return true if the cursor is on the first row; false otherwise
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public boolean isFirst() throws SQLException {
+		checkNotClosed();
+		return curRow == 1;
+	}
+	/**
+	 * Retrieves whether the cursor is on the last row of this ResultSet object.
+	 *
+	 * @return true if the cursor is on the last row; false otherwise
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public boolean isLast() throws SQLException {
+		checkNotClosed();
+		return curRow == tupleCount;
+	}
+	/**
+	 * Moves the cursor to the last row in this ResultSet object.
+	 *
+	 * @return true if the cursor is on a valid row; false if there are no rows
+	 *         in the result set
+	 * @throws SQLException if a database access error occurs or the result set
+	 *         type is TYPE_FORWARD_ONLY
+	 * @throws SQLException if a database access error occurs or this method is called on a closed result set
+	 */
+	@Override
+	public boolean last() throws SQLException {
+		return absolute(-1);
+	}
+	/**
+	 * Moves the cursor down one row from its current position. A ResultSet
+	 * cursor is initially positioned before the first row; the first call to
+	 * the method next makes the first row the current row; the second call
+	 * makes the second row the current row, and so on.
+	 *
+	 * If an input stream is open for the current row, a call to the method
+	 * next will implicitly close it. A ResultSet object's warning chain is
+	 * cleared when a new row is read.
+	 *
+	 * @return true if the new current row is valid; false if there are no
+	 *         more rows
+	 * @throws SQLException if a database access error occurs or ResultSet is
+	 *         closed
+	 */
+	@Override
+	public boolean next() throws SQLException {
+		return relative(1);
+	}
+	/**
+	 * Moves the cursor to the previous row in this ResultSet object.
+	 *
+	 * @return true if the cursor is on a valid row; false if it is off
+	 *         the result set
+	 * @throws SQLException if a database access error occurs or ResultSet is
+	 *         closed or the result set type is TYPE_FORWARD_ONLY
+	 */
+	@Override
+	public boolean previous() throws SQLException {
+		return relative(-1);
+	}
+	/**
+	 * Moves the cursor a relative number of rows, either positive or negative.
+	 * Attempting to move beyond the first/last row in the result set positions
+	 * the cursor before/after the the first/last row. Calling relative(0) is
+	 * valid, but does not change the cursor position.
+	 *
+	 * Note: Calling the method relative(1) is identical to calling the method
+	 * next() and calling the method relative(-1) is identical to calling the
+	 * method previous().
+	 *
+	 * @param rows an int specifying the number of rows to move from the current
+	 *        row; a positive number moves the cursor forward; a negative number
+	 *        moves the cursor backward
+	 * @return true if the cursor is on a row; false otherwise
+	 * @throws SQLException if a database access error occurs, there is no current
+	 *         row, or the result set type is TYPE_FORWARD_ONLY
+	 */
+	@Override
+	public boolean relative(final int rows) throws SQLException {
+		return absolute(curRow + rows);
+	}
+	/**
+	 * Retrieves whether a row has been deleted. A deleted row may leave a visible "hole" in a result set.
+	 * This method can be used to detect holes in a result set.
+	 * The value returned depends on whether or not this ResultSet object can detect deletions.
+	 *
+	 * Note: Support for the rowDeleted method is optional with a result set concurrency of CONCUR_READ_ONLY
+	 *
+	 * Returns: true if the current row is detected to have been deleted by the owner or another; false otherwise
+	 *
+	 * Throws:
+	 *     SQLException - if a database access error occurs or this method is called on a closed result set
+	 * Since: 1.2
+	 * See Also: DatabaseMetaData.deletesAreDetected(int)
+	 */
+	@Override
+	public boolean rowDeleted() throws SQLException {
+		checkNotClosed();
+		return false;
+	}
+	/**
+	 * Retrieves whether the current row has had an insertion.
+	 * The value returned depends on whether or not this ResultSet object can detect visible inserts.
+	 *
+	 * Note: Support for the rowInserted method is optional with a result set concurrency of CONCUR_READ_ONLY
+	 *
+	 * Returns: true if the current row is detected to have been inserted; false otherwise
+	 *
+	 * Throws:
+	 *     SQLException - if a database access error occurs or this method is called on a closed result set
+	 * Since: 1.2
+	 * See Also: DatabaseMetaData.insertsAreDetected(int)
+	 */
+	@Override
+	public boolean rowInserted() throws SQLException {
+		checkNotClosed();
+		return false;
+	}
+	/**
+	 * Retrieves whether the current row has been updated.
+	 * The value returned depends on whether or not the result set can detect updates.
+	 *
+	 * Note: Support for the rowUpdated method is optional with a result set concurrency of CONCUR_READ_ONLY
+	 *
+	 * Returns: true if the current row is detected to have been visibly updated by the owner or another; false otherwise
+	 *
+	 * Throws:
+	 *     SQLException - if a database access error occurs or this method is called on a closed result set
+	 * Since: 1.2
+	 * See Also: DatabaseMetaData.updatesAreDetected(int)
+	 */
+	@Override
+	public boolean rowUpdated() throws SQLException {
+		checkNotClosed();
+		return false;
+	}
+	/* Next methods are all related to updateable result sets, which we do not support.
+	 * @throws SQLFeatureNotSupportedException if the JDBC driver does not support this method
+	 */
+	@Override
+	public void cancelRowUpdates() throws SQLException {
+		throw newSQLFeatureNotSupportedException("cancelRowUpdates");
+	}
+	@Override
+	public void deleteRow() throws SQLException {
+		throw newSQLFeatureNotSupportedException("deleteRow");
+	}
+	@Override
+	public void insertRow() throws SQLException {
+		throw newSQLFeatureNotSupportedException("insertRow");
+	}
+	@Override
+	public void moveToCurrentRow() throws SQLException {
+		throw newSQLFeatureNotSupportedException("moveToCurrentRow");
+	}
+	@Override
+	public void moveToInsertRow() throws SQLException {
+		throw newSQLFeatureNotSupportedException("moveToInsertRow");
+	}
+	@Override
+	public void refreshRow() throws SQLException {
+		throw newSQLFeatureNotSupportedException("refreshRow");
+	}
+	@Override
+	public void updateArray(int columnIndex, Array x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateArray");
+	}
+	@Override
+	public void updateArray(String columnLabel, Array x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateArray");
+	}
+	@Override
+	public void updateAsciiStream(int columnIndex, InputStream x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateAsciiStream");
+	}
+	@Override
+	public void updateAsciiStream(int columnIndex, InputStream x, int length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateAsciiStream");
+	}
+	@Override
+	public void updateAsciiStream(int columnIndex, InputStream x, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateAsciiStream");
+	}
+	@Override
+	public void updateAsciiStream(String columnLabel, InputStream x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateAsciiStream");
+	}
+	@Override
+	public void updateAsciiStream(String columnLabel, InputStream x, int length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateAsciiStream");
+	}
+	@Override
+	public void updateAsciiStream(String columnLabel, InputStream x, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateAsciiStream");
+	}
+	@Override
+	public void updateBigDecimal(int columnIndex, BigDecimal x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBigDecimal");
+	}
+	@Override
+	public void updateBigDecimal(String columnLabel, BigDecimal x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBigDecimal");
+	}
+	@Override
+	public void updateBinaryStream(int columnIndex, InputStream x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBinaryStream");
+	}
+	@Override
+	public void updateBinaryStream(int columnIndex, InputStream x, int length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBinaryStream");
+	}
+	@Override
+	public void updateBinaryStream(int columnIndex, InputStream x, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBinaryStream");
+	}
+	@Override
+	public void updateBinaryStream(String columnLabel, InputStream x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBinaryStream");
+	}
+	@Override
+	public void updateBinaryStream(String columnLabel, InputStream x, int length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBinaryStream");
+	}
+	@Override
+	public void updateBinaryStream(String columnLabel, InputStream x, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBinaryStream");
+	}
+	@Override
+	public void updateBlob(int columnIndex, Blob x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBlob");
+	}
+	@Override
+	public void updateBlob(int columnIndex, InputStream s) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBlob");
+	}
+	@Override
+	public void updateBlob(int columnIndex, InputStream s, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBlob");
+	}
+	@Override
+	public void updateBlob(String columnLabel, Blob x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBlob");
+	}
+	@Override
+	public void updateBlob(String columnLabel, InputStream s) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBlob");
+	}
+	@Override
+	public void updateBlob(String columnLabel, InputStream s, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBlob");
+	}
+	@Override
+	public void updateBoolean(int columnIndex, boolean x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBoolean");
+	}
+	@Override
+	public void updateBoolean(String columnLabel, boolean x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBoolean");
+	}
+	@Override
+	public void updateByte(int columnIndex, byte x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateByte");
+	}
+	@Override
+	public void updateByte(String columnLabel, byte x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateByte");
+	}
+	@Override
+	public void updateBytes(int columnIndex, byte[] x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBytes");
+	}
+	@Override
+	public void updateBytes(String columnLabel, byte[] x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateBytes");
+	}
+	@Override
+	public void updateCharacterStream(int columnIndex, Reader x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateCharacterStream");
+	}
+	@Override
+	public void updateCharacterStream(int columnIndex, Reader x, int length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateCharacterStream");
+	}
+	@Override
+	public void updateCharacterStream(int columnIndex, Reader x, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateCharacterStream");
+	}
+	@Override
+	public void updateCharacterStream(String columnLabel, Reader reader) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateCharacterStream");
+	}
+	@Override
+	public void updateCharacterStream(String columnLabel, Reader reader, int length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateCharacterStream");
+	}
+	@Override
+	public void updateCharacterStream(String columnLabel, Reader reader, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateCharacterStream");
+	}
+	@Override
+	public void updateNCharacterStream(int columnIndex, Reader x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNCharacterStream");
+	}
+	@Override
+	public void updateNCharacterStream(int columnIndex, Reader x, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNCharacterStream");
+	}
+	@Override
+	public void updateNCharacterStream(String columnLabel, Reader reader) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNCharacterStream");
+	}
+	@Override
+	public void updateNCharacterStream(String columnLabel, Reader reader, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNCharacterStream");
+	}
+	@Override
+	public void updateClob(int columnIndex, Clob x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateClob");
+	}
+	@Override
+	public void updateClob(int columnIndex, Reader r) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateClob");
+	}
+	@Override
+	public void updateClob(int columnIndex, Reader r, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateClob");
+	}
+	@Override
+	public void updateClob(String columnLabel, Clob x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateClob");
+	}
+	@Override
+	public void updateClob(String columnLabel, Reader r) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateClob");
+	}
+	@Override
+	public void updateClob(String columnLabel, Reader r, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateClob");
+	}
+	@Override
+	public void updateNClob(int columnIndex, NClob x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNClob");
+	}
+	@Override
+	public void updateNClob(int columnIndex, Reader r) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNClob");
+	}
+	@Override
+	public void updateNClob(int columnIndex, Reader r, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNClob");
+	}
+	@Override
+	public void updateNClob(String columnLabel, NClob x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNClob");
+	}
+	@Override
+	public void updateNClob(String columnLabel, Reader r) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNClob");
+	}
+	@Override
+	public void updateNClob(String columnLabel, Reader r, long length) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNClob");
+	}
+	@Override
+	public void updateDate(int columnIndex, java.sql.Date x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateDate");
+	}
+	@Override
+	public void updateDate(String columnLabel, java.sql.Date x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateDate");
+	}
+	@Override
+	public void updateDouble(int columnIndex, double x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateDouble");
+	}
+	@Override
+	public void updateDouble(String columnLabel, double x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateDouble");
+	}
+	@Override
+	public void updateFloat(int columnIndex, float x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateFloat");
+	}
+	@Override
+	public void updateFloat(String columnLabel, float x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateFloat");
+	}
+	@Override
+	public void updateInt(int columnIndex, int x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateInt");
+	}
+	@Override
+	public void updateInt(String columnLabel, int x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateInt");
+	}
+	@Override
+	public void updateLong(int columnIndex, long x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateLong");
+	}
+	@Override
+	public void updateLong(String columnLabel, long x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateLong");
+	}
+	@Override
+	public void updateNull(int columnIndex) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNull");
+	}
+	@Override
+	public void updateNull(String columnLabel) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNull");
+	}
+	@Override
+	public void updateObject(int columnIndex, Object x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateObject");
+	}
+	@Override
+	public void updateObject(int columnIndex, Object x, int scale) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateObject");
+	}
+	@Override
+	public void updateObject(String columnLabel, Object x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateObject");
+	}
+	@Override
+	public void updateObject(String columnLabel, Object x, int scale) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateObject");
+	}
+	@Override
+	public void updateRef(int columnIndex, Ref x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateRef");
+	}
+	@Override
+	public void updateRef(String columnLabel, Ref x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateRef");
+	}
+	@Override
+	public void updateRow() throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateRow");
+	}
+	@Override
+	public void updateRowId(int columnIndex, RowId x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateRowId");
+	}
+	@Override
+	public void updateRowId(String columnLabel, RowId x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateRowId");
+	}
+	@Override
+	public void updateShort(int columnIndex, short x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateShort");
+	}
+	@Override
+	public void updateShort(String columnLabel, short x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateShort");
+	}
+	@Override
+	public void updateString(int columnIndex, String x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateString");
+	}
+	@Override
+	public void updateString(String columnLabel, String x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateString");
+	}
+	@Override
+	public void updateNString(int columnIndex, String x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNString");
+	}
+	@Override
+	public void updateNString(String columnLabel, String x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateNString");
+	}
+	@Override
+	public void updateSQLXML(int columnIndex, SQLXML x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateSQLXML");
+	}
+	@Override
+	public void updateSQLXML(String columnLabel, SQLXML x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateSQLXML");
+	}
+	@Override
+	public void updateTime(int columnIndex, Time x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateTime");
+	}
+	@Override
+	public void updateTime(String columnLabel, Time x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateTime");
+	}
+	@Override
+	public void updateTimestamp(int columnIndex, Timestamp x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateTimestamp");
+	}
+	@Override
+	public void updateTimestamp(String columnLabel, Timestamp x) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateTimestamp");
+	}
+	// Chapter 14.2.3.3 Sun JDBC 3.0 Specification
+	/**
+	 * Reports whether the last column read had a value of SQL NULL. Note that
+	 * you must first call one of the getter methods on a column to try to read
+	 * its value and then call the method wasNull to see if the value read was
+	 * SQL NULL.
+	 *
+	 * @return true if the last column value read was SQL NULL and false otherwise
+	 */
+	@Override
+	public boolean wasNull() {
+		return lastReadWasNull;
+	}
+	//== Java 1.7 methods (JDBC 4.1)
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object and will convert from the SQL type of
+	 * the column to the requested Java data type, if the conversion is
+	 * supported.  If the conversion is not supported or null is
+	 * specified for the type, a SQLException is thrown.
+	 *
+	 * At a minimum, an implementation must support the conversions defined
+	 * in Appendix B, Table B-3 and conversion of appropriate user defined
+	 * SQL types to a Java type which implements SQLData, or Struct.
+	 * Additional conversions may be supported and are vendor defined.
+	 *
+	 * @param columnIndex the first column is 1, the second is 2, ...
+	 * @param type Class representing the Java data type to convert the
+	 *        designated column to
+	 * @return an instance of type holding the column value
+	 * @throws SQLException if conversion is not supported, type is
+	 *         null or another error occurs. The getCause() method of
+	 *         the exception may provide a more detailed exception, for
+	 *         example, if a conversion error occurs
+	 * @throws SQLFeatureNotSupportedException the JDBC driver does
+	 *         not support this method
+	 */
+	@Override
+	public <T> T getObject(final int columnIndex, final Class<T> type) throws SQLException {
+		checkNotClosed();
+		if (type == null)
+			throw new SQLException("type is null", "M1M05");
+		throw newSQLFeatureNotSupportedException("getObject(column, Class<T> type)");
+	}
+	/**
+	 * Retrieves the value of the designated column in the current row
+	 * of this ResultSet object and will convert from the SQL type of
+	 * the column to the requested Java data type, if the conversion is
+	 * supported.  If the conversion is not supported or null is
+	 * specified for the type, a SQLException is thrown.
+	 *
+	 * @param columnLabel the label for the column specified with the
+	 *        SQL AS clause. If the SQL AS clause was not specified,
+	 *        then the label is the name of the column
+	 * @param type Class representing the Java data type to convert the
+	 *        designated column to
+	 * @return an instance of type holding the column value
+	 * @throws SQLException if conversion is not supported, type is
+	 *         null or another error occurs. The getCause() method of
+	 *         the exception may provide a more detailed exception, for
+	 *         example, if a conversion error occurs
+	 * @throws SQLFeatureNotSupportedException the JDBC driver does
+	 *         not support this method
+	 */
+	@Override
+	public <T> T getObject(final String columnLabel, final Class<T> type) throws SQLException {
+		return getObject(findColumn(columnLabel), type);
+	}
+	//== Java 1.8 methods (JDBC 4.2)
+	@Override
+	public void updateObject(int columnIndex, Object x, SQLType targetSqlType, int scaleOrLength) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateObject");
+	}
+	@Override
+	public void updateObject(String columnLabel, Object x, SQLType targetSqlType, int scaleOrLength) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateObject");
+	}
+	@Override
+	public void updateObject(int columnIndex, Object x, SQLType targetSqlType) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateObject");
+	}
+	@Override
+	public void updateObject(String columnLabel, Object x, SQLType targetSqlType) throws SQLException {
+		throw newSQLFeatureNotSupportedException("updateObject");
+	}
+	//== end methods of interface ResultSet
+	//== internal helper methods which do not belong to the JDBC interface
+	/**
+	 * Adds a warning to the pile of warnings this ResultSet 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
+	 */
+	private void addWarning(final String reason, final String sqlstate) {
+		SQLWarning warng = new SQLWarning(reason, sqlstate);
+		if (warnings == null) {
+			warnings = warng;
+		} else {
+			warnings.setNextWarning(warng);
+		}
+	}
+	/**
+	 * Local helper method to test whether the ResultSet object is closed
+	 * When closed it throws an SQLException
+	 */
+	private void checkNotClosed() throws SQLException {
+		if (isClosed())
+			throw new SQLException("ResultSet is closed", "M1M20");
+	}
+	/**
+	 * Small helper method that formats the "Invalid Column Index number ..." message
+	 * and creates a new SQLDataException object whose SQLState is set
+	 * to "22010": invalid indicator parameter value.
+	 *
+	 * @param colIdx the column index number
+	 * @return a new created SQLDataException object with SQLState 22010
+	 */
+	public static final SQLDataException newSQLInvalidColumnIndexException(final int colIdx) {
+		return new SQLDataException("Invalid Column Index number: " + colIdx, "22010");
+	}
+	/**
+	 * Small helper method that formats the "Could not convert value to a number" message
+	 * and creates a new SQLDataException object whose SQLState is set
+	 * to "22003": Numeric value out of range.
+	 *
+	 * @param error the NumberFormatException
+	 * @return a new created SQLDataException object with SQLState 22003
+	 */
+	private static final SQLDataException newSQLNumberFormatException(final NumberFormatException error) {
+		return new SQLDataException("Could not convert value to a number. " + error.getMessage(), "22003");
+	}
+}

Mercurial > hg > monetdb-java

comparison src/main/java/org/monetdb/jdbc/MonetResultSet.java @ 391:f523727db392