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

x33g5p2x  于2022-01-30 转载在 其他  
字(15.2k)|赞(0)|评价(0)|浏览(279)

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

Select.setConsistencyLevel介绍

暂无

代码示例

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

  1. /**
  2.  * Get all entities from cassandra database.
  3.  * @return <code>List</code> of entities
  4.  */
  5. public List<T> find() {
  6.  LOG.debug("Get all entities from column family {}", getColumnFamilyName());
  7.  return findListByStatement(
  8.    QueryBuilder.select()
  9.      .all().from(getColumnFamilyName())
  10.      .setConsistencyLevel(getReadConsistencyLevel()));
  11. }

代码示例来源：origin: otaviojava/Easy-Cassandra

  1. @Override
  2. public SelectBuilder<T> withConsistencyLevel(ConsistencyLevel consistency) {
  3.   select.setConsistencyLevel(consistency);
  4.   return this;
  5. }

代码示例来源：origin: stackoverflow.com

  1. Select s = QueryBuilder.select().from("employee");
  2.    s.where(QueryBuilder.eq("id", "234"));
  3.    s.setConsistencyLevel(ConsistencyLevel.QUORUM) ;

代码示例来源：origin: Stratio/stratio-cassandra-benchmark

  1. public void run() {
  2.   try {
  3.     RateLimiter rateLimiter = RateLimiter.create(rate);
  4.     for (String data : dataset) {
  5.       rateLimiter.acquire();
  6.       String clause = String.format("{%s : {type : \"lucene\", default_field : \"%s\", query : \"%s\"}}",
  7.                      relevance ? "query" : "filter",
  8.                      column,
  9.                      data);
  10.       Select select = QueryBuilder.select()
  11.                     .from(keyspace, table)
  12.                     .where(QueryBuilder.eq(column, clause))
  13.                     .limit(limit);
  14.       long startTime = System.currentTimeMillis();
  15.       ResultSet rs = session.execute(select.setConsistencyLevel(ConsistencyLevel.ONE));
  16.       List<Row> rows = rs.all();
  17.       long queryTime = System.currentTimeMillis() - startTime;
  18.       stats.inc(queryTime);
  19.       logger.debug("QUERY : " + select.toString() + " " + queryTime + " ms");
  20.       for (Row row : rows) {
  21.         logger.debug("\tROW : " + row);
  22.       }
  23.     }
  24.   } catch (Exception e) {
  25.     e.printStackTrace();
  26.     logger.error(e);
  27.   }
  28. }

代码示例来源：origin: valchkou/cassandra-driver-mapping

  1. private static void appendOptions(Select select, ReadOptions options) {
  2.   if (options != null) {
  3.     if (options.getConsistencyLevel() != null) {
  4.       select.setConsistencyLevel(options.getConsistencyLevel());
  5.     }
  6.     if (options.getRetryPolicy() != null) {
  7.       select.setRetryPolicy(options.getRetryPolicy());
  8.     }
  9.   }
  10. }

代码示例来源：origin: Contrast-Security-OSS/cassandra-migration

  1. /**
  2.  * Calculates the installed rank for the new migration to be inserted.
  3.  *
  4.  * @return The installed rank.
  5.  */
  6. private int calculateInstalledRank() {
  7.   Statement statement = new SimpleStatement(
  8.       "UPDATE " + keyspace.getName() + "." + tableName + COUNTS_TABLE_NAME_SUFFIX +
  9.           " SET count = count + 1" +
  10.           "WHERE name = 'installed_rank';");
  11.   session.execute(statement);
  12.   Select select = QueryBuilder
  13.       .select("count")
  14.       .from(tableName + COUNTS_TABLE_NAME_SUFFIX);
  15.   select.where(eq("name", "installed_rank"));
  16.   select.setConsistencyLevel(this.consistencyLevel);
  17.   ResultSet result = session.execute(select);
  18.   return (int) result.one().getLong("count");
  19. }

代码示例来源：origin: otaviojava/Easy-Cassandra

  1. protected Select prepareCount(Class<?> bean, ConsistencyLevel consistency) {
  2.     ClassInformation classInformation = ClassInformations.INSTACE.getClass(bean);
  3.     KeySpaceInformation key = classInformation.getKeySpace(keySpace);
  4.     Select select = QueryBuilder.select().countAll()
  5.         .from(key.getKeySpace(), key.getColumnFamily());
  6.     select.setConsistencyLevel(consistency);
  7.     return select;
  8.   }
  9. }

