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

RegularStatement.setIdempotent介绍

暂无

代码示例

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

private RegularStatement statementWithIdempotency(Boolean idempotency) {
  RegularStatement statement = new SimpleStatement("fake statement");
  if (idempotency != null) {
   statement.setIdempotent(idempotency);
   assertThat(statement.isIdempotent()).isEqualTo(idempotency);
  } else {
   assertThat(statement.isIdempotent()).isNull();
  }
  return statement;
 }
}

代码示例来源：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: dmart28/gcplot

@Override
public void add(T event) {
  connector.session().execute(addStatement(event).setIdempotent(true));
}

代码示例来源：origin: dmart28/gcplot

@Override
public void addAsync(T event) {
  connector.session().executeAsync(addStatement(event).setIdempotent(true));
}

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

private RegularStatement statementWithIdempotency(Boolean idempotency) {
  RegularStatement statement = new SimpleStatement("fake statement");
  if (idempotency != null) {
   statement.setIdempotent(idempotency);
   assertThat(statement.isIdempotent()).isEqualTo(idempotency);
  } else {
   assertThat(statement.isIdempotent()).isNull();
  }
  return statement;
 }
}

代码示例来源：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();
}