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

Update.with介绍

[英]Returns the assignments of this UPDATE statement.
[中]返回此UPDATE语句的赋值。

代码示例

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

@Override
public String generateAccessToken(String externalId, String tenantId) {
 LOG.debug("Generating access token for endpoint user with external id {} and tenant id {}",
   externalId, tenantId);
 String accessToken = UUID.randomUUID().toString();
 Update.Where query = update(getColumnFamilyName())
   .with(set(CassandraModelConstants.EP_USER_ACCESS_TOKEN_PROPERTY, accessToken))
   .where(eq(EP_USER_EXTERNAL_ID_PROPERTY, externalId))
   .and(eq(EP_USER_TENANT_ID_PROPERTY, tenantId));
 execute(query);
 LOG.trace("Generated access token {} for endpoint user by query {}", accessToken, query);
 return accessToken;
}

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

updateStmt.with(QueryBuilder.set(field, QueryBuilder.bindMarker()));

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

@Override
public CassandraEndpointProfile updateServerProfile(byte[] keyHash,
                          int version,
                          String serverProfile) {
 LOG.debug("Updating server profile for endpoint profile with key hash [{}] "
     + "with schema version [{}]",
   Utils.encodeHexString(keyHash), version);
 ByteBuffer key = ByteBuffer.wrap(keyHash);
 Statement update = QueryBuilder.update(EP_COLUMN_FAMILY_NAME)
   .with(set(EP_SERVER_PROFILE_PROPERTY, serverProfile))
   .and(set(EP_SERVER_PROFILE_VERSION_PROPERTY, version))
   .where(eq(EP_EP_KEY_HASH_PROPERTY, key));
 execute(update, ConsistencyLevel.ALL);
 return findById(key);
}

代码示例来源：origin: Netflix/conductor

/**
 * @return cql query statement to add a new task_id to workflow_id mapping to the "task_lookup" table
 */
public String getUpdateTaskLookupStatement() {
  return QueryBuilder.update(keyspace, TABLE_TASK_LOOKUP)
      .with(set(WORKFLOW_ID_KEY, bindMarker()))
      .where(eq(TASK_ID_KEY, bindMarker()))
      .getQueryString();
}

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

QueryBuilder
    .update(TOKENS_TABLE)
    .with(setInactiveTime)
    .where(inKey).and(whereTokenInactive)
    .using(usingTTL)
QueryBuilder
.update(TOKENS_TABLE)
.with(setAccessedTime)
.where(inKey).and(whereTokenAccessed)
.using(usingTTL)

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

/**
 * Adds an assignment to the UPDATE statement those options are part of.
 *
 * @param assignment the assignment to add.
 * @return the assignments of the UPDATE statement those options are part of.
 */
public Assignments with(Assignment assignment) {
 return statement.with(assignment);
}

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

/**
 * Adds an assignment to the UPDATE statement this WHERE clause is part of.
 *
 * @param assignment the assignment to add.
 * @return the assignments of the UPDATE statement this WHERE clause is part of.
 */
public Assignments with(Assignment assignment) {
 return statement.with(assignment);
}

代码示例来源：origin: Netflix/conductor

/**
 * @return cql query statement to update the total_tasks in a shard for a workflow in the "workflows" table
 */
public String getUpdateTotalTasksStatement() {
  return QueryBuilder.update(keyspace, TABLE_WORKFLOWS)
      .with(set(TOTAL_TASKS_KEY, bindMarker()))
      .where(eq(WORKFLOW_ID_KEY, bindMarker()))
      .and(eq(SHARD_ID_KEY, bindMarker()))
      .getQueryString();
}

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

/**
 * Adds an assignment to the UPDATE statement those conditions are part of.
 *
 * @param assignment the assignment to add.
 * @return the assignments of the UPDATE statement those conditions are part of.
 */
public Assignments with(Assignment assignment) {
 return statement.with(assignment);
}

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

.with(set("schema_id", String.valueOf(schemaId + idShift)))
.where(eq("topic_id", ids[0]))
.and(eq("nf_type", ids[1]))
.with(set("schema_id", String.valueOf(schemaId + idShift)))
.where(eq("ep_key_hash", epKeyHash))
.and(eq("last_mod_time", lastModTime))

代码示例来源：origin: Netflix/conductor

/**
 * @return cql query statement to update the total_partitions for a workflow in the "workflows" table
 */
