in modules/persistence/src/main/java/org/apache/sandesha2/storage/jdbc/PersistentRMSBeanMgr.java [42:276]
private String requestForModel(RMSBean bean) {
StringBuilder sql = new StringBuilder(" select * from wsrm_rms");
if (bean == null) return sql.toString();
String op = " where ";
String clause = bean.getSequenceID();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" sequence_id='");
sql.append(clause);
sql.append("'");
}
EndpointReference epr = bean.getToEndpointReference();
if (epr != null) {
sql.append(op);
op = " and ";
sql.append(" to_epr_addr='");
sql.append(epr.getAddress());
sql.append("'");
}
epr = bean.getReplyToEndpointReference();
if (epr != null) {
sql.append(op);
op = " and ";
sql.append(" reply_to_epr_addr='");
sql.append(epr.getAddress());
sql.append("'");
}
epr = bean.getAcksToEndpointReference();
if (epr != null) {
sql.append(op);
op = " and ";
sql.append(" acks_to_epr_addr='");
sql.append(epr.getAddress());
sql.append("'");
}
clause = bean.getRMVersion();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" rm_version='");
sql.append(clause);
sql.append("'");
}
clause = bean.getSecurityTokenData();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" security_token_data='");
sql.append(clause);
sql.append("'");
}
clause = bean.getCreateSeqMsgID();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" create_seq_msg_id='");
sql.append(clause);
sql.append("'");
}
clause = bean.getInternalSequenceID();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" internal_sequence_id='");
sql.append(clause);
sql.append("'");
}
clause = bean.getCreateSequenceMsgStoreKey();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" create_sequence_msg_store_key='");
sql.append(clause);
sql.append("'");
}
clause = bean.getReferenceMessageStoreKey();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" create_sequence_msg_store_key='");
sql.append(clause);
sql.append("'");
}
clause = bean.getTransportTo();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" transport_to='");
sql.append(clause);
sql.append("'");
}
clause = bean.getOfferedEndPoint();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" offered_endpoint='");
sql.append(clause);
sql.append("'");
}
epr = bean.getOfferedEndPointEPR();
if (epr != null) {
sql.append(op);
op = " and ";
sql.append(" offered_endpoint_epr_addr='");
sql.append(epr.getAddress());
sql.append("'");
}
clause = bean.getOfferedSequence();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" offered_sequence='");
sql.append(clause);
sql.append("'");
}
clause = bean.getAnonymousUUID();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" anonymous_uuid='");
sql.append(clause);
sql.append("'");
}
RangeString xrs = bean.getClientCompletedMessages();
if (xrs != null) {
sql.append(op);
op = " and ";
sql.append(" client_completed_messages='");
sql.append(xrs.toString());
sql.append("'");
}
clause = bean.getInternalSeqIDOfSeqUsedForReallocation();
if (clause != null) {
sql.append(op);
op = " and ";
sql.append(" internalSeqIDOfSeqUsedForReallocation='");
sql.append(clause);
sql.append("'");
}
if ((bean.getRmsFlags() & RMSBean.LAST_SEND_ERROR_TIME_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" last_send_error_timestamp=");
sql.append(bean.getLastSendErrorTimestamp());
}
if ((bean.getRmsFlags() & RMSBean.LAST_OUT_MSG_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" last_out_message=");
sql.append(bean.getLastOutMessage());
}
if ((bean.getRmsFlags() & RMSBean.HIGHEST_OUT_MSG_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" highest_out_message_number=");
sql.append(bean.getHighestOutMessageNumber());
}
if ((bean.getRmsFlags() & RMSBean.NEXT_MSG_NUM_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" next_message_number=");
sql.append(bean.getNextMessageNumber());
}
if ((bean.getRmsFlags() & RMSBean.TERMINATE_ADDED_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" terminate_added=");
sql.append(bean.isTerminateAdded() ? 1 : 0);
}
if ((bean.getRmsFlags() & RMSBean.TIMED_OUT_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" timed_out=");
sql.append(bean.isTimedOut() ? 1 : 0);
}
if ((bean.getRmsFlags() & RMSBean.SEQ_CLOSED_CLIENT_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" sequence_closed_client=");
sql.append(bean.isSequenceClosedClient() ? 1 : 0);
}
if ((bean.getRmsFlags() & RMSBean.TERM_PAUSER_FOR_CS) != 0) {
sql.append(op);
op = " and ";
sql.append(" termination_pauser_for_cs=");
sql.append(bean.isTerminationPauserForCS() ? 1 : 0);
}
if ((bean.getRmsFlags() & RMSBean.EXPECTED_REPLIES) != 0) {
sql.append(op);
op = " and ";
sql.append(" expected_replies=");
sql.append(bean.getExpectedReplies());
}
if ((bean.getRmsFlags() & RMSBean.SOAP_VERSION_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" soap_version=");
sql.append(bean.getSoapVersion());
}
if ((bean.getFlags() & RMSBean.LAST_ACTIVATED_TIME_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" last_activated_time=");
sql.append(bean.getLastActivatedTime());
}
if ((bean.getFlags() & RMSBean.CLOSED_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" closed=");
sql.append(bean.isClosed() ? 1 : 0);
}
if ((bean.getFlags() & RMSBean.TERMINATED_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" terminated_flag=");
sql.append(bean.isTerminated() ? 1 : 0);
}
if ((bean.getFlags() & RMSBean.POLLING_MODE_FLAG) != 0) {
sql.append(op);
op = " and ";
sql.append(" polling_mode=");
sql.append(bean.isPollingMode() ? 1 : 0);
}
/* only for WSRM 1.0 ?
if ( (bean.getFlags() & 0x0010000) != 0 ) {
sql.append(op);
op = " and ";
sql.append(" replay_model=");
sql.append(bean.isReplayModel() ? 1:0);
} */
if (log.isDebugEnabled()) log.debug("requestForModel " + sql.toString());
return sql.toString();
}