Я создал столбец семью, как это от CLI-com.datastax.driver.core.exceptions.InvalidQueryException используя драйвер Datastax Java
create column family profile
with key_validation_class = 'UTF8Type'
and comparator = 'UTF8Type'
and default_validation_class = 'UTF8Type'
and column_metadata = [
{column_name : account, validation_class : 'UTF8Type'}
{column_name : advertising, validation_class : 'UTF8Type'}
{column_name : behavior, validation_class : 'UTF8Type'}
{column_name : info, validation_class : 'UTF8Type'}
];
Теперь я пытался вставить в эту семью на колонке с использованием Datastax Java функции драйвера
public void upsertAttributes(final String userId, final Map<String, String> attributes) {
String batchInsert = "INSERT INTO PROFILE(id, account, advertising, behavior, info) VALUES ('12345', 'hello11', 'bye2234', 'bye1', 'bye2') ";
CassandraDatastaxConnection.getInstance().getSession().execute(batchInsert);
}
Я всегда получаю эту exception-
com.datastax.driver.core.exceptions.InvalidQ ueryException: несконфигурированным ColumnFamily профиль
И таким образом, я пытаюсь создать инициализации соединения/сеанса Cassandra с помощью Datastax Java
функции драйвераprivate CassandraDatastaxConnection() {
try{
cluster = Cluster.builder().addContactPoint("localhost").build();
session = cluster.connect("my_keyspace");
} catch (NoHostAvailableException e) {
throw new RuntimeException(e);
}
}
Я бегу Cassandra 1.2.3. И я могу подключиться к Cassandra, используя вышеприведенный код. Единственная проблема, с которой я столкнулся, - это вставлять.
Я хотел бы знать, могу ли я вставлять в семейство столбцов (которые я создал из режима CLI) с помощью драйвера Java Datastax или нет? Как только я пытаюсь вставить в Column Family, который я создал в режиме CLI, я всегда получаю исключение выше.
Но если я попытаюсь вставить в другую таблицу, которую я создал в CQLsh mode
, я могу вставить в нее.
Любая помощь будет оценена по достоинству.