org.quartz.utils.Key.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(8.5k)|赞(0)|评价(0)|浏览(104)

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

Key.<init>介绍

[英]Construct a new key with the given name and group.
[中]使用给定的名称和组构造一个新密钥。

代码示例

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

public Key getKey() {
  if(key == null) {
    key = new Key(getName(), getGroup());
  }
  return key;
}

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

public Key getKey() {
  if(key == null) {
    key = new Key(getName(), getGroup());
  }
  return key;
}

代码示例来源：origin: quartz/quartz-all

public Key getKey() {
  if(key == null) {
    key = new Key(getName(), getGroup());
  }
  return key;
}

代码示例来源：origin: quartz/quartz-all

public Key[] selectMisfiredTriggersInState(Connection conn, String state,
    long ts) throws SQLException {
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
    ps = conn.prepareStatement(rtp(SELECT_MISFIRED_TRIGGERS_IN_STATE));
    ps.setBigDecimal(1, new BigDecimal(String.valueOf(ts)));
    ps.setString(2, state);
    rs = ps.executeQuery();
    ArrayList list = new ArrayList();
    while (rs.next()) {
      String triggerName = rs.getString(COL_TRIGGER_NAME);
      String groupName = rs.getString(COL_TRIGGER_GROUP);
      list.add(new Key(triggerName, groupName));
    }
    Object[] oArr = list.toArray();
    Key[] kArr = new Key[oArr.length];
    System.arraycopy(oArr, 0, kArr, 0, oArr.length);
    return kArr;
  } finally {
    closeResultSet(rs);
    closeStatement(ps);
  }
}

代码示例来源：origin: quartz/quartz-all

public Key getKey() {
  if(key == null) {
    key = new Key(getName(), getGroup());
  }
  return key;
}

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

public Key[] selectMisfiredTriggersInState(Connection conn, String state,
    long ts) throws SQLException {
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
    ps = conn.prepareStatement(rtp(SELECT_MISFIRED_TRIGGERS_IN_STATE));
    ps.setBigDecimal(1, new BigDecimal(String.valueOf(ts)));
    ps.setString(2, state);
    rs = ps.executeQuery();
    ArrayList list = new ArrayList();
    while (rs.next()) {
      String triggerName = rs.getString(COL_TRIGGER_NAME);
      String groupName = rs.getString(COL_TRIGGER_GROUP);
      list.add(new Key(triggerName, groupName));
    }
    Object[] oArr = list.toArray();
    Key[] kArr = new Key[oArr.length];
    System.arraycopy(oArr, 0, kArr, 0, oArr.length);
    return kArr;
  } finally {
    closeResultSet(rs);
    closeStatement(ps);
  }
}

代码示例来源：origin: quartz/quartz-all

public Key[] selectVolatileTriggers(Connection conn) throws SQLException {
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
    ps = conn.prepareStatement(rtp(SELECT_VOLATILE_TRIGGERS));
    setBoolean(ps, 1, true);
    rs = ps.executeQuery();
    ArrayList list = new ArrayList();
    while (rs.next()) {
      String triggerName = rs.getString(COL_TRIGGER_NAME);
      String groupName = rs.getString(COL_TRIGGER_GROUP);
      list.add(new Key(triggerName, groupName));
    }
    Object[] oArr = list.toArray();
    Key[] kArr = new Key[oArr.length];
    System.arraycopy(oArr, 0, kArr, 0, oArr.length);
    return kArr;
  } finally {
    closeResultSet(rs);
    closeStatement(ps);
  }
}

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

public Key[] selectVolatileJobs(Connection conn) throws SQLException {
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
    ps = conn.prepareStatement(rtp(SELECT_VOLATILE_JOBS));
    setBoolean(ps, 1, true);
    rs = ps.executeQuery();
    ArrayList list = new ArrayList();
    while (rs.next()) {
      String triggerName = rs.getString(COL_JOB_NAME);
      String groupName = rs.getString(COL_JOB_GROUP);
      list.add(new Key(triggerName, groupName));
    }
    Object[] oArr = list.toArray();
    Key[] kArr = new Key[oArr.length];
    System.arraycopy(oArr, 0, kArr, 0, oArr.length);
    return kArr;
  } finally {
    closeResultSet(rs);
    closeStatement(ps);
  }
}

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

/**
 * <p>
 * Select all of the triggers in a given state.
 * </p>
 * 
 * @param conn
 *          the DB Connection
 * @param state
 *          the state the triggers must be in
 * @return an array of trigger <code>Key</code> s
 */
public Key[] selectTriggersInState(Connection conn, String state)
  throws SQLException {
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
    ps = conn.prepareStatement(rtp(SELECT_TRIGGERS_IN_STATE));
    ps.setString(1, state);
    rs = ps.executeQuery();
    ArrayList list = new ArrayList();
    while (rs.next()) {
      list.add(new Key(rs.getString(1), rs.getString(2)));
    }
    Key[] sArr = (Key[]) list.toArray(new Key[list.size()]);
    return sArr;
  } finally {
    closeResultSet(rs);
    closeStatement(ps);
  }
}

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

public List selectStatefulJobsOfTriggerGroup(Connection conn,
    String groupName) throws SQLException {
  ArrayList jobList = new ArrayList();
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
    ps = conn
        .prepareStatement(rtp(SELECT_STATEFUL_JOBS_OF_TRIGGER_GROUP));
    ps.setString(1, groupName);
    setBoolean(ps, 2, true);
    rs = ps.executeQuery();
    while (rs.next()) {
      jobList.add(new Key(rs.getString(COL_JOB_NAME), rs
          .getString(COL_JOB_GROUP)));
    }
  } finally {
    closeResultSet(rs);
    closeStatement(ps);
  }
  return jobList;
}