代码示例来源：origin: smartcat-labs/cassandra-migration-tool-java

  1. /**
  2.  * Get current database version for given migration type with ALL consistency. Select one row since
  3.  * migration history is saved ordered descending by timestamp. If there are no rows in the schema_version table,
  4.  * return 0 as default database version. Data version is changed by executing migrations.
  5.  *
  6.  * @param type Migration type
  7.  * @return Database version for given type
  8.  */
  9. public int getCurrentVersion(final MigrationType type) {
  10.   final Statement select = QueryBuilder.select().all().from(SCHEMA_VERSION_CF)
  11.       .where(QueryBuilder.eq(TYPE, type.name())).limit(1).setConsistencyLevel(ConsistencyLevel.ALL);
  12.   final ResultSet result = session.execute(select);
  13.   final Row row = result.one();
  14.   return row == null ? 0 : row.getInt(VERSION);
  15. }

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

  1. @Override
  2. public ResponseData get(Object rkey, Object colName) throws OperationException {
  3.   Session session = DataStaxClientConnection.instance.session();
  4.   TableMetadata tm = DataStaxClientConnection.instance.getKeyspaceMetadata().getTable(cfName);
  5.   String partitionKey = tm.getPartitionKey().get(0).getName();
  6.   
  7.   Query query = QueryBuilder.select(colName.toString()).from(cfName).where(QueryBuilder.eq(partitionKey, rkey)).limit(1000000)
  8.       .setConsistencyLevel(ConsistencyLevel.valueOf(com.netflix.jmeter.properties.Properties.instance.cassandra.getReadConsistency()));
  9.   
  10.   ResultSetFuture rs = session.executeAsync(query);
  11.   int size = 0;
  12.   try {
  13.     Row row = rs.getUninterruptibly(1000000, TimeUnit.MILLISECONDS).one();
  14.     size = row != null ? row.getBytesUnsafe(colName.toString()).capacity() : 0;
  15.   }
  16.   catch (TimeoutException e) {
  17.     e.printStackTrace();
  18.     throw new OperationException(e);
  19.   }
  20.   return new DataStaxClientResponseData("", size, "", 0, rkey, colName, null);
  21. }

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

  1. @Override
  2.   protected ResultSet queryRowGroupRowsAfter(Row row) {
  3.     Statement statement = selectDeltaFrom(_placement.getBlockedDeltaTableDDL())
  4.         .where(eq(_placement.getBlockedDeltaTableDDL().getRowKeyColumnName(), getKey(row)))
  5.         .and(gt(ImmutableList.of(_placement.getBlockedDeltaTableDDL().getChangeIdColumnName(), _placement.getBlockedDeltaTableDDL().getBlockColumnName()),
  6.             ImmutableList.of(getChangeId(row), getBlock(row))))
  7.         .orderBy(asc(_placement.getBlockedDeltaTableDDL().getChangeIdColumnName()))
  8.         .setConsistencyLevel(_consistency);
  9.     return AdaptiveResultSet.executeAdaptiveQuery(_placement.getKeyspace().getCqlSession(), statement, _driverConfig.getSingleRowFetchSize());
  10.   }
  11. }

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

  1. @Override
  2.   protected ResultSet queryRowGroupRowsAfter(Row row) {
  3.     Statement statement = selectDeltaFrom(_placement.getBlockedDeltaTableDDL())
  4.         .where(eq(_placement.getBlockedDeltaTableDDL().getRowKeyColumnName(), getKey(row)))
  5.         .and(gt(ImmutableList.of(_placement.getBlockedDeltaTableDDL().getChangeIdColumnName(), _placement.getBlockedDeltaTableDDL().getBlockColumnName()),
  6.             ImmutableList.of(getChangeId(row), getBlock(row))))
  7.         .orderBy(asc(_placement.getBlockedDeltaTableDDL().getChangeIdColumnName()))
  8.         .setConsistencyLevel(_consistency);
  9.     return AdaptiveResultSet.executeAdaptiveQuery(_placement.getKeyspace().getCqlSession(), statement, _driverConfig.getSingleRowFetchSize());
  10.   }
  11. }

