0
package com.nokia.main;

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;

/*
 cassandra.contactpoints=localhost,127.0.0.1
 cassandra.port=9042
 cassandra.keyspace=ranga*/
public class CassandraConnection {
    public static void main(String[] args) {
        String serverIp = "127.0.0.1";
        String keyspace = "ranga";
        CassandraConnection connection;

        Cluster cluster = Cluster.builder().addContactPoints(serverIp).build();

        Session session = cluster.connect(keyspace);

        String cqlStatement = "SELECT * FROM employee";
        for (Row row : session.execute(cqlStatement)) {
            System.out.println(row.toString());
        }

    }

}

So and getting Exception Exception in thread "main" com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:9042 (com.datastax.driver.core.exceptions.InvalidQueryException: unconfigure

4
  • Is Cassandra running on localhost? Is native/binary transport (tcp/9042) listening on 127.0.0.1? Commented Jan 25, 2017 at 4:14
  • Please provide complete exception message. Seems the (com.datastax.driver.core.exceptions.InvalidQueryException: unconfigure .....) is incomplete message. Commented Jan 25, 2017 at 5:05
  • Possible duplicate to -- stackoverflow.com/questions/16136525/… Commented Jan 25, 2017 at 5:06
  • Now my code is working fine and add in below mentioned dependency------------------- <dependency> <groupId>com.datastax.cassandra</groupId> <artifactId>cassandra-driver-core</artifactId> <version>3.1.3</version> </dependency> <dependency> <groupId>com.datastax.cassandra</groupId> <artifactId>cassandra-driver-mapping</artifactId> <version>3.1.3</version> </dependency> <dependency> <groupId>com.datastax.cassandra</groupId> <artifactId>cassandra-driver-extras</artifactId> <version>3.1.3</version> </dependency> Commented Jan 25, 2017 at 8:13

0

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.