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

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

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

Select.orderBy介绍

[英]Adds an ORDER BY clause to this statement.
[中]将ORDER BY子句添加到此语句中。

代码示例

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

/**
 * Adds an ORDER BY clause to the {@code SELECT} statement this {@code WHERE} clause if part of.
 *
 * @param orderings the orderings to add.
 * @return the {@code SELECT} statement this {@code WHERE} clause is part of.
 * @throws IllegalStateException if an {@code ORDER BY} clause has already been provided.
 */
public Select orderBy(Ordering... orderings) {
 return statement.orderBy(orderings);
}

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

String name = formatKey(order.getKey());
if (order.getValue() == Order.ASC) {
  select.orderBy(QueryBuilder.asc(name));
} else {
  assert order.getValue() == Order.DESC;
  select.orderBy(QueryBuilder.desc(name));

代码示例来源：origin: io.prestosql.cassandra/cassandra-driver

/**
 * Adds an ORDER BY clause to the SELECT statement this WHERE clause if
 * part of.
 *
 * @param orderings the orderings to add.
 * @return the select statement this Where clause if part of.
 * @throws IllegalStateException if an ORDER BY clause has already been
 *                               provided.
 */
public Select orderBy(Ordering... orderings) {
  return statement.orderBy(orderings);
}

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

/**
 * Adds an ORDER BY clause to the SELECT statement this WHERE clause if
 * part of.
 *
 * @param orderings the orderings to add.
 * @return the select statement this Where clause if part of.
 *
 * @throws IllegalStateException if an ORDER BY clause has already been
 * provided.
 */
public Select orderBy(Ordering... orderings) {
  return statement.orderBy(orderings);
}

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

/**
 * Adds an ORDER BY clause to the SELECT statement this WHERE clause if
 * part of.
 *
 * @param orderings the orderings to add.
 * @return the select statement this Where clause if part of.
 * @throws IllegalStateException if an ORDER BY clause has already been
 *                               provided.
 */
public Select orderBy(Ordering... orderings) {
  return statement.orderBy(orderings);
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-driver

/**
 * Adds an ORDER BY clause to the SELECT statement this WHERE clause if
 * part of.
 *
 * @param orderings the orderings to add.
 * @return the select statement this Where clause if part of.
 * @throws IllegalStateException if an ORDER BY clause has already been
 *                               provided.
 */
public Select orderBy(Ordering... orderings) {
  return statement.orderBy(orderings);
}

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

.from("foo")
    .groupBy("c1", column("c2"), raw("c3"))
    .orderBy(asc("c1"))
    .toString())
.isEqualTo("SELECT * FROM foo GROUP BY c1,c2,c3 ORDER BY c1 ASC;");
    .where(eq("x", 42))
    .groupBy("c1", column("c2"), raw("c3"))
    .orderBy(asc("c1"))
    .toString())
.isEqualTo("SELECT * FROM foo WHERE x=42 GROUP BY c1,c2,c3 ORDER BY c1 ASC;");

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

