3

こんにちは、複合キーを使用して、この種の列ファミリー行に挿入したいと思います。

CREATE TABLE my_items (
user_id uuid,
item_id uuid,
description varchar,
 PRIMARY KEY (user_id, item_id));

だから私はこれを試します：

StringSerializer stringSerializer = StringSerializer.get();
    UUIDSerializer uuidSerializer = UUIDSerializer.get();
    CompositeSerializer compositeSerializer = CompositeSerializer.get();

    HColumn<String, UUID> hColumnObj_userID = HFactory.createColumn("user_id", userID, stringSerializer, uuidSerializer);
    HColumn<String, UUID> hColumnObj_itemID= HFactory.createColumn("item_id", itemID, stringSerializer, uuidSerializer);

    Mutator<Composite> mutator = HFactory.createMutator(
            repository.getKeyspace(),
            compositeSerializer);
    Composite colKey = new Composite();
    colKey.addComponent(userID, uuidSerializer);
    colKey.addComponent(itemID, uuidSerializer);

    mutator.addInsertion(colKey,
            "my_items", hColumnObj_userID);
    mutator.addInsertion(colKey,
            "my_items", hColumnObj_itemID);

    mutator.execute();

上記のコードの何が問題になっていますか? 「InvalidRequestException(why:UUID は正確に 16 バイトである必要があります)」というエラーが表示され続けます。また、上記で説明した列ファミリーにデータを挿入するにはどうすればよいですか。

乾杯

4

1 に答える 1

7

Hector は、UUID と文字列を含む Composite を期待していたようですが、文字列しか見つかりませんでした。

Hector コードを記述する前に、create DDL を CQL が使用する実際のストレージ パターンに変換する必要があります。この場合、2 つの主キーがありますが、最初の user_id のみが行キーとして使用されます。それは常にそうです。その他の主キー (この場合は item_id) は、最初の主キーを除くすべての列の複合列名を形成するために使用されます。つまり、my_items 列ファミリーに Hector を使用する場合、item_ID 用と説明用の 2 つの列を作成する必要があります。

item_id 値の列名は、主キー 2...n (この例では item_id) の値と値の定数文字列名 ("item_id") で構成される複合です。

description 値の列名も、item_id 値と値の名前 (「description」) を組み合わせたものです。

同じ user_id で item_id 値が異なる 3 つの CQL テーブル行を記述した場合、行キーが共通の user_id 値であり、6 つの列、item_id 列、および説明を持つ単一の列ファミリー行になります。 3 つの CQL テーブル行のそれぞれの列。

コードは次のようになります。

import java.util.UUID;

import me.prettyprint.cassandra.serializers.CompositeSerializer;
import me.prettyprint.cassandra.serializers.IntegerSerializer;
import me.prettyprint.cassandra.serializers.StringSerializer;
import me.prettyprint.cassandra.serializers.UUIDSerializer;
import me.prettyprint.hector.api.Keyspace;
import me.prettyprint.hector.api.beans.Composite;
import me.prettyprint.hector.api.beans.HColumn;
import me.prettyprint.hector.api.beans.AbstractComposite.ComponentEquality;
import me.prettyprint.hector.api.factory.HFactory;
import me.prettyprint.hector.api.mutation.Mutator;

    // put this here to make it compile cleanly

    Keyspace keyspace = null;
    UUID userID = null;
    UUID itemID = null;
    String description = null;

            // Row key is user_id of type UUID

    Mutator<UUID> mutator = HFactory.createMutator(
            keyspace,
            UUIDSerializer.get());

        // write column for itemID.  
        // Column name is composite of itemID value and constant "item_id"
        // Row key is value of userID

    Composite itemIdColumnName = new Composite();
    itemIdColumnName.addComponent(itemID    , UUIDSerializer.get());
    itemIdColumnName.addComponent("item_id" , StringSerializer.get());
        // HFactory.createColumn takes args: column name, column value, serializer for column name, serializer for column value
    HColumn<Composite, UUID> hColumnObj_itemID = HFactory.createColumn(itemIdColumnName, userID, new CompositeSerializer(), UUIDSerializer.get());
    mutator.addInsertion(userID, "my_items", hColumnObj_itemID);

    // write column for description.  
    // Column name is composite of itemID value and constant "description"
    // Row key is value of userID

    Composite descriptionColumnName = new Composite();
    itemIdColumnName.addComponent(itemID    , UUIDSerializer.get());
    itemIdColumnName.addComponent("description" , StringSerializer.get());
    HColumn<Composite, String> hColumnObj_description = HFactory.createColumn(descriptionColumnName, description , new CompositeSerializer(), StringSerializer.get());
    mutator.addInsertion(userID, "my_items", hColumnObj_description);

    mutator.execute();
于 2012-08-08T17:04:38.460 に答える