private String requestForModel()

in modules/persistence/src/main/java/org/apache/sandesha2/storage/jdbc/PersistentRMDBeanMgr.java [45:199]
155 lines of code
26 McCabe index (conditional complexity)

	private String requestForModel(RMDBean bean) {
		StringBuilder sql = new StringBuilder(" select * from wsrm_rmd");
		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.getReferenceMessageKey();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" reference_message_key='");
			sql.append(clause);
			sql.append("'");
		}
		clause = bean.getHighestInMessageId();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" highest_in_message_id='");
			sql.append(clause);
			sql.append("'");
		}
		clause = bean.getLastInMessageId();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" last_in_message_id='");
			sql.append(clause);
			sql.append("'");
		}
		clause = bean.getToAddress();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" to_address='");
			sql.append(clause);
			sql.append("'");
		}
		clause = bean.getOutboundInternalSequence();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" outbound_internal_sequence='");
			sql.append(clause);
			sql.append("'");
		}
		clause = bean.getOutboundInternalSequence();
		if (clause != null) {
			sql.append(op);
			op = " and ";
			sql.append(" outbound_internal_sequence='");
			sql.append(clause);
			sql.append("'");
		}
		RangeString rs = bean.getServerCompletedMessages();
		if (rs != null) {
			sql.append(op);
			op = " and ";
			sql.append(" server_completed_messages='");
			sql.append(rs.toString());
			sql.append("'");
		}
		rs = bean.getOutOfOrderRanges();
		if (rs != null) {
			sql.append(op);
			op = " and ";
			sql.append(" outof_order_ranges='");
			sql.append(rs.toString());
			sql.append("'");
		}
		if ((bean.getRmdFlags() & RMDBean.NEXT_MSG_NO_FLAG) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" next_msgno_to_process=");
			sql.append(bean.getNextMsgNoToProcess());
		}
		if ((bean.getRmdFlags() & RMDBean.HIGHEST_IN_MSG_FLAG) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" highest_in_message_number=");
			sql.append(bean.getHighestInMessageNumber());
		}
		if ((bean.getFlags() & RMDBean.LAST_ACTIVATED_TIME_FLAG) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" last_activated_time=");
			sql.append(bean.getLastActivatedTime());
		}
		if ((bean.getFlags() & RMDBean.CLOSED_FLAG) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" closed=");
			sql.append(bean.isClosed() ? 1 : 0);
		}
		if ((bean.getFlags() & RMDBean.TERMINATED_FLAG) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" terminated_flag=");
			sql.append(bean.isTerminated() ? 1 : 0);
		}
		if ((bean.getFlags() & RMDBean.POLLING_MODE_FLAG) != 0) {
			sql.append(op);
			op = " and ";
			sql.append(" polling_mode=");
			sql.append(bean.isPollingMode() ? 1 : 0);
		}
		if (log.isDebugEnabled()) log.debug("requestForModel " + sql.toString());
		return sql.toString();
	}