Какой должна быть строка подключения при использовании драйвера CQL jdbc - PullRequest
8 голосов
/ 07 октября 2011

Какой должна быть строка подключения при использовании драйвера CQL jdbc?

Смогу ли я найти подходящий / полный пример для CQL с использованием драйвера CQL JDBC в Java онлайн?

Ответы [ 2 ]

12 голосов
/ 07 октября 2011

Вам понадобится jar cql с сайта apache.

Вот базовый тест, который я использовал после ввода данных через CLI (используя пример из вики):

public class CqlJdbcTestBasic {
public static void main(String[] args) {
    Connection con = null;
    try {
        Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver");
        con = DriverManager.getConnection("jdbc:cassandra:root/root@localhost:9160/MyKeyspace");

        String query = "SELECT KEY, 'first', last FROM User WHERE age=42";

        Statement stmt = con.createStatement();
        ResultSet result = stmt.executeQuery(query);

        while (result.next()) {
            System.out.println(result.getString("KEY"));
            System.out.println(result.getString("first"));
            System.out.println(result.getString("last"));
        }

    } catch (ClassNotFoundException e) {
        e.printStackTrace();
    } catch (SQLException e) {
        e.printStackTrace();
    } finally {
        if (con != null) {
            try {
                con.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            con = null;
        }
    }
}
}

Пользователь / пароль (root / root) кажется произвольным, просто обязательно укажите Keyspace (MyKeyspace)

Заметьте, 'first' указан в строке запроса, потому что это ключевое слово CQL

2 голосов
/ 27 марта 2013

Вы также можете попробовать использовать драйвер cassandra-jdbc из http://code.google.com/a/apache-extras.org/p/cassandra-jdbc/.

В качестве альтернативы, используя следующую зависимость maven:

<dependency>
    <groupId>org.apache-extras.cassandra-jdbc</groupId>
    <artifactId>cassandra-jdbc</artifactId>
    <version>1.2.1</version>
</dependency>
...