com.couchbase.client.java.Bucket类的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(9.2k)|赞(0)|评价(0)|浏览(159)

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

Bucket介绍

[英]Defines operations that can be executed synchronously against a Couchbase Server bucket. Note that only a subset of the provided operations are available for "memcached" type buckets. Also, some other operations are only available against specific versions of Couchbase Server. Default timeouts are always applied and can be configured through the CouchbaseEnvironment. Overloads are also available to change them on a per-call basis.
[中]定义可对Couchbase服务器存储桶同步执行的操作。请注意，提供的操作只有一个子集可用于“memcached”类型的bucket。此外，一些其他操作仅适用于Couchbase Server的特定版本。默认超时始终应用，并且可以通过CouchbaseEnvironment进行配置。重载也可用于在每次调用的基础上更改它们。

代码示例

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

@Override
  public long removeByPattern(String regex) throws IOException {
    Statement statement = Delete.deleteFromCurrentBucket().where(regexpContains("meta().id", regex));
    final N1qlQueryResult result = bucket.query(N1qlQuery.simple(statement));
    if (logger.isDebugEnabled()) {
      logger.debug("Deleted documents using regex {}, result={}", regex, result);
    }
    return result.info().mutationCount();
  }
}

代码示例来源：origin: apache/incubator-gobblin

@Override
public WriteResponse write(D record)
  throws IOException {
 try {
  D doc = _bucket.upsert(record);
  return new GenericWriteResponse(doc);
 } catch (Exception e) {
  throw new IOException("Failed to write to Couchbase cluster", e);
 }
}

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

/**
 * Performs the {@link #read(String, String, Set, Map)} operation via Key/Value ("get").
 *
 * @param docId the document ID
 * @param fields the fields to be loaded
 * @param result the result map where the doc needs to be converted into
 * @return The result of the operation.
 */
private Status readKv(final String docId, final Set<String> fields, final Map<String, ByteIterator> result)
 throws Exception {
 RawJsonDocument loaded = bucket.get(docId, RawJsonDocument.class);
 if (loaded == null) {
  return Status.NOT_FOUND;
 }
 decode(loaded.content(), fields, result);
 return Status.OK;
}

代码示例来源：origin: apache/incubator-gobblin

@Override
 public void close() {
  if (!_bucket.isClosed()) {
   try {
    _bucket.close();
   } catch (Exception e) {
    log.warn("Failed to close bucket", e);
   }
  }
  try {
   _cluster.disconnect();
  } catch (Exception e) {
   log.warn("Failed to disconnect from cluster", e);
  }
 }
}

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

@Override
public <K, V> boolean replace(AtomicCacheEntry<K, V, Long> entry, Serializer<K> keySerializer, Serializer<V> valueSerializer) throws IOException {
  final Long revision = entry.getRevision().orElse(0L);
  final String docId = toDocumentId(entry.getKey(), keySerializer);
  final Document doc = toDocument(docId, entry.getValue(), valueSerializer, revision);
  try {
    if (revision < 0) {
      // If the document does not exist yet, try to create one.
      try {
        bucket.insert(doc);
        return true;
      } catch (DocumentAlreadyExistsException e) {
        return false;
      }
    }
    bucket.replace(doc);
    return true;
  } catch (DocumentDoesNotExistException|CASMismatchException e) {
    return false;
  }
}

代码示例来源：origin: testcontainers/testcontainers-java

@After
public void clear() {
  if (getCouchbaseContainer().isIndex() && getCouchbaseContainer().isQuery() && getCouchbaseContainer().isPrimaryIndex()) {
    getBucket().query(
      N1qlQuery.simple(String.format("DELETE FROM `%s`", getBucket().name()),
        N1qlParams.build().consistency(ScanConsistency.STATEMENT_PLUS)));
  } else {
    getBucket().bucketManager().flush();
  }
}

代码示例来源：origin: testcontainers/testcontainers-java

@Test
  public void shouldCreateView() {
    View view = DefaultView.create(VIEW_NAME, VIEW_FUNCTION);
    DesignDocument document = DesignDocument.create(VIEW_NAME, Lists.newArrayList(view));
    getBucket().bucketManager().insertDesignDocument(document);
    DesignDocument result = getBucket().bucketManager().getDesignDocument(VIEW_NAME);
    Assert.assertEquals(1, result.views().size());
    View resultView = result.views().get(0);
    Assert.assertEquals(VIEW_NAME, resultView.name());
  }
}

代码示例来源：origin: org.arquillian.ape/arquillian-ape-nosql-couchbase

@Override
public void disconnect() {
  if (bucket != null) {
    bucket.close();
  }
}

代码示例来源：origin: Impetus/Kundera

/**
 * Execute native query.
 *
 * @param n1qlQuery
 *            the n1ql query
 * @param em
 *            the entity manager
 * @return the list
 */
public List executeNativeQuery(String n1qlQuery, EntityMetadata em)
{
  N1qlQueryResult result = bucket
      .query(N1qlQuery.simple(n1qlQuery, N1qlParams.build().consistency(ScanConsistency.REQUEST_PLUS)));
  LOGGER.debug("Executed query : " + n1qlQuery + " on the " + bucket.name() + " Bucket");
  validateQueryResults(n1qlQuery, result);
  return result.allRows();
}

代码示例来源：origin: neo4j-contrib/neo4j-apoc-procedures