select().countAll().from("foo").orderBy(asc("a"), desc("b")).orderBy(asc("a"), desc("b"));
 fail("Expected an IllegalStateException");
} catch (IllegalStateException e) {
 select().from("foo").orderBy();
 fail("Expected an IllegalArgumentException");
} catch (IllegalArgumentException e) {

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

@Override
public SelectBuilder<T> desc(String name) {
  select.orderBy(QueryBuilder.desc(classBean.toColumn(name)));
  return this;
}

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

@Override
public SelectBuilder<T> asc(String name) {
  select.orderBy(QueryBuilder.asc(classBean.toColumn(name)));
  return this;
}

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

public Optional<DateTime> getTimeOfOldestIntervalTrafficDataMessage( MessageSource messageSource, IntegrationPeriod integrationPeriod, TrafficDataType trafficDataType )
 {
   Select select = QueryBuilder.select( "message_time" ).from( "messages", "data_message" );
   select.where( QueryBuilder.eq( "message_source_id", messageSource.getId().getId() ) )
       .and( QueryBuilder.eq( "traffic_data_type", trafficDataType.name() ) )
       .and( QueryBuilder.eq( "integration_period", integrationPeriod.name() ) );
   select.orderBy( QueryBuilder.asc( "message_time" ) );
   select.limit( 1 );
   Date date = m_cassandraOperations.queryForObject( select, Date.class );
   if( date != null )
   {
     Optional<DateTime> result = Optional.of( new DateTime( date ) );
     logger.debug( "oldest interval: {} ({}/{}/{})", result, messageSource.getName(), trafficDataType, integrationPeriod );
     return result;
   }
   else
   {
     return Optional.absent();
   }
 }

代码示例来源：origin: scalar-labs/scalardb

private Select prepare(Scan scan) {
 Select select = getSelect(scan);
 createStatement(select.where(), scan);
 List<Ordering> orderings = getOrderings(scan.getOrderings());
 if (!orderings.isEmpty()) {
  select.orderBy(orderings.toArray(new Ordering[orderings.size()]));
 }
 if (scan.getLimit() > 0) {
  select.limit(scan.getLimit());
 }
 return select;
}

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

.where(eq("a", 1))
        .groupBy("a", "b", "c")
        .orderBy(desc("b"), desc("c"))))
.containsExactly(row(1, 4, 24, 2L, 24), row(1, 2, 12, 1L, 12), row(1, 2, 6, 1L, 6));
        .where(eq("a", 1))
        .groupBy("a", "b", "c")
        .orderBy(desc("b"), desc("c"))
        .perPartitionLimit(1)))
.containsExactly(row(1, 4, 24, 2L, 24));
        .where(eq("a", 1))
        .groupBy("a", "b", "c")
        .orderBy(desc("b"), desc("c"))
        .limit(2)))
.containsExactly(row(1, 4, 24, 2L, 24), row(1, 2, 12, 1L, 12));
        .where(in("a", 1, 2, 4))
        .groupBy("a", "b")
        .orderBy(desc("b"), desc("c"))
        .setFetchSize(Integer.MAX_VALUE)))
.containsExactly(
        .where(in("a", 1, 2, 4))
        .groupBy("a", "b")
        .orderBy(desc("b"), desc("c"))
        .limit(3)
        .setFetchSize(Integer.MAX_VALUE)))

代码示例来源：origin: org.springframework.data/spring-data-cassandra

private static Select createSelectAndOrder(List<Selector> selectors, CqlIdentifier from, Filter filter, Sort sort) {
  Select select;
  if (selectors.isEmpty()) {
    select = QueryBuilder.select().all().from(from.toCql());
  } else {
    Selection selection = QueryBuilder.select();
    selectors.forEach(selector ->
      selector.getAlias().map(CqlIdentifier::toCql).ifPresent(getSelection(selection, selector)::as));
    select = selection.from(from.toCql());
  }
  for (CriteriaDefinition criteriaDefinition : filter) {
    select.where(toClause(criteriaDefinition));
  }
  if (sort.isSorted()) {
    List<Ordering> orderings = new ArrayList<>();
    for (Order order : sort) {
      if (order.isAscending()) {
        orderings.add(QueryBuilder.asc(order.getProperty()));
      } else {
        orderings.add(QueryBuilder.desc(order.getProperty()));
      }
    }
    if (!orderings.isEmpty()) {
      select.orderBy(orderings.toArray(new Ordering[orderings.size()]));
    }
  }
  return select;
}

代码示例来源：origin: com.stratio.meta/meta-core

sel.orderBy(orderings);

代码示例来源：origin: io.zipkin.zipkin2/zipkin-storage-cassandra-v1

