9

我是 cassandra 和 hector 的新手，所以我正在尝试执行 cql 查询，但问题是并非所有列都是字符串类型，所以我如何执行查询“select * from users”？

我的列族如下所示：

UPDATE COLUMN FAMILY users
WITH comparator = UTF8Type
AND key_validation_class=UTF8Type
AND column_metadata = [
{column_name: full_name, validation_class: UTF8Type}
{column_name: email, validation_class: UTF8Type}
{column_name: state, validation_class: UTF8Type, index_type: KEYS}
{column_name: gender, validation_class: UTF8Type}
{column_name: birth_year, validation_class: LongType, index_type: KEYS}
{column_name: education, validation_class: UTF8Type}
];

我使用以下代码来执行查询：

CqlQuery<String, String, String> cqlQuery = new CqlQuery<String, String, String>(Keyspace,stringSerializer,stringSerializer,stringSerializer);

    cqlQuery.setQuery("select * from users");

    QueryResult<CqlRows<String, String, String>> result = cqlQuery.execute();


    if (result != null && result.get() != null) {
        List<Row<String, String, String>> list = result.get().getList();
        for (Row row : list) {
            System.out.println(".");
            List columns = row.getColumnSlice().getColumns();
            for (Iterator iterator = columns.iterator(); iterator.hasNext();) {
                HColumn column = (HColumn) iterator.next();
                System.out.print(column.getName() + ":" + column.getValue()
                        + "\t");
            }
            System.out.println("");
        }
    }

但是由于验证类 Long 的“birth_year”列，我无法获得该值。假设只有一条记录，我得到以下结果：

KEY:Carl birth_year: 'strange chars?' full_name:Carl Smith gender:M eduction:electrician state:LA

如果我将查询更改为：

CqlQuery<String, String, Long> cqlQuery =  new CqlQuery<String, String, Long>
TutorialBase.tutorialKeyspace, stringSerializer, stringSerializer, longSerializer);

    cqlQuery.setQuery("select birth_year from users");

比它有效。

那么如何只使用一个查询来做到这一点，如果我在列族的行中有更多的数据类型（如布尔值和浮点数）怎么办？

4

1 回答 1

11

您在 CqlRows 中将值类型指定为字符串，因此每个值都应为字符串。因为要混合 Value 类型，所以要保留列元数据，还要在 schema 中指定默认验证类为BytesType，然后在 CqlRows 中使用 ByteBuffer 作为类型：

QueryResult<CqlRows<String, String, ByteBuffer>> result = cqlQuery.execute();

然后，在处理值时，您必须转换为适当的类型，而不是遍历列，您可能会按名称获取特定列：

ColumnSlice<String, ByteBuffer> slice = row.getColumnSlice();
HColumn<String,ByteBuffer> col = slice.getColumnByName("birth_year");
System.out.println(" birth_year: " + col.getValue().getLong());

当然，必须使用 java.nio.charset.Charset 以不同方式处理字符串：

Charset.defaultCharset().decode(col.getValue()).toString()

您可以从 Column 元数据中确定类型，但我只通过 Thrift API（请参阅 ColumnDef）完成此操作，因此不确定如何通过 Hector API 完成此操作。但是 HColumn 确实提供了一个 getValueSerializer() 方法，所以这可能是一个开始。

于 2011-10-11T22:19:42.167 回答