cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From eev...@apache.org
Subject svn commit: r1069593 [1/2] - in /cassandra/trunk: ./ drivers/java/src/org/apache/cassandra/cql/driver/jdbc/ drivers/java/test/
Date Thu, 10 Feb 2011 22:34:05 GMT
Author: eevans
Date: Thu Feb 10 22:34:05 2011
New Revision: 1069593

URL: http://svn.apache.org/viewvc?rev=1069593&view=rev
Log:
basic JDBC'ish (non-compliant) driver for CQL

Patch by Vivek Mishra; reviewed by eevans for CASSANDRA-2124

Added:
    cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/
    cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraConnection.java
    cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraDriver.java
    cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraResultSet.java
    cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraStatement.java
    cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/DriverResolverException.java
    cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/InvalidUrlException.java
    cassandra/trunk/drivers/java/test/
    cassandra/trunk/drivers/java/test/BaseTest.java
    cassandra/trunk/drivers/java/test/JdbcDriverTest.java
Modified:
    cassandra/trunk/build.xml

Modified: cassandra/trunk/build.xml
URL: http://svn.apache.org/viewvc/cassandra/trunk/build.xml?rev=1069593&r1=1069592&r2=1069593&view=diff
==============================================================================
--- cassandra/trunk/build.xml (original)
+++ cassandra/trunk/build.xml Thu Feb 10 22:34:05 2011
@@ -46,6 +46,7 @@
     <property name="test.data" value="${test.dir}/data"/>
     <property name="test.name" value="*Test"/>
     <property name="test.unit.src" value="${test.dir}/unit"/>
+    <property name="test.src.driver" value="${basedir}/drivers/java/test"/>
     <property name="test.long.src" value="${test.dir}/long"/>
     <property name="test.distributed.src" value="${test.dir}/distributed"/>
     <property name="dist.dir" value="${build.dir}/dist"/>
@@ -513,6 +514,7 @@
       <classpath refid="cassandra.classpath"/>
       <src path="${test.unit.src}"/>
       <src path="${test.long.src}"/>
+      <src path="${test.src.driver}"/>
     </javac>
 
     <!-- Non-java resources needed by the test suite -->
@@ -578,6 +580,9 @@
     <testmacro suitename="unit" inputdir="${test.unit.src}" timeout="60000">
       <jvmarg value="-Dlegacy-sstable-root=${test.data}/legacy-sstables"/>
     </testmacro>
+    <testmacro suitename="driverunit" inputdir="${test.src.driver}" timeout="60000">
+      <jvmarg value="-Dlegacy-sstable-root=${test.data}/legacy-sstables"/>
+    </testmacro>
   </target>
     
   <target name="msg-ser-gen-test" depends="build-test" description="Generates message serializations">
@@ -735,6 +740,7 @@
   <classpathentry kind="src" path="src/gen-java"/>
   <classpathentry kind="src" path="interface/thrift/gen-java"/>
   <classpathentry kind="src" path="drivers/java/src"/>
+  <classpathentry kind="src" path="drivers/java/test"/>
   <classpathentry kind="src" path="test/unit"/>
   <classpathentry kind="src" path="test/long"/>
   <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>

Added: cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraConnection.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraConnection.java?rev=1069593&view=auto
==============================================================================
--- cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraConnection.java (added)
+++ cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraConnection.java Thu Feb 10 22:34:05 2011
@@ -0,0 +1,653 @@
+/*
+ * 
+ * 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.cassandra.cql.driver.jdbc;
+
+import java.sql.Array;
+import java.sql.Blob;
+import java.sql.CallableStatement;
+import java.sql.Clob;
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.NClob;
+import java.sql.PreparedStatement;
+import java.sql.SQLClientInfoException;
+import java.sql.SQLException;
+import java.sql.SQLWarning;
+import java.sql.SQLXML;
+import java.sql.Savepoint;
+import java.sql.Statement;
+import java.sql.Struct;
+import java.util.Map;
+import java.util.Properties;
+
+import org.apache.cassandra.thrift.AuthenticationException;
+import org.apache.cassandra.thrift.AuthorizationException;
+import org.apache.cassandra.thrift.InvalidRequestException;
+import org.apache.cassandra.thrift.TimedOutException;
+import org.apache.cassandra.thrift.UnavailableException;
+import org.apache.thrift.TException;
+import org.apache.thrift.transport.TTransportException;
+
+/**
+ * Implementation class for {@link Connection}.
+ */
+public class CassandraConnection implements Connection
+{
+    
+    /** The cassandra con. */
+    private org.apache.cassandra.cql.driver.Connection cassandraCon;
+    
+    /**
+     * Instantiates a new cassandra connection.
+     *
+     * @param url the url
+     */
+    public CassandraConnection(String url)
+    {
+        try
+        {
+            final int splitIndex = url.indexOf('@');
+            final String usr_pwd = url.substring(0, splitIndex);
+            final String host_port = url.substring(splitIndex + 1);
+            final int usr_colonIdx = usr_pwd.lastIndexOf(':');
+            final int usr_backwardIdx = usr_pwd.indexOf('/');
+            final String userName = usr_pwd.substring(usr_colonIdx + 1, usr_backwardIdx);
+            final String password = usr_pwd.substring(usr_backwardIdx + 1);
+            final int host_colonIdx = host_port.indexOf(':');
+            final String hostName = host_port.substring(0, host_colonIdx);
+            final int host_backwardIdx = host_port.indexOf('/');
+            final String port = host_port.substring(host_colonIdx + 1, host_backwardIdx);
+            final String keyspace = host_port.substring(host_backwardIdx + 1);
+            cassandraCon = new org.apache.cassandra.cql.driver.Connection(hostName, Integer.valueOf(port), userName,
+                                                                                                                             password);
+            final String useQ = "USE " + keyspace;
+            cassandraCon.execute(useQ);
+        }
+        catch (NumberFormatException e)
+        {
+            throw new DriverResolverException(e.getMessage());
+        }
+        catch (TTransportException e)
+        {
+            throw new DriverResolverException(e.getMessage());
+        }
+        catch (AuthenticationException e)
+        {
+            throw new DriverResolverException(e.getMessage());
+        }
+        catch (AuthorizationException e)
+        {
+            throw new DriverResolverException(e.getMessage());
+        }
+        catch (TException e)
+        {
+            throw new DriverResolverException(e.getMessage());
+        }
+        catch (InvalidRequestException e)
+        {
+            throw new DriverResolverException(e.getMessage());
+        }
+        catch (UnavailableException e)
+        {
+            throw new DriverResolverException(e.getMessage());
+        }
+        catch (TimedOutException e)
+        {
+            throw new DriverResolverException(e.getMessage());
+        }
+
+    }
+    
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public boolean isWrapperFor(Class<?> arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    
+    /**
+     * @param <T>
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public <T> T unwrap(Class<T> arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+
+    /**
+     * @throws SQLException
+     */
+    public void clearWarnings() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * On close of connection.
+     *
+     * @throws SQLException the sQL exception
+     */
+    public void close() throws SQLException
+    {
+        if (cassandraCon != null)
+        {
+            cassandraCon.close();
+        }
+    }
+
+
+    /**
+     * @throws SQLException
+     */
+    public void commit() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Array createArrayOf(String arg0, Object[] arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public Blob createBlob() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public Clob createClob() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public NClob createNClob() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public SQLXML createSQLXML() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public Statement createStatement() throws SQLException
+    {
+        return new CassandraStatement(this.cassandraCon);
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Statement createStatement(int arg0, int arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @return
+     * @throws SQLException
+     */
+    public Statement createStatement(int arg0, int arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Struct createStruct(String arg0, Object[] arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean getAutoCommit() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public String getCatalog() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public Properties getClientInfo() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public String getClientInfo(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public int getHoldability() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public DatabaseMetaData getMetaData() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public int getTransactionIsolation() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public Map<String, Class<?>> getTypeMap() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public SQLWarning getWarnings() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean isClosed() throws SQLException
+    {
+        return false;
+    }
+
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean isReadOnly() throws SQLException
+    {
+        return false;
+    }
+
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public boolean isValid(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public String nativeSQL(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public CallableStatement prepareCall(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @return
+     * @throws SQLException
+     */
+    public CallableStatement prepareCall(String arg0, int arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @param arg3
+     * @return
+     * @throws SQLException
+     */
+    public CallableStatement prepareCall(String arg0, int arg1, int arg2, int arg3) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param sql
+     * @return
+     * @throws SQLException
+     */
+    public PreparedStatement prepareStatement(String sql) throws SQLException
+    {
+        return new CassandraStatement(this.cassandraCon, sql);
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public PreparedStatement prepareStatement(String arg0, int arg1) throws SQLException
+    {
+        return null;
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public PreparedStatement prepareStatement(String arg0, int[] arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public PreparedStatement prepareStatement(String arg0, String[] arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @return
+     * @throws SQLException
+     */
+    public PreparedStatement prepareStatement(String arg0, int arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @param arg3
+     * @return
+     * @throws SQLException
+     */
+    public PreparedStatement prepareStatement(String arg0, int arg1, int arg2, int arg3) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void releaseSavepoint(Savepoint arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+
+    }
+
+
+    /**
+     * @throws SQLException
+     */ 
+    public void rollback() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+
+    }
+
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void rollback(Savepoint arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+
+    }
+
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void setAutoCommit(boolean arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+
+    }
+
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void setCatalog(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @throws SQLClientInfoException
+     */
+    public void setClientInfo(Properties arg0) throws SQLClientInfoException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLClientInfoException
+     */
+    public void setClientInfo(String arg0, String arg1) throws SQLClientInfoException
+    {
+        throw new UnsupportedOperationException("method not supported");
+
+    }
+
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void setHoldability(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+    
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void setReadOnly(boolean arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+    
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public Savepoint setSavepoint() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+    
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Savepoint setSavepoint(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+    
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void setTransactionIsolation(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+    
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void setTypeMap(Map<String, Class<?>> arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+}

Added: cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraDriver.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraDriver.java?rev=1069593&view=auto
==============================================================================
--- cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraDriver.java (added)
+++ cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraDriver.java Thu Feb 10 22:34:05 2011
@@ -0,0 +1,134 @@
+/*
+ * 
+ * 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.cassandra.cql.driver.jdbc;
+
+import java.sql.Connection;
+import java.sql.Driver;
+import java.sql.DriverManager;
+import java.sql.DriverPropertyInfo;
+import java.sql.SQLException;
+import java.util.Properties;
+
+/**
+  * The Class CassandraDriver.
+  */
+ public class CassandraDriver implements Driver
+{
+    
+    /** The Constant MAJOR_VERSION. */
+    private static final int MAJOR_VERSION = 1;
+    
+    /** The Constant MINOR_VERSION. */
+    private static final int MINOR_VERSION = 0;
+
+    /** The ACCEPT s_ url. */
+    private static String ACCEPTS_URL = "jdbc:cassandra";
+    
+//    private static final Logger logger = LoggerFactory.getLogger(CassandraDriver.class); 
+
+    static
+    {
+        // Register the CassandraDriver with DriverManager
+        try
+        {
+            CassandraDriver driverInst = new CassandraDriver();
+            DriverManager.registerDriver(driverInst);
+        }
+        catch (SQLException e)
+        {
+            throw new DriverResolverException(e.getMessage());
+        }
+    }
+
+    
+    /**
+     * Method to validate whether provided connection url matches with pattern or not.
+     *
+     * @param url  connection url.
+     * @return true, if successful
+     * @throws SQLException the sQL exception
+     */
+    public boolean acceptsURL(String url) throws SQLException
+    {
+        return url.startsWith(ACCEPTS_URL);
+    }
+
+    /**
+     * Method to return connection instance for given connection url and connection props.
+     *
+     * @param url               connection url.
+     * @param props          connection properties.
+     * @return connection connection instance.
+     * @throws SQLException the sQL exception
+     */
+    public Connection connect(String url, Properties props) throws SQLException
+    {
+        if (acceptsURL(url))
+        {
+            return new CassandraConnection(url);
+        }
+        else
+        {
+            throw new InvalidUrlException("Invalid connection url:" + url + ". should start with jdbc:cassandra");
+        }
+    }
+
+    /**
+     * Returns default major version.
+     * @return MAJOR_VERSION major version.
+     */
+    public int getMajorVersion()
+    {
+        return MAJOR_VERSION;
+    }
+
+    /**
+     * Returns default minor version.
+     * @return MINOR_VERSION minor version.
+     */
+    public int getMinorVersion()
+    {
+        return MINOR_VERSION;
+    }
+
+    /**
+     * Returns default driver property info object.
+     *
+     * @param arg0 the arg0
+     * @param arg1 the arg1
+     * @return driverPropertyInfo
+     * @throws SQLException the sQL exception
+     */
+    public DriverPropertyInfo[] getPropertyInfo(String arg0, Properties arg1) throws SQLException
+    {
+        return new DriverPropertyInfo[0];
+    }
+
+   /**
+    * Returns true, if it is jdbc compliant.    
+    * @return value true, if it is jdbc compliant.
+    */
+    public boolean jdbcCompliant()
+    {
+        return false;
+    }
+
+}

Added: cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraResultSet.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraResultSet.java?rev=1069593&view=auto
==============================================================================
--- cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraResultSet.java (added)
+++ cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/driver/jdbc/CassandraResultSet.java Thu Feb 10 22:34:05 2011
@@ -0,0 +1,1982 @@
+/*
+ * 
+ * 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.cassandra.cql.driver.jdbc;
+
+import java.io.InputStream;
+import java.io.Reader;
+import java.math.BigDecimal;
+import java.net.URL;
+import java.sql.Array;
+import java.sql.Blob;
+import java.sql.Clob;
+import java.sql.Date;
+import java.sql.NClob;
+import java.sql.Ref;
+import java.sql.ResultSet;
+import java.sql.ResultSetMetaData;
+import java.sql.RowId;
+import java.sql.SQLException;
+import java.sql.SQLWarning;
+import java.sql.SQLXML;
+import java.sql.Statement;
+import java.sql.Time;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.WeakHashMap;
+import org.apache.cassandra.thrift.Column;
+import org.apache.cassandra.thrift.CqlResult;
+import org.apache.cassandra.thrift.CqlRow;
+
+/**
+ * The Class CassandraResultSet.
+ */
+class CassandraResultSet implements ResultSet
+{
+    
+    /** The r set. */
+    private CqlResult rSet;
+    
+    /** The r set iter. */
+    private Iterator<CqlRow> rSetIter;
+    
+    /** The row. */
+    private CqlRow row;
+    
+    /** The values. */
+    private List<Object> values = new ArrayList<Object>();
+    
+    /** The value map. */
+    private Map<String, Object> valueMap = new WeakHashMap<String, Object>();
+
+    /**
+     * Instantiates a new cassandra result set.
+     *
+     * @param resultSet the result set
+     */
+    CassandraResultSet(CqlResult resultSet)
+    {
+        this.rSet = resultSet;
+        rSetIter = rSet.getRowsIterator();
+    }
+
+    /**
+     * @param iface
+     * @return
+     * @throws SQLException
+     */
+    public boolean isWrapperFor(Class<?> iface) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param <T>
+     * @param iface
+     * @return
+     * @throws SQLException
+     */
+    public <T> T unwrap(Class<T> iface) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public boolean absolute(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void afterLast() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void beforeFirst() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void cancelRowUpdates() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void clearWarnings() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void close() throws SQLException
+    {
+        valueMap.clear();
+        values.clear();
+        valueMap = null;
+        values = null;
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void deleteRow() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public int findColumn(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean first() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Array getArray(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Array getArray(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public InputStream getAsciiStream(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public InputStream getAsciiStream(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public BigDecimal getBigDecimal(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public BigDecimal getBigDecimal(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public BigDecimal getBigDecimal(int arg0, int arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public BigDecimal getBigDecimal(String arg0, int arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public InputStream getBinaryStream(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public InputStream getBinaryStream(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Blob getBlob(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Blob getBlob(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public boolean getBoolean(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public boolean getBoolean(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public byte getByte(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public byte getByte(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public byte[] getBytes(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public byte[] getBytes(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Reader getCharacterStream(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Reader getCharacterStream(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Clob getClob(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Clob getClob(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public int getConcurrency() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public String getCursorName() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Date getDate(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Date getDate(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Date getDate(int arg0, Calendar arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Date getDate(String arg0, Calendar arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public double getDouble(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public double getDouble(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public int getFetchDirection() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public int getFetchSize() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public float getFloat(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public float getFloat(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public int getHoldability() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public int getInt(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public int getInt(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public long getLong(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public long getLong(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public ResultSetMetaData getMetaData() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Reader getNCharacterStream(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Reader getNCharacterStream(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public NClob getNClob(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public NClob getNClob(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public String getNString(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public String getNString(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Object getObject(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Object getObject(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Object getObject(int arg0, Map<String, Class<?>> arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Object getObject(String arg0, Map<String, Class<?>> arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Ref getRef(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Ref getRef(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public int getRow() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public RowId getRowId(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public RowId getRowId(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public SQLXML getSQLXML(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public SQLXML getSQLXML(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public short getShort(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public short getShort(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public Statement getStatement() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param index
+     * @return
+     * @throws SQLException
+     */
+    public String getString(int index) throws SQLException 
+    {
+        return values.get(index) != null ? values.get(index).toString() : null;
+    }
+
+    /**
+     * @param name
+     * @return
+     * @throws SQLException
+     */
+    public String getString(String name) throws SQLException
+    {
+        return valueMap.get(name) != null ? valueMap.get(name).toString() : null;
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Time getTime(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Time getTime(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Time getTime(int arg0, Calendar arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Time getTime(String arg0, Calendar arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Timestamp getTimestamp(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public Timestamp getTimestamp(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Timestamp getTimestamp(int arg0, Calendar arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @return
+     * @throws SQLException
+     */
+    public Timestamp getTimestamp(String arg0, Calendar arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public int getType() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public URL getURL(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public URL getURL(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public InputStream getUnicodeStream(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public InputStream getUnicodeStream(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public SQLWarning getWarnings() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void insertRow() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean isAfterLast() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean isBeforeFirst() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean isClosed() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean isFirst() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean isLast() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean last() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void moveToCurrentRow() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void moveToInsertRow() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public synchronized boolean next() throws SQLException
+    {
+        if (!values.isEmpty() || !valueMap.isEmpty())
+        {
+            values.clear();
+            valueMap.clear();
+        }
+        if (rSetIter != null && rSetIter.hasNext())
+        {
+            row = rSetIter.next();
+            List<Column> cols = row.getColumns();
+            for (Column col : cols)
+            {
+                String name = new String(col.getName());
+                String value = new String(col.getValue());
+                values.add(value);
+                valueMap.put(name, value);
+            }
+            return !(values.isEmpty() && valueMap.isEmpty());
+        } 
+        else
+        {
+            return false;
+        }
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean previous() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void refreshRow() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @return
+     * @throws SQLException
+     */
+    public boolean relative(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean rowDeleted() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean rowInserted() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean rowUpdated() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void setFetchDirection(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void setFetchSize(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateArray(int arg0, Array arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateArray(String arg0, Array arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateAsciiStream(int arg0, InputStream arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateAsciiStream(String arg0, InputStream arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateAsciiStream(int arg0, InputStream arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateAsciiStream(String arg0, InputStream arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateAsciiStream(int arg0, InputStream arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateAsciiStream(String arg0, InputStream arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBigDecimal(int arg0, BigDecimal arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBigDecimal(String arg0, BigDecimal arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBinaryStream(int arg0, InputStream arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBinaryStream(String arg0, InputStream arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateBinaryStream(int arg0, InputStream arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateBinaryStream(String arg0, InputStream arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateBinaryStream(int arg0, InputStream arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateBinaryStream(String arg0, InputStream arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBlob(int arg0, Blob arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBlob(String arg0, Blob arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBlob(int arg0, InputStream arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBlob(String arg0, InputStream arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateBlob(int arg0, InputStream arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateBlob(String arg0, InputStream arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBoolean(int arg0, boolean arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBoolean(String arg0, boolean arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateByte(int arg0, byte arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateByte(String arg0, byte arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBytes(int arg0, byte[] arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateBytes(String arg0, byte[] arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateCharacterStream(int arg0, Reader arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateCharacterStream(String arg0, Reader arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateCharacterStream(int arg0, Reader arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateCharacterStream(String arg0, Reader arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateCharacterStream(int arg0, Reader arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateCharacterStream(String arg0, Reader arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateClob(int arg0, Clob arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateClob(String arg0, Clob arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateClob(int arg0, Reader arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateClob(String arg0, Reader arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateClob(int arg0, Reader arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateClob(String arg0, Reader arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateDate(int arg0, Date arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateDate(String arg0, Date arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateDouble(int arg0, double arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateDouble(String arg0, double arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateFloat(int arg0, float arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateFloat(String arg0, float arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateInt(int arg0, int arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateInt(String arg0, int arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateLong(int arg0, long arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateLong(String arg0, long arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateNCharacterStream(int arg0, Reader arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateNCharacterStream(String arg0, Reader arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateNCharacterStream(int arg0, Reader arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateNCharacterStream(String arg0, Reader arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateNClob(int arg0, NClob arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateNClob(String arg0, NClob arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateNClob(int arg0, Reader arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateNClob(String arg0, Reader arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateNClob(int arg0, Reader arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateNClob(String arg0, Reader arg1, long arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateNString(int arg0, String arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateNString(String arg0, String arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void updateNull(int arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @throws SQLException
+     */
+    public void updateNull(String arg0) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateObject(int arg0, Object arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateObject(String arg0, Object arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateObject(int arg0, Object arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @param arg2
+     * @throws SQLException
+     */
+    public void updateObject(String arg0, Object arg1, int arg2) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateRef(int arg0, Ref arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateRef(String arg0, Ref arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @throws SQLException
+     */
+    public void updateRow() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateRowId(int arg0, RowId arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateRowId(String arg0, RowId arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateSQLXML(int arg0, SQLXML arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateSQLXML(String arg0, SQLXML arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateShort(int arg0, short arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateShort(String arg0, short arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateString(int arg0, String arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateString(String arg0, String arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateTime(int arg0, Time arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateTime(String arg0, Time arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateTimestamp(int arg0, Timestamp arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @param arg0
+     * @param arg1
+     * @throws SQLException
+     */
+    public void updateTimestamp(String arg0, Timestamp arg1) throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+    /**
+     * @return
+     * @throws SQLException
+     */
+    public boolean wasNull() throws SQLException
+    {
+        throw new UnsupportedOperationException("method not supported");
+    }
+
+}



Mime
View raw message