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

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

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

QueryBuilder.bindMarker介绍

[英]An object representing an anonymous bind marker (a question mark).

This can be used wherever a value is expected. For instance, one can do:

Insert i = QueryBuilder.insertInto("test").value("k", 0)

[中]表示匿名绑定标记（问号）的对象。
这可以在任何需要值的地方使用。例如，一个人可以做：

Insert i = QueryBuilder.insertInto("test").value("k", 0)

代码示例

代码示例来源：origin: prestodb/presto

public CassandraPageSink(
    CassandraSession cassandraSession,
    String schemaName,
    String tableName,
    List<String> columnNames,
    List<Type> columnTypes,
    boolean generateUUID)
{
  this.cassandraSession = requireNonNull(cassandraSession, "cassandraSession");
  requireNonNull(schemaName, "schemaName is null");
  requireNonNull(tableName, "tableName is null");
  requireNonNull(columnNames, "columnNames is null");
  this.columnTypes = ImmutableList.copyOf(requireNonNull(columnTypes, "columnTypes is null"));
  this.generateUUID = generateUUID;
  Insert insert = insertInto(schemaName, tableName);
  if (generateUUID) {
    insert.value("id", bindMarker());
  }
  for (int i = 0; i < columnNames.size(); i++) {
    String columnName = columnNames.get(i);
    checkArgument(columnName != null, "columnName is null at position: %d", i);
    insert.value(columnName, bindMarker());
  }
  this.insert = cassandraSession.prepare(insert);
}

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

/**
 * @return cql query statement to insert a new workflow into the "workflows" table
 */
public String getInsertWorkflowStatement() {
  return QueryBuilder.insertInto(keyspace, TABLE_WORKFLOWS)
      .value(WORKFLOW_ID_KEY, bindMarker())
      .value(SHARD_ID_KEY, bindMarker())
      .value(TASK_ID_KEY, bindMarker())
      .value(ENTITY_KEY, ENTITY_TYPE_WORKFLOW)
      .value(PAYLOAD_KEY, bindMarker())
      .value(TOTAL_TASKS_KEY, bindMarker())
      .value(TOTAL_PARTITIONS_KEY, bindMarker())
      .getQueryString();
}

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

/**
 * @return cql query statement to insert a new task into the "workflows" table
 */
public String getInsertTaskStatement() {
  return QueryBuilder.insertInto(keyspace, TABLE_WORKFLOWS)
      .value(WORKFLOW_ID_KEY, bindMarker())
      .value(SHARD_ID_KEY, bindMarker())
      .value(TASK_ID_KEY, bindMarker())
      .value(ENTITY_KEY, ENTITY_TYPE_TASK)
      .value(PAYLOAD_KEY, bindMarker())
      .getQueryString();
}

代码示例来源：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: 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: 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 retrieve a task from the "workflows" table
 */
public String getSelectTaskStatement() {
  return QueryBuilder.select(PAYLOAD_KEY)
      .from(keyspace, TABLE_WORKFLOWS)
      .where(eq(WORKFLOW_ID_KEY, bindMarker()))
      .and(eq(SHARD_ID_KEY, bindMarker()))
      .and(eq(ENTITY_KEY, ENTITY_TYPE_TASK))
      .and(eq(TASK_ID_KEY, bindMarker()))
      .getQueryString();
}

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

/**
 * @return cql query statement to delete a workflow from the "workflows" table
 */
public String getDeleteWorkflowStatement() {
  return QueryBuilder.delete()
      .from(keyspace, TABLE_WORKFLOWS)
      .where(eq(WORKFLOW_ID_KEY, bindMarker()))
      .and(eq(SHARD_ID_KEY, bindMarker()))
      .getQueryString();
}

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

/**
   * @return cql query statement to delete a task from the "workflows" table
   */
  public String getDeleteTaskStatement() {
    return QueryBuilder.delete()
        .from(keyspace, TABLE_WORKFLOWS)
        .where(eq(WORKFLOW_ID_KEY, bindMarker()))
        .and(eq(SHARD_ID_KEY, bindMarker()))
        .and(eq(ENTITY_KEY, ENTITY_TYPE_TASK))
        .and(eq(TASK_ID_KEY, bindMarker()))
        .getQueryString();
  }
}

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

/**
 * @return cql query statement to retrieve a workflow with its tasks from the "workflows" table
 */
public String getSelectWorkflowWithTasksStatement() {
  return QueryBuilder.select()
      .all()
      .from(keyspace, TABLE_WORKFLOWS)
      .where(eq(WORKFLOW_ID_KEY, bindMarker()))
      .and(eq(SHARD_ID_KEY, bindMarker()))
      .getQueryString();
}

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

insertStmt.value(YCSB_KEY, QueryBuilder.bindMarker());
 insertStmt.value(field, QueryBuilder.bindMarker());

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

.where(QueryBuilder.eq(YCSB_KEY, QueryBuilder.bindMarker())));
stmt.setConsistencyLevel(writeConsistencyLevel);
if (trace) {

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

/**
 * @return cql query statement to delete a task_id to workflow_id mapping from the "task_lookup" table
 */
public String getDeleteTaskLookupStatement() {
  return QueryBuilder.delete()
      .from(keyspace, TABLE_TASK_LOOKUP)
      .where(eq(TASK_ID_KEY, bindMarker()))
      .getQueryString();
}

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

/**
 * @return cql query statement to retrieve the workflow_id for a particular task_id from the "task_lookup" table
 */
public String getSelectTaskFromLookupTableStatement() {
  return QueryBuilder.select(WORKFLOW_ID_KEY)
      .from(keyspace, TABLE_TASK_LOOKUP)
      .where(eq(TASK_ID_KEY, bindMarker()))
      .getQueryString();
}

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

updateStmt.with(QueryBuilder.set(field, QueryBuilder.bindMarker()));
updateStmt.where(QueryBuilder.eq(YCSB_KEY, QueryBuilder.bindMarker()));

代码示例来源：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/storm

getQuery.and(eq(key, bindMarker()));
.values(allFields, Collections.<Object>nCopies(allFields.size(), bindMarker()));

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

/**
 * @return cql query statement to retrieve the total_tasks and total_partitions for a workflow from the "workflows" table
 */
public String getSelectTotalStatement() {
  return QueryBuilder.select(TOTAL_TASKS_KEY, TOTAL_PARTITIONS_KEY)
      .from(keyspace, TABLE_WORKFLOWS)
      .where(eq(WORKFLOW_ID_KEY, bindMarker()))
      .and(eq(SHARD_ID_KEY, 1))
      .getQueryString();
}

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

.where(QueryBuilder.eq(YCSB_KEY, QueryBuilder.bindMarker()))
            .limit(1));
stmt.setConsistencyLevel(readConsistencyLevel);

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

/**
 * @return cql query statement to retrieve a workflow (without its tasks) from the "workflows" table
 */
public String getSelectWorkflowStatement() {
  return QueryBuilder.select(PAYLOAD_KEY)
      .from(keyspace, TABLE_WORKFLOWS)
      .where(eq(WORKFLOW_ID_KEY, bindMarker()))
      .and(eq(SHARD_ID_KEY, 1))
      .and(eq(ENTITY_KEY, ENTITY_TYPE_WORKFLOW))
      .getQueryString();
}

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

QueryBuilder

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    QueryBuilder类方法

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