com.datastax.driver.core.querybuilder.QueryBuilder.ttl()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(6.9k)|赞(0)|评价(0)|浏览(157)

本文整理了Java中com.datastax.driver.core.querybuilder.QueryBuilder.ttl方法的一些代码示例，展示了QueryBuilder.ttl的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueryBuilder.ttl方法的具体详情如下：
包路径：com.datastax.driver.core.querybuilder.QueryBuilder
类名称：QueryBuilder
方法名：ttl

QueryBuilder.ttl介绍

[英]Option to set the ttl for a modification query (insert, update or delete).
[中]选项设置修改查询的ttl（插入、更新或删除）。

代码示例

代码示例来源：origin: apache/usergrid

final Using timeToLive = QueryBuilder.ttl(ttl);

代码示例来源：origin: apache/usergrid

@Override
public void writeMessageData( final UUID messageId, final DatabaseQueueMessageBody messageBody ) {
  Preconditions.checkArgument(QakkaUtils.isTimeUuid(messageId), "MessageId is not a type 1 UUID");
  logger.trace("writeMessageData {}", messageId);
  Statement insert = QueryBuilder.insertInto(TABLE_MESSAGE_DATA)
      .value( COLUMN_MESSAGE_ID, messageId)
      .value( COLUMN_MESSAGE_DATA, messageBody.getBlob())
      .value( COLUMN_CONTENT_TYPE, messageBody.getContentType())
    .using( QueryBuilder.ttl( maxTtl ) );
  cassandraClient.getApplicationSession().execute(insert);
}

代码示例来源：origin: apache/usergrid

final Using usingTTL = QueryBuilder.ttl(ttl);

代码示例来源：origin: apache/usergrid

QueryBuilder.set("value", DataType.serializeValue(inactiveTime, ProtocolVersion.NEWEST_SUPPORTED));
final Using usingTTL = QueryBuilder.ttl(ttl);

代码示例来源：origin: jooby-project/jooby

private static String insertSQL(final String table, final int timeout) {
 Insert insertInto = insertInto(table)
   .value(ID, raw("?"))
   .value(CREATED_AT, raw("?"))
   .value(ACCESSED_AT, raw("?"))
   .value(SAVED_AT, raw("?"))
   .value(ATTRIBUTES, raw("?"));
 if (timeout > 0) {
  insertInto.using(ttl(timeout));
 }
 return insertInto.getQueryString();
}

代码示例来源：origin: apache/usergrid

Statement mapKey;
if (ttl > 0){
  Using timeToLive = QueryBuilder.ttl(ttl);

代码示例来源：origin: apache/usergrid

if(timeToLive > 0){
  ttl = QueryBuilder.ttl(timeToLive);

代码示例来源：origin: apache/usergrid

private Statement createWriteMessageStatement( DatabaseQueueMessage message ) {
  final UUID queueMessageId =  message.getQueueMessageId() == null ?
    QakkaUtils.getTimeUuid() : message.getQueueMessageId();
  final long shardId;
  if ( message.getShardId() != null ) {
    shardId = message.getShardId();
  } else if ( DatabaseQueueMessage.Type.DEFAULT.equals( message.getType() )) {
    Shard shard = shardStrategy.selectShard(
      message.getQueueName(), message.getRegion(), Shard.Type.DEFAULT, message.getQueueMessageId() );
    shardId = shard.getShardId();
  } else {
    Shard shard = shardStrategy.selectShard(
      message.getQueueName(), message.getRegion(), Shard.Type.INFLIGHT, message.getQueueMessageId() );
    shardId = shard.getShardId();
  }
  Statement insert = QueryBuilder.insertInto(getTableName(message.getType()))
    .value( COLUMN_QUEUE_NAME,       message.getQueueName())
    .value( COLUMN_REGION,           message.getRegion())
    .value( COLUMN_SHARD_ID,         shardId)
    .value( COLUMN_MESSAGE_ID,       message.getMessageId())
    .value( COLUMN_QUEUE_MESSAGE_ID, queueMessageId)
    .value( COLUMN_INFLIGHT_AT,      message.getInflightAt())
    .value( COLUMN_QUEUED_AT,        message.getQueuedAt())
    .using( QueryBuilder.ttl( maxTtl ) );
  return insert;
}

代码示例来源：origin: pulsarIO/realtime-analytics

insert.using(QueryBuilder.ttl(TTL));
insertRequest.add(insert);

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

3.4
      })
    .using(ttl(24))
    .and(timestamp(42));
assertEquals(insert.toString(), query);

代码示例来源：origin: otaviojava/Easy-Cassandra

