5

Spring Data Cassandra 1.0.0 を使用しています。私は自分のエンティティを永続化して読み返すことができました。ただし、エンティティの 1 つのフィールドのみを返すクエリを実行したいと考えています。

これは私が試したことです：

public Optional<DateTime> getTimeOfOldestIntervalTrafficDataMessage( MessageSource messageSource, IntegrationPeriod integrationPeriod, TrafficDataType trafficDataType )
{
    Select select = QueryBuilder.select( "message_time" ).from( "messages", "data_message" );
    select.where( QueryBuilder.eq( "message_source_id", messageSource.getId().getId() ) )
            .and( QueryBuilder.eq( "data_type", trafficDataType.name() ) )
            .and( QueryBuilder.eq( "integration_period", integrationPeriod.name() ) );

    List<Date> result = cassandraOperations.select( select, Date.class );
    if (result.size() > 0)
    {
        return Optional.of( new DateTime( FluentIterable.from( result ).toSortedSet( Ordering.natural() ).first() ) );
    }
    else
    {
        return Optional.absent();
    }
}

cassandraOperationsはCassandraTemplateインスタンスです。

だから私はテーブルmessage_timeから選ぶだけです。data_messageこれはtimestamp列なのでDate.class、select()メソッドに a を渡しますが、これにより次の例外が発生します。

org.springframework.data.mapping.model.MappingException: No mapping metadata found for java.util.Date
    at org.springframework.data.cassandra.convert.MappingCassandraConverter.readRow(MappingCassandraConverter.java:111)
    at org.springframework.data.cassandra.convert.MappingCassandraConverter.read(MappingCassandraConverter.java:202)
    at org.springframework.data.cassandra.core.CassandraConverterRowCallback.doWith(CassandraConverterRowCallback.java:47)
    at org.springframework.data.cassandra.core.CassandraTemplate.select(CassandraTemplate.java:455)
    at org.springframework.data.cassandra.core.CassandraTemplate.select(CassandraTemplate.java:253)
    at com.mycomp.app.infrastructure.cassandra.CassandraMessageRepository.getTimeOfOldestIntervalTrafficDataMessage(CassandraMessageRepository.java:130)

1 つのフィールドだけを照会するにはどうすればよいですか?

PS: このクエリを実行するためのより効率的な方法をご存じでしたら、それもお知らせいただければ幸いです。

4

1 に答える 1

6

それを行う方法を見つけました：

public Optional<DateTime> getTimeOfOldestIntervalTrafficDataMessage( MessageSource messageSource, IntegrationPeriod integrationPeriod, TrafficDataType trafficDataType )
    {
        Select select = QueryBuilder.select( "message_time" ).from( "messages", "data_message" );
        select.where( QueryBuilder.eq( "message_source_id", messageSource.getId().getId() ) )
                .and( QueryBuilder.eq( "traffic_data_type", trafficDataType.name() ) )
                .and( QueryBuilder.eq( "integration_period", integrationPeriod.name() ) );
        select.orderBy( QueryBuilder.asc( "message_time" ) );
        select.limit( 1 );

        Date date = m_cassandraOperations.queryForObject( select, Date.class );
        if( date != null )
        {
            Optional<DateTime> result = Optional.of( new DateTime( date ) );
            logger.debug( "oldest interval: {} ({}/{}/{})", result, messageSource.getName(), trafficDataType, integrationPeriod );
            return result;
        }
        else
        {
            return Optional.absent();
        }
    }

queryForObject()関数は行く方法です。また、順序付けと制限を使用して、必要なものを見つける作業を Cassandra に実行させました。

于 2014-06-10T15:31:14.393 に答える