2015-08-03 198 views
2

您能否提供一个使用datastax API注释来映射集合以使用Map的示例。java cassandra对象映射注释

class pojo { 

    @PartitionKey(value = 0) 
    @Column(name = "user_id") 
    String userId; 

    @Column(name = "attributes") 
     // How to map it 
     Map<String, String> attributes; 
    } 

错误日志:

2015-08-03 16:33:34,568 INFO com.jpma.jpmc.slot.persistance.DAOFactory main - Cassandra Cluster Details: ConnectionCfg [userName=test, password=test, port=9042, seeds=[Ljava.lang.String;@1a85bd75, keySpace=test] 
java.lang.Class 
2015-08-03 16:33:34,646 DEBUG com.datastax.driver.mapping.EntityMapper main - Preparing query INSERT INTO "test"."user_event_date"("user_id","entry_date","entry_time","app","attributes","user_ip","user_authschemes") VALUES (?,?,?,?,?,?,?); 
com.datastax.driver.core.exceptions.InvalidQueryException: Unknown identifier attributes 
+1

你可以分享你的'创建表'cql吗?这可能只是抱怨没有“属性”列。驱动程序将为每个查询创建预先准备好的语句,这些语句将作为您声明的模型的结果进行生成,而且看起来服务器正在拒绝这个语句。 –

+0

是的,你是正确的问题解决。 –

回答

3

根据您所看到的,我猜,attributes未在表定义中定义的错误消息。你介意用这个编辑你的文章吗?

但是,当我建立我的CQL表像这样(注意itemid复合分区键和version):

CREATE TABLE products.itemmaster (
    itemid text, 
    version int, 
    productid uuid, 
    supplierskumap map<uuid, text>, 
    PRIMARY KEY ((itemid,version), productid) 
); 

...插入该行:

INSERT INTO products.itemmaster (itemid,version,productid,supplierskumap) 
VALUES ('item1',1,26893749-dcfc-42c7-892c-bee8c9cff630, 
     {1351f82f-5dc5-4328-82f4-962429c92a2b:'86CCG123'}); 

...和我建立我的POJO是这样的:

@Table(keyspace = "products", name = "itemmaster") 
public class Product { 
    @PartitionKey(0) 
    private String itemid; 
    @PartitionKey(1) 
    private int version; 
    @ClusteringColumn 
    private UUID productid; 
    @Column(name="supplierskumap") 
    private Map<UUID,String> suppliersku; 

    public UUID getProductid() { 
     return productid; 
    } 
    public void setProductid(UUID _productid) { 
     this.productid = _productid; 
    } 
    public int getVersion() { 
     return this.version; 
    } 
    public void setVersion(int _version) 
    { 
     this.version = _version; 
    } 
    public String getItemid() { 
     return itemid; 
    } 
    public void setItemid(String _itemid) { 
     this.itemid = _itemid; 
    } 
    public Map<UUID, String> getSuppliersku() { 
     return suppliersku; 
    } 
    public void setSuppliersku(Map<UUID, String> _suppliersku) { 
     this.suppliersku = _suppliersku; 
    } 
} 

...用这个构造函数和我的数据访问对象(DAO)上方法:

public ProductsDAO() 
{ 
    session = connect(CASSANDRA_NODES, USERNAME, PASSWORD); 
    prodMapper = new MappingManager(session).mapper(Product.class); 
} 

public Product getProd(String itemid, int version, UUID productid) { 
    return prodMapper.get(itemid,version,sku); 
} 

...那么这个main类成功查询我的表格和地图我Map

private static void main(String[] args) { 
     ProductsDAO dao = new ProductsDAO(); 
     Product prod = dao.getProd("item1", 1, UUID.fromString("26893749-dcfc-42c7-892c-bee8c9cff630")); 

     System.out.println(
       prod.getProductid() + " - " + 
       prod.getItemid() + " - " + 
       prod.getSuppliersku().get(UUID.fromString("1351f82f-5dc5-4328-82f4-962429c92a2b"))); 

     dao.closeCassandra(); 
} 

...并产生这样的输出:

26893749-dcfc-42c7-892c-bee8c9cff630 - item1 - 86CCG123 

注意:编辑上述示例以支持复合分区键。

+0

是的,我得到了问题,你可以分享一个例子来获取对象时,我有一种化合物partion关键@PartitionKey(0) \t @Column(name =“USER_ID”) \t字符串userid; \t \t @PartitionKey(1) \t @Column(名称= “attribute_key”) \t字符串attributeKey; –

+0

@PavanKumar编辑。希望这可以帮助! – Aaron