public String getUpdateTotalPartitionsStatement() {
  return QueryBuilder.update(keyspace, TABLE_WORKFLOWS)
      .with(set(TOTAL_PARTITIONS_KEY, bindMarker()))
      .and(set(TOTAL_TASKS_KEY, bindMarker()))
      .where(eq(WORKFLOW_ID_KEY, bindMarker()))
      .and(eq(SHARD_ID_KEY, 1))
      .getQueryString();
}

代码示例来源：origin: Netflix/conductor

/**
 * @return cql query statement to update a workflow in the "workflows" table
 */
public String getUpdateWorkflowStatement() {
  return QueryBuilder.update(keyspace, TABLE_WORKFLOWS)
      .with(set(PAYLOAD_KEY, bindMarker()))
      .where(eq(WORKFLOW_ID_KEY, bindMarker()))
      .and(eq(SHARD_ID_KEY, 1))
      .and(eq(ENTITY_KEY, ENTITY_TYPE_WORKFLOW))
      .and(eq(TASK_ID_KEY, ""))
      .getQueryString();
}

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

public void updateShardPointer(final Shard shard){
  Assignment assignment = QueryBuilder.set(COLUMN_POINTER, shard.getPointer());
  Clause queueNameClause = QueryBuilder.eq(COLUMN_QUEUE_NAME, shard.getQueueName());
  Clause regionClause = QueryBuilder.eq(COLUMN_REGION, shard.getRegion());
  Clause activeClause = QueryBuilder.eq(COLUMN_ACTIVE, 1);
  Clause shardIdClause = QueryBuilder.eq(COLUMN_SHARD_ID, shard.getShardId());
  Statement update = QueryBuilder.update(getTableName(shard.getType()))
      .with(assignment)
      .where(queueNameClause)
      .and(regionClause)
      .and(activeClause)
      .and(shardIdClause);
  cassandraClient.getQueueMessageSession().execute(update);
}

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

.with(set("body", bodyEncoded))
.where(eq("user_id", userId))
.and(eq("app_token", appToken))

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

public void increaseCounter(CassandraSessionPool.Session session,
                HugeType type, long increment) {
    Update update = QueryBuilder.update(TABLE);
    update.with(QueryBuilder.incr(formatKey(HugeKeys.ID), increment));
    update.where(formatEQ(HugeKeys.SCHEMA_TYPE, type.name()));
    session.execute(update);
  }
}

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

public void insert(CassandraSessionPool.Session session,
          CassandraBackendEntry.Row entry) {
  Update update = QueryBuilder.update(this.table);
  update.with(QueryBuilder.add(ELEMENT_IDS, entry.id().asLong()));
  update.where(CassandraTable.formatEQ(HugeKeys.NAME,
                     entry.column(HugeKeys.NAME)));
  session.add(update);
}

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

@Test(
  groups = "unit",
  expectedExceptions = {IllegalArgumentException.class})
public void batchMixedCounterTest() throws Exception {
 batch()
   .add(update("foo").with(incr("a", 1)))
   .add(update("foo").with(set("b", 2)))
   .add(update("foo").with(incr("c", 3)))
   .using(timestamp(42));
}

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

@SuppressWarnings("deprecation")
 @Test(groups = "short")
 public void should_handle_collections_of_tuples() {
  String query;
  BuiltStatement statement;
  query = "UPDATE foo SET l=[(1,2)] WHERE k=1;";
  TupleType tupleType = cluster().getMetadata().newTupleType(cint(), cint());
  List<TupleValue> list = ImmutableList.of(tupleType.newValue(1, 2));
  statement = update("foo").with(set("l", list)).where(eq("k", 1));
  assertThat(statement.toString()).isEqualTo(query);
 }
}

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

@Test(groups = "unit", expectedExceptions = CodecNotFoundException.class)
public void rejectUnknownValueTest() throws Exception {
 RegularStatement s =
   update("foo").with(set("a", new byte[13])).where(eq("k", 2)).setForceNoValues(true);
 s.getQueryString();
}

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

private ImmutableList<BuiltStatement> idempotentBuiltStatements() {
 return ImmutableList.<BuiltStatement>of(
   update("foo").with(set("v", 1)).where(eq("k", 1)), // set simple value
   update("foo").with(add("s", 1)).where(eq("k", 1)), // add to set
   update("foo").with(put("m", "a", 1)).where(eq("k", 1)), // put in map
   // select statements should be idempotent even with function calls
   select().countAll().from("foo").where(eq("k", 1)),
   select().ttl("v").from("foo").where(eq("k", 1)),
   select().writeTime("v").from("foo").where(eq("k", 1)),
   select().fcall("token", "k").from("foo").where(eq("k", 1)));
}