本文整理了Java中com.datastax.driver.core.RegularStatement.setSerialConsistencyLevel
方法的一些代码示例,展示了RegularStatement.setSerialConsistencyLevel
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RegularStatement.setSerialConsistencyLevel
方法的具体详情如下:
包路径:com.datastax.driver.core.RegularStatement
类名称: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();
}
内容来源于网络,如有侵权,请联系作者删除!