代码示例来源：origin: otaviojava/Easy-Cassandra

  1. /**
  2.  * create the {@link QueryBean}.
  3.  * @param bean the bean
  4.  * @param consistency the consistency
  5.  * @param <T> kind of class
  6.  * @return {@link QueryBean}
  7.  */
  8. protected <T> QueryBean createQueryBean(Class<T> bean,
  9.     ConsistencyLevel consistency) {
  10.   ClassInformation classInformation = ClassInformations.INSTACE.getClass(bean);
  11.   QueryBean byKeyBean = prepare(new QueryBean(), classInformation);
  12.   KeySpaceInformation keySpaceInformation = classInformation.getKeySpace(keySpace);
  13.   byKeyBean.select = QueryBuilder.select(byKeyBean.getArray()).from(
  14.       keySpaceInformation.getKeySpace(), keySpaceInformation.getColumnFamily());
  15.   byKeyBean.select.setConsistencyLevel(consistency);
  16.   return byKeyBean;
  17. }

代码示例来源：origin: Stratio/stratio-cassandra-test

  1. public List<Row> selectAllFromIndexQueryWithFiltering(int limit, String name, Object value) {
  2.   String search = search().query(all()).refresh(true).toJson();
  3.   return execute(QueryBuilder.select()
  4.                 .from(keyspace, table)
  5.                 .where(QueryBuilder.eq(indexColumn, search))
  6.                 .and(QueryBuilder.eq(name, value))
  7.                 .limit(limit)
  8.                 .allowFiltering()
  9.                 .setConsistencyLevel(consistencyLevel));
  10. }

