Wie fügt man JSON mit der Java API in die Cassandra Datenbank ein?

Question

Dies ist der Code, mit dem ich mein Programm geschrieben habe, aber es gibt Fehler - bitte geben Sie uns einige Vorschläge mit dem korrigierten Code.

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

Die Fehler werden auf diese einer Aussage gerichtet, so dachte ich, dass es nicht notwendig, den gesamten Code here.TABLE Anwender präsentiert werden bereits in der cassandra Datenbank mit den Spalten-ID, Alter und Zustand geschaffen. Ich konnte nirgendwo eine richtige Antwort für dieses Problem finden, ich hoffe mein Problem ist hier gelöst.

Answer 1

hier die Arbeits Abfrage und unter Java-Code, wo ich es einfügen und die Ergebnisse

"INTO Benutzer JSON INSERT‚{\ "id \": 888, \ "age \": 21, \" Zustand \ ": \" 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); 
} 

}

Ergebnis

cqlsh: mykeyspace> select * from Benutzer;

ID | Alter | Zustand ------ + ----- + -------

1745 | 12 | smith

123 | 21 | TX

888 | 21 | TX