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

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

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

QueryBuilder.gt介绍

[英]Creates a "greater than" WHERE clause for a group of clustering columns.

For instance, gt(Arrays.asList("a", "b"), Arrays.asList(2, "test")) will generate the CQL WHERE clause (a, b) > (2, 'test') .

Please note that this variant is only supported starting with Cassandra 2.0.6.
[中]为一组群集列创建一个“大于”WHERE子句。
例如，gt（Arrays.asList（“a”、“b”）、数组。asList（2，“测试”）将生成CQL WHERE子句（a，b）>（2，“测试”）。
请注意，仅从Cassandra 2.0.6开始支持此变体。

代码示例

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

private void advance(){
  Clause queueNameClause = QueryBuilder.eq( ShardSerializationImpl.COLUMN_QUEUE_NAME, queueName);
  Clause regionClause = QueryBuilder.eq( ShardSerializationImpl.COLUMN_REGION, region);
  Clause activeClause = QueryBuilder.eq( ShardSerializationImpl.COLUMN_ACTIVE, 1);
  Clause shardIdClause;
  if (nextStart == 0L && lastShardId.isPresent()) {
    shardIdClause = QueryBuilder.gt( ShardSerializationImpl.COLUMN_SHARD_ID, lastShardId.get() );
  } else if (nextStart == 0L && !lastShardId.isPresent()) {
    shardIdClause = QueryBuilder.gte( ShardSerializationImpl.COLUMN_SHARD_ID, 0L );
  } else {
    shardIdClause = QueryBuilder.gt( ShardSerializationImpl.COLUMN_SHARD_ID, nextStart );
  }
  Statement query = QueryBuilder.select().all().from(ShardSerializationImpl.getTableName(shardType))
      .where(queueNameClause)
      .and(regionClause)
      .and(activeClause)
      .and(shardIdClause)
      .limit(PAGE_SIZE);
  List<Row> rows = cassandraClient.getQueueMessageSession().execute(query).all();
  currentIterator = getIteratorFromRows(rows);
}

代码示例来源：origin: kaaproject/kaa

@Override
public List<CassandraNotification> findNotificationsByTopicIdAndVersionAndStartSecNum(
  String topicId, int seqNum, int sysNfVersion, int userNfVersion) {
 LOG.debug("Try to find notifications by topic id {} start sequence number {} "
     + "system schema version {} user schema version {}",
   topicId, seqNum, sysNfVersion, userNfVersion);
 List<CassandraNotification> resultList = new ArrayList<>();
 Where systemQuery = select().from(getColumnFamilyName())
   .where(eq(NF_TOPIC_ID_PROPERTY, topicId))
   .and(eq(NF_NOTIFICATION_TYPE_PROPERTY, NotificationTypeDto.SYSTEM.name()))
   .and(eq(NF_VERSION_PROPERTY, sysNfVersion))
   .and(QueryBuilder.gt(NF_SEQ_NUM_PROPERTY, seqNum));
 Where userQuery = select().from(getColumnFamilyName())
   .where(eq(NF_TOPIC_ID_PROPERTY, topicId))
   .and(eq(NF_NOTIFICATION_TYPE_PROPERTY, NotificationTypeDto.USER.name()))
   .and(eq(NF_VERSION_PROPERTY, userNfVersion))
   .and(QueryBuilder.gt(NF_SEQ_NUM_PROPERTY, seqNum));
 List<CassandraNotification> systemList = findListByStatement(systemQuery);
 List<CassandraNotification> userList = findListByStatement(userQuery);
 resultList.addAll(systemList);
 resultList.addAll(userList);
 if (LOG.isTraceEnabled()) {
  LOG.trace("Found notifications {} by topic id {}, seqNum {}, sysVer {}, userVer {} ",
    Arrays.toString(
      resultList.toArray()), topicId, seqNum, sysNfVersion, userNfVersion);
 }
 return resultList;
}

代码示例来源：origin: hugegraph/hugegraph

return QueryBuilder.eq(key, value);
case GT:
  return QueryBuilder.gt(key, value);
case GTE:
  return QueryBuilder.gte(key, value);

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

Clause messageIdClause = QueryBuilder.gt( COLUMN_QUEUE_MESSAGE_ID, nextStart);
query = QueryBuilder.select().all().from(QueueMessageSerializationImpl.getTableName(messageType))
    .where(queueNameClause)

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

