-1

私はastyanaの書き込み操作を試していて、そのためにcqlshを使用していました。単にクエリを使用すると、結果を取得できます

keyspace.prepareQuery(COLUMN_FAMILY).withCql("insert into scan_request (customer_id, uuid, scan_type, status, content_size, request_time, request_content_hash) values ("+dao.getCustomerId()+","+"'"+dao.getUuId()+"',"+dao.getScanType()+","+dao.getStatus()+","+dao.getContentSize()+",'2012-12-12 12:12:12', '"+dao.getRequestContentHash()+"');")
            .execute();

ただし、準備済みステートメントを使用して同じことを行うと、以下のエラーが発生します。

        this.getKeyspace()
        .prepareQuery(COLUMN_FAMILY)
            .withCql(INSERT_STATEMENT)
        .asPreparedStatement()
            .withIntegerValue(dao.getCustomerId())
            .withStringValue(dao.getUuId())
            .withIntegerValue(dao.getScanType())
            .withIntegerValue(dao.getStatus())
            .withIntegerValue(dao.getContentSize())
            .withStringValue("'2012-12-12 12:12:12'")
            .withStringValue(dao.getRequestContentHash())
        .execute();

以下のエラーが表示されます

Exception in thread "main" java.lang.RuntimeException: failed to write data to C*
    at com.tools.dbaccess.cassandra.astyanax.AstyanaxClient.write(AstyanaxClient.java:155)
    at com.tools.dbaccess.cassandra.astyanax.AstyanaxClient.main(AstyanaxClient.java:164)
Caused by: com.netflix.astyanax.connectionpool.exceptions.BadRequestException: BadRequestException: [host=localhost(127.0.0.1):9160, latency=11(11), attempts=1]InvalidRequestException(why:Expected 8 or 0 byte long for date (21))
    at com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException(ThriftConverter.java:159)
    at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:65)
    at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:28)
    at com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(ThriftSyncConnectionFactoryImpl.java:151)
    at com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(AbstractExecuteWithFailoverImpl.java:69)
    at com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(AbstractHostPartitionConnectionPool.java:256)
    at com.netflix.astyanax.thrift.AbstractThriftCqlQuery$3.execute(AbstractThriftCqlQuery.java:80)
    at com.tools.dbaccess.cassandra.astyanax.AstyanaxClient.write(AstyanaxClient.java:144)
    ... 1 more
Caused by: InvalidRequestException(why:Expected 8 or 0 byte long for date (21))
    at org.apache.cassandra.thrift.Cassandra$execute_prepared_cql3_query_result.read(Cassandra.java:41868)
    at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
    at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_prepared_cql3_query(Cassandra.java:1689)
    at org.apache.cassandra.thrift.Cassandra$Client.execute_prepared_cql3_query(Cassandra.java:1674)
    at com.netflix.astyanax.thrift.ThriftCql3Query.execute_prepared_cql_query(ThriftCql3Query.java:29)
    at com.netflix.astyanax.thrift.AbstractThriftCqlQuery$3$1.internalExecute(AbstractThriftCqlQuery.java:92)
    at com.netflix.astyanax.thrift.AbstractThriftCqlQuery$3$1.internalExecute(AbstractThriftCqlQuery.java:82)
    at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:60)

タイムスタンプをテーブルに保存しようとすると、間違っていると思います。しかし、準備済みステートメントにタイムスタンプを保存するのに適切なものは何も見つかりませんでした。データベース内のフィールドのデータ型は「timestamp」です。

4

2 に答える 2

0

あなたが得たのは、NullPointerExceptionあなたの値のいくつかがnullでないことを確認しましたか?

于 2013-06-25T13:54:17.590 に答える