如何使用Java API將JSON插入cassandra數據庫？

這是我用來編寫我的程序的代碼，但有錯誤 - 請給我們一些建議，更正的代碼。如何使用Java API將JSON插入cassandra數據庫？

session.execute("INSERT INTO users JSON '{'id':'user123' , 'age':21 ,'state':'TX'}';");

的錯誤是針對這個說法，所以我認爲它沒有必要展示整個代碼here.TABLE用戶已經在擁有ID，年齡和狀態卡桑德拉數據庫中創建。我無法在任何地方找到任何適當的答案，我希望我的問題在這裏得到解決。

來源

2016-05-14 liam

在這裏，工作查詢及以下的Java代碼，我將其插入，結果

「INSERT INTO用戶JSON「{\ 」ID \「 888 \ 」年齡\「：21 \」狀態\ 「：\」 TX \ 「}'」;

import com.datastax.driver.core.Cluster; 
import com.datastax.driver.core.Row; 
import com.datastax.driver.core.Session; 

public class CasandarConnect { 

public static void main(String[] args) { 
    String serverIP = "127.0.0.1"; 
    String keyspace = "mykeyspace"; 

    Cluster cluster = Cluster.builder() 
     .addContactPoints(serverIP) 
     .build(); 

    Session session = cluster.connect(keyspace); 

    String cqlStatement = "INSERT INTO users JSON '{\"id\":888 , \"age\":21 ,\"state\":\"TX\"}'"; 
    session.execute(cqlStatement); 
}

}

結果

cqlsh：mykeyspace> SELECT * FROM用戶;

id |年齡|狀態 ------ + ----- + -------

1745 | 12 |史密斯

123 | 21 | TX

888 | 21 | TX

來源

2016-05-14 10:29:15 likeToCode

如何使用Java API將JSON插入cassandra數據庫？

回答

相關問題