.from("foo")
    .where(eq("k", 4))
    .and(gt(Arrays.asList("c1", "c2"), Arrays.<Object>asList("a", 2)));
assertEquals(select.toString(), query);

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

@Test(groups = "unit")
public void should_not_serialize_raw_query_values() {
 RegularStatement select = select().from("test").where(gt("i", raw("1")));
 assertThat(select.getQueryString()).doesNotContain("?");
 assertThat(select.getValues(ProtocolVersion.NEWEST_SUPPORTED, CodecRegistry.DEFAULT_INSTANCE))
   .isNull();
}

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

delete = delete().from("foo").where(gt("k=1 OR k", 42));
assertEquals(delete.toString(), query);
delete = delete().from("foo").where(gt(token("k)>0 OR token(k"), fcall("token", 42)));
assertEquals(delete.toString(), query);

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

select = select().all().from("foo").where(gt("k=1 OR k", 42)).limit(42);
assertEquals(select.toString(), query);
select = select().all().from("foo").where(gt(token("k)>0 OR token(k"), fcall("token", 42)));
assertEquals(select.toString(), query);

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

select = select().all().from("foo").where(eq("k", 4)).and(gt("c", "a")).and(lte("c", "z"));
assertEquals(select.toString(), query);
  select().all().from("foo").where().and(eq("k", 4)).and(gt("c", "a")).and(lte("c", "z"));
assertEquals(select.toString(), query);
select = select().all().from("foo").where(gt("k", 42)).limit(42);
assertEquals(select.toString(), query);
select = select().all().from("foo").where(gt(token("k"), fcall("token", 42)));
assertEquals(select.toString(), query);
select = select().all().from("foo2").where(gt(token("a", "b"), fcall("token", 42, 101)));
assertEquals(select.toString(), query);

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

.from("foo")
.where(eq("a", bindMarker()))
.and(gt("b", bindMarker()))
.orderBy(desc("b"))
.perPartitionLimit(bindMarker())

代码示例来源：origin: info.archinnov/integration-test-2_1

/**
 * Generate an ... <strong>IF set > ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithCaseSensitivePK_Delete.E Gt(final Set<String> set) {
 boundValues.add(set);
 encodedValues.add(meta.set.encodeFromJava(set, Optional.of(cassandraOptions)));
 where.onlyIf(QueryBuilder.gt("\"setString\"", QueryBuilder.bindMarker("\"setString\"")));
 return EntityWithCaseSensitivePK_Delete.E.this;
}

代码示例来源：origin: info.archinnov/integration-test-2_1

/**
 * Generate an ... <strong>IF list > ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithBeanValidation_Update.E Gt(final List<String> list) {
 boundValues.add(list);
 encodedValues.add(meta.list.encodeFromJava(list, Optional.of(cassandraOptions)));
 where.onlyIf(QueryBuilder.gt("list", QueryBuilder.bindMarker("list")));
 return EntityWithBeanValidation_Update.E.this;
}

代码示例来源：origin: info.archinnov/integration-test-2_1

/**
 * Generate a SELECT ... FROM ... WHERE ... <strong>token(layer) > ?</strong> */
@SuppressWarnings("static-access")
public final EntityLayer1_Select.E Gt(Long tokenValue) {
 where.and(QueryBuilder.gt("token(layer)", QueryBuilder.bindMarker("tokenValue")));
 boundValues.add(tokenValue);
 encodedValues.add(tokenValue);
 return new EntityLayer1_Select.E(where, cassandraOptions);
}

代码示例来源：origin: info.archinnov/integration-test-2_1

/**
 * Generate a SELECT ... FROM ... WHERE ... <strong>token(id) > ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithByteBufferType_Select.E_TM Gt(Long tokenValue) {
 where.and(QueryBuilder.gt("token(id)", QueryBuilder.bindMarker("tokenValue")));
 boundValues.add(tokenValue);
 encodedValues.add(tokenValue);
 return new EntityWithByteBufferType_Select.E_TM(where, cassandraOptions);
}

代码示例来源：origin: info.archinnov/integration-test-2_1

/**
 * Generate a SELECT ... FROM ... WHERE ... <strong>token(layer) > ? AND token(layer) < ?</strong> */
