org.jooq.Field.minus()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(4.5k)|赞(0)|评价(0)|浏览(79)

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

Field.minus介绍

[英]An alias for #sub(Number).
[中]#sub(Number)的别名。

代码示例

代码示例来源:origin: my2iu/Jinq

@Override public ColumnExpressions<?> mathOpValue(TypedValue.MathOpValue val, Void in) throws TypedValueVisitorException
{
 ColumnExpressions<?> left = val.left.visit(this, in);
 ColumnExpressions<?> right = val.right.visit(this, in);
 Field leftField = (Field)left.getOnlyColumn();
 Field rightField = (Field)right.getOnlyColumn();
 Field resultField;
 switch(val.op)
 {
 case minus: resultField = leftField.minus(rightField); break;
 case plus: resultField = leftField.plus(rightField); break;
 case mul: resultField = leftField.mul(rightField); break;
 default:
   throw new TypedValueVisitorException("Unknown math operator");
 }
 return ColumnExpressions.singleColumn(left.reader, resultField); 
}

代码示例来源:origin: com.walmartlabs.concord.server/concord-server

@Override
public void performTask() {
  Field<Timestamp> cutoff = currentTimestamp().minus(field("interval '10 minutes'"));
  int n = watchdogDao.failStalled(cutoff);
  log.info("run -> {} command(s) are timed out", n);
}

代码示例来源:origin: com.walmartlabs.concord.server/concord-server

private void failStalled() {
  Field<Timestamp> cutOff = currentTimestamp().minus(interval(MAX_STALLED_AGE));
  dao.transaction(tx -> {
    List<String> ids = dao.pollStalled(tx, cutOff);
    for(String id : ids) {
      dao.fail(tx, id);
      log.info("failStalled -> marked as failed: {}", id);
    }
  });
}

代码示例来源:origin: com.walmartlabs.concord.server/concord-server

@Override
  public void run() {
    watchdogDao.transaction(tx -> {
      Field<Timestamp> cutOff = currentTimestamp().minus(interval(cfg.getMaxStalledAge()));
      List<ProcessKey> pks = watchdogDao.pollStalled(tx, POTENTIAL_STALLED_STATUSES, cutOff, 1);
      for (ProcessKey pk : pks) {
        queueDao.updateAgentId(tx, pk, null, ProcessStatus.FAILED);
        logManager.warn(pk, "Process stalled, no heartbeat for more than a minute");
        log.info("processStalled -> marked as failed: {}", pk);
      }
    });
  }
}

代码示例来源:origin: com.walmartlabs.concord.server/concord-server

@Override
  public void run() {
    watchdogDao.transaction(tx -> {
      Field<Timestamp> cutOff = currentTimestamp().minus(interval(cfg.getMaxStartFailureAge()));
      List<ProcessKey> pks = watchdogDao.pollStalled(tx, FAILED_TO_START_STATUSES, cutOff, 1);
      for (ProcessKey pk : pks) {
        queueDao.updateAgentId(tx, pk, null, ProcessStatus.FAILED);
        logManager.warn(pk, "Process failed to start");
        log.info("processStartFailures -> marked as failed: {}", pk);
      }
    });
  }
}

代码示例来源:origin: com.walmartlabs.concord.server/concord-server

@Override
public void run() {
  Field<Timestamp> maxAge = currentTimestamp().minus(interval(cfg.getMaxFailureHandlingAge()));
  for (PollEntry e : POLL_ENTRIES) {
    List<ProcessEntry> parents = watchdogDao.poll(e, maxAge, 1);
    for (ProcessEntry parent : parents) {
      process(e, parent);
    }
  }
}

代码示例来源:origin: com.openle.module.lambda/lambda

@Override public ColumnExpressions<?> mathOpValue(TypedValue.MathOpValue val, Void in) throws TypedValueVisitorException
{
 ColumnExpressions<?> left = val.left.visit(this, in);
 ColumnExpressions<?> right = val.right.visit(this, in);
 Field leftField = (Field)left.getOnlyColumn();
 Field rightField = (Field)right.getOnlyColumn();
 Field resultField;
 switch(val.op)
 {
 case minus: resultField = leftField.minus(rightField); break;
 case plus: resultField = leftField.plus(rightField); break;
 case mul: resultField = leftField.mul(rightField); break;
 default:
   throw new TypedValueVisitorException("Unknown math operator");
 }
 return ColumnExpressions.singleColumn(left.reader, resultField); 
}

代码示例来源:origin: com.walmartlabs.concord.server/concord-server

public boolean removeMeta(PartialProcessKey processKey, String key) {
  UUID instanceId = processKey.getInstanceId();
  return txResult(tx -> {
    Field<String> v = field("{0}", String.class, PROCESS_QUEUE.META).minus(value(key));
    int i = tx.update(PROCESS_QUEUE)
        .set(PROCESS_QUEUE.META, v)
        .where(PROCESS_QUEUE.INSTANCE_ID.eq(instanceId))
        .execute();
    return i == 1;
  });
}

代码示例来源:origin: com.walmartlabs.concord.server/concord-server

public List<ApiKeyEntry> poll(int days) {
  return txResult(tx ->
      tx.select(API_KEYS.KEY_ID,
          API_KEYS.KEY_NAME,
          API_KEYS.EXPIRED_AT,
          API_KEYS.USER_ID)
          .from(API_KEYS)
          .where(API_KEYS.EXPIRED_AT.isNotNull()
              .and(currentTimestamp().greaterOrEqual(trunc(API_KEYS.EXPIRED_AT).minus(days))
                  .and(API_KEYS.LAST_NOTIFIED_AT.isNull()
                      .or(API_KEYS.LAST_NOTIFIED_AT.lessOrEqual(API_KEYS.EXPIRED_AT.minus(days))))))
          .fetch(this::toEntry));
}

相关文章