Mailing-List: contact commits-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@cassandra.apache.org
Date: Sun, 21 Aug 2011 17:11:27 +0000 (UTC)
From: "Rick Shaw (JIRA)" <jira@apache.org>
To: commits@cassandra.apache.org
Message-ID: 
 <870502346.56760.1313946687270.JavaMail.tomcat@hel.zones.apache.org>
In-Reply-To: 
 <1433846415.47532.1313631209461.JavaMail.tomcat@hel.zones.apache.org>
Subject: [jira] [Updated] (CASSANDRA-3052) CQL: ResultSet.next() gives NPE
 when run after an INSERT or CREATE statement
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


     [ https://issues.apache.org/jira/browse/CASSANDRA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Rick Shaw updated CASSANDRA-3052:
---------------------------------

    Attachment: statement-improper-result.txt

Patch checks to make sure the intended result is returned from the various {{execute}} method variants. 

> CQL: ResultSet.next() gives NPE when run after an INSERT or CREATE statement
> ----------------------------------------------------------------------------
>
>                 Key: CASSANDRA-3052
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-3052
>             Project: Cassandra
>          Issue Type: Bug
>    Affects Versions: 0.8.4
>            Reporter: Cathy Daw
>              Labels: JDBC, cql
>             Fix For: 0.8.5
>
>         Attachments: statement-improper-result.txt
>
>
> This test script used to work until I upgraded the jdbc driver to 1.0.4.
> *CQL 1.0.4*: apache-cassandra-cql-1.0.4-SNAPSHOT.jar build at revision 1158979
> *Repro Script*: 
> * drop in test directory, change package declaration and run:  ant test -Dtest.name=resultSetNPE
> * The script gives you a NullPointerException when you uncomment out the following lines after a CREATE or INSERT statement.
> {code}
> colCount = res.getMetaData().getColumnCount();
> res.next();
> {code}
> * Please note that there is no need to comment out those lines if a SELECT statement was run prior.
> {code}
> package com.datastax.bugs;
> 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 resultSetNPE {
>     
>     @Test
>     public void createKS() throws Exception {   
>         Connection initConn = null;
>         Connection connection = null;
>         ResultSet res;
>         Statement stmt;
>         int colCount = 0;
>         
>         Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver");
>         
>         // Check create keyspace
>         initConn = DriverManager.getConnection("jdbc:cassandra://127.0.0.1:9160/default");     
>         stmt = initConn.createStatement();
>         try {
>           System.out.println("Running DROP KS Statement");  
>           res = stmt.executeQuery("DROP KEYSPACE ks1");  
>           // res.next();
>           
>         } catch (SQLException e) {
>             if (e.getMessage().startsWith("Keyspace does not exist")) 
>             {
>                 // Do nothing - this just means you tried to drop something that was not there.
>                 // res = stmt.executeQuery("CREATE KEYSPACE ks1 with strategy_class =  'org.apache.cassandra.locator.SimpleStrategy' and strategy_options:replication_factor=1");  
>             } 
>         }   
>           
>         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();
>         initConn.close();    
>     }  
>  
>     @Test
>     public void createCF() throws Exception 
>     {   
>         Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver");
>         int colCount = 0;
>         Connection connection = DriverManager.getConnection("jdbc:cassandra://127.0.0.1:9160/ks1");     
>         Statement stmt = connection.createStatement();
>         System.out.print("Running CREATE CF Statement");
>         ResultSet 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();
>         
>         connection.close();               
>     }  
>     
>     @Test
>     public void simpleSelect() throws Exception 
>     {   
>         Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver");
>         int colCount = 0;
>         Connection connection = DriverManager.getConnection("jdbc:cassandra://127.0.0.1:9160/ks1");     
>         Statement stmt = connection.createStatement();
>         
>         System.out.print("Running INSERT Statement");
>         ResultSet 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 KEY, gender, state FROM users");  
>         colCount = res.getMetaData().getColumnCount();
>         System.out.println(" -- Column Count: " + colCount); 
>         res.getRow();
>         res.next();
>             
>         connection.close(); 
>     }  
> }
> {code}

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira