How to insert JSON into cassandra database using java API?

Question

This is the code I have used for writing my program but there are errors - please give us some suggestions with the corrected code.

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

The errors are directed to this one statement so I thought that its not necessary to present the whole code here.TABLE users has already been created in the cassandra database with the columns id, age and state. I could not find any proper answers for this problem anywhere, I hope my problem is solved here.

vindev · Accepted Answer · 2018-03-15 07:57:41Z

2

Here is the working query and below java code where I insert it and the results

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

}

Result

cqlsh:mykeyspace> select * from users;

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

edited Mar 15, 2018 at 7:57

vindev

2,2802 gold badges15 silver badges20 bronze badges

answered May 14, 2016 at 10:29

likeToCode

8522 gold badges10 silver badges20 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How to insert JSON into cassandra database using java API?

1 Answer 1

Result

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Result

Comments

Your Answer

Sign up or log in

Post as a guest

Related