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

QueryBuilder.token介绍

[英]The token of a column name.
[中]列名的标记。

代码示例

代码示例来源：origin: brianfrankcooper/YCSB

scanStmt.append(initialStmt.substring(0, initialStmt.length() - 1));
scanStmt.append(" WHERE ");
scanStmt.append(QueryBuilder.token(YCSB_KEY));
scanStmt.append(" >= ");
scanStmt.append("token(");

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

@Test(groups = "short")
public void dateHandlingTest() throws Exception {
 Date d = new Date();
 session().execute(insertInto("dateTest").value("t", d));
 String query = select().from("dateTest").where(eq(token("t"), fcall("token", d))).toString();
 List<Row> rows = session().execute(query).all();
 assertEquals(1, rows.size());
 Row r1 = rows.get(0);
 assertEquals(d, r1.getTimestamp("t"));
}

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

Object end = QueryBuilder.raw(shard.end());
return Clauses.and(
    QueryBuilder.gte(QueryBuilder.token(col), start),
    QueryBuilder.lt(QueryBuilder.token(col), end));

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

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(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(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.stratio.meta/meta-core

case "=":
 clause =
   QueryBuilder.eq(QueryBuilder.token(names.toArray(new String[names.size()])), value);
 break;
case ">":
 clause =
   QueryBuilder.gt(QueryBuilder.token(names.toArray(new String[names.size()])), value);
 break;
case ">=":
 clause =
   QueryBuilder.gte(QueryBuilder.token(names.toArray(new String[names.size()])), value);
 break;
case "<":
 clause =
   QueryBuilder.lt(QueryBuilder.token(names.toArray(new String[names.size()])), value);
 break;
case "<=":
 clause =
   QueryBuilder.lte(QueryBuilder.token(names.toArray(new String[names.size()])), value);
 break;
default:

代码示例来源：origin: tenmax/cqlkit

ArrayList<String> cqlList = new ArrayList<>();
for (TokenRange subrange : tokenRange.unwrap()) {
  String token = QueryBuilder.token(partitionKeys.toArray(new String[]{}));

代码示例来源：origin: ucbrise/anna

scanStmt.append(initialStmt.substring(0, initialStmt.length() - 1));
scanStmt.append(" WHERE ");
scanStmt.append(QueryBuilder.token(YCSB_KEY));
scanStmt.append(" >= ");
scanStmt.append("token('");

代码示例来源：origin: tenmax/cqlkit

ArrayList<String> cqlList = new ArrayList<>();
for (TokenRange subrange : tokenRange.unwrap()) {
  String token = QueryBuilder.token(partitionKeys.toArray(new String[]{}));

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

/**
 * Scans a range of keys and returns an iterator containing each row's columns as an iterable.
 */
private Iterator<Iterable<Row>> rowScan(DeltaPlacement placement, @Nullable AstyanaxTable table, ByteBufferRange keyRange,
                    ReadConsistency consistency) {
  ByteBuffer startToken = keyRange.getStart();
  ByteBuffer endToken = keyRange.getEnd();
  // Note: if Cassandra is asked to perform a token range query where start >= end it will wrap
  // around which is absolutely *not* what we want.
  checkArgument(AstyanaxStorage.compareKeys(startToken, endToken) < 0, "Cannot scan rows which loop from maximum- to minimum-token");
  TableDDL tableDDL = placement.getDeltaTableDDL();
  Statement statement = selectFrom(tableDDL)
      .where(gt(token(tableDDL.getRowKeyColumnName()), startToken))
      .and(lte(token(tableDDL.getRowKeyColumnName()), endToken))
      .setConsistencyLevel(SorConsistencies.toCql(consistency));
  return deltaQueryAsync(placement, statement, false, "Failed to scan token range [%s, %s] for %s",
      ByteBufferUtil.bytesToHex(startToken), ByteBufferUtil.bytesToHex(endToken),
      table != null ? table : "multiple tables");
}

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

@Test(groups = "short")
public void dateHandlingTest() throws Exception {
 Date d = new Date();
 session().execute(insertInto("dateTest").value("t", d));
 String query = select().from("dateTest").where(eq(token("t"), fcall("token", d))).toString();
 List<Row> rows = session().execute(query).all();
 assertEquals(1, rows.size());
 Row r1 = rows.get(0);
 assertEquals(d, r1.getTimestamp("t"));
}

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

/**
 * Scans a range of keys and returns an iterator containing each row's columns as an iterable.
 */
private Iterator<Iterable<Row>> rowScan(DeltaPlacement placement, @Nullable AstyanaxTable table, ByteBufferRange keyRange,
                    ReadConsistency consistency) {
  ByteBuffer startToken = keyRange.getStart();
  ByteBuffer endToken = keyRange.getEnd();
  // Note: if Cassandra is asked to perform a token range query where start >= end it will wrap
  // around which is absolutely *not* what we want.
  checkArgument(AstyanaxStorage.compareKeys(startToken, endToken) < 0, "Cannot scan rows which loop from maximum- to minimum-token");
  BlockedDeltaTableDDL tableDDL = placement.getBlockedDeltaTableDDL();
  Statement statement = selectDeltaFrom(tableDDL)
      .where(gt(token(tableDDL.getRowKeyColumnName()), startToken))
      .and(lte(token(tableDDL.getRowKeyColumnName()), endToken))
      .setConsistencyLevel(SorConsistencies.toCql(consistency));
  return deltaQueryAsync(placement, statement, false, "Failed to scan token range [%s, %s] for %s",
      ByteBufferUtil.bytesToHex(startToken), ByteBufferUtil.bytesToHex(endToken),
      table != null ? table : "multiple tables");
}

代码示例来源：origin: bazaarvoice/emodb

/**
 * Scans a range of keys and returns an iterator containing each row's columns as an iterable.
 */
private Iterator<Iterable<Row>> rowScan(DeltaPlacement placement, @Nullable AstyanaxTable table, ByteBufferRange keyRange,
                    ReadConsistency consistency) {
  ByteBuffer startToken = keyRange.getStart();
  ByteBuffer endToken = keyRange.getEnd();
  // Note: if Cassandra is asked to perform a token range query where start >= end it will wrap
  // around which is absolutely *not* what we want.
  checkArgument(AstyanaxStorage.compareKeys(startToken, endToken) < 0, "Cannot scan rows which loop from maximum- to minimum-token");
  BlockedDeltaTableDDL tableDDL = placement.getBlockedDeltaTableDDL();
  Statement statement = selectDeltaFrom(tableDDL)
      .where(gt(token(tableDDL.getRowKeyColumnName()), startToken))
      .and(lte(token(tableDDL.getRowKeyColumnName()), endToken))
      .setConsistencyLevel(SorConsistencies.toCql(consistency));
  return deltaQueryAsync(placement, statement, false, "Failed to scan token range [%s, %s] for %s",
      ByteBufferUtil.bytesToHex(startToken), ByteBufferUtil.bytesToHex(endToken),
      table != null ? table : "multiple tables");
}

代码示例来源：origin: bazaarvoice/emodb

/**
 * Scans a range of keys and returns an iterator containing each row's columns as an iterable.
 */
private Iterator<Iterable<Row>> rowScan(DeltaPlacement placement, @Nullable AstyanaxTable table, ByteBufferRange keyRange,
                    ReadConsistency consistency) {
  ByteBuffer startToken = keyRange.getStart();
  ByteBuffer endToken = keyRange.getEnd();
  // Note: if Cassandra is asked to perform a token range query where start >= end it will wrap
  // around which is absolutely *not* what we want.
  checkArgument(AstyanaxStorage.compareKeys(startToken, endToken) < 0, "Cannot scan rows which loop from maximum- to minimum-token");
  TableDDL tableDDL = placement.getDeltaTableDDL();
  Statement statement = selectFrom(tableDDL)
      .where(gt(token(tableDDL.getRowKeyColumnName()), startToken))
      .and(lte(token(tableDDL.getRowKeyColumnName()), endToken))
      .setConsistencyLevel(SorConsistencies.toCql(consistency));
  return deltaQueryAsync(placement, statement, false, "Failed to scan token range [%s, %s] for %s",
      ByteBufferUtil.bytesToHex(startToken), ByteBufferUtil.bytesToHex(endToken),
      table != null ? table : "multiple tables");
}

代码示例来源：origin: com.baidu.hugegraph/hugegraph-cassandra

Object end = QueryBuilder.raw(shard.end());
return Clauses.and(
    QueryBuilder.gte(QueryBuilder.token(col), start),
    QueryBuilder.lt(QueryBuilder.token(col), end));

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

private Iterator<Iterable<Row>> migrationScan(DeltaPlacement placement, ByteBufferRange keyRange,
                    ReadConsistency consistency) {
  ByteBuffer startToken = keyRange.getStart();
  ByteBuffer endToken = keyRange.getEnd();
  // Note: if Cassandra is asked to perform a token range query where start >= end it will wrap
  // around which is absolutely *not* what we want.
  checkArgument(AstyanaxStorage.compareKeys(startToken, endToken) < 0, "Cannot migrate rows which loop from maximum- to minimum-token");
  TableDDL tableDDL = placement.getDeltaTableDDL();
  // Our query needs to be inclusive on both sides so that we ensure that we get all records in the event of a re-split
  Statement statement = selectFrom(tableDDL)
      .where(gte(token(tableDDL.getRowKeyColumnName()), startToken))
      .and(lte(token(tableDDL.getRowKeyColumnName()), endToken))
      .setConsistencyLevel(SorConsistencies.toCql(consistency));
  return deltaQueryAsync(placement, statement, false, "Failed to scan (for migration) token range [%s, %s] for %s",
      ByteBufferUtil.bytesToHex(startToken), ByteBufferUtil.bytesToHex(endToken),
      "multiple tables");
}

代码示例来源：origin: bazaarvoice/emodb

private Iterator<Iterable<Row>> migrationScan(DeltaPlacement placement, ByteBufferRange keyRange,
                    ReadConsistency consistency) {
  ByteBuffer startToken = keyRange.getStart();
  ByteBuffer endToken = keyRange.getEnd();
  // Note: if Cassandra is asked to perform a token range query where start >= end it will wrap
  // around which is absolutely *not* what we want.
  checkArgument(AstyanaxStorage.compareKeys(startToken, endToken) < 0, "Cannot migrate rows which loop from maximum- to minimum-token");
  TableDDL tableDDL = placement.getDeltaTableDDL();
  // Our query needs to be inclusive on both sides so that we ensure that we get all records in the event of a re-split
  Statement statement = selectFrom(tableDDL)
      .where(gte(token(tableDDL.getRowKeyColumnName()), startToken))
      .and(lte(token(tableDDL.getRowKeyColumnName()), endToken))
      .setConsistencyLevel(SorConsistencies.toCql(consistency));
  return deltaQueryAsync(placement, statement, false, "Failed to scan (for migration) token range [%s, %s] for %s",
      ByteBufferUtil.bytesToHex(startToken), ByteBufferUtil.bytesToHex(endToken),
      "multiple tables");
}

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

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

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

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