@SuppressWarnings("static-access")
public final EntityLayer1_Select.E Gt_And_Lt(Long tokenValue1, Long tokenValue2) {
 where.and(QueryBuilder.gt("token(layer)",QueryBuilder.bindMarker("tokenValue1")));
 where.and(QueryBuilder.lt("token(layer)",QueryBuilder.bindMarker("tokenValue2")));
 boundValues.add(tokenValue1);
 encodedValues.add(tokenValue1);
 boundValues.add(tokenValue2);
 encodedValues.add(tokenValue2);
 return new EntityLayer1_Select.E(where, cassandraOptions);
}

代码示例来源：origin: info.archinnov/integration-test-2_1

/**
 * Generate a SELECT ... FROM ... WHERE ... <strong>token(layer) > ? AND token(layer) < ?</strong> */
@SuppressWarnings("static-access")
public final EntityLayer1_Select.E_TM Gt_And_Lt(Long tokenValue1, Long tokenValue2) {
 where.and(QueryBuilder.gt("token(layer)",QueryBuilder.bindMarker("tokenValue1")));
 where.and(QueryBuilder.lt("token(layer)",QueryBuilder.bindMarker("tokenValue2")));
 boundValues.add(tokenValue1);
 encodedValues.add(tokenValue1);
 boundValues.add(tokenValue2);
 encodedValues.add(tokenValue2);
 return new EntityLayer1_Select.E_TM(where, cassandraOptions);
}

代码示例来源：origin: info.archinnov/integration-test-2_1

/**
 * Generate a SELECT ... FROM ... WHERE ... <strong>token(layer) > ? AND token(layer) <= ?</strong> */
@SuppressWarnings("static-access")
public final EntityLayer1_Select.E_TM Gt_And_Lte(Long tokenValue1, Long tokenValue2) {
 where.and(QueryBuilder.gt("token(layer)",QueryBuilder.bindMarker("tokenValue1")));
 where.and(QueryBuilder.lte("token(layer)",QueryBuilder.bindMarker("tokenValue2")));
 boundValues.add(tokenValue1);
 encodedValues.add(tokenValue1);
 boundValues.add(tokenValue2);
 encodedValues.add(tokenValue2);
 return new EntityLayer1_Select.E_TM(where, cassandraOptions);
}

代码示例来源：origin: info.archinnov/integration-test-2_1

/**
 * Generate a SELECT ... FROM ... WHERE ... <strong>token(id) > ? AND token(id) < ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithByteBufferType_Select.E_TM Gt_And_Lt(Long tokenValue1, Long tokenValue2) {
 where.and(QueryBuilder.gt("token(id)",QueryBuilder.bindMarker("tokenValue1")));
 where.and(QueryBuilder.lt("token(id)",QueryBuilder.bindMarker("tokenValue2")));
 boundValues.add(tokenValue1);
 encodedValues.add(tokenValue1);
 boundValues.add(tokenValue2);
 encodedValues.add(tokenValue2);
 return new EntityWithByteBufferType_Select.E_TM(where, cassandraOptions);
}

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

.from("test_ppl")
.where(eq("a", bindMarker()))
.and(gt("b", bindMarker()))
.perPartitionLimit(bindMarker())
.allowFiltering()
.from("test_ppl")
.where(eq("a", bindMarker()))
.and(gt("b", bindMarker()))
.orderBy(desc("b"))
.perPartitionLimit(bindMarker())

代码示例来源：origin: com.bazaarvoice.emodb/emodb-sor

@Override
  protected ResultSet queryRowGroupRowsAfter(Row row) {
    Statement statement = selectDeltaFrom(_placement.getBlockedDeltaTableDDL())
        .where(eq(_placement.getBlockedDeltaTableDDL().getRowKeyColumnName(), getKey(row)))
        .and(gt(ImmutableList.of(_placement.getBlockedDeltaTableDDL().getChangeIdColumnName(), _placement.getBlockedDeltaTableDDL().getBlockColumnName()),
            ImmutableList.of(getChangeId(row), getBlock(row))))
        .orderBy(asc(_placement.getBlockedDeltaTableDDL().getChangeIdColumnName()))
        .setConsistencyLevel(_consistency);
    return AdaptiveResultSet.executeAdaptiveQuery(_placement.getKeyspace().getCqlSession(), statement, _driverConfig.getSingleRowFetchSize());
  }
}

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

QueryBuilder

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    QueryBuilder类方法

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