代码示例来源：origin: Contrast-Security-OSS/cassandra-migration

  1. .from(keyspace.getName(), tableName);
  2. select.setConsistencyLevel(this.consistencyLevel);
  3. ResultSet results = session.execute(select);
  4. List<AppliedMigration> resultsList = new ArrayList<>();

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

  1. private Iterator<ProtoStashTokenRange> getTokenRangesBetweenIntraShard(String stashId, String placement,
  2.                                     ByteBuffer fromInclusive, ByteBuffer toExclusive) {
  3.   // Since the range falls entirely within a single shard run a targeted query that only looks for the beginning
  4.   // of that shard.
  5.   ByteBuffer startToken = RowKeyUtils.getRowKeyRaw(RowKeyUtils.getShardId(fromInclusive), RowKeyUtils.getTableUuid(fromInclusive), new byte[0]);
  6.   ResultSet resultSet = _placementCache.get(_systemTablePlacement)
  7.       .getKeyspace()
  8.       .getCqlSession()
  9.       .execute(
  10.           QueryBuilder.select(TABLE_JSON_COLUMN)
  11.               .from(STASH_TOKEN_RANGE_TABLE)
  12.               .where(QueryBuilder.eq(STASH_ID_COLUMN, stashId))
  13.               .and(QueryBuilder.eq(DATA_CENTER_COLUMN, _dataCenters.getSelf().getName()))
  14.               .and(QueryBuilder.eq(PLACEMENT_COLUMN, placement))
  15.               .and(QueryBuilder.eq(RANGE_TOKEN_COLUMN, startToken))
  16.               .and(QueryBuilder.eq(IS_START_TOKEN_COLUMN, true))
  17.               .limit(1)
  18.               .setConsistencyLevel(ConsistencyLevel.LOCAL_QUORUM));
  19.   Row row = resultSet.one();
  20.   if (row == null) {
  21.     return Iterators.emptyIterator();
  22.   }
  23.   TableJson tableJson = toTableJson(row.getString(0));
  24.   return Iterators.singletonIterator(new ProtoStashTokenRange(fromInclusive, toExclusive, tableJson));
  25. }

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

  1. private Iterator<ProtoStashTokenRange> getTokenRangesBetweenIntraShard(String stashId, String placement,
  2.                                     ByteBuffer fromInclusive, ByteBuffer toExclusive) {
  3.   // Since the range falls entirely within a single shard run a targeted query that only looks for the beginning
  4.   // of that shard.
  5.   ByteBuffer startToken = RowKeyUtils.getRowKeyRaw(RowKeyUtils.getShardId(fromInclusive), RowKeyUtils.getTableUuid(fromInclusive), new byte[0]);
  6.   ResultSet resultSet = _placementCache.get(_systemTablePlacement)
  7.       .getKeyspace()
  8.       .getCqlSession()
  9.       .execute(
  10.           QueryBuilder.select(TABLE_JSON_COLUMN)
  11.               .from(STASH_TOKEN_RANGE_TABLE)
  12.               .where(QueryBuilder.eq(STASH_ID_COLUMN, stashId))
  13.               .and(QueryBuilder.eq(DATA_CENTER_COLUMN, _dataCenters.getSelf().getName()))
  14.               .and(QueryBuilder.eq(PLACEMENT_COLUMN, placement))
  15.               .and(QueryBuilder.eq(RANGE_TOKEN_COLUMN, startToken))
  16.               .and(QueryBuilder.eq(IS_START_TOKEN_COLUMN, true))
  17.               .limit(1)
  18.               .setConsistencyLevel(ConsistencyLevel.LOCAL_QUORUM));
  19.   Row row = resultSet.one();
  20.   if (row == null) {
  21.     return Iterators.emptyIterator();
  22.   }
  23.   TableJson tableJson = toTableJson(row.getString(0));
  24.   return Iterators.singletonIterator(new ProtoStashTokenRange(fromInclusive, toExclusive, tableJson));
  25. }

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

  1. /**
  2.  * Reads columns from the delta or delta history table.  The range of columns, order, and limit can be
  3.  * parameterized.
  4.  */
  5. private ResultSet columnScan(DeltaPlacement placement, TableDDL tableDDL, ByteBuffer rowKey, Range<RangeTimeUUID> columnRange,
  6.                boolean ascending, int limit, ConsistencyLevel consistency) {
  7.   Select.Where where = selectFrom(tableDDL)
  8.       .where(eq(tableDDL.getRowKeyColumnName(), rowKey));
  9.   if (columnRange.hasLowerBound()) {
  10.     if (columnRange.lowerBoundType() == BoundType.CLOSED) {
  11.       where = where.and(gte(tableDDL.getChangeIdColumnName(), columnRange.lowerEndpoint().getUuid()));
  12.     } else {
  13.       where = where.and(gt(tableDDL.getChangeIdColumnName(), columnRange.lowerEndpoint().getUuid()));
  14.     }
  15.   }
  16.   if (columnRange.hasUpperBound()) {
  17.     if (columnRange.upperBoundType() == BoundType.CLOSED) {
  18.       where = where.and(lte(tableDDL.getChangeIdColumnName(), columnRange.upperEndpoint().getUuid()));
  19.     } else {
  20.       where = where.and(lt(tableDDL.getChangeIdColumnName(), columnRange.upperEndpoint().getUuid()));
  21.     }
  22.   }
  23.   Statement statement = where
  24.       .orderBy(ascending ? asc(tableDDL.getChangeIdColumnName()) : desc(tableDDL.getChangeIdColumnName()))
  25.       .limit(limit)
  26.       .setConsistencyLevel(consistency);
  27.   return AdaptiveResultSet.executeAdaptiveQuery(placement.getKeyspace().getCqlSession(), statement, _driverConfig.getSingleRowFetchSize());
  28. }

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

  1. /**
  2.  * Reads columns from the delta or delta history table.  The range of columns, order, and limit can be
  3.  * parameterized.
  4.  */
  5. private ResultSet columnScan(DeltaPlacement placement, TableDDL tableDDL, ByteBuffer rowKey, Range<RangeTimeUUID> columnRange,
  6.                boolean ascending, int limit, ConsistencyLevel consistency) {
  7.   Select.Where where = selectFrom(tableDDL)
  8.       .where(eq(tableDDL.getRowKeyColumnName(), rowKey));
  9.   if (columnRange.hasLowerBound()) {
  10.     if (columnRange.lowerBoundType() == BoundType.CLOSED) {
  11.       where = where.and(gte(tableDDL.getChangeIdColumnName(), columnRange.lowerEndpoint().getUuid()));
  12.     } else {
  13.       where = where.and(gt(tableDDL.getChangeIdColumnName(), columnRange.lowerEndpoint().getUuid()));
  14.     }
  15.   }
  16.   if (columnRange.hasUpperBound()) {
  17.     if (columnRange.upperBoundType() == BoundType.CLOSED) {
  18.       where = where.and(lte(tableDDL.getChangeIdColumnName(), columnRange.upperEndpoint().getUuid()));
  19.     } else {
  20.       where = where.and(lt(tableDDL.getChangeIdColumnName(), columnRange.upperEndpoint().getUuid()));
  21.     }
  22.   }
  23.   Statement statement = where
  24.       .orderBy(ascending ? asc(tableDDL.getChangeIdColumnName()) : desc(tableDDL.getChangeIdColumnName()))
  25.       .limit(limit)
  26.       .setConsistencyLevel(consistency);
  27.   return AdaptiveResultSet.executeAdaptiveQuery(placement.getKeyspace().getCqlSession(), statement, _driverConfig.getSingleRowFetchSize());
  28. }

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

  1. /**
  2.  * Reads columns from the delta or delta history table.  The range of columns, order, and limit can be
  3.  * parameterized.
  4.  */
  5. private ResultSet columnScan(DeltaPlacement placement, TableDDL tableDDL, ByteBuffer rowKey, Range<RangeTimeUUID> columnRange,
  6.                boolean ascending, ConsistencyLevel consistency) {
  7.   Select.Where where = (tableDDL == placement.getBlockedDeltaTableDDL() ? selectDeltaFrom(placement.getBlockedDeltaTableDDL()) : selectFrom(tableDDL))
  8.       .where(eq(tableDDL.getRowKeyColumnName(), rowKey));
  9.   if (columnRange.hasLowerBound()) {
  10.     if (columnRange.lowerBoundType() == BoundType.CLOSED) {
  11.       where = where.and(gte(tableDDL.getChangeIdColumnName(), columnRange.lowerEndpoint().getUuid()));
  12.     } else {
  13.       where = where.and(gt(tableDDL.getChangeIdColumnName(), columnRange.lowerEndpoint().getUuid()));
  14.     }
  15.   }
  16.   if (columnRange.hasUpperBound()) {
  17.     if (columnRange.upperBoundType() == BoundType.CLOSED) {
  18.       where = where.and(lte(tableDDL.getChangeIdColumnName(), columnRange.upperEndpoint().getUuid()));
  19.     } else {
  20.       where = where.and(lt(tableDDL.getChangeIdColumnName(), columnRange.upperEndpoint().getUuid()));
  21.     }
  22.   }
  23.   Statement statement = where
  24.       .orderBy(ascending ? asc(tableDDL.getChangeIdColumnName()) : desc(tableDDL.getChangeIdColumnName()))
  25.       .setConsistencyLevel(consistency);
  26.   return AdaptiveResultSet.executeAdaptiveQuery(placement.getKeyspace().getCqlSession(), statement, _driverConfig.getSingleRowFetchSize());
  27. }

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

  1. /**
  2.  * Reads columns from the delta or delta history table.  The range of columns, order, and limit can be
  3.  * parameterized.
  4.  */
  5. private ResultSet columnScan(DeltaPlacement placement, TableDDL tableDDL, ByteBuffer rowKey, Range<RangeTimeUUID> columnRange,
  6.                boolean ascending, ConsistencyLevel consistency) {
  7.   Select.Where where = (tableDDL == placement.getBlockedDeltaTableDDL() ? selectDeltaFrom(placement.getBlockedDeltaTableDDL()) : selectFrom(tableDDL))
  8.       .where(eq(tableDDL.getRowKeyColumnName(), rowKey));
  9.   if (columnRange.hasLowerBound()) {
  10.     if (columnRange.lowerBoundType() == BoundType.CLOSED) {
  11.       where = where.and(gte(tableDDL.getChangeIdColumnName(), columnRange.lowerEndpoint().getUuid()));
  12.     } else {
  13.       where = where.and(gt(tableDDL.getChangeIdColumnName(), columnRange.lowerEndpoint().getUuid()));
  14.     }
  15.   }
  16.   if (columnRange.hasUpperBound()) {
  17.     if (columnRange.upperBoundType() == BoundType.CLOSED) {
  18.       where = where.and(lte(tableDDL.getChangeIdColumnName(), columnRange.upperEndpoint().getUuid()));
  19.     } else {
  20.       where = where.and(lt(tableDDL.getChangeIdColumnName(), columnRange.upperEndpoint().getUuid()));
  21.     }
  22.   }
  23.   Statement statement = where
  24.       .orderBy(ascending ? asc(tableDDL.getChangeIdColumnName()) : desc(tableDDL.getChangeIdColumnName()))
  25.       .setConsistencyLevel(consistency);
  26.   return AdaptiveResultSet.executeAdaptiveQuery(placement.getKeyspace().getCqlSession(), statement, _driverConfig.getSingleRowFetchSize());
  27. }

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

select

相关文章

    查看更多

    热门标签

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

    最新文章

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