Beispiel zur Verwendung der Karte cql-Typ mit dem DataStax java-Treiber

Ich versuche, mit dem datastax java-Treiber zu aktualisieren und die Abfrage eine Spalte mit der Familie, eine Karte-Feld. Hat jemand ein Beispiel zur Verwendung der cql-Sammlungen mit dem Datastax Java-Treiber?

Dank

InformationsquelleAutor ftrujillo | 2013-12-03

  1. 5

    Will ich hinzufügen, einige Beispiele für die Verwendung der CQL-Sammlungen mit einfachen und prepared statements zu den aktuellen Java-Treiber-doc.

    Können Sie CQL-Sammlungen mit vorbereiteten Anweisungen sind. Es gibt ein Beispiel in der Java-Treiber-doc in der Schnellstart-Abschnitt.

    http://docs.datastax.com/en/developer/java-driver/2.0/java-driver/quick_start/qsSimpleClientBoundStatements_t.html

    Schritt 4 bindet ein Java-HashSet-Objekt zu einer CQL-set-Spalte in der Lieder-Tabelle.

    OK, ich aktualisiert die Java-Treiber-docs hinzufügen, ein Thema auf diese.
    vielen Dank für die updates der DataStax docs!
    Der link ist leider down
    Link down ist in der Zukunft nicht einen link posten, ohne sich mit den relevanten Codeausschnitt, falls der link down geht.

    InformationsquelleAutor Jim Bisso

  2. 4

    Normalerweise würde ich Fragen, was Sie versucht haben, aber ich weiß, dass dies nicht in der DataStax Dokumentation für die Java-Treiber. Werde ich gehen Sie durch, was für mich gearbeitet.

    Ein paar Dinge zu beachten:

    • Der DataStax Cassandra Java-Klasse verwiesen mich an meine Variablen direkt in die CQL-text (anstelle der Bindung der Karte). Ich vermute, dass die Bindung Sammlungen nicht funktioniert zu der Zeit der Produktion (für die Klasse videos).
    • Sammlungen können nicht abgefragt werden mit DevCenter, so müssen Sie überprüfen Sie Ihre Werte über die Kommandozeile mit cqlsh wenn Sie möchten, um zu sehen, was Sie außerhalb Ihrer app.

    Aktualisieren einer vorhandenen Zeile (in der "users" - Tabelle, die eine Map<varchar,varchar> phone_numbers), versuchen Sie so etwas wie dieses:

    String cqlQuery = "UPDATE users SET phone_numbers = phone_numbers + ";
cqlQuery += "{'" + phoneType + "':'" + phoneNumber+ "'} ";
cqlQuery += "WHERE username = ?";

PreparedStatement preparedStatement = getSession().prepare(cqlQuery);
BoundStatement boundStatement = preparedStatement.bind(user);
getSession().execute(boundStatement);

    Besseren Weg, dies zu tun (unter der Annahme einer Map<String,String> phoneNumbers), binden die Sammlung, um die vorbereitete Anweisung wie diese:

    String cqlQuery = "UPDATE users SET phone_numbers = ? ";
cqlQuery += "WHERE username = ?";

PreparedStatement preparedStatement = getSession().prepare(cqlQuery);
BoundStatement boundStatement = preparedStatement.bind(phoneNumbers,user);
getSession().execute(boundStatement);

    Ebenfalls, Lesen Sie es wieder aus:

    String cqlQuery2 = "SELECT phone_numbers FROM users WHERE username = ?";

PreparedStatement preparedStatement2 = getSession().prepare(cqlQuery2);
BoundStatement boundStatement2 = preparedStatement2.bind(user);
ResultSet result2 = getSession().execute(boundStatement2);

Map<String,String> newMap = result2.one().getMap("phone_numbers", String.class, String.class);

    Bedeckten kaum das heute in der (freien) CAS101J Klasse auf DataStax Akademie.

    Die Dokumentation ist aktualisiert, schauen Sie hier:datastax.com/documentation/developer/java-driver/1.0/webhelp/...

    InformationsquelleAutor Aaron

  3. 0

    Hier ist, wie ich es Tat; Diese hat-mapping für ein Tupel Spalte in Kassandra sowie die anzeigen-Spalte von Cassandra. Ich war mit Scala mit der DataStax Cassandra Java-Treiber

    Benötigte Einfuhren

    import java.lang
import java.text.SimpleDateFormat

import com.datastax.driver.core._
import com.datastax.driver.core.querybuilder.QueryBuilder

import scala.collection.Map
import org.apache.spark.SparkContext
import org.apache.spark.SparkConf
import com.datastax.spark.connector.cql.CassandraConnector
import org.apache.spark.rdd.RDD
import scala.collection.JavaConversions._

    Code-snippet

    val simpleDateFormat: SimpleDateFormat = new SimpleDateFormat("dd-MM-yyyy H:mm:ss")
val start_date: java.util.Date = simpleDateFormat.parse(val("StartTime").replaceAll(":(\\s+)", ":"))

val b_tuple= session.getCluster().getMetadata().newTupleType(DataType.cint(), DataType.cint(), DataType.text())
val time_tuple = session.getCluster().getMetadata().newTupleType(DataType.timestamp(), DataType.timestamp())

val time_tuple_value = time_tuple.newValue(start_date, end_date)
val b_tuple_value = bin_cell_tuple.newValue(b._1: lang.Integer, b._2: lang.Integer, val("xxx"))

val statement_2: Statement = QueryBuilder.insertInto("keyspace", "table_name")
          .value("b_key", bin_cell_tuple_value)
          .value("time_key", time_tuple_value)
          .value("some_map", mapAsJavaMap(my_scala_map))
session.executeAsync(statement_2)

    InformationsquelleAutor Alex Punnen

Schreibe einen Kommentar