package com.planet_ink.fakedb; import java.io.InputStream; import java.io.Reader; import java.sql.NClob; import java.sql.RowId; import java.sql.SQLException; import java.sql.SQLFeatureNotSupportedException; import java.sql.SQLXML; import java.util.ArrayList; import java.util.Hashtable; import java.util.List; import java.util.Map; import java.util.Vector; import com.planet_ink.fakedb.Backend.*; /* Copyright 2001 Thomas Neumann Copyright 2004-2019 Bo Zimmerman Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ public class ResultSet implements java.sql.ResultSet { private final Statement statement; private final Backend.FakeTable fakeTable; private java.util.Iterator<Backend.RecordInfo> iter; private int currentRow = 0; private final List<FakeCondition> conditions; private final ComparableValue[] values; private final int[] showCols; private final int[] orderByKeyDexCols; private final String[] orderByConditions; private final Map<String, Integer> showColMap = new Hashtable<String, Integer>(); private boolean wasNullFlag = false; private Object countValue = null; private boolean closeStatementOnClose; private static final List<RecordInfo> fakeList = new Vector<RecordInfo>(1); static { final RecordInfo info = new RecordInfo(0, 0); info.indexedData = new ComparableValue[0]; fakeList.add(info); } ResultSet(final Statement stmt, final Backend.FakeTable table, final int[] showCols, final List<FakeCondition> conditions, final int[] orderByKeyDexCols, final String[] orderByConditions) { this.statement = stmt; this.fakeTable = table; this.conditions = conditions; currentRow = 0; this.values = new ComparableValue[table.numColumns()]; this.showCols = showCols; this.orderByKeyDexCols = orderByKeyDexCols; this.orderByConditions = orderByConditions; this.iter = table.indexIterator(this.orderByKeyDexCols, this.orderByConditions); try { this.closeStatementOnClose = stmt.isCloseOnCompletion(); } catch (final SQLException e) { this.closeStatementOnClose = false; } for (int s = 0; s < showCols.length; s++) { if (showCols[s] == FakeColumn.INDEX_COUNT) { showColMap.put("COUNT", Integer.valueOf(FakeColumn.INDEX_COUNT)); int ct = 0; while (iter.hasNext()) { iter.next(); ct++; } countValue = Integer.valueOf(ct); iter = fakeList.iterator(); } else showColMap.put(table.getColumnName(showCols[s]), Integer.valueOf(s)); } } @Override public java.sql.Statement getStatement() throws java.sql.SQLException { return statement; } @Override public boolean next() throws java.sql.SQLException { while (true) { if (!iter.hasNext()) return false; final Backend.RecordInfo rowInfo = iter.next(); if (countValue != null) { currentRow++; return true; } if (conditions.size() > 0) { final boolean[] dataLoaded = new boolean[1]; dataLoaded[0] = false; if (!fakeTable.recordCompare(rowInfo, conditions, dataLoaded, values)) continue; currentRow++; if (!dataLoaded[0]) dataLoaded[0] = fakeTable.getRecord(values, rowInfo); if (!dataLoaded[0]) return false; return true; } currentRow++; return fakeTable.getRecord(values, rowInfo); } } @Override public void close() throws java.sql.SQLException { if ((this.statement != null) && (closeStatementOnClose)) this.statement.close(); } @Override public boolean wasNull() throws java.sql.SQLException { return wasNullFlag; } private Object getProperValue(int columnIndex) { wasNullFlag = false; if ((columnIndex < 1) || (columnIndex > showCols.length)) { wasNullFlag = true; return null; } columnIndex = showCols[columnIndex - 1]; if (columnIndex == FakeColumn.INDEX_COUNT) return this.countValue; final Object v = values[columnIndex].getValue(); if (v == null) { wasNullFlag = true; return null; } return v; } @Override public String getString(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return null; return o.toString(); } @Override public java.sql.Array getArray(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return null; throw new java.sql.SQLException(); } @Override public java.sql.Blob getBlob(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return null; throw new java.sql.SQLException(); } @Override public java.sql.Clob getClob(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return null; throw new java.sql.SQLException(); } @Override public java.sql.Ref getRef(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return null; throw new java.sql.SQLException(); } @Override public boolean getBoolean(final int columnIndex) throws java.sql.SQLException { final String s = getString(columnIndex); if ((s != null) && (s.length() > 0)) { switch (Character.toUpperCase(s.charAt(0))) { case 'T': case 'Y': case '1': return true; } } return false; } @Override public byte getByte(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return 0; if (o instanceof Integer) return ((Integer) o).byteValue(); if (o instanceof Long) return ((Long) o).byteValue(); try { return Byte.parseByte(o.toString()); } catch (final NumberFormatException e) { throw new java.sql.SQLException(e.getMessage()); } } @Override public short getShort(final int columnIndex) throws java.sql.SQLException { return (short) getLong(columnIndex); } @Override public int getInt(final int columnIndex) throws java.sql.SQLException { return (int) getLong(columnIndex); } @Override public long getLong(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return 0; if (o instanceof Integer) return ((Integer) o).longValue(); if (o instanceof Long) return ((Long) o).longValue(); try { return Long.parseLong(o.toString()); } catch (final NumberFormatException e) { throw new java.sql.SQLException(e.getMessage()); } } @Override public float getFloat(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return 0; if (o instanceof Integer) return ((Integer) o).floatValue(); if (o instanceof Long) return ((Long) o).floatValue(); try { return Float.parseFloat(o.toString()); } catch (final NumberFormatException e) { throw new java.sql.SQLException(e.getMessage()); } } @Override public double getDouble(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return 0; if (o instanceof Integer) return ((Integer) o).doubleValue(); if (o instanceof Long) return ((Long) o).doubleValue(); try { return Double.parseDouble(o.toString()); } catch (final NumberFormatException e) { throw new java.sql.SQLException(e.getMessage()); } } @Override public java.math.BigDecimal getBigDecimal(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return new java.math.BigDecimal(0); try { return new java.math.BigDecimal(o.toString()); } catch (final NumberFormatException e) { throw new java.sql.SQLException(e.getMessage()); } } /** * @deprecated */ @Deprecated @Override public java.math.BigDecimal getBigDecimal(final int columnIndex, final int scale) throws java.sql.SQLException { final java.math.BigDecimal decimal = getBigDecimal(columnIndex); decimal.setScale(scale); return decimal; } @Override public byte[] getBytes(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return null; try { return o.toString().getBytes(); } catch (final NumberFormatException e) { throw new java.sql.SQLException(e.getMessage()); } } @Override public java.sql.Date getDate(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return null; if (o instanceof Integer) return new java.sql.Date(((Integer) o).longValue()); if (o instanceof Long) return new java.sql.Date(((Long) o).longValue()); try { return java.sql.Date.valueOf(o.toString()); } catch (final NumberFormatException e) { throw new java.sql.SQLException(e.getMessage()); } } @Override public java.sql.Time getTime(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return null; if (o instanceof Integer) return new java.sql.Time(((Integer) o).longValue()); if (o instanceof Long) return new java.sql.Time(((Long) o).longValue()); try { return java.sql.Time.valueOf(o.toString()); } catch (final NumberFormatException e) { throw new java.sql.SQLException(e.getMessage()); } } @Override public java.sql.Timestamp getTimestamp(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); if (o == null) return null; if (o instanceof Integer) return new java.sql.Timestamp(((Integer) o).longValue()); if (o instanceof Long) return new java.sql.Timestamp(((Long) o).longValue()); try { return java.sql.Timestamp.valueOf(o.toString()); } catch (final NumberFormatException e) { throw new java.sql.SQLException(e.getMessage()); } } @Override public java.io.InputStream getAsciiStream(final int columnIndex) throws java.sql.SQLException { return getBinaryStream(columnIndex); } /** * @deprecated */ @Deprecated @Override public java.io.InputStream getUnicodeStream(final int columnIndex) throws java.sql.SQLException { return getBinaryStream(columnIndex); } @Override public java.io.InputStream getBinaryStream(final int columnIndex) throws java.sql.SQLException { final byte b[] = getBytes(columnIndex); if (b == null) return null; return new java.io.ByteArrayInputStream(b); } @Override public java.io.Reader getCharacterStream(final int columnIndex) throws java.sql.SQLException { final String s = getString(columnIndex); if (s == null) return null; return new java.io.CharArrayReader(s.toCharArray()); } @Override public Object getObject(final int columnIndex) throws java.sql.SQLException { final Object o = getProperValue(columnIndex); return o; } @Override public java.net.URL getURL(final int columnIndex) throws java.sql.SQLException { final String s = getString(columnIndex); if (s == null) return null; try { return new java.net.URL(s); } catch (final java.net.MalformedURLException e) { throw new java.sql.SQLException(e.getMessage()); } } @Override public int findColumn(final String columnName) throws java.sql.SQLException { if (!showColMap.containsKey(columnName)) return -1; return showColMap.get(columnName).intValue() + 1; } @Override public String getString(final String columnName) throws java.sql.SQLException { return getString(findColumn(columnName)); } @Override public java.sql.Array getArray(final String columnName) throws java.sql.SQLException { return getArray(findColumn(columnName)); } @Override public java.sql.Blob getBlob(final String columnName) throws java.sql.SQLException { return getBlob(findColumn(columnName)); } @Override public java.sql.Clob getClob(final String columnName) throws java.sql.SQLException { return getClob(findColumn(columnName)); } @Override public java.sql.Ref getRef(final String columnName) throws java.sql.SQLException { return getRef(findColumn(columnName)); } @Override public boolean getBoolean(final String columnName) throws java.sql.SQLException { return getBoolean(findColumn(columnName)); } @Override public byte getByte(final String columnName) throws java.sql.SQLException { return getByte(findColumn(columnName)); } @Override public short getShort(final String columnName) throws java.sql.SQLException { return getShort(findColumn(columnName)); } @Override public int getInt(final String columnName) throws java.sql.SQLException { return getInt(findColumn(columnName)); } @Override public long getLong(final String columnName) throws java.sql.SQLException { return getLong(findColumn(columnName)); } @Override public float getFloat(final String columnName) throws java.sql.SQLException { return getFloat(findColumn(columnName)); } @Override public double getDouble(final String columnName) throws java.sql.SQLException { return getDouble(findColumn(columnName)); } @Override public java.math.BigDecimal getBigDecimal(final String columnName) throws java.sql.SQLException { return getBigDecimal(findColumn(columnName)); } /** * @deprecated */ @Deprecated @Override public java.math.BigDecimal getBigDecimal(final String columnName, final int scale) throws java.sql.SQLException { return getBigDecimal(findColumn(columnName), scale); } @Override public byte[] getBytes(final String columnName) throws java.sql.SQLException { return getBytes(findColumn(columnName)); } @Override public java.sql.Date getDate(final String columnName) throws java.sql.SQLException { return getDate(findColumn(columnName)); } @Override public java.sql.Date getDate(final int columnName, final java.util.Calendar c) throws java.sql.SQLException { return getDate(columnName); } @Override public java.sql.Date getDate(final String columnName, final java.util.Calendar c) throws java.sql.SQLException { return getDate(findColumn(columnName)); } @Override public java.sql.Time getTime(final String columnName) throws java.sql.SQLException { return getTime(findColumn(columnName)); } @Override public java.sql.Time getTime(final int columnName, final java.util.Calendar c) throws java.sql.SQLException { return getTime(columnName); } @Override public java.sql.Time getTime(final String columnName, final java.util.Calendar c) throws java.sql.SQLException { return getTime(findColumn(columnName)); } @Override public java.sql.Timestamp getTimestamp(final String columnName) throws java.sql.SQLException { return getTimestamp(findColumn(columnName)); } @Override public java.sql.Timestamp getTimestamp(final int columnName, final java.util.Calendar c) throws java.sql.SQLException { return getTimestamp(columnName); } @Override public java.sql.Timestamp getTimestamp(final String columnName, final java.util.Calendar c) throws java.sql.SQLException { return getTimestamp(findColumn(columnName)); } @Override public java.io.Reader getCharacterStream(final String columnName) throws java.sql.SQLException { return getCharacterStream(findColumn(columnName)); } @Override public java.io.InputStream getAsciiStream(final String columnName) throws java.sql.SQLException { return getAsciiStream(findColumn(columnName)); } /** * @deprecated */ @Deprecated @Override public java.io.InputStream getUnicodeStream(final String columnName) throws java.sql.SQLException { return getUnicodeStream(findColumn(columnName)); } @Override public java.io.InputStream getBinaryStream(final String columnName) throws java.sql.SQLException { return getBinaryStream(findColumn(columnName)); } @Override public java.net.URL getURL(final String columnName) throws java.sql.SQLException { return getURL(findColumn(columnName)); } @Override public Object getObject(final String columnName) throws java.sql.SQLException { return getObject(findColumn(columnName)); } @Override public java.sql.SQLWarning getWarnings() throws java.sql.SQLException { return null; } @Override public void clearWarnings() throws java.sql.SQLException { } @Override public String getCursorName() throws java.sql.SQLException { throw new java.sql.SQLException("Positioned Update not supported.", "S1C00"); } @Override public java.sql.ResultSetMetaData getMetaData() throws java.sql.SQLException { return new java.sql.ResultSetMetaData() { @Override public <T> T unwrap(final Class<T> iface) throws SQLException { return null; } @Override public boolean isWrapperFor(final Class<?> iface) throws SQLException { return false; } @Override public int getColumnCount() throws SQLException { return showCols.length; } @Override public boolean isAutoIncrement(final int column) throws SQLException { return false; } @Override public boolean isCaseSensitive(final int column) throws SQLException { return true; } @Override public boolean isSearchable(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return false; return true; } @Override public boolean isCurrency(final int column) throws SQLException { return false; } @Override public int isNullable(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return columnNoNulls; return fakeTable.getColumnInfo(showCols[column - 1]).canNull ? columnNullable : columnNoNulls; } @Override public boolean isSigned(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return false; switch (fakeTable.getColumnInfo(showCols[column - 1]).type) { case FakeColumn.TYPE_INTEGER: return true; case FakeColumn.TYPE_LONG: return true; case FakeColumn.TYPE_STRING: return false; case FakeColumn.TYPE_UNKNOWN: return false; } return false; } @Override public int getColumnDisplaySize(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return 6; switch (fakeTable.getColumnInfo(showCols[column - 1]).type) { case FakeColumn.TYPE_INTEGER: return 9; case FakeColumn.TYPE_LONG: return 19; case FakeColumn.TYPE_STRING: return 40; case FakeColumn.TYPE_UNKNOWN: return 10; } return 10; } @Override public String getColumnLabel(final int column) throws SQLException { return getColumnName(column); } @Override public String getColumnName(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return "COUNT"; return fakeTable.getColumnName(showCols[column - 1]); } @Override public String getSchemaName(final int column) throws SQLException { return statement.getFakeConnection().getSchema(); } @Override public int getPrecision(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return 9; switch (fakeTable.getColumnInfo(showCols[column - 1]).type) { case FakeColumn.TYPE_INTEGER: return 9; case FakeColumn.TYPE_LONG: return 19; case FakeColumn.TYPE_STRING: return Integer.MAX_VALUE; case FakeColumn.TYPE_UNKNOWN: return 0; } return 0; } @Override public int getScale(final int column) throws SQLException { return 0; } @Override public String getTableName(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return "FAKEDB"; return fakeTable.getColumnInfo(showCols[column - 1]).tableName; } @Override public String getCatalogName(final int column) throws SQLException { return statement.getConnection().getCatalog(); } @Override public int getColumnType(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return java.sql.Types.INTEGER; switch (fakeTable.getColumnInfo(showCols[column - 1]).type) { case FakeColumn.TYPE_INTEGER: return java.sql.Types.INTEGER; case FakeColumn.TYPE_LONG: return java.sql.Types.BIGINT; case FakeColumn.TYPE_STRING: return java.sql.Types.VARCHAR; case FakeColumn.TYPE_UNKNOWN: return java.sql.Types.JAVA_OBJECT; } return java.sql.Types.JAVA_OBJECT; } @Override public String getColumnTypeName(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return "integer"; switch (fakeTable.getColumnInfo(showCols[column - 1]).type) { case FakeColumn.TYPE_INTEGER: return "integer"; case FakeColumn.TYPE_LONG: return "long"; case FakeColumn.TYPE_STRING: return "string"; case FakeColumn.TYPE_UNKNOWN: return "unknown"; } return "unknown"; } @Override public boolean isReadOnly(final int column) throws SQLException { return false; } @Override public boolean isWritable(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return false; return true; } @Override public boolean isDefinitelyWritable(final int column) throws SQLException { return isWritable(column); } @Override public String getColumnClassName(final int column) throws SQLException { if ((column < 1) || (column >= showCols.length)) throw new SQLException("Value out of range."); if (showCols[column - 1] == FakeColumn.INDEX_COUNT) return Integer.class.getName(); switch (fakeTable.getColumnInfo(showCols[column - 1]).type) { case FakeColumn.TYPE_INTEGER: return Integer.class.getName(); case FakeColumn.TYPE_LONG: return Long.class.getName(); case FakeColumn.TYPE_STRING: return String.class.getName(); case FakeColumn.TYPE_UNKNOWN: return String.class.getName(); } return String.class.getName(); } }; } @Override public void updateArray(final int columnIndex, final java.sql.Array x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateArray(final String columnName, final java.sql.Array x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateAsciiStream(final int columnIndex, final java.io.InputStream x, final int length) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateAsciiStream(final String columnName, final java.io.InputStream x, final int length) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateBigDecimal(final int columnIndex, final java.math.BigDecimal x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateBigDecimal(final String columnName, final java.math.BigDecimal x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateBinaryStream(final int columnIndex, final java.io.InputStream x, final int length) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateBinaryStream(final String columnName, final java.io.InputStream x, final int length) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateBlob(final int columnIndex, final java.sql.Blob x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateBlob(final String columnName, final java.sql.Blob x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateBoolean(final int columnIndex, final boolean x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateBoolean(final String columnName, final boolean x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateByte(final int columnIndex, final byte x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateByte(final String columnName, final byte x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateBytes(final int columnIndex, final byte[] x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateBytes(final String columnName, final byte[] x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateCharacterStream(final int columnIndex, final java.io.Reader x, final int length) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateCharacterStream(final String columnName, final java.io.Reader reader, final int length) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateClob(final int columnIndex, final java.sql.Clob x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateClob(final String columnName, final java.sql.Clob x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateDate(final int columnIndex, final java.sql.Date x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateDate(final String columnName, final java.sql.Date x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateDouble(final int columnIndex, final double x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateDouble(final String columnName, final double x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateFloat(final int columnIndex, final float x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateFloat(final String columnName, final float x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateInt(final int columnIndex, final int x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateInt(final String columnName, final int x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateLong(final int columnIndex, final long x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateLong(final String columnName, final long x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateNull(final int columnIndex) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateNull(final String columnName) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateObject(final int columnIndex, final Object x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateObject(final int columnIndex, final Object x, final int scale) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateObject(final String columnName, final Object x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateObject(final String columnName, final Object x, final int scale) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateRef(final int columnIndex, final java.sql.Ref x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateRef(final String columnName, final java.sql.Ref x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateRow() throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateShort(final int columnIndex, final short x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateShort(final String columnName, final short x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateString(final int columnIndex, final String x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateString(final String columnName, final String x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateTime(final int columnIndex, final java.sql.Time x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateTime(final String columnName, final java.sql.Time x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateTimestamp(final int columnIndex, final java.sql.Timestamp x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void updateTimestamp(final String columnName, final java.sql.Timestamp x) throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void deleteRow() throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void moveToInsertRow() throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void moveToCurrentRow() throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void cancelRowUpdates() throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void insertRow() throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public void refreshRow() throws java.sql.SQLException { throw new java.sql.SQLException(); } @Override public int getRow() { return currentRow; } @Override public boolean first() { return false; } @Override public boolean previous() { return false; } @Override public boolean isFirst() { return false; } private boolean afterLast = false; @Override public boolean last() { try { while (next()) { } } catch (final java.sql.SQLException sqle) { sqle.printStackTrace(); } afterLast = true; return true; } @Override public boolean isLast() { return false; } @Override public void beforeFirst() throws java.sql.SQLException { if (fakeTable == null) throw new java.sql.SQLException(); iter = fakeTable.indexIterator(this.orderByKeyDexCols, this.orderByConditions); currentRow = 0; } @Override public boolean isBeforeFirst() { return (currentRow == 0); } @Override public void afterLast() { last(); } @Override public boolean isAfterLast() { return afterLast; } @Override public boolean absolute(final int i) { return true; } @Override public boolean relative(final int i) { return false; } @Override public boolean rowDeleted() { return false; } @Override public boolean rowInserted() { return false; } @Override public boolean rowUpdated() { return false; } @Override public int getConcurrency() { return 0; } @Override public int getType() { return 0; } @Override public void setFetchSize(final int i) throws java.sql.SQLException { statement.setFetchSize(i); } @Override public int getFetchSize() throws java.sql.SQLException { return statement.getFetchSize(); } @Override public void setFetchDirection(final int i) throws java.sql.SQLException { statement.setFetchDirection(i); } @Override public int getFetchDirection() throws java.sql.SQLException { return statement.getFetchDirection(); } public int getResultSetConcurrency() throws java.sql.SQLException { return statement.getResultSetConcurrency(); } public int getResultSetType() throws java.sql.SQLException { return statement.getResultSetType(); } @Override public int getHoldability() throws SQLException { return 0; } @Override public Reader getNCharacterStream(final int arg0) throws SQLException { return null; } @Override public Reader getNCharacterStream(final String arg0) throws SQLException { return null; } @Override public NClob getNClob(final int arg0) throws SQLException { return null; } @Override public NClob getNClob(final String arg0) throws SQLException { return null; } @Override public String getNString(final int arg0) throws SQLException { return null; } @Override public String getNString(final String arg0) throws SQLException { return null; } // public Object getObject(int arg0, Map arg1) throws SQLException { return // getString(arg0); } @Override public Object getObject(final int arg0, final Map<String, Class<?>> arg1) throws SQLException { return getString(arg0); } @Override public Object getObject(final String arg0, final Map<String, Class<?>> arg1) throws SQLException { return getObject(findColumn(arg0), arg1); } // public Object getObject(String arg0, Map arg1) throws SQLException { // return getObject(findColumn(arg0),arg1); } @Override public RowId getRowId(final int arg0) throws SQLException { return null; } @Override public RowId getRowId(final String arg0) throws SQLException { return null; } @Override public SQLXML getSQLXML(final int arg0) throws SQLException { return null; } @Override public SQLXML getSQLXML(final String arg0) throws SQLException { return null; } @SuppressWarnings("unchecked") public <T> T getObject(final int columnIndex, final Class<T> type) throws SQLException { if (type == Long.class) return (T) Long.valueOf(this.getLong(columnIndex)); if (type == Integer.class) return (T) Long.valueOf(this.getInt(columnIndex)); if (type == Short.class) return (T) Short.valueOf(this.getShort(columnIndex)); if (type == String.class) return (T) String.valueOf(this.getString(columnIndex)); if (type == Short.class) return (T) Short.valueOf(this.getShort(columnIndex)); if (type == Double.class) return (T) Double.valueOf(this.getDouble(columnIndex)); if (type == Float.class) return (T) Float.valueOf(this.getFloat(columnIndex)); if (type == Byte.class) return (T) Byte.valueOf(this.getByte(columnIndex)); if (type == Boolean.class) return (T) Boolean.valueOf(this.getBoolean(columnIndex)); if (type == java.sql.Array.class) return (T) this.getArray(columnIndex); if (type == java.sql.Blob.class) return (T) this.getBlob(columnIndex); if (type == java.sql.Clob.class) return (T) this.getClob(columnIndex); if (type == java.math.BigDecimal.class) return (T) this.getBigDecimal(columnIndex); if (type == byte[].class) return (T) this.getBytes(columnIndex); if (type == java.sql.Date.class) return (T) this.getDate(columnIndex); if (type == java.sql.Time.class) return (T) this.getTime(columnIndex); if (type == java.sql.Timestamp.class) return (T) this.getTimestamp(columnIndex); if (type == Object.class) return (T) this.getObject(columnIndex); throw new SQLFeatureNotSupportedException(); } public <T> T getObject(final String columnLabel, final Class<T> type) throws SQLException { return getObject(findColumn(columnLabel), type); } @Override public boolean isClosed() throws SQLException { return false; } @Override public void updateAsciiStream(final int arg0, final InputStream arg1) throws SQLException { } @Override public void updateAsciiStream(final String arg0, final InputStream arg1) throws SQLException { } @Override public void updateAsciiStream(final int arg0, final InputStream arg1, final long arg2) throws SQLException { } @Override public void updateAsciiStream(final String arg0, final InputStream arg1, final long arg2) throws SQLException { } @Override public void updateBinaryStream(final int arg0, final InputStream arg1) throws SQLException { } @Override public void updateBinaryStream(final String arg0, final InputStream arg1) throws SQLException { } @Override public void updateBinaryStream(final int arg0, final InputStream arg1, final long arg2) throws SQLException { } @Override public void updateBinaryStream(final String arg0, final InputStream arg1, final long arg2) throws SQLException { } @Override public void updateBlob(final int arg0, final InputStream arg1) throws SQLException { } @Override public void updateBlob(final String arg0, final InputStream arg1) throws SQLException { } @Override public void updateBlob(final int arg0, final InputStream arg1, final long arg2) throws SQLException { } @Override public void updateBlob(final String arg0, final InputStream arg1, final long arg2) throws SQLException { } @Override public void updateCharacterStream(final int arg0, final Reader arg1) throws SQLException { } @Override public void updateCharacterStream(final String arg0, final Reader arg1) throws SQLException { } @Override public void updateCharacterStream(final int arg0, final Reader arg1, final long arg2) throws SQLException { } @Override public void updateCharacterStream(final String arg0, final Reader arg1, final long arg2) throws SQLException { } @Override public void updateClob(final int arg0, final Reader arg1) throws SQLException { } @Override public void updateClob(final String arg0, final Reader arg1) throws SQLException { } @Override public void updateClob(final int arg0, final Reader arg1, final long arg2) throws SQLException { } @Override public void updateClob(final String arg0, final Reader arg1, final long arg2) throws SQLException { } @Override public void updateNCharacterStream(final int arg0, final Reader arg1) throws SQLException { } @Override public void updateNCharacterStream(final String arg0, final Reader arg1) throws SQLException { } @Override public void updateNCharacterStream(final int arg0, final Reader arg1, final long arg2) throws SQLException { } @Override public void updateNCharacterStream(final String arg0, final Reader arg1, final long arg2) throws SQLException { } @Override public void updateNClob(final int arg0, final NClob arg1) throws SQLException { } @Override public void updateNClob(final String arg0, final NClob arg1) throws SQLException { } @Override public void updateNClob(final int arg0, final Reader arg1) throws SQLException { } @Override public void updateNClob(final String arg0, final Reader arg1) throws SQLException { } @Override public void updateNClob(final int arg0, final Reader arg1, final long arg2) throws SQLException { } @Override public void updateNClob(final String arg0, final Reader arg1, final long arg2) throws SQLException { } @Override public void updateNString(final int arg0, final String arg1) throws SQLException { } @Override public void updateNString(final String arg0, final String arg1) throws SQLException { } @Override public void updateRowId(final int arg0, final RowId arg1) throws SQLException { } @Override public void updateRowId(final String arg0, final RowId arg1) throws SQLException { } @Override public void updateSQLXML(final int arg0, final SQLXML arg1) throws SQLException { } @Override public void updateSQLXML(final String arg0, final SQLXML arg1) throws SQLException { } @Override public boolean isWrapperFor(final Class<?> iface) throws SQLException { return false; } @Override public <T> T unwrap(final Class<T> iface) throws SQLException { return null; } }