DataStax Support Forums » User Favorites: hsliberato

DataStax Support Forums » User Favorites: hsliberato hsliberato Software, Support, and Training for Apache Cassandra en-US Thu, 20 Jun 2013 00:52:44 +0000 http://bbpress.org/?v=1.0.3 <![CDATA[Search]]> q http://www.datastax.com/support-forums/search.php affy on "Cassandra-JDBC 1.1.2: cannot create KEYSPACE on Cassandra 1.2 using CQL 3 syntax" http://www.datastax.com/support-forums/topic/cassandra-jdbc-112-cannot-create-keyspace-on-cassandra-12-using-cql-3-syntax#post-9176 Wed, 27 Feb 2013 04:05:00 +0000 affy 9176@http://www.datastax.com/support-forums/ I downloaded source files and complied them in IDE, I then used jar command to create the jar file manually. Some other jar files are needed to compile these source files, and fortunately, the project I am working on has all of required jar files included. You likely can find all of dependent jar files from here: <a href="http://cassandra.apache.org/download/" rel="nofollow">http://cassandra.apache.org/download/</a>. hsliberato on "Cassandra-JDBC 1.1.2: cannot create KEYSPACE on Cassandra 1.2 using CQL 3 syntax" http://www.datastax.com/support-forums/topic/cassandra-jdbc-112-cannot-create-keyspace-on-cassandra-12-using-cql-3-syntax#post-9079 Wed, 20 Feb 2013 12:14:43 +0000 hsliberato 9079@http://www.datastax.com/support-forums/ Hi guys, I have the same problem. How can I build a .jar file from this URL? affy on "Cassandra-JDBC 1.1.2: cannot create KEYSPACE on Cassandra 1.2 using CQL 3 syntax" http://www.datastax.com/support-forums/topic/cassandra-jdbc-112-cannot-create-keyspace-on-cassandra-12-using-cql-3-syntax#post-8963 Thu, 07 Feb 2013 01:18:29 +0000 affy 8963@http://www.datastax.com/support-forums/ Thanks for helping out. I built Cassandra-JDBC from the URL mentioned above, and it works with Cassandra 1.2. By the way, is there any plan to create a Cassandra-JDBC-1.2.* jar file and make it publicly available? Julien.Campan on "Cassandra-JDBC 1.1.2: cannot create KEYSPACE on Cassandra 1.2 using CQL 3 syntax" http://www.datastax.com/support-forums/topic/cassandra-jdbc-112-cannot-create-keyspace-on-cassandra-12-using-cql-3-syntax#post-8936 Wed, 06 Feb 2013 08:28:19 +0000 Julien.Campan 8936@http://www.datastax.com/support-forums/ Hello, if you want to use Cassandra-JDBC driver with Cassandra 1.2.x , you have to download the trunk version of Cassandra-JDBC. You can find it and build it in <a href="https://code.google.com/a/apache-extras.org/p/cassandra-jdbc/source/browse/?name=trunk#git%2Fsrc%2Fmain" rel="nofollow">https://code.google.com/a/apache-extras.org/p/cassandra-jdbc/source/browse/?name=trunk#git%2Fsrc%2Fmain</a> You will have a cassandra-jdbc-1.2.0-SNAPSHOT.jar and this one is compatible with cassandra 1.2.x. affy on "Cassandra-JDBC 1.1.2: cannot create KEYSPACE on Cassandra 1.2 using CQL 3 syntax" http://www.datastax.com/support-forums/topic/cassandra-jdbc-112-cannot-create-keyspace-on-cassandra-12-using-cql-3-syntax#post-8930 Wed, 06 Feb 2013 01:46:02 +0000 affy 8930@http://www.datastax.com/support-forums/ I am new to Cassandra. I have a Cassandra 1.2 installed on a Linux box (java 1.6.0_38) which is configured to AllowAllAuthenticator. I also have a Java test program running on a Windows XP box (java 1.6.0_18) which tries to access Cassandra 1.2 using Cassandra-JDBC 1.1.2. The Java test program tries to execute two statements using CQL 3 syntax: (1) "CREATE KEYSPACE test_1 WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 3 };" (2) "SELECT keyspace_name, strategy_class FROM system.schema_keyspaces;"; Execution of (1) failed and the following exception is thrown: java.sql.SQLSyntaxErrorException: line 1:97 no viable alternative at character '}' at org.apache.cassandra.cql.jdbc.CassandraStatement.doExecute(CassandraStatement.java:179) at org.apache.cassandra.cql.jdbc.CassandraStatement.executeUpdate(CassandraStatement.java:236) at TestCassandraClient.executeDDL(TestCassandraClient.java:70) at TestCassandraClient.main(TestCassandraClient.java:41) Caused by: InvalidRequestException(why:line 1:97 no viable alternative at character '}') at org.apache.cassandra.thrift.Cassandra$execute_cql_query_result.read(Cassandra.java:36625) at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql_query(Cassandra.java:1525) at org.apache.cassandra.thrift.Cassandra$Client.execute_cql_query(Cassandra.java:1511) at org.apache.cassandra.cql.jdbc.CassandraConnection.execute(CassandraConnection.java:397) at org.apache.cassandra.cql.jdbc.CassandraConnection.execute(CassandraConnection.java:421) at org.apache.cassandra.cql.jdbc.CassandraStatement.doExecute(CassandraStatement.java:161) ... 3 more Execution of (2) succeeded. The URL used by the test program to create a java.sql.Connection is similar to the one shown below: "jdbc:cassandra://10.168.11.220:9160/system?version=3.0.0" The test program is a standalone Java program which only includes cassandra-jdbc-1.1.2.jar and jar files shipped with Cassandra 1.2 in its -classpath. The test program is included below FYI. I can execute (1) in 'cqlsh' without any problem. After (1) is executed in 'cqlsh', execute the test program again, the newly created test_1 KEYSPACE will be listed by (2) as shown below: ====== List Keyspace ====== Result 1: name=[test_1], class=[org.apache.cassandra.locator.SimpleStrategy] Result 2: name=[system_auth], class=[org.apache.cassandra.locator.SimpleStrategy] Result 3: name=[system], class=[org.apache.cassandra.locator.LocalStrategy] Result 4: name=[DEMO], class=[org.apache.cassandra.locator.NetworkTopologyStrategy] Result 5: name=[system_traces], class=[org.apache.cassandra.locator.SimpleStrategy] Total rows retrieved: 5 In 'cqlsh', after test_1 is created, I do 'DROP KEYSPACE test_1;' followed by 'SELECT * FROM system.schema_keyspaces;', test_1 won't be listed. However, if I execute the test program again, test_1 is still listed with NULL class, as shown below: ====== List Keyspace ====== Result 1: name=[test_1], class=[null] Result 2: name=[system_auth], class=[org.apache.cassandra.locator.SimpleStrategy] Result 3: name=[system], class=[org.apache.cassandra.locator.LocalStrategy] Result 4: name=[DEMO], class=[org.apache.cassandra.locator.NetworkTopologyStrategy] Result 5: name=[system_traces], class=[org.apache.cassandra.locator.SimpleStrategy] Total rows retrieved: 5 I have two questions and would appreciate if someone can help me out: (a) Does Cassandra-JDBC 1.1.2 work with Cassandra 1.2/CQL3? If it does, why a syntax error exception is thrown when (1) is executed in the test program? (b) If Cassandra-JDBC 1.1.2 does work with Cassandra 1.2/CQL3, why test_1 KEYSPACE is still included in the query result returned by (2) after it is dropped by 'cqlsh'? And, why test_1 is not reported by 'SELECT * FROM system.schema_keyspaces;' when executed in 'cqlsh'? Thanks <code> // ------ Below is the test program FYI ------ import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; import java.util.Properties; import org.apache.log4j.PropertyConfigurator; public class TestCassandraClient { public static void main(String[] args) { String host = "10.168.11.220"; String port = "9160"; String keyspace = "system"; for( int i=0; i<args.length; i++ ) { String argument = args[i]; if ( argument.equals("-h") ) { host = args[++i]; } else if ( argument.equals("-p") ) { port = args[++i]; } else if ( argument.equals("-k") ) { keyspace = args[++i]; } } String url = "jdbc:cassandra://" + host + ":" + port + "/" + keyspace + "?version=3.0.0"; debug("URL is being set to [" + url + "]"); initLogger(); Connection conn = null; Statement stmt = null; ResultSet rs = null; try { Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver"); conn = DriverManager.getConnection(url); debug("Connection to server established."); debug("------ Create Keyspace ------"); String ddl = "CREATE KEYSPACE test_1 WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 3 };"; executeDDL(conn, ddl); debug("====== List Keyspace ======"); String query = "SELECT keyspace_name, strategy_class FROM system.schema_keyspaces;"; stmt = conn.createStatement(); rs = stmt.executeQuery(query); int count = 0; while( rs.next() ) { ++count; String ksName = rs.getString(1); String ksClass = rs.getString(2); debug("Result " + count + ": name=[" + ksName + "], class=[" + ksClass + "]"); } debug("Total rows retrieved: " + count); } catch(Exception e) { e.printStackTrace(); } finally { close(rs); close(stmt); close(conn); } } private static void executeDDL(Connection conn, String ddl) { Statement stmt = null; try { debug("Executing DDL: [" + ddl + "]..."); stmt = conn.createStatement(); int rowCount = stmt.executeUpdate(ddl); debug("DDL executed, row count = " + rowCount); } catch(Throwable t) { debug("Failed to execute DDL:"); t.printStackTrace(); } finally { close(stmt); } } private static void close(ResultSet rs) { if ( rs != null ) { try { rs.close(); } catch(Throwable ignore) { } } } private static void close(Statement stmt) { if ( stmt != null ) { try { stmt.close(); } catch(Throwable ignore) { } } } private static void close(Connection conn) { if ( conn != null ) { try { conn.close(); } catch(Throwable ignore) { } } } private static void initLogger() { Properties p = new Properties(); p.setProperty("log4j.rootLogger", "warn, CONSOLE"); p.setProperty("log4j.appender.CONSOLE", "org.apache.log4j.ConsoleAppender"); p.setProperty("log4j.appender.CONSOLE.layout", "org.apache.log4j.PatternLayout"); PropertyConfigurator.configure(p); } private static void debug(String msg) { System.out.println(msg); } } </code>