Как спасти Кассандру из Явы?

Question

Я новичок в Cassandra и работаю над проектом, который использует Cassandra в качестве базы данных.Cassandra установлена ​​на другом устройстве, и мне придется сохранить его на БД удаленно.

У меня мало знаний о Cassandra и ее функциях, но я хорошо разбираюсь в MySQL.

Какие шаги нужно предпринять, чтобы сохранить сообщение в Cassandra?Могу ли я использовать ту же базу данных, что и в MySQL?

Я считаю, что мне придется подключиться к серверу Cassandra и затем сохранить его.

Cluster cluster = Cluster.builder().addContactPoint("localhost").withPort(3306).build();

Я использовал это утверждение дляподключиться к Кассандре.(замена localhost на ip устройства)

Answer 1

Создайте сеанс с созданным кластером и пространством ключей:

Session session = cluster.connect("keyspace");

создайте пространство ключей, если у вас его нет.

, затем используйте

session.execute(query);

чтобы выполнить любой запрос по вашему выбору.

запрос должен быть строковым, а не нулевым.

например:

    String query= "INSERT INTO keyspace.table_name (id, lastname, firstname) VALUES (6ab09bec-e68e-48d9-a5f8-97e6fb4c9b47, 'KRUIKSWIJK','Steven');";
    session.execute(query);

Answer 2

Лучше всего начинать с документации java драйвера .Если вы используете maven, его довольно легко настроить, но я часто нахожу, что примеры не всегда дают полный pom.xml, поэтому вы можете использовать некоторые из примеров в проекте github

Краткое руководство по дает очень простой пример:

Cluster cluster = null;
try {
    cluster = Cluster.builder()   
            .addContactPoint("127.0.0.1")
            .build();
    Session session = cluster.connect();   
    ResultSet rs = session.execute("select release_version from system.local");
    Row row = rs.one();
    System.out.println(row.getString("release_version"));
} finally {
    if (cluster != null) cluster.close();
}

Другими интересными объектами являются пул соединений и балансировка нагрузки