public static boolean fillDB(CouchbaseCluster cluster) {
  Bucket couchbaseBucket = cluster.openBucket(BUCKET_NAME);
  couchbaseBucket.insert(JsonDocument.create("artist:vincent_van_gogh", VINCENT_VAN_GOGH));
  N1qlQueryResult queryResult = couchbaseBucket.query(N1qlQuery.simple(String.format(QUERY, BUCKET_NAME), N1qlParams.build().consistency(ScanConsistency.REQUEST_PLUS)));
  couchbaseBucket.close();
  return queryResult.info().resultCount() == 1;
}

代码示例来源：origin: neo4j-contrib/neo4j-apoc-procedures

@Test
@SuppressWarnings("unchecked")
public void testUpsertViaCall() {
  testCall(graphDB, "CALL apoc.couchbase.upsert({host}, {bucket}, 'testUpsertViaCall', {data})",
      map("host", HOST, "bucket", BUCKET_NAME, "data", VINCENT_VAN_GOGH.toString()),
      r -> {
        assertTrue(r.get("content") instanceof Map);
        Map<String, Object> content = (Map<String, Object>) r.get("content");
        assertTrue(content.get("notableWorks") instanceof List);
        List<String> notableWorks = (List<String>) content.get("notableWorks");
        checkDocumentContent(
            (String) content.get("firstName"),
            (String) content.get("secondName"),
            (String) content.get("lastName"),
            notableWorks);
        couchbaseBucket.remove("testUpsertViaCall");
        assertFalse(couchbaseBucket.exists("testUpsertViaCall"));
      });
}

代码示例来源：origin: Impetus/Kundera

@Override
protected void onPersist(EntityMetadata entityMetadata, Object entity, Object id, List<RelationHolder> rlHolders)
{
  JsonDocument doc = handler.getDocumentFromEntity(entityMetadata, entity, kunderaMetadata);
  if (!isUpdate)
  {
    bucket.insert(doc);
    LOGGER.debug("Inserted document with ID : " + doc.id() + " in the " + bucket.name() + " Bucket");
  }
  else
  {
    bucket.upsert(doc);
    LOGGER.debug("Updated document with ID : " + doc.id() + " in the " + bucket.name() + " Bucket");
  }
}

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

RawJsonDocument document = bucket.get(docId, RawJsonDocument.class);
    if (document != null) {
      outputStreamCallback = out -> {
    BinaryDocument document = bucket.get(docId, BinaryDocument.class);
    if (document != null) {
      outputStreamCallback = out -> {
updatedAttrs.put(CouchbaseAttributes.Bucket.key(), bucket.name());
updatedAttrs.put(CouchbaseAttributes.DocId.key(), docId);
updatedAttrs.put(CouchbaseAttributes.Cas.key(), String.valueOf(doc.cas()));

代码示例来源：origin: testcontainers/testcontainers-java

@Test
public void shouldInsertDocument() {
  RawJsonDocument expected = RawJsonDocument.create(ID, DOCUMENT);
  getBucket().upsert(expected);
  RawJsonDocument result = getBucket().get(ID, RawJsonDocument.class);
  Assert.assertEquals(expected.content(), result.content());
}

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

final ReplicateTo replicateTo = ReplicateTo.valueOf(context.getProperty(REPLICATE_TO).getValue());
final Bucket bucket = openBucket(context);
doc = bucket.upsert(doc, persistTo, replicateTo);
updatedAttrs.put(CouchbaseAttributes.Bucket.key(), bucket.name());
updatedAttrs.put(CouchbaseAttributes.DocId.key(), docId);
updatedAttrs.put(CouchbaseAttributes.Cas.key(), String.valueOf(doc.cas()));

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

@Override
public <K> boolean remove(K key, Serializer<K> serializer) throws IOException {
  try {
    bucket.remove(toDocumentId(key, serializer));
    return true;
  } catch (DocumentDoesNotExistException e) {
    return false;
  }
}

代码示例来源：origin: Impetus/Kundera

/**
 * Close bucket.
 *
 * @param bucket
 *            the bucket
 */
public static void closeBucket(Bucket bucket)
{
  if (bucket != null)
  {
    if (!bucket.close())
    {
      LOGGER.error("Not able to close bucket [" + bucket.name() + "].");
      throw new KunderaException("Not able to close bucket [" + bucket.name() + "].");
    }
    else
    {
      LOGGER.debug("Bucket [" + bucket.name() + "] is closed!");
    }
  }
}

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

@Override
public <K, V> boolean putIfAbsent(K key, V value, Serializer<K> keySerializer, Serializer<V> valueSerializer) throws IOException {
  final String docId = toDocumentId(key, keySerializer);
  final Document doc = toDocument(docId, value, valueSerializer);
  try {
    bucket.insert(doc);
    return true;
  } catch (DocumentAlreadyExistsException e) {
    return false;
  }
}

代码示例来源：origin: neo4j-contrib/neo4j-apoc-procedures

@Test
public void testRemoveViaCall() {
  couchbaseBucket.insert(JsonDocument.create("testRemove", JsonObject.empty()));
  testCall(graphDB, "CALL apoc.couchbase.remove({host}, {bucket}, 'testRemove')",
      map("host", HOST, "bucket", BUCKET_NAME),
      r -> assertFalse(couchbaseBucket.exists("testRemove")));
}

代码示例来源：origin: jooby-project/jooby

AsyncBucket async = bucket.async();
bind.apply(AsyncBucket.class, name, async);
Repository repo = bucket.repository();
AsyncRepository asyncrepo = repo.async();
buckets.forEach(n -> Try.apply(() -> r.require(n, Bucket.class).close())
  .onFailure(x -> log.debug("bucket {} close operation resulted in exception", n, x))
  .orElse(false));

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

Bucket

相关文章

    查看更多

    热门标签

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

    最新文章

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