ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [12/58] [abbrv] incubator-ignite git commit: sprint-1 - JDBC renaming and reshuffling.
Date Fri, 06 Feb 2015 20:47:34 GMT
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/17d816fe/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcPreparedStatement.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcPreparedStatement.java b/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcPreparedStatement.java
deleted file mode 100644
index 36cdb3e..0000000
--- a/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcPreparedStatement.java
+++ /dev/null
@@ -1,411 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-
-package org.apache.ignite.jdbc;
-
-import java.io.*;
-import java.math.*;
-import java.net.*;
-import java.sql.*;
-import java.sql.Date;
-import java.util.*;
-
-/**
- * JDBC prepared statement implementation.
- */
-class IgniteJdbcPreparedStatement extends IgniteJdbcStatement implements PreparedStatement {
-    /** SQL query. */
-    private final String sql;
-
-    /** Arguments count. */
-    private final int argsCnt;
-
-    /**
-     * Creates new prepared statement.
-     *
-     * @param conn Connection.
-     * @param sql SQL query.
-     */
-    IgniteJdbcPreparedStatement(IgniteJdbcConnection conn, String sql) {
-        super(conn);
-
-        this.sql = sql;
-
-        argsCnt = sql.replaceAll("[^?]", "").length();
-    }
-
-    /** {@inheritDoc} */
-    @Override public ResultSet executeQuery() throws SQLException {
-        ResultSet rs = executeQuery(sql);
-
-        args = null;
-
-        return rs;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int executeUpdate() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setNull(int paramIdx, int sqlType) throws SQLException {
-        setArgument(paramIdx, null);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setBoolean(int paramIdx, boolean x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setByte(int paramIdx, byte x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setShort(int paramIdx, short x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setInt(int paramIdx, int x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setLong(int paramIdx, long x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setFloat(int paramIdx, float x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setDouble(int paramIdx, double x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setBigDecimal(int paramIdx, BigDecimal x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setString(int paramIdx, String x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setBytes(int paramIdx, byte[] x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setDate(int paramIdx, Date x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setTime(int paramIdx, Time x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setTimestamp(int paramIdx, Timestamp x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setAsciiStream(int paramIdx, InputStream x, int length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setUnicodeStream(int paramIdx, InputStream x, int length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setBinaryStream(int paramIdx, InputStream x, int length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void clearParameters() throws SQLException {
-        ensureNotClosed();
-
-        args = null;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setObject(int paramIdx, Object x, int targetSqlType) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setObject(int paramIdx, Object x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean execute() throws SQLException {
-        return execute(sql);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void addBatch() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setCharacterStream(int paramIdx, Reader x, int length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setRef(int paramIdx, Ref x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setBlob(int paramIdx, Blob x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setClob(int paramIdx, Clob x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setArray(int paramIdx, Array x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public ResultSetMetaData getMetaData() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Meta data for prepared statement is not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setDate(int paramIdx, Date x, Calendar cal) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setTime(int paramIdx, Time x, Calendar cal) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setTimestamp(int paramIdx, Timestamp x, Calendar cal) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setNull(int paramIdx, int sqlType, String typeName) throws SQLException {
-        setNull(paramIdx, sqlType);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setURL(int paramIdx, URL x) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public ParameterMetaData getParameterMetaData() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Meta data for prepared statement is not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setRowId(int paramIdx, RowId x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setNString(int paramIdx, String val) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setNCharacterStream(int paramIdx, Reader val, long length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setNClob(int paramIdx, NClob val) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setClob(int paramIdx, Reader reader, long length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setBlob(int paramIdx, InputStream inputStream, long length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setNClob(int paramIdx, Reader reader, long length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setSQLXML(int paramIdx, SQLXML xmlObj) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setObject(int paramIdx, Object x, int targetSqlType,
-        int scaleOrLength) throws SQLException {
-        setArgument(paramIdx, x);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setAsciiStream(int paramIdx, InputStream x, long length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setBinaryStream(int paramIdx, InputStream x, long length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setCharacterStream(int paramIdx, Reader x, long length) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setAsciiStream(int paramIdx, InputStream x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setBinaryStream(int paramIdx, InputStream x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setCharacterStream(int paramIdx, Reader x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setNCharacterStream(int paramIdx, Reader val) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setClob(int paramIdx, Reader reader) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setBlob(int paramIdx, InputStream inputStream) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setNClob(int paramIdx, Reader reader) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /**
-     * Sets query argument value.
-     *
-     * @param paramIdx Index.
-     * @param val Value.
-     * @throws SQLException If index is invalid.
-     */
-    private void setArgument(int paramIdx, Object val) throws SQLException {
-        ensureNotClosed();
-
-        if (paramIdx < 1 || paramIdx > argsCnt)
-            throw new SQLException("Parameter index is invalid: " + paramIdx);
-
-        if (args == null)
-            args = new Object[argsCnt];
-
-        args[paramIdx - 1] = val;
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/17d816fe/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcResultSet.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcResultSet.java b/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcResultSet.java
deleted file mode 100644
index 6d839b8..0000000
--- a/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcResultSet.java
+++ /dev/null
@@ -1,1520 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-
-package org.apache.ignite.jdbc;
-
-import org.apache.ignite.client.*;
-import org.apache.ignite.internal.util.typedef.internal.*;
-import org.apache.ignite.jdbc.typedef.*;
-
-import java.io.*;
-import java.math.*;
-import java.net.*;
-import java.sql.*;
-import java.sql.Date;
-import java.util.*;
-
-/**
- * JDBC result set implementation.
- */
-class IgniteJdbcResultSet implements ResultSet {
-    /** Task name. */
-    private static final String TASK_NAME =
-        "org.apache.ignite.internal.processors.cache.query.jdbc.GridCacheQueryJdbcTask";
-
-    /** Statement. */
-    private final IgniteJdbcStatement stmt;
-
-    /** Node ID. */
-    private final UUID nodeId;
-
-    /** Future ID. */
-    private final UUID futId;
-
-    /** Table names. */
-    private final List<String> tbls;
-
-    /** Column names. */
-    private final List<String> cols;
-
-    /** Class names. */
-    private final List<String> types;
-
-    /** Fields iterator. */
-    private Iterator<List<Object>> fields;
-
-    /** Finished flag. */
-    private boolean finished;
-
-    /** Current position. */
-    private int pos;
-
-    /** Current. */
-    private List<Object> curr;
-
-    /** Closed flag. */
-    private boolean closed;
-
-    /** Was {@code NULL} flag. */
-    private boolean wasNull;
-
-    /** Fetch size. */
-    private int fetchSize;
-
-    /**
-     * Creates new result set.
-     *
-     * @param stmt Statement.
-     * @param nodeId Node ID.
-     * @param futId Future ID.
-     * @param tbls Table names.
-     * @param cols Column names.
-     * @param types Types.
-     * @param fields Fields.
-     * @param finished Finished flag.
-     * @param fetchSize Fetch size.
-     */
-    IgniteJdbcResultSet(IgniteJdbcStatement stmt, UUID nodeId, UUID futId,
-                        List<String> tbls, List<String> cols, List<String> types,
-                        Collection<List<Object>> fields, boolean finished, int fetchSize) {
-        assert stmt != null;
-        assert nodeId != null;
-        assert futId != null;
-        assert tbls != null;
-        assert cols != null;
-        assert types != null;
-        assert fields != null;
-        assert fetchSize > 0;
-
-        this.stmt = stmt;
-        this.nodeId = nodeId;
-        this.futId = futId;
-        this.tbls = tbls;
-        this.cols = cols;
-        this.types = types;
-        this.fetchSize = fetchSize;
-        this.fields = fields.iterator();
-        this.finished = finished;
-    }
-
-    /**
-     * Creates new result set with predefined fields.
-     * Result set created with this constructor will
-     * never execute remote tasks.
-     *
-     * @param stmt Statement.
-     * @param tbls Table names.
-     * @param cols Column names.
-     * @param types Types.
-     * @param fields Fields.
-     */
-    IgniteJdbcResultSet(IgniteJdbcStatement stmt, List<String> tbls, List<String> cols,
-                        List<String> types, Collection<List<Object>> fields) {
-        assert stmt != null;
-        assert tbls != null;
-        assert cols != null;
-        assert types != null;
-        assert fields != null;
-
-        this.stmt = stmt;
-        this.tbls = tbls;
-        this.cols = cols;
-        this.types = types;
-        this.fields = fields.iterator();
-
-        nodeId = null;
-        futId = null;
-
-        // Prevent task execution.
-        finished = true;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean next() throws SQLException {
-        ensureNotClosed();
-
-        if (fields == null && !finished) {
-            assert nodeId != null;
-            assert futId != null;
-
-            try {
-                GridClientCompute compute = stmt.connection().client().compute();
-
-                GridClientCompute prj = compute.projection(compute.node(nodeId));
-
-                byte[] packet = prj.execute(TASK_NAME, JU.marshalArgument(
-                    JU.taskArgument(nodeId, futId, fetchSize, stmt.getMaxRows())));
-
-                byte status = packet[0];
-                byte[] data = new byte[packet.length - 1];
-
-                U.arrayCopy(packet, 1, data, 0, data.length);
-
-                if (status == 1)
-                    throw JU.unmarshalError(data);
-                else {
-                    List<?> msg = JU.unmarshal(data);
-
-                    assert msg.size() == 2;
-
-                    fields = ((Collection<List<Object>>)msg.get(0)).iterator();
-                    finished = (Boolean)msg.get(1);
-                }
-            }
-            catch (GridClientException e) {
-                throw new SQLException("Failed to query GridGain.", e);
-            }
-        }
-
-        if (fields != null && fields.hasNext()) {
-            curr = fields.next();
-
-            if (!fields.hasNext())
-                fields = null;
-
-            pos++;
-
-            return true;
-        }
-        else {
-            curr = null;
-
-            return false;
-        }
-    }
-
-    /** {@inheritDoc} */
-    @Override public void close() throws SQLException {
-        closed = true;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean wasNull() throws SQLException {
-        return wasNull;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getString(int colIdx) throws SQLException {
-        return getTypedValue(colIdx, String.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean getBoolean(int colIdx) throws SQLException {
-        Boolean val = getTypedValue(colIdx, Boolean.class);
-
-        return val != null ? val : false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public byte getByte(int colIdx) throws SQLException {
-        Byte val = getTypedValue(colIdx, Byte.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public short getShort(int colIdx) throws SQLException {
-        Short val = getTypedValue(colIdx, Short.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getInt(int colIdx) throws SQLException {
-        Integer val = getTypedValue(colIdx, Integer.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public long getLong(int colIdx) throws SQLException {
-        Long val = getTypedValue(colIdx, Long.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public float getFloat(int colIdx) throws SQLException {
-        Float val = getTypedValue(colIdx, Float.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public double getDouble(int colIdx) throws SQLException {
-        Double val = getTypedValue(colIdx, Double.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public BigDecimal getBigDecimal(int colIdx, int scale) throws SQLException {
-        return getTypedValue(colIdx, BigDecimal.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public byte[] getBytes(int colIdx) throws SQLException {
-        return getTypedValue(colIdx, byte[].class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Date getDate(int colIdx) throws SQLException {
-        return getTypedValue(colIdx, Date.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Time getTime(int colIdx) throws SQLException {
-        return getTypedValue(colIdx, Time.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Timestamp getTimestamp(int colIdx) throws SQLException {
-        return getTypedValue(colIdx, Timestamp.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public InputStream getAsciiStream(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public InputStream getUnicodeStream(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public InputStream getBinaryStream(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Stream are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getString(String colLb) throws SQLException {
-        return getTypedValue(colLb, String.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean getBoolean(String colLb) throws SQLException {
-        Boolean val = getTypedValue(colLb, Boolean.class);
-
-        return val != null ? val : false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public byte getByte(String colLb) throws SQLException {
-        Byte val = getTypedValue(colLb, Byte.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public short getShort(String colLb) throws SQLException {
-        Short val = getTypedValue(colLb, Short.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getInt(String colLb) throws SQLException {
-        Integer val = getTypedValue(colLb, Integer.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public long getLong(String colLb) throws SQLException {
-        Long val = getTypedValue(colLb, Long.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public float getFloat(String colLb) throws SQLException {
-        Float val = getTypedValue(colLb, Float.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public double getDouble(String colLb) throws SQLException {
-        Double val = getTypedValue(colLb, Double.class);
-
-        return val != null ? val : 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public BigDecimal getBigDecimal(String colLb, int scale) throws SQLException {
-        return getTypedValue(colLb, BigDecimal.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public byte[] getBytes(String colLb) throws SQLException {
-        return getTypedValue(colLb, byte[].class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Date getDate(String colLb) throws SQLException {
-        return getTypedValue(colLb, Date.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Time getTime(String colLb) throws SQLException {
-        return getTypedValue(colLb, Time.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Timestamp getTimestamp(String colLb) throws SQLException {
-        return getTypedValue(colLb, Timestamp.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public InputStream getAsciiStream(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public InputStream getUnicodeStream(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public InputStream getBinaryStream(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public SQLWarning getWarnings() throws SQLException {
-        ensureNotClosed();
-
-        return null;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void clearWarnings() throws SQLException {
-        ensureNotClosed();
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getCursorName() throws SQLException {
-        ensureNotClosed();
-
-        return null;
-    }
-
-    /** {@inheritDoc} */
-    @Override public ResultSetMetaData getMetaData() throws SQLException {
-        ensureNotClosed();
-
-        return new IgniteJdbcResultSetMetadata(tbls, cols, types);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Object getObject(int colIdx) throws SQLException {
-        return getTypedValue(colIdx, Object.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Object getObject(String colLb) throws SQLException {
-        return getTypedValue(colLb, Object.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public int findColumn(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        int idx = cols.indexOf(colLb.toUpperCase());
-
-        if (idx == -1)
-            throw new SQLException("Column not found: " + colLb);
-
-        return idx + 1;
-    }
-
-    /** {@inheritDoc} */
-    @Override public Reader getCharacterStream(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Reader getCharacterStream(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Streams are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public BigDecimal getBigDecimal(int colIdx) throws SQLException {
-        return getTypedValue(colIdx, BigDecimal.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public BigDecimal getBigDecimal(String colLb) throws SQLException {
-        return getTypedValue(colLb, BigDecimal.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isBeforeFirst() throws SQLException {
-        ensureNotClosed();
-
-        return pos < 1;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isAfterLast() throws SQLException {
-        ensureNotClosed();
-
-        return finished && fields == null && curr == null;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isFirst() throws SQLException {
-        ensureNotClosed();
-
-        return pos == 1;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isLast() throws SQLException {
-        ensureNotClosed();
-
-        return finished && fields == null && curr != null;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void beforeFirst() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLException("Result set is forward-only.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void afterLast() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLException("Result set is forward-only.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean first() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLException("Result set is forward-only.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean last() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLException("Result set is forward-only.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getRow() throws SQLException {
-        ensureNotClosed();
-
-        return isAfterLast() ? 0 : pos;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean absolute(int row) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLException("Result set is forward-only.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean relative(int rows) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLException("Result set is forward-only.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean previous() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLException("Result set is forward-only.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setFetchDirection(int direction) throws SQLException {
-        ensureNotClosed();
-
-        if (direction != FETCH_FORWARD)
-            throw new SQLFeatureNotSupportedException("Only forward direction is supported");
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getFetchDirection() throws SQLException {
-        ensureNotClosed();
-
-        return FETCH_FORWARD;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setFetchSize(int fetchSize) throws SQLException {
-        ensureNotClosed();
-
-        if (fetchSize <= 0)
-            throw new SQLException("Fetch size must be greater than zero.");
-
-        this.fetchSize = fetchSize;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getFetchSize() throws SQLException {
-        ensureNotClosed();
-
-        return fetchSize;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getType() throws SQLException {
-        ensureNotClosed();
-
-        return stmt.getResultSetType();
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getConcurrency() throws SQLException {
-        ensureNotClosed();
-
-        return CONCUR_READ_ONLY;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean rowUpdated() throws SQLException {
-        ensureNotClosed();
-
-        return false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean rowInserted() throws SQLException {
-        ensureNotClosed();
-
-        return false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean rowDeleted() throws SQLException {
-        ensureNotClosed();
-
-        return false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNull(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBoolean(int colIdx, boolean x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateByte(int colIdx, byte x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateShort(int colIdx, short x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateInt(int colIdx, int x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateLong(int colIdx, long x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateFloat(int colIdx, float x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateDouble(int colIdx, double x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBigDecimal(int colIdx, BigDecimal x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateString(int colIdx, String x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBytes(int colIdx, byte[] x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateDate(int colIdx, Date x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateTime(int colIdx, Time x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateTimestamp(int colIdx, Timestamp x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateAsciiStream(int colIdx, InputStream x, int len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBinaryStream(int colIdx, InputStream x, int len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateCharacterStream(int colIdx, Reader x, int len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateObject(int colIdx, Object x, int scaleOrLen) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateObject(int colIdx, Object x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNull(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBoolean(String colLb, boolean x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateByte(String colLb, byte x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateShort(String colLb, short x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateInt(String colLb, int x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateLong(String colLb, long x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateFloat(String colLb, float x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateDouble(String colLb, double x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBigDecimal(String colLb, BigDecimal x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateString(String colLb, String x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBytes(String colLb, byte[] x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateDate(String colLb, Date x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateTime(String colLb, Time x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateTimestamp(String colLb, Timestamp x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateAsciiStream(String colLb, InputStream x, int len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBinaryStream(String colLb, InputStream x, int len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateCharacterStream(String colLb, Reader reader, int len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateObject(String colLb, Object x, int scaleOrLen) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateObject(String colLb, Object x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void insertRow() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateRow() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void deleteRow() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void refreshRow() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Row refreshing is not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void cancelRowUpdates() throws SQLException {
-        ensureNotClosed();
-    }
-
-    /** {@inheritDoc} */
-    @Override public void moveToInsertRow() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void moveToCurrentRow() throws SQLException {
-        ensureNotClosed();
-    }
-
-    /** {@inheritDoc} */
-    @Override public Statement getStatement() throws SQLException {
-        ensureNotClosed();
-
-        return stmt;
-    }
-
-    /** {@inheritDoc} */
-    @Override public Object getObject(int colIdx, Map<String, Class<?>> map) throws SQLException {
-        return getTypedValue(colIdx, Object.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Ref getRef(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Blob getBlob(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Clob getClob(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Array getArray(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Object getObject(String colLb, Map<String, Class<?>> map) throws SQLException {
-        return getTypedValue(colLb, Object.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Ref getRef(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Blob getBlob(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Clob getClob(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Array getArray(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Date getDate(int colIdx, Calendar cal) throws SQLException {
-        return getTypedValue(colIdx, Date.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Date getDate(String colLb, Calendar cal) throws SQLException {
-        return getTypedValue(colLb, Date.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Time getTime(int colIdx, Calendar cal) throws SQLException {
-        return getTypedValue(colIdx, Time.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Time getTime(String colLb, Calendar cal) throws SQLException {
-        return getTypedValue(colLb, Time.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Timestamp getTimestamp(int colIdx, Calendar cal) throws SQLException {
-        return getTypedValue(colIdx, Timestamp.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Timestamp getTimestamp(String colLb, Calendar cal) throws SQLException {
-        return getTypedValue(colLb, Timestamp.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public URL getURL(int colIdx) throws SQLException {
-        return getTypedValue(colIdx, URL.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public URL getURL(String colLb) throws SQLException {
-        return getTypedValue(colLb, URL.class);
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateRef(int colIdx, Ref x) throws SQLException {
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateRef(String colLb, Ref x) throws SQLException {
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBlob(int colIdx, Blob x) throws SQLException {
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBlob(String colLb, Blob x) throws SQLException {
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateClob(int colIdx, Clob x) throws SQLException {
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateClob(String colLb, Clob x) throws SQLException {
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateArray(int colIdx, Array x) throws SQLException {
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateArray(String colLb, Array x) throws SQLException {
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public RowId getRowId(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public RowId getRowId(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateRowId(int colIdx, RowId x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateRowId(String colLb, RowId x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getHoldability() throws SQLException {
-        ensureNotClosed();
-
-        return HOLD_CURSORS_OVER_COMMIT;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isClosed() throws SQLException {
-        return closed;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNString(int colIdx, String nStr) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNString(String colLb, String nStr) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNClob(int colIdx, NClob nClob) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNClob(String colLb, NClob nClob) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public NClob getNClob(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public NClob getNClob(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public SQLXML getSQLXML(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public SQLXML getSQLXML(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateSQLXML(int colIdx, SQLXML xmlObj) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateSQLXML(String colLb, SQLXML xmlObj) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getNString(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getNString(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Reader getNCharacterStream(int colIdx) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Reader getNCharacterStream(String colLb) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("SQL-specific types are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNCharacterStream(int colIdx, Reader x, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNCharacterStream(String colLb, Reader reader, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateAsciiStream(int colIdx, InputStream x, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBinaryStream(int colIdx, InputStream x, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateCharacterStream(int colIdx, Reader x, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateAsciiStream(String colLb, InputStream x, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBinaryStream(String colLb, InputStream x, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateCharacterStream(String colLb, Reader reader, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBlob(int colIdx, InputStream inputStream, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBlob(String colLb, InputStream inputStream, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateClob(int colIdx, Reader reader, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateClob(String colLb, Reader reader, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNClob(int colIdx, Reader reader, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNClob(String colLb, Reader reader, long len) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNCharacterStream(int colIdx, Reader x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNCharacterStream(String colLb, Reader reader) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateAsciiStream(int colIdx, InputStream x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBinaryStream(int colIdx, InputStream x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateCharacterStream(int colIdx, Reader x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateAsciiStream(String colLb, InputStream x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBinaryStream(String colLb, InputStream x) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateCharacterStream(String colLb, Reader reader) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBlob(int colIdx, InputStream inputStream) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateBlob(String colLb, InputStream inputStream) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateClob(int colIdx, Reader reader) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateClob(String colLb, Reader reader) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNClob(int colIdx, Reader reader) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void updateNClob(String colLb, Reader reader) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public <T> T unwrap(Class<T> iface) throws SQLException {
-        if (!isWrapperFor(iface))
-            throw new SQLException("Result set is not a wrapper for " + iface.getName());
-
-        return (T)this;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isWrapperFor(Class<?> iface) throws SQLException {
-        return iface != null && iface == ResultSet.class;
-    }
-
-    /** {@inheritDoc} */
-    @Override public <T> T getObject(int colIdx, Class<T> type) throws SQLException {
-        return getTypedValue(colIdx, type);
-    }
-
-    /** {@inheritDoc} */
-    @Override public <T> T getObject(String colLb, Class<T> type) throws SQLException {
-        return getTypedValue(colLb, type);
-    }
-
-    /**
-     * Gets casted field value by label.
-     *
-     * @param colLb Column label.
-     * @param cls Value class.
-     * @return Casted field value.
-     * @throws SQLException In case of error.
-     */
-    private <T> T getTypedValue(String colLb, Class<T> cls) throws SQLException {
-        ensureNotClosed();
-        ensureHasCurrentRow();
-
-        int colIdx = cols.indexOf(colLb.toUpperCase()) + 1;
-
-        if (colIdx <= 0)
-            throw new SQLException("Invalid column label: " + colLb);
-
-        return getTypedValue(colIdx, cls);
-    }
-
-    /**
-     * Gets casted field value by index.
-     *
-     * @param colIdx Column index.
-     * @param cls Value class.
-     * @return Casted field value.
-     * @throws SQLException In case of error.
-     */
-    private <T> T getTypedValue(int colIdx, Class<T> cls) throws SQLException {
-        ensureNotClosed();
-        ensureHasCurrentRow();
-
-        try {
-            T val = cls == String.class ? (T)String.valueOf(curr.get(colIdx - 1)) : (T)curr.get(colIdx - 1);
-
-            wasNull = val == null;
-
-            return val;
-        }
-        catch (IndexOutOfBoundsException ignored) {
-            throw new SQLException("Invalid column index: " + colIdx);
-        }
-        catch (ClassCastException ignored) {
-            throw new SQLException("Value is an not instance of " + cls.getName());
-        }
-    }
-
-    /**
-     * Ensures that result set is not closed.
-     *
-     * @throws SQLException If result set is closed.
-     */
-    private void ensureNotClosed() throws SQLException {
-        if (closed)
-            throw new SQLException("Result set is closed.");
-    }
-
-    /**
-     * Ensures that result set is positioned on a row.
-     *
-     * @throws SQLException If result set is not positioned on a row.
-     */
-    private void ensureHasCurrentRow() throws SQLException {
-        if (curr == null)
-            throw new SQLException("Result set is not positioned on a row.");
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/17d816fe/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcResultSetMetadata.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcResultSetMetadata.java b/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcResultSetMetadata.java
deleted file mode 100644
index e95e9aa..0000000
--- a/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcResultSetMetadata.java
+++ /dev/null
@@ -1,172 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-
-package org.apache.ignite.jdbc;
-
-import org.apache.ignite.jdbc.typedef.*;
-
-import java.sql.*;
-import java.util.*;
-
-/**
- * JDBC result set metadata implementation.
- */
-class IgniteJdbcResultSetMetadata implements ResultSetMetaData {
-    /** Column width. */
-    private static final int COL_WIDTH = 30;
-
-    /** Table names. */
-    private final List<String> tbls;
-
-    /** Column names. */
-    private final List<String> cols;
-
-    /** Class names. */
-    private final List<String> types;
-
-    /**
-     * @param tbls Table names.
-     * @param cols Column names.
-     * @param types Types.
-     */
-    IgniteJdbcResultSetMetadata(List<String> tbls, List<String> cols, List<String> types) {
-        assert cols != null;
-        assert types != null;
-
-        this.tbls = tbls;
-        this.cols = cols;
-        this.types = types;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getColumnCount() throws SQLException {
-        return cols.size();
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isAutoIncrement(int col) throws SQLException {
-        return false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isCaseSensitive(int col) throws SQLException {
-        return false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isSearchable(int col) throws SQLException {
-        return false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isCurrency(int col) throws SQLException {
-        return false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int isNullable(int col) throws SQLException {
-        return columnNullable;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isSigned(int col) throws SQLException {
-        return true;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getColumnDisplaySize(int col) throws SQLException {
-        return COL_WIDTH;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getColumnLabel(int col) throws SQLException {
-        return cols.get(col - 1);
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getColumnName(int col) throws SQLException {
-        return cols.get(col - 1);
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getSchemaName(int col) throws SQLException {
-        return "";
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getPrecision(int col) throws SQLException {
-        return 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getScale(int col) throws SQLException {
-        return 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getTableName(int col) throws SQLException {
-        return tbls != null ? tbls.get(col - 1) : "";
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getCatalogName(int col) throws SQLException {
-        return "";
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getColumnType(int col) throws SQLException {
-        return JU.type(types.get(col - 1));
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getColumnTypeName(int col) throws SQLException {
-        return JU.typeName(types.get(col - 1));
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isReadOnly(int col) throws SQLException {
-        return true;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isWritable(int col) throws SQLException {
-        return false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isDefinitelyWritable(int col) throws SQLException {
-        return false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public String getColumnClassName(int col) throws SQLException {
-        return types.get(col - 1);
-    }
-
-    /** {@inheritDoc} */
-    @Override public <T> T unwrap(Class<T> iface) throws SQLException {
-        if (!isWrapperFor(iface))
-            throw new SQLException("Result set meta data is not a wrapper for " + iface.getName());
-
-        return (T)this;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isWrapperFor(Class<?> iface) throws SQLException {
-        return iface == ResultSetMetaData.class;
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/17d816fe/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcStatement.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcStatement.java b/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcStatement.java
deleted file mode 100644
index 027768d..0000000
--- a/modules/core/src/main/java/org/apache/ignite/jdbc/IgniteJdbcStatement.java
+++ /dev/null
@@ -1,449 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-
-package org.apache.ignite.jdbc;
-
-import org.apache.ignite.client.*;
-import org.apache.ignite.internal.util.typedef.internal.*;
-import org.apache.ignite.jdbc.typedef.*;
-
-import java.sql.*;
-import java.util.*;
-
-import static java.sql.ResultSet.*;
-
-/**
- * JDBC statement implementation.
- */
-class IgniteJdbcStatement implements Statement {
-    /** Task name. */
-    private static final String TASK_NAME =
-        "org.apache.ignite.internal.processors.cache.query.jdbc.GridCacheQueryJdbcTask";
-
-    /** Default fetch size. */
-    private static final int DFLT_FETCH_SIZE = 1024;
-
-    /** Connection. */
-    private final IgniteJdbcConnection conn;
-
-    /** Closed flag. */
-    private boolean closed;
-
-    /** Rows limit. */
-    private int maxRows;
-
-    /** Query timeout. */
-    private int timeout;
-
-    /** Current result set. */
-    private ResultSet rs;
-
-    /** Query arguments. */
-    protected Object[] args;
-
-    /** Fetch size. */
-    private int fetchSize = DFLT_FETCH_SIZE;
-
-    /**
-     * Creates new statement.
-     *
-     * @param conn Connection.
-     */
-    IgniteJdbcStatement(IgniteJdbcConnection conn) {
-        assert conn != null;
-
-        this.conn = conn;
-    }
-
-    /** {@inheritDoc} */
-    @Override public ResultSet executeQuery(String sql) throws SQLException {
-        ensureNotClosed();
-
-        rs = null;
-
-        if (sql == null || sql.isEmpty())
-            throw new SQLException("SQL query is empty");
-
-        try {
-            byte[] packet = conn.client().compute().execute(TASK_NAME,
-                JU.marshalArgument(JU.taskArgument(conn.nodeId(), conn.cacheName(), sql, timeout, args, fetchSize,
-                    maxRows)));
-
-            byte status = packet[0];
-            byte[] data = new byte[packet.length - 1];
-
-            U.arrayCopy(packet, 1, data, 0, data.length);
-
-            if (status == 1)
-                throw JU.unmarshalError(data);
-            else {
-                List<?> msg = JU.unmarshal(data);
-
-                assert msg.size() == 7;
-
-                UUID nodeId = (UUID)msg.get(0);
-                UUID futId = (UUID)msg.get(1);
-                List<String> tbls = (List<String>)msg.get(2);
-                List<String> cols = (List<String>)msg.get(3);
-                List<String> types = (List<String>)msg.get(4);
-                Collection<List<Object>> fields = (Collection<List<Object>>)msg.get(5);
-                boolean finished = (Boolean)msg.get(6);
-
-                return new IgniteJdbcResultSet(this, nodeId, futId, tbls, cols, types, fields, finished, fetchSize);
-            }
-        }
-        catch (GridClientException e) {
-            throw new SQLException("Failed to query GridGain.", e);
-        }
-    }
-
-    /** {@inheritDoc} */
-    @Override public int executeUpdate(String sql) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void close() throws SQLException {
-        closed = true;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getMaxFieldSize() throws SQLException {
-        ensureNotClosed();
-
-        return 0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setMaxFieldSize(int max) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Field size limitation is not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getMaxRows() throws SQLException {
-        ensureNotClosed();
-
-        return maxRows;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setMaxRows(int maxRows) throws SQLException {
-        ensureNotClosed();
-
-        this.maxRows = maxRows;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setEscapeProcessing(boolean enable) throws SQLException {
-        ensureNotClosed();
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getQueryTimeout() throws SQLException {
-        ensureNotClosed();
-
-        return timeout;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setQueryTimeout(int timeout) throws SQLException {
-        ensureNotClosed();
-
-        this.timeout = timeout * 1000;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void cancel() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Cancellation is not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public SQLWarning getWarnings() throws SQLException {
-        ensureNotClosed();
-
-        return null;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void clearWarnings() throws SQLException {
-        ensureNotClosed();
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setCursorName(String name) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean execute(String sql) throws SQLException {
-        ensureNotClosed();
-
-        rs = executeQuery(sql);
-
-        return true;
-    }
-
-    /** {@inheritDoc} */
-    @Override public ResultSet getResultSet() throws SQLException {
-        ensureNotClosed();
-
-        ResultSet rs0 = rs;
-
-        rs = null;
-
-        return rs0;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getUpdateCount() throws SQLException {
-        ensureNotClosed();
-
-        return -1;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean getMoreResults() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Multiple open results are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setFetchDirection(int direction) throws SQLException {
-        ensureNotClosed();
-
-        if (direction != FETCH_FORWARD)
-            throw new SQLFeatureNotSupportedException("Only forward direction is supported");
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getFetchDirection() throws SQLException {
-        ensureNotClosed();
-
-        return FETCH_FORWARD;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setFetchSize(int fetchSize) throws SQLException {
-        ensureNotClosed();
-
-        if (fetchSize <= 0)
-            throw new SQLException("Fetch size must be greater than zero.");
-
-        this.fetchSize = fetchSize;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getFetchSize() throws SQLException {
-        ensureNotClosed();
-
-        return fetchSize;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getResultSetConcurrency() throws SQLException {
-        ensureNotClosed();
-
-        return CONCUR_READ_ONLY;
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getResultSetType() throws SQLException {
-        ensureNotClosed();
-
-        return TYPE_FORWARD_ONLY;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void addBatch(String sql) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public void clearBatch() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public int[] executeBatch() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public Connection getConnection() throws SQLException {
-        ensureNotClosed();
-
-        return conn;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean getMoreResults(int curr) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Multiple open results are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public ResultSet getGeneratedKeys() throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public int executeUpdate(String sql, int autoGeneratedKeys) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public int executeUpdate(String sql, int[] colIndexes) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public int executeUpdate(String sql, String[] colNames) throws SQLException {
-        ensureNotClosed();
-
-        throw new SQLFeatureNotSupportedException("Updates are not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean execute(String sql, int autoGeneratedKeys) throws SQLException {
-        ensureNotClosed();
-
-        if (autoGeneratedKeys == RETURN_GENERATED_KEYS)
-            throw new SQLFeatureNotSupportedException("Updates are not supported.");
-
-        return execute(sql);
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean execute(String sql, int[] colIndexes) throws SQLException {
-        ensureNotClosed();
-
-        if (colIndexes != null && colIndexes.length > 0)
-            throw new SQLFeatureNotSupportedException("Updates are not supported.");
-
-        return execute(sql);
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean execute(String sql, String[] colNames) throws SQLException {
-        ensureNotClosed();
-
-        if (colNames != null && colNames.length > 0)
-            throw new SQLFeatureNotSupportedException("Updates are not supported.");
-
-        return execute(sql);
-    }
-
-    /** {@inheritDoc} */
-    @Override public int getResultSetHoldability() throws SQLException {
-        ensureNotClosed();
-
-        return HOLD_CURSORS_OVER_COMMIT;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isClosed() throws SQLException {
-        return closed;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void setPoolable(boolean poolable) throws SQLException {
-        ensureNotClosed();
-
-        if (poolable)
-            throw new SQLFeatureNotSupportedException("Pooling is not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isPoolable() throws SQLException {
-        ensureNotClosed();
-
-        return false;
-    }
-
-    /** {@inheritDoc} */
-    @Override public <T> T unwrap(Class<T> iface) throws SQLException {
-        if (!isWrapperFor(iface))
-            throw new SQLException("Statement is not a wrapper for " + iface.getName());
-
-        return (T)this;
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isWrapperFor(Class<?> iface) throws SQLException {
-        return iface != null && iface == Statement.class;
-    }
-
-    /** {@inheritDoc} */
-    @Override public void closeOnCompletion() throws SQLException {
-        throw new SQLFeatureNotSupportedException("closeOnCompletion is not supported.");
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean isCloseOnCompletion() throws SQLException {
-        ensureNotClosed();
-
-        return false;
-    }
-
-    /**
-     * Sets timeout in milliseconds.
-     *
-     * @param timeout Timeout.
-     */
-    void timeout(int timeout) {
-        this.timeout = timeout;
-    }
-
-    /**
-     * @return Connection.
-     */
-    IgniteJdbcConnection connection() {
-        return conn;
-    }
-
-    /**
-     * Ensures that statement is not closed.
-     *
-     * @throws SQLException If statement is closed.
-     */
-    protected void ensureNotClosed() throws SQLException {
-        if (closed)
-            throw new SQLException("Statement is closed.");
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/17d816fe/modules/core/src/main/java/org/apache/ignite/jdbc/package.html
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/jdbc/package.html b/modules/core/src/main/java/org/apache/ignite/jdbc/package.html
deleted file mode 100644
index 776a0f6..0000000
--- a/modules/core/src/main/java/org/apache/ignite/jdbc/package.html
+++ /dev/null
@@ -1,23 +0,0 @@
-<!--
-  Licensed to the Apache Software Foundation (ASF) under one or more
-  contributor license agreements.  See the NOTICE file distributed with
-  this work for additional information regarding copyright ownership.
-  The ASF licenses this file to You 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.
-  -->
-<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<html>
-<body>
-<!-- Package description. -->
-    Contains JDBC driver for In-Memory Data Grid.
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/17d816fe/modules/core/src/main/java/org/apache/ignite/jdbc/typedef/JU.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/jdbc/typedef/JU.java b/modules/core/src/main/java/org/apache/ignite/jdbc/typedef/JU.java
deleted file mode 100644
index 7ba3eb6..0000000
--- a/modules/core/src/main/java/org/apache/ignite/jdbc/typedef/JU.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-
-package org.apache.ignite.jdbc.typedef;
-
-import org.apache.ignite.jdbc.util.*;
-
-/**
- * Defines internal {@code typedef} for {@link org.apache.ignite.jdbc.util.IgniteJdbcUtils}.
- */
-@SuppressWarnings("ExtendsUtilityClass")
-public class JU extends IgniteJdbcUtils {
-    // No-op
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/17d816fe/modules/core/src/main/java/org/apache/ignite/jdbc/typedef/package.html
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/jdbc/typedef/package.html b/modules/core/src/main/java/org/apache/ignite/jdbc/typedef/package.html
deleted file mode 100644
index 73ea452..0000000
--- a/modules/core/src/main/java/org/apache/ignite/jdbc/typedef/package.html
+++ /dev/null
@@ -1,23 +0,0 @@
-<!--
-  Licensed to the Apache Software Foundation (ASF) under one or more
-  contributor license agreements.  See the NOTICE file distributed with
-  this work for additional information regarding copyright ownership.
-  The ASF licenses this file to You 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.
-  -->
-<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
-<html>
-<body>
-<!-- Package description. -->
-    JDBC typedefs.
-</body>
-</html>


Mime
View raw message