alpha/alpha-spec-saga-db/src/main/java/org/apache/servicecomb/pack/alpha/spec/saga/db/TxEventEnvelopeRepository.java [229:240]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  @Query("SELECT t FROM TxEvent t " +
      "WHERE t.type = 'SagaStartedEvent' " +
      "AND EXISTS(  SELECT t1.globalTxId " +
      "FROM TxEvent t1 WHERE t1.globalTxId = t.globalTxId  " +
      "AND t1.type IN ('TxAbortedEvent')) " +
      "AND EXISTS(  SELECT t1.globalTxId FROM " +
      "TxEvent t1 WHERE t1.globalTxId = t.globalTxId  " +
      "AND t1.type IN ('SagaEndedEvent')) " +
      "AND EXISTS(  SELECT t1.globalTxId FROM TxEvent t1 " +
      "WHERE t1.globalTxId = t.globalTxId  " +
      "AND t1.type IN ('TxCompensatedEvent')) " +
      "ORDER BY t.surrogateId DESC")
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



alpha/alpha-spec-saga-db/src/main/java/org/apache/servicecomb/pack/alpha/spec/saga/db/TxEventEnvelopeRepository.java [243:254]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  @Query("SELECT t FROM TxEvent t " +
      "WHERE t.type = 'SagaStartedEvent' " +
      "AND EXISTS(  SELECT t1.globalTxId " +
      "FROM TxEvent t1 WHERE t1.globalTxId = t.globalTxId  " +
      "AND t1.type IN ('TxAbortedEvent')) " +
      "AND EXISTS(  SELECT t1.globalTxId FROM " +
      "TxEvent t1 WHERE t1.globalTxId = t.globalTxId  " +
      "AND t1.type IN ('SagaEndedEvent')) " +
      "AND EXISTS(  SELECT t1.globalTxId FROM TxEvent t1 " +
      "WHERE t1.globalTxId = t.globalTxId  " +
      "AND t1.type IN ('TxCompensatedEvent')) " +
      "ORDER BY t.surrogateId DESC")
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -