You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ee...@apache.org on 2011/02/10 23:34:05 UTC
svn commit: r1069593 [1/2] - in /cassandra/trunk: ./
drivers/java/src/org/apache/cassandra/cql/driver/jdbc/ drivers/java/test/
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");
+ }
+
+}