如何使用 java API 将 JSON 插入 cassandra 数据库？

【问题标题】：How to insert JSON into cassandra database using java API?如何使用 java API 将 JSON 插入 cassandra 数据库？
【发布时间】：2016-09-10 12:50:31
【问题描述】：

这是我用来编写程序的代码，但有错误 - 请给我们一些建议，并提供更正的代码。

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

错误指向这一语句，所以我认为没有必要在这里展示整个代码。TABLE 用户已经在 cassandra 数据库中创建，列有 id、age 和 state。我在任何地方都找不到这个问题的任何正确答案，我希望我的问题在这里得到解决。

【问题讨论】：

标签： java json cassandra

【解决方案1】：

这是工作查询，下面是我插入它的 java 代码和结果

"INSERT INTO users JSON '{\"id\":888 , \"age\":21 ,\"state\":\"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 users;

 id   | age | state
------+-----+-------
 1745 |  12 | smith
  123 |  21 |    TX
  888 |  21 |    TX

【讨论】：