我和你有同样的问题，我认为我解决的方法对你有用。
我有一个使用@PrimaryKeyColumn 注释的Category.java 类。
@PrimaryKeyColumn(name = "language_id", ordinal = 1, type = PrimaryKeyType.PARTITIONED)
private String languageId;
我的选择、插入操作适用于 spring-data-cassandra，但我的删除操作不能。
然后，spring-data-cassandra参考提供的这一行，不起作用：
cassandraOperations.delete(category);
(http://docs.spring.io/spring-data/cassandra/docs/1.2.0.RC1/reference/html/)
它抛出一个异常“Unknown Key identifier languageId”。
在内部生成的 CQL 语句如下：
DELETE FROM categories WHERE id='sdffsd' AND languageId='EN';
然后就可以看到列名生成错误了。
我的 Category.java 类如下：
package com.ehub.hmap.db.entities;
import org.springframework.cassandra.core.PrimaryKeyType;
import org.springframework.data.cassandra.mapping.Column;
import org.springframework.data.cassandra.mapping.PrimaryKeyColumn;
import org.springframework.data.cassandra.mapping.Table;
@Table(value = "categories")
public class Category {
@PrimaryKeyColumn(name = "id", ordinal = 0, type = PrimaryKeyType.PARTITIONED)
private String id;
@PrimaryKeyColumn(name = "language_id", ordinal = 1, type = PrimaryKeyType.PARTITIONED)
private String languageId;
@Column
private String description;
@Column
private String tooltip;
public Category(String id, String languageId, String description,
String tooltip) {
this.id = id;
this.languageId = languageId;
this.description = description;
this.tooltip = tooltip;
}
public String getId() {
return id;
}
public String getLanguageId() {
return languageId;
}
public String getDescription() {
return description;
}
public String getTooltip() {
return tooltip;
}
}
我从我的 Jersey REST 方法开始详细说明我的解决方案。
@POST
@Path("/deleteCategory")
@Consumes({ MediaType.APPLICATION_JSON })
@Produces(MediaType.APPLICATION_JSON)
public Response deleteCategory(Category category) {
dataManager.deleteEntity(Category.class, category);
return Response.ok().build();
}
在我的 DataManager.java 类中，我有：
/**
* Delete an entity at DB
*
* @param entity: T type object
* @return
*/
public <T> void deleteEntity(Class<T> typedClass, T entity) {
// Start building the query
Delete delete = QueryBuilder.delete().from(CassandraUtil.getTableName(typedClass));
// Get a map<key,value> where key is the Db column name and value is the model name
Map<String, String> map = CassandraUtil.getTableKeyMap(typedClass);
for (Map.Entry<String, String> entry : map.entrySet())
{
// getKey() has the DB name, and getValue() has the model name
delete.where(QueryBuilder.eq(entry.getKey(), CassandraUtil.getPropertyValue(entity, entry.getValue())));
}
cassandraOperations.execute(delete);
}
在我的 CassandraUtil.java 我有：
/**
* Gets a <key,value> map where each key is the name of the column at Db and
* value is the name of the field at your model.
*
* @param Annotated Typed class corresponding to your entity model.
* @return Map with Db column name and Model name.
*/
public static <T> Map<String,String> getTableKeyMap(Class<T> typedClass) {
Map<String, String> map = new HashMap<String, String>();
if (typedClass != null)
{
Field[] fields = typedClass.getDeclaredFields();
for (Field field : fields) {
try {
String dbName = null;
field.setAccessible(true);
// Checks PrimaryKeyColumn annotation
PrimaryKeyColumn pkc = field.getAnnotation(PrimaryKeyColumn.class);
if (pkc != null)
{
dbName = (pkc.name() != null) ? pkc.name(): field.getName();
// dbName gets the name of the column in Db
// getName() obtains the name in our model
map.put(dbName, field.getName());
}
// Checks PrimaryKey annotation
PrimaryKey pk = field.getAnnotation(PrimaryKey.class);
if (pk != null)
{
dbName = (pk.value() != null) ? pk.value(): field.getName();
// dbName gets the name of the column in Db
// getName() obtains the name in our model
map.put(dbName, field.getName());
}
} catch (IllegalArgumentException
| SecurityException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
return map;
}
public static <T> String getPropertyValue(T obj, String name) {
String str = null;
if (name != null)
{
try
{
Class<T> objClass = (Class<T>) obj.getClass();
Field field = objClass.getDeclaredField(name);
field.setAccessible(true);
String val = field.get(obj) != null ? field.get(obj).toString(): "";
return val;
}
catch (Exception iEx) {
}
}
return str;
}
希望对你有帮助！！我知道它可以更好地解决，所以......任何评论都应该受到赞赏。