Factory(Session session, TimestampCodec timestampCodec) {
 this.session = session;
 this.timestampCodec = timestampCodec;
 this.preparedStatement =
   session.prepare(
     QueryBuilder.select("ts", "trace_id")
       .from(Tables.SERVICE_SPAN_NAME_INDEX)
       .where(
         QueryBuilder.eq(
           "service_span_name", QueryBuilder.bindMarker("service_span_name")))
       .and(QueryBuilder.gte("ts", QueryBuilder.bindMarker("start_ts")))
       .and(QueryBuilder.lte("ts", QueryBuilder.bindMarker("end_ts")))
       .limit(QueryBuilder.bindMarker("limit_"))
       .orderBy(QueryBuilder.desc("ts")));
}

代码示例来源：origin: io.zipkin.zipkin2/zipkin-storage-cassandra-v1

Factory(Session session, TimestampCodec timestampCodec, Set<Integer> buckets) {
 this.session = session;
 this.timestampCodec = timestampCodec;
 this.preparedStatement =
   session.prepare(
     QueryBuilder.select("ts", "trace_id")
       .from(Tables.ANNOTATIONS_INDEX)
       .where(QueryBuilder.eq("annotation", QueryBuilder.bindMarker("annotation")))
       .and(QueryBuilder.in("bucket", buckets))
       .and(QueryBuilder.gte("ts", QueryBuilder.bindMarker("start_ts")))
       .and(QueryBuilder.lte("ts", QueryBuilder.bindMarker("end_ts")))
       .limit(QueryBuilder.bindMarker("limit_"))
       .orderBy(QueryBuilder.desc("ts")));
}

代码示例来源：origin: io.zipkin.zipkin2/zipkin-storage-cassandra-v1

Factory(Session session, TimestampCodec timestampCodec, Set<Integer> buckets) {
 this.session = session;
 this.timestampCodec = timestampCodec;
 this.preparedStatement =
   session.prepare(
     QueryBuilder.select("ts", "trace_id")
       .from(Tables.SERVICE_NAME_INDEX)
       .where(QueryBuilder.in("service_name", QueryBuilder.bindMarker("service_names")))
       .and(QueryBuilder.in("bucket", buckets))
       .and(QueryBuilder.gte("ts", QueryBuilder.bindMarker("start_ts")))
       .and(QueryBuilder.lte("ts", QueryBuilder.bindMarker("end_ts")))
       .limit(QueryBuilder.bindMarker("limit_"))
       .orderBy(QueryBuilder.desc("ts")));
}

代码示例来源：origin: io.zipkin.zipkin2/zipkin-storage-cassandra-v1

Factory(Session session, TimestampCodec timestampCodec, Set<Integer> buckets) {
 this.session = session;
 this.timestampCodec = timestampCodec;
 this.preparedStatement =
   session.prepare(
     QueryBuilder.select("ts", "trace_id")
       .from(Tables.SERVICE_NAME_INDEX)
       .where(QueryBuilder.eq("service_name", QueryBuilder.bindMarker("service_name")))
       .and(QueryBuilder.in("bucket", buckets))
       .and(QueryBuilder.gte("ts", QueryBuilder.bindMarker("start_ts")))
       .and(QueryBuilder.lte("ts", QueryBuilder.bindMarker("end_ts")))
       .limit(QueryBuilder.bindMarker("limit_"))
       .orderBy(QueryBuilder.desc("ts")));
}

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

.from("foo")
    .groupBy("c1", column("c2"), raw("c3"))
    .orderBy(asc("c1"))
    .toString())
.isEqualTo("SELECT * FROM foo GROUP BY c1,c2,c3 ORDER BY c1 ASC;");
    .where(eq("x", 42))
    .groupBy("c1", column("c2"), raw("c3"))
    .orderBy(asc("c1"))
    .toString())
.isEqualTo("SELECT * FROM foo WHERE x=42 GROUP BY c1,c2,c3 ORDER BY c1 ASC;");

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

select

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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