Connection to Cassandra

[Devendra Mahajan]

How to use LightLink with Cassandra & CQL3. Using Java Driver provided by Datastax Cassandra.

[Vitaliy Shevchuk]

Hello, 

You can try using Cassandra JDBC driver. 

http://dbeaver.jkiss.org/2012/12/05/cassandra-driver/

https://code.google.com/archive/a/apache-extras.org/p/cassandra-jdbc

It should work.

The native Cassandra Java driver support is not implemented yet, but I would be find it very intresting to do so. 

Maybe if you can help with use cases and beta testing, we can get it running quite quickly ? 

Regards,

Vitaliy

[Devendra Mahajan]

Yes, Sure.

[Devendra Mahajan]

Tried JDBC Driver but facing issue CQL3. 

Getting this error,

Exception in thread "main" org.springframework.jdbc.BadSqlGrammarException: PreparedStatementCallback; bad SQL grammar [SELECT site_id, site_name FROM site_master]; nested exception is java.sql.SQLSyntaxErrorException: InvalidRequestException(why:CQL2 has been removed in Cassandra 3.0. Please use CQL3 instead)

at org.springframework.jdbc.support.SQLExceptionSubclassTranslator.doTranslate(SQLExceptionSubclassTranslator.java:91)

at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:73)

at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:81)

at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:660)

at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:695)

at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:722)

at org.springframework.jdbc.core.JdbcTemplate.query(JdbcTemplate.java:772)

at org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate.query(NamedParameterJdbcTemplate.java:192)

at org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate.query(NamedParameterJdbcTemplate.java:204)

at com.rein.Application.main(Application.java:21)

Caused by: java.sql.SQLSyntaxErrorException: InvalidRequestException(why:CQL2 has been removed in Cassandra 3.0. Please use CQL3 instead)

at org.apache.cassandra.cql.jdbc.CassandraPreparedStatement.<init>(CassandraPreparedStatement.java:103)

at org.apache.cassandra.cql.jdbc.CassandraConnection.prepareStatement(CassandraConnection.java:388)

at org.apache.cassandra.cql.jdbc.CassandraConnection.prepareStatement(CassandraConnection.java:372)

at org.apache.cassandra.cql.jdbc.CassandraConnection.prepareStatement(CassandraConnection.java:50)

at org.springframework.jdbc.core.PreparedStatementCreatorFactory$PreparedStatementCreatorImpl.createPreparedStatement(PreparedStatementCreatorFactory.java:238)

at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:638)

... 6 more

Caused by: InvalidRequestException(why:CQL2 has been removed in Cassandra 3.0. Please use CQL3 instead)

at org.apache.cassandra.thrift.Cassandra$prepare_cql_query_result.read(Cassandra.java:38738)

at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)

at org.apache.cassandra.thrift.Cassandra$Client.recv_prepare_cql_query(Cassandra.java:1598)

at org.apache.cassandra.thrift.Cassandra$Client.prepare_cql_query(Cassandra.java:1584)

at org.apache.cassandra.cql.jdbc.CassandraConnection.prepare(CassandraConnection.java:518)

at org.apache.cassandra.cql.jdbc.CassandraConnection.prepare(CassandraConnection.java:532)

at org.apache.cassandra.cql.jdbc.CassandraPreparedStatement.<init>(CassandraPreparedStatement.java:96)

... 11 more