代码示例来源：origin: quartz/quartz-all

/**
 * <p>
 * Select all of the triggers in a given state.
 * </p>
 * 
 * @param conn
 *          the DB Connection
 * @param state
 *          the state the triggers must be in
 * @return an array of trigger <code>Key</code> s
 */
public Key[] selectTriggersInState(Connection conn, String state)
  throws SQLException {
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
    ps = conn.prepareStatement(rtp(SELECT_TRIGGERS_IN_STATE));
    ps.setString(1, state);
    rs = ps.executeQuery();
    ArrayList list = new ArrayList();
    while (rs.next()) {
      list.add(new Key(rs.getString(1), rs.getString(2)));
    }
    Key[] sArr = (Key[]) list.toArray(new Key[list.size()]);
    return sArr;
  } finally {
    closeResultSet(rs);
    closeStatement(ps);
  }
}

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

public Key[] selectVolatileTriggers(Connection conn) throws SQLException {
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
    ps = conn.prepareStatement(rtp(SELECT_VOLATILE_TRIGGERS));
    setBoolean(ps, 1, true);
    rs = ps.executeQuery();
    ArrayList list = new ArrayList();
    while (rs.next()) {
      String triggerName = rs.getString(COL_TRIGGER_NAME);
      String groupName = rs.getString(COL_TRIGGER_GROUP);
      list.add(new Key(triggerName, groupName));
    }
    Object[] oArr = list.toArray();
    Key[] kArr = new Key[oArr.length];
    System.arraycopy(oArr, 0, kArr, 0, oArr.length);
    return kArr;
  } finally {
    closeResultSet(rs);
    closeStatement(ps);
  }
}

代码示例来源：origin: quartz/quartz-all

public Key[] selectVolatileJobs(Connection conn) throws SQLException {
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
    ps = conn.prepareStatement(rtp(SELECT_VOLATILE_JOBS));
    setBoolean(ps, 1, true);
    rs = ps.executeQuery();
    ArrayList list = new ArrayList();
    while (rs.next()) {
      String triggerName = rs.getString(COL_JOB_NAME);
      String groupName = rs.getString(COL_JOB_GROUP);
      list.add(new Key(triggerName, groupName));
    }
    Object[] oArr = list.toArray();
    Key[] kArr = new Key[oArr.length];
    System.arraycopy(oArr, 0, kArr, 0, oArr.length);
    return kArr;
  } finally {
    closeResultSet(rs);
    closeStatement(ps);
  }
}

代码示例来源：origin: quartz/quartz-all

public List selectStatefulJobsOfTriggerGroup(Connection conn,
    String groupName) throws SQLException {
  ArrayList jobList = new ArrayList();
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
    ps = conn
        .prepareStatement(rtp(SELECT_STATEFUL_JOBS_OF_TRIGGER_GROUP));
    ps.setString(1, groupName);
    setBoolean(ps, 2, true);
    rs = ps.executeQuery();
    while (rs.next()) {
      jobList.add(new Key(rs.getString(COL_JOB_NAME), rs
          .getString(COL_JOB_GROUP)));
    }
  } finally {
    closeResultSet(rs);
    closeStatement(ps);
  }
  return jobList;
}

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

while (rs.next()) {
  String triggerName = rs.getString(COL_TRIGGER_NAME);
  list.add(new Key(triggerName, groupName));

代码示例来源：origin: quartz/quartz-all

while (rs.next()) {
  String triggerName = rs.getString(COL_TRIGGER_NAME);
  list.add(new Key(triggerName, groupName));

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

String triggerName = rs.getString(COL_TRIGGER_NAME);
String groupName = rs.getString(COL_TRIGGER_GROUP);
list.add(new Key(triggerName, groupName));

代码示例来源：origin: quartz/quartz-all

return new Key(rs.getString(COL_TRIGGER_NAME), rs
      .getString(COL_TRIGGER_GROUP));
} else {

代码示例来源：origin: com.opensymphony.quartz/com.springsource.org.quartz

rec.setSchedulerInstanceId(rs.getString(COL_INSTANCE_NAME));
rec.setTriggerIsVolatile(getBoolean(rs, COL_IS_VOLATILE));
rec.setTriggerKey(new Key(rs.getString(COL_TRIGGER_NAME), rs
    .getString(COL_TRIGGER_GROUP)));
if (!rec.getFireInstanceState().equals(STATE_ACQUIRED)) {
  rec.setJobRequestsRecovery(rs
      .getBoolean(COL_REQUESTS_RECOVERY));
  rec.setJobKey(new Key(rs.getString(COL_JOB_NAME), rs
      .getString(COL_JOB_GROUP)));

代码示例来源：origin: quartz/quartz-all

rec.setSchedulerInstanceId(rs.getString(COL_INSTANCE_NAME));
rec.setTriggerIsVolatile(getBoolean(rs, COL_IS_VOLATILE));
rec.setTriggerKey(new Key(rs.getString(COL_TRIGGER_NAME), rs
    .getString(COL_TRIGGER_GROUP)));
if (!rec.getFireInstanceState().equals(STATE_ACQUIRED)) {
  rec.setJobRequestsRecovery(rs
      .getBoolean(COL_REQUESTS_RECOVERY));
  rec.setJobKey(new Key(rs.getString(COL_JOB_NAME), rs
      .getString(COL_JOB_GROUP)));

内容来源于网络，如有侵权，请联系作者删除！

Key

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com