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

x33g5p2x  于2022-02-01 转载在 其他  
字(2.2k)|赞(0)|评价(0)|浏览(116)

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

Update.toString介绍

暂无

代码示例

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

@Override
public String toString() {
  return update.toString();
}

代码示例来源:origin: kloiasoft/eventapis

@Override
public String updateEvent(EventKey eventKey, @Nullable RecordedEvent newEventData, @Nullable EventState newEventState, @Nullable String newEventType) throws EventStoreException {
  Update update = QueryBuilder.update(tableName);
  update.where(QueryBuilder.eq(ENTITY_ID, eventKey.getEntityId()))
      .and(QueryBuilder.eq(VERSION, eventKey.getVersion()))
      .ifExists();
  if (newEventData != null)
    update.with(QueryBuilder.set(EVENT_DATA, createEventStr(newEventData)));
  if (newEventState != null)
    update.with(QueryBuilder.set(STATUS, newEventState.name()));
  if (newEventType != null)
    update.with(QueryBuilder.set(EVENT_TYPE, newEventType));
  try {
    ResultSet execute = cassandraSession.execute(update);
    log.debug("Update Event, Result:" + execute.toString() + " Update: " + update.toString());
    return execute.toString();
  } catch (Exception e) {
    log.warn(e.getMessage(), e);
    throw new EventStoreException(e.getMessage(), e);
  }
}

代码示例来源:origin: kloiasoft/eventapis

@Override
public List<EntityEvent> markFail(String key) {
  Select select = QueryBuilder.select().from(tableNameByOps);
  select.where(QueryBuilder.eq(OP_ID, key));
  List<Row> entityEventDatas = cassandraSession.execute(select, PagingIterable::all);
  return entityEventDatas.stream().map(
      CassandraViewQuery::convertToEntityEvent
  ).filter(entityEvent -> {
    try {
      Update update = QueryBuilder.update(tableName);
      update.where(QueryBuilder.eq(ENTITY_ID, entityEvent.getEventKey().getEntityId()))
          .and(QueryBuilder.eq(VERSION, entityEvent.getEventKey().getVersion()))
          .ifExists();
      update.with(QueryBuilder.set(STATUS, "FAILED"));
      ResultSet execute = cassandraSession.execute(update);
      log.debug("Failure Mark Result:" + execute.toString() + " Update: " + update.toString());
      return true;
    } catch (Exception e) {
      log.warn(e.getMessage(), e);
      return false;
    }
  }).collect(Collectors.toList());
}

相关文章