2

我一直在阅读 Spring Data Cassandra 文档（http://docs.spring.io/spring-data/cassandra/docs/1.0.1.RELEASE/reference/html/cassandra.core.html）基本上，适当的注释，我希望 CassandraTemplate 将一行映射到 POJO 对象，但它没有像我预期的那样工作。

对于通话，

cassandraOps.queryForObject(s, Person.class)

我收到如下错误：

线程“main”java.lang.ClassCastException 中的异常：java.lang.String 无法转换为 Person

有什么我想念的吗？以下是上述文档中的相同复制和粘贴。

人员类看起来像：

@Table
public class Person {

    @PrimaryKey
    private String id;

    private String name;
    private int age;

    public Person(String id, String name, int age) {
        this.id = id;
        this.name = name;
        this.age = age;
    }

    public String getId() {
        return id;
    }

    public String getName() {
        return name;
    }

    public int getAge() {    
        return age;
    }

    @Override
    public String toString() {
        return "Person [id=" + id + ", name=" + name + ", age=" + age + "]";
    }

}

应用程序类看起来像......：

public class CassandraApp {
    private static final Logger LOG = LoggerFactory.getLogger(CassandraApp.class);

    private static Cluster cluster;
    private static Session session;

    public static void main(String[] args) {

        try {

            cluster = Cluster.builder().addContactPoints(InetAddress.getLocalHost()).build();
            session = cluster.connect("mykeyspace");
            CassandraOperations cassandraOps = new CassandraTemplate(session);
            cassandraOps.insert(new Person("1234567890", "David", 40));

            Select s = QueryBuilder.select().from("person");
            s.where(QueryBuilder.eq("id", "1234567890"));

            LOG.info(cassandraOps.queryForObject(s, Person.class).getId());

            cassandraOps.truncate("person");

        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
   }
}
4

2 回答 2

2

CassandraTemplate'squeryForObject(String,Class)不适用于任意对象映射。它以JdbcTemplate'squeryForObject(String,Class)方法为模型。它旨在采用 Cassandra 驱动程序可以直接转换的类型。

要转换任意应用程序定义的类，请使用queryForObject(String,RowMapper<T>)其重载之一。CqlTemplate 不知道如何映射任意类；您必须RowMapper<T>为您的班级提供实施T。

于 2014-10-22T22:40:22.323 回答
2

你可以这样做： -

String myQuery = "select * from person where id=1234567890";

Person personObj = cassandraOperations.selectOne(myQuery, Person.class);

<< 全部 List<Person> personListObj = cassandraOperations.select(myQuery, Person.class);>>

这项工作对我来说完美地使用了 cassandraTemplete 对象......没有尝试 cassandraOperation。

如果您的 pojo 类的变量名不同，您也可能需要 @Column(value = "your_columnName_in_DB")

喜欢
@Column(value = "name") private String userName; @Column(value = "age") private int userAge;

如果它的工作回到这里？

您还可以帮我将动态值传递给 myQuery 字符串吗？使用 object[] 与 SQL 中的 prepareStatment 相同

谢谢。

于 2015-08-07T08:18:07.953 回答