com.datastax.driver.core.exceptions.InvalidQueryException使用Datastax Java驅動程序

我創造了我的專欄的家人像這樣從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輪廓

而且通過這種方式，我想創建連接/會話初始化使用卡桑德拉Datastax Java來驅動程序 -

private CassandraDatastaxConnection() { 

    try{ 
    cluster = Cluster.builder().addContactPoint("localhost").build(); 
    session = cluster.connect("my_keyspace");   
    } catch (NoHostAvailableException e) { 

      throw new RuntimeException(e); 
    } 
}

我正在卡桑德拉1.2.3。我可以使用上面的代碼連接到Cassandra。我面臨的唯一問題是插入時。

，我想知道的是我是否能插入列族（即我從CLI模式創建）使用Datastax Java驅動程序或沒有？只要我試圖插入我在CLI模式下創建的Column Family，我總是會得到上述異常。

，但如果我嘗試插入，我在CQLsh mode已創建的另一個表，我能夠插入到這一點。

任何幫助將不勝感激。

來源

2013-04-21 ferhan

我的猜測：你的CLI columnfamilies是在一個不同的密鑰空間。

來源

2013-04-22 18:26:36 jbellis

com.datastax.driver.core.exceptions.InvalidQueryException使用Datastax Java驅動程序

回答

相關問題