com.datastax.driver.core.RegularStatement.setSerialConsistencyLevel()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(3.8k)|赞(0)|评价(0)|浏览(78)

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

RegularStatement.setSerialConsistencyLevel介绍

暂无

代码示例

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

@Test(groups = "short")
public void prepareStatementInheritPropertiesTest() {
 RegularStatement toPrepare = new SimpleStatement("SELECT * FROM test WHERE k=?");
 toPrepare.setConsistencyLevel(ConsistencyLevel.QUORUM);
 toPrepare.setSerialConsistencyLevel(ConsistencyLevel.LOCAL_SERIAL);
 toPrepare.setRetryPolicy(FallthroughRetryPolicy.INSTANCE);
 if (protocolVersion.compareTo(V4) >= 0)
  toPrepare.setOutgoingPayload(ImmutableMap.of("foo", Bytes.fromHexString("0xcafebabe")));
 toPrepare.setIdempotent(true);
 toPrepare.enableTracing();
 PreparedStatement prepared = session().prepare(toPrepare);
 assertThat(prepared.getConsistencyLevel()).isEqualTo(ConsistencyLevel.QUORUM);
 assertThat(prepared.getSerialConsistencyLevel()).isEqualTo(ConsistencyLevel.LOCAL_SERIAL);
 assertThat(prepared.getRetryPolicy()).isEqualTo(FallthroughRetryPolicy.INSTANCE);
 if (protocolVersion.compareTo(V4) >= 0)
  assertThat(prepared.getOutgoingPayload())
    .isEqualTo(ImmutableMap.of("foo", Bytes.fromHexString("0xcafebabe")));
 assertThat(prepared.isIdempotent()).isTrue();
 assertThat(prepared.isTracing()).isTrue();
 BoundStatement bs = prepared.bind("someValue");
 assertThat(bs.getConsistencyLevel()).isEqualTo(ConsistencyLevel.QUORUM);
 assertThat(bs.getSerialConsistencyLevel()).isEqualTo(ConsistencyLevel.LOCAL_SERIAL);
 assertThat(bs.getRetryPolicy()).isEqualTo(FallthroughRetryPolicy.INSTANCE);
 if (protocolVersion.compareTo(V4) >= 0)
  assertThat(bs.getOutgoingPayload())
    .isEqualTo(ImmutableMap.of("foo", Bytes.fromHexString("0xcafebabe")));
 assertThat(bs.isIdempotent()).isTrue();
 assertThat(bs.isTracing()).isTrue();
}

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

@Test(groups = "short")
public void prepareStatementInheritPropertiesTest() {
 RegularStatement toPrepare = new SimpleStatement("SELECT * FROM test WHERE k=?");
 toPrepare.setConsistencyLevel(ConsistencyLevel.QUORUM);
 toPrepare.setSerialConsistencyLevel(ConsistencyLevel.LOCAL_SERIAL);
 toPrepare.setRetryPolicy(FallthroughRetryPolicy.INSTANCE);
 if (protocolVersion.compareTo(V4) >= 0)
  toPrepare.setOutgoingPayload(ImmutableMap.of("foo", Bytes.fromHexString("0xcafebabe")));
 toPrepare.setIdempotent(true);
 toPrepare.enableTracing();
 PreparedStatement prepared = session().prepare(toPrepare);
 assertThat(prepared.getConsistencyLevel()).isEqualTo(ConsistencyLevel.QUORUM);
 assertThat(prepared.getSerialConsistencyLevel()).isEqualTo(ConsistencyLevel.LOCAL_SERIAL);
 assertThat(prepared.getRetryPolicy()).isEqualTo(FallthroughRetryPolicy.INSTANCE);
 if (protocolVersion.compareTo(V4) >= 0)
  assertThat(prepared.getOutgoingPayload())
    .isEqualTo(ImmutableMap.of("foo", Bytes.fromHexString("0xcafebabe")));
 assertThat(prepared.isIdempotent()).isTrue();
 assertThat(prepared.isTracing()).isTrue();
 BoundStatement bs = prepared.bind("someValue");
 assertThat(bs.getConsistencyLevel()).isEqualTo(ConsistencyLevel.QUORUM);
 assertThat(bs.getSerialConsistencyLevel()).isEqualTo(ConsistencyLevel.LOCAL_SERIAL);
 assertThat(bs.getRetryPolicy()).isEqualTo(FallthroughRetryPolicy.INSTANCE);
 if (protocolVersion.compareTo(V4) >= 0)
  assertThat(bs.getOutgoingPayload())
    .isEqualTo(ImmutableMap.of("foo", Bytes.fromHexString("0xcafebabe")));
 assertThat(bs.isIdempotent()).isTrue();
 assertThat(bs.isTracing()).isTrue();
}

相关文章