@Override
public DeleteBuilder<T> withTtl(int ttl) {
  delete.using(QueryBuilder.ttl(ttl));
  return this;
}
@Override

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

batch()
    .add(insertInto(table).values(new String[] {"k", "a"}, new Object[] {42, 1}))
    .add(update(table).using(ttl(400)));
assertEquals(batch.getRoutingKey(protocolVersion, codecRegistry), bb);
assertEquals(batch.toString(), batch_query);

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

.and(ttl(24));
assertEquals(insert.toString(), query);
       3.4
      })
    .using(ttl(24))
    .and(timestamp(42));
assertEquals(insert.toString(), query);
       3.4
      })
    .using(ttl(bindMarker()))
    .and(timestamp(bindMarker()));
assertEquals(insert.toString(), query);

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

update = update("foo").using(ttl(400));
assertEquals(update.toString(), query);
 update("foo").using(ttl(-400));
 fail("Expected an IllegalArgumentException");
} catch (IllegalArgumentException e) {

代码示例来源：origin: com.yugabyte/cassandra-driver-mapping

@Override
void modifyQueryString(BuiltStatement query) {
  ((Insert) query).using().and(
      QueryBuilder.ttl(QueryBuilder.bindMarker()));
}

代码示例来源：origin: org.opennms.newts/newts-cassandra-search

@Override
  public RegularStatement toStatement() {
    LOG.trace("Inserting attribute in context: '{}' with resource id: '{}' with name: '{}' and value: '{}'",
        m_context, m_resourceId, m_field, m_value);
    return insertInto(Constants.Schema.T_ATTRS)
      .value(Constants.Schema.C_ATTRS_CONTEXT, m_context.getId())
      .value(Constants.Schema.C_ATTRS_RESOURCE, m_resourceId)
      .value(Constants.Schema.C_ATTRS_ATTR, m_field)
      .value(Constants.Schema.C_ATTRS_VALUE, m_value)
      .using(ttl(m_ttl));
  }
}

代码示例来源：origin: OpenNMS/newts

@Override
  public RegularStatement toStatement() {
    LOG.trace("Inserting attribute in context: '{}' with resource id: '{}' with name: '{}' and value: '{}'",
        m_context, m_resourceId, m_field, m_value);
    return insertInto(Constants.Schema.T_ATTRS)
      .value(Constants.Schema.C_ATTRS_CONTEXT, m_context.getId())
      .value(Constants.Schema.C_ATTRS_RESOURCE, m_resourceId)
      .value(Constants.Schema.C_ATTRS_ATTR, m_field)
      .value(Constants.Schema.C_ATTRS_VALUE, m_value)
      .using(ttl(m_ttl));
  }
}

代码示例来源：origin: io.zipkin.zipkin2/zipkin-storage-cassandra-v1

Factory(CassandraStorage storage, int indexTtl) {
 super(storage.autocompleteTtl, storage.autocompleteCardinality);
 session = storage.session();
 Insert insertQuery = QueryBuilder.insertInto(Tables.SERVICE_NAMES)
  .value("service_name", QueryBuilder.bindMarker("service_name"));
 if (indexTtl > 0) insertQuery.using(QueryBuilder.ttl(indexTtl));
 preparedStatement = session.prepare(insertQuery);
}

代码示例来源：origin: io.zipkin.zipkin2/zipkin-storage-cassandra-v1

Factory(CassandraStorage storage, int indexTtl) {
 super(storage.autocompleteTtl, storage.autocompleteCardinality);
 session = storage.session();
 Insert insertQuery = QueryBuilder.insertInto(TABLE_AUTOCOMPLETE_TAGS)
  .value("key", QueryBuilder.bindMarker("key"))
  .value("value", QueryBuilder.bindMarker("value"));
 if (indexTtl > 0) insertQuery.using(QueryBuilder.ttl(indexTtl));
 preparedStatement = session.prepare(insertQuery);
}

代码示例来源：origin: io.zipkin.zipkin2/zipkin-storage-cassandra-v1

Factory(CassandraStorage storage, int indexTtl) {
 super(storage.autocompleteTtl, storage.autocompleteCardinality);
 session = storage.session();
 Insert insertQuery = QueryBuilder.insertInto(Tables.SPAN_NAMES)
  .value("service_name", QueryBuilder.bindMarker("service_name"))
  .value("bucket", 0) // bucket is deprecated on this index
  .value("span_name", QueryBuilder.bindMarker("span_name"));
 if (indexTtl > 0) insertQuery.using(QueryBuilder.ttl(indexTtl));
 preparedStatement = session.prepare(insertQuery);
}

内容来源于网络，如有侵权，请联系作者删除！

QueryBuilder

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    QueryBuilder类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com