java - com.datastax.driver.core.exceptions.InvalidQueryException 使用 Datastax Java 驱动程序

Question

我从 CLI 中创建了这样的列族-

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);

    }

我总是遇到这个异常-

com.datastax.driver.core.exceptions.InvalidQueryException: unconfigured columnfamily profile

通过这种方式，我尝试使用 Datastax java 驱动程序创建到 Cassandra 的连接/ session 初始化-

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。我面临的唯一问题是插入时。

我想知道的是我是否可以使用 Datastax Java 驱动程序插入列族(我从 CLI 模式创建)？一旦我尝试插入我在 CLI 模式下创建的 Column Family，我总是会遇到上述异常。

但是如果我尝试插入到我在 CQLsh 模式 中创建的另一个表中，我可以插入到该表中。

我们将不胜感激。

Answer 1

我的猜测:您的 CLI 列族位于不同的键空间中。