[
https://issues.apache.org/jira/browse/CASSANDRA-2734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13043270#comment-13043270
]
Aaron Morton commented on CASSANDRA-2734:
-----------------------------------------
I think there is a reasonable case for handling it better, it just may be out
of scope for the current CQL dev cycle.
Imagine long running code, a schema change, and a situation where the code does
not have to be restarted to start executing queries using the new or modified
CF's. Or imagine creating a Query Tool for cassandra like other DB's have,
where DDL and DML statement are run.
Jonathan, in the future could we include the schema id in the query response
and in the response when the client reads the schema (currently
describe_keyspaces). Then we could invalidate the client side meta data.
I'll take another look at the column count example.
> NPE running res.next() for a select statement
> ---------------------------------------------
>
> Key: CASSANDRA-2734
> URL: https://issues.apache.org/jira/browse/CASSANDRA-2734
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.8.0 beta 2
> Reporter: Cathy Daw
> Assignee: Aaron Morton
> Priority: Minor
> Labels: cql
>
> *The following statement fails when used with a Statement or
> PreparedStatement*
> {code}
> res = stmt.executeQuery("SELECT bar FROM users");
> res.next();
> {code}
> *Error Message*
> {code}
> [junit] Testcase: simpleSelect(com.datastax.cql.reproBugTest): Caused
> an ERROR
> [junit] null
> [junit] java.lang.NullPointerException
> [junit] at
> org.apache.cassandra.cql.jdbc.ColumnDecoder.makeKeyColumn(ColumnDecoder.java:136)
> [junit] at
> org.apache.cassandra.cql.jdbc.CResultSet.next(CResultSet.java:388)
> [junit] at
> com.datastax.cql.reproBugTest.simpleSelect(reproBugTest.java:57)
> [junit]
> [junit]
> [junit] Test com.datastax.cql.reproBugTest FAILED
> {code}
> *Here is a quick repro. Showing that res.next() works with other statements
> but not select.*
> _Also notice that ResultSet.getMetaData().getColumnCount() always returns
> zero._
> _I noticed in the existing driver tests similar test cases, so not sure the
> issue._
> *Steps to run script*
> * you will need to drop this in your test directory
> * change the package declaration
> * ant test -Dtest.name=reproBugTest
> {code}
> package com.datastax.cql;
> import java.sql.DriverManager;
> import java.sql.Connection;
> import java.sql.ResultSet;
> import java.sql.SQLException;
> import java.sql.Statement;
> import org.junit.Test;
> public class reproBugTest {
>
> @Test
> public void simpleSelect() throws Exception {
> Connection connection = null;
> ResultSet res;
> Statement stmt;
> int colCount = 0;
>
> try {
> Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver");
>
> // Check create keyspace
> connection =
> DriverManager.getConnection("jdbc:cassandra:root/[email protected]:9160/default");
>
> stmt = connection.createStatement();
> try {
> System.out.println("Running DROP KS Statement");
> res = stmt.executeQuery("DROP KEYSPACE ks1");
> res.next();
>
> System.out.println("Running CREATE KS Statement");
> res = stmt.executeQuery("CREATE KEYSPACE ks1 with
> strategy_class = 'org.apache.cassandra.locator.SimpleStrategy' and
> strategy_options:replication_factor=1");
> res.next();
> } catch (SQLException e) {
> if (e.getMessage().startsWith("Keyspace does not exist"))
> {
> res = stmt.executeQuery("CREATE KEYSPACE ks1 with
> strategy_class = 'org.apache.cassandra.locator.SimpleStrategy' and
> strategy_options:replication_factor=1");
> }
> }
> connection.close();
>
> // Run Test
> connection =
> DriverManager.getConnection("jdbc:cassandra:root/[email protected]:9160/ks1");
>
> stmt = connection.createStatement();
> System.out.print("Running CREATE CF Statement");
> res = stmt.executeQuery("CREATE COLUMNFAMILY users (KEY varchar
> PRIMARY KEY, password varchar, gender varchar, session_token varchar, state
> varchar, birth_year bigint)");
> colCount = res.getMetaData().getColumnCount();
> System.out.println(" -- Column Count: " + colCount);
> res.next();
>
> System.out.print("Running INSERT Statement");
> res = stmt.executeQuery("INSERT INTO users (KEY, password) VALUES
> ('user1', 'ch@nge')");
> colCount = res.getMetaData().getColumnCount();
> System.out.println(" -- Column Count: " + colCount);
> res.next();
>
> System.out.print("Running SELECT Statement");
> res = stmt.executeQuery("SELECT bar FROM users");
> colCount = res.getMetaData().getColumnCount();
> System.out.println(" -- Column Count: " + colCount);
> res.getRow();
> res.next();
>
> connection.close();
> } catch (SQLException e) {
> e.printStackTrace();
> }
> }
>
> }
> {code}
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
