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

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

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

QueryBuilder.appendAll介绍

[英]Append a list of values to a list column.

This will generate: name = name + list.
[中]将值列表附加到列表列。
这将生成:name=name+list。

代码示例

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

/**
 * Append a value to a list column.
 *
 * <p>This will generate: {@code name = name + [value]}.
 *
 * @param name the column name (must be of type list).
 * @param value the value to append. Using a BindMarker here is not supported. To use a BindMarker
 *     use {@code QueryBuilder#appendAll} with a singleton list.
 * @return the correspond assignment (to use in an update query)
 */
public static Assignment append(String name, Object value) {
 if (value instanceof BindMarker) {
  throw new InvalidQueryException(
    "Binding a value in append() is not supported, use appendAll() and bind a singleton list");
 }
 return appendAll(name, Collections.singletonList(value));
}

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

/**
 * Append several elements to the collection column of a row
 */
@Override
public void append(CassandraSessionPool.Session session,
          CassandraBackendEntry.Row entry) {
  List<HugeKeys> idNames = this.idColumnName();
  List<HugeKeys> colNames = this.modifiableColumnName();
  Map<HugeKeys, Object> columns = entry.columns();
  Update update = QueryBuilder.update(table());
  for (HugeKeys key : colNames) {
    if (!columns.containsKey(key)) {
      continue;
    }
    String name = formatKey(key);
    Object value = columns.get(key);
    if (value instanceof Map) {
      update.with(QueryBuilder.putAll(name, (Map<?, ?>) value));
    } else if (value instanceof List) {
      update.with(QueryBuilder.appendAll(name, (List<?>) value));
    } else {
      update.with(QueryBuilder.append(name, value));
    }
  }
  for (HugeKeys idName : idNames) {
    assert columns.containsKey(idName);
    update.where(formatEQ(idName, columns.get(idName)));
  }
  session.add(update);
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET listofoptional = listofoptional + [?]</strong> */
@SuppressWarnings("static-access")
public final EntityWithComplexTypes_Update.Cols AppendTo(final Optional<String> listOfOptional_element) {
 where.with(QueryBuilder.appendAll("listofoptional", QueryBuilder.bindMarker("listofoptional")));
 boundValues.add(Arrays.asList(listOfOptional_element));
 encodedValues.add(meta.listOfOptional.encodeFromJava(Arrays.asList(listOfOptional_element), Optional.of(cassandraOptions)));
 return EntityWithComplexTypes_Update.Cols.this;
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET longlist = longlist + [?]</strong> */
@SuppressWarnings("static-access")
public final EntityWithNativeCollections_Update.Cols AppendTo(final Long longList_element) {
 where.with(QueryBuilder.appendAll("longlist", QueryBuilder.bindMarker("longlist")));
 boundValues.add(Arrays.asList(longList_element));
 encodedValues.add(meta.longList.encodeFromJava(Arrays.asList(longList_element), Optional.of(cassandraOptions)));
 return EntityWithNativeCollections_Update.Cols.this;
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET doublelist = doublelist + [?]</strong> */
@SuppressWarnings("static-access")
public final EntityWithNativeCollections_Update.Cols AppendTo(final Double doubleList_element) {
 where.with(QueryBuilder.appendAll("doublelist", QueryBuilder.bindMarker("doublelist")));
 boundValues.add(Arrays.asList(doubleList_element));
 encodedValues.add(meta.doubleList.encodeFromJava(Arrays.asList(doubleList_element), Optional.of(cassandraOptions)));
 return EntityWithNativeCollections_Update.Cols.this;
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET listudt = listudt + [?]</strong> */
@SuppressWarnings("static-access")
public final EntityWithUDTs_Update.Cols AppendTo(final SimpleUDTWithNoKeyspace listUDT_element) {
 where.with(QueryBuilder.appendAll("listudt", QueryBuilder.bindMarker("listudt")));
 boundValues.add(Arrays.asList(listUDT_element));
 encodedValues.add(meta.listUDT.encodeFromJava(Arrays.asList(listUDT_element), Optional.of(cassandraOptions)));
 return EntityWithUDTs_Update.Cols.this;
}

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

.and(prepend("b", 3))
    .and(append("c", "a"))
    .and(appendAll("d", Arrays.asList(1, 2, 3)))
    .and(discard("e", 1));
assertEquals(update.toString(), query);

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

/**
 * Generate an UPDATE FROM ... <strong>SET "listString" = "listString" + [?]</strong> */
@SuppressWarnings("static-access")
public final EntityWithCaseSensitivePK_Update.Cols AppendTo(final String list_element) {
 where.with(QueryBuilder.appendAll("\"listString\"", QueryBuilder.bindMarker("\"listString\"")));
 boundValues.add(Arrays.asList(list_element));
 encodedValues.add(meta.list.encodeFromJava(Arrays.asList(list_element), Optional.of(cassandraOptions)));
 return new EntityWithCaseSensitivePK_Update.Cols(where, cassandraOptions);
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET liststring = liststring + [?]</strong> */
@SuppressWarnings("static-access")
public final EntityForJSONCall_Update.Cols AppendTo(final String listString_element) {
 where.with(QueryBuilder.appendAll("liststring", QueryBuilder.bindMarker("liststring")));
 boundValues.add(Arrays.asList(listString_element));
 encodedValues.add(meta.listString.encodeFromJava(Arrays.asList(listString_element), Optional.of(cassandraOptions)));
 return new EntityForJSONCall_Update.Cols(where, cassandraOptions);
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET listofoptional = listofoptional + [?]</strong> */
@SuppressWarnings("static-access")
public final EntityWithComplexTypes_Update.Cols AppendTo(final Optional<String> listOfOptional_element) {
 where.with(QueryBuilder.appendAll("listofoptional", QueryBuilder.bindMarker("listofoptional")));
 boundValues.add(Arrays.asList(listOfOptional_element));
 encodedValues.add(meta.listOfOptional.encodeFromJava(Arrays.asList(listOfOptional_element), Optional.of(cassandraOptions)));
 return new EntityWithComplexTypes_Update.Cols(where, cassandraOptions);
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET list = list + ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithBeanValidation_Update.Cols AppendAllTo(final java.util.List<String> list_element) {
 where.with(QueryBuilder.appendAll("list", QueryBuilder.bindMarker("list")));
 boundValues.add(list_element);
 encodedValues.add(meta.list.encodeFromJava(list_element, Optional.of(cassandraOptions)));
 return EntityWithBeanValidation_Update.Cols.this;
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET consistencyList = consistencyList + ?</strong> */
@SuppressWarnings("static-access")
public final SimpleEntity_Update.Cols AppendAllTo(final List<ConsistencyLevel> consistencyList_element) {
 where.with(QueryBuilder.appendAll("consistencylist", QueryBuilder.bindMarker("consistencylist")));
 boundValues.add(consistencyList_element);
 encodedValues.add(meta.consistencyList.encodeFromJava(consistencyList_element, Optional.of(cassandraOptions)));
 return SimpleEntity_Update.Cols.this;
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET listUdt = listUdt + ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithComplexTypes_Update.Cols AppendAllTo(final List<TestUDT> listUdt_element) {
 where.with(QueryBuilder.appendAll("list_udt", QueryBuilder.bindMarker("list_udt")));
 boundValues.add(listUdt_element);
 encodedValues.add(meta.listUdt.encodeFromJava(listUdt_element, Optional.of(cassandraOptions)));
 return EntityWithComplexTypes_Update.Cols.this;
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET longList = longList + ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithNativeCollections_Update.Cols AppendAllTo(final List<Long> longList_element) {
 where.with(QueryBuilder.appendAll("longlist", QueryBuilder.bindMarker("longlist")));
 boundValues.add(longList_element);
 encodedValues.add(meta.longList.encodeFromJava(longList_element, Optional.of(cassandraOptions)));
 return EntityWithNativeCollections_Update.Cols.this;
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET listoflongarray = listoflongarray + [?]</strong> */
@SuppressWarnings("static-access")
public final EntityWithComplexTypes_Update.Cols AppendTo(final long[] listOfLongArray_element) {
 where.with(QueryBuilder.appendAll("listoflongarray", QueryBuilder.bindMarker("listoflongarray")));
 boundValues.add(Arrays.asList(listOfLongArray_element));
 encodedValues.add(meta.listOfLongArray.encodeFromJava(Arrays.asList(listOfLongArray_element), Optional.of(cassandraOptions)));
 return new EntityWithComplexTypes_Update.Cols(where, cassandraOptions);
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET doublelist = doublelist + [?]</strong> */
@SuppressWarnings("static-access")
public final EntityWithNativeCollections_Update.Cols AppendTo(final Double doubleList_element) {
 where.with(QueryBuilder.appendAll("doublelist", QueryBuilder.bindMarker("doublelist")));
 boundValues.add(Arrays.asList(doubleList_element));
 encodedValues.add(meta.doubleList.encodeFromJava(Arrays.asList(doubleList_element), Optional.of(cassandraOptions)));
 return new EntityWithNativeCollections_Update.Cols(where, cassandraOptions);
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET collectionIndex = collectionIndex + ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithIndicesForJSON_Update.Cols AppendAllTo(final List<String> collectionIndex_element) {
 where.with(QueryBuilder.appendAll("collectionindex", QueryBuilder.bindMarker("collectionindex")));
 boundValues.add(collectionIndex_element);
 encodedValues.add(meta.collectionIndex.encodeFromJava(collectionIndex_element, Optional.of(cassandraOptions)));
 return EntityWithIndicesForJSON_Update.Cols.this;
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET listOfOptional = listOfOptional + ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithComplexTypes_Update.Cols AppendAllTo(final List<Optional<String>> listOfOptional_element) {
 where.with(QueryBuilder.appendAll("listofoptional", QueryBuilder.bindMarker("listofoptional")));
 boundValues.add(listOfOptional_element);
 encodedValues.add(meta.listOfOptional.encodeFromJava(listOfOptional_element, Optional.of(cassandraOptions)));
 return EntityWithComplexTypes_Update.Cols.this;
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET list = list + ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithCaseSensitivePK_Update.Cols AppendAllTo(final java.util.List<String> list_element) {
 where.with(QueryBuilder.appendAll("\"listString\"", QueryBuilder.bindMarker("\"listString\"")));
 boundValues.add(list_element);
 encodedValues.add(meta.list.encodeFromJava(list_element, Optional.of(cassandraOptions)));
 return new EntityWithCaseSensitivePK_Update.Cols(where, cassandraOptions);
}

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

/**
 * Generate an UPDATE FROM ... <strong>SET listNesting = listNesting + ?</strong> */
@SuppressWarnings("static-access")
public final EntityWithComplexTypes_Update.Cols AppendAllTo(final List<Map<java.lang.Integer, String>> listNesting_element) {
 where.with(QueryBuilder.appendAll("list_nesting", QueryBuilder.bindMarker("list_nesting")));
 boundValues.add(listNesting_element);
 encodedValues.add(meta.listNesting.encodeFromJava(listNesting_element, Optional.of(cassandraOptions)));
 return new EntityWithComplexTypes_Update.Cols(where, cassandraOptions);
}

相关文章

微信公众